目录

• 1-Eureka-Server
• 2-Eureka-Client
• 3-Ribbon
• 4-Feign
• 5-Hystrix
• 6-Feign结合Hystrix
• 7-断路器Dashboard监控仪表盘
• 8-Zuul
• 9-Sleuth
• 10-Zipkin
• 11-Config
• 12-Bus
• 13-微服务改造为配置中心总结

1-Eureka-Server

1.1 新建eureka-server项目，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>

1.2 修改application.yml

1.2.1 单例

server:port: 8761eureka:instance:hostname: localhostclient:registerWithEureka: falsefetchRegistry: falseserviceUrl:defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

1.2.2 多例

---
spring:profiles: peer1
eureka:instance:hostname: peer1client:serviceUrl:defaultZone: http://peer2/eureka/---
spring:profiles: peer2
eureka:instance:hostname: peer2client:serviceUrl:defaultZone: http://peer1/eureka/

1.3 添加注解

@EnableEurekaServer

2-Eureka-Client

2.1 对应的服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

2.2 修改application.yml

eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/

2.3 添加注解

@EnableEurekaClient

3-Ribbon

3.1 对应的服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-ribbon</artifactId>
</dependency>

3.2 修改application.yml

beebee-archives-thrift-consumer: # 服务提供者的名称ribbon:NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule # 负载均衡策略

3.3 启动类

@Bean
@LoadBalanced
public RestTemplate restTemplate() {return new RestTemplate();
}

3.4 添加工具类 EurekaUtil

@Configuration
public class EurekaUtil {@Autowiredprivate  RestTemplate restTemplate;@Autowiredprivate  LoadBalancerClient loadBalancerClient;/*** 远程调用* @param server 调用的服务器* @param method 调用的方法* @param p 方法的参数*/public <P> String remoteInvoke(String server, String method, P p) {ServiceInstance serviceInstance = loadBalancerClient.choose(server);return restTemplate.postForObject("http://" + serviceInstance.getServiceId() + method, p, String.class);}
}

3.5 Controller调用

@PostMapping("/getList")
public String getList(ArchivesListParam param) {return eurekaUtil.remoteInvoke(Server.BEEBEE_ARCHIVES_THRIFT_PROVIDER_CLIENT, Method.ARCHIVES_GET_LIST, param);
}

4-Feign

4.1 在调用方order-service服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>

4.2 启动类添加注解

@EnableFeignClients

4.3 在service.impl下，添加 interface

@FeignClient(name = "product-service") // 该服务名要与被调用方product-service中的一致
public interface ProductClient {@GetMapping("/api/v1/product/find") // 该方法要与被调用方product-service中的一致String findById(@RequestParam("id") int id);
}

4.4 在OrderServiceImpl下使用

@Autowired
private ProductClient productClient;String resp = productClient.findById(productId);

5-Hystrix

5.1 对应的服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

5.2 启动类添加注解

@EnableCircuitBreaker

5.3 OrderController使用

@Autowired
private StringRedisTemplate redisTemplate;@RequestMapping("save")
@HystrixCommand(fallbackMethod = "saveOrderFail")
public Object save(int userId, int productId, HttpServletRequest request) {Map<String, Object> data = new HashMap<>();data.put("code", 0);data.put("data", orderService.save(userId, productId));return data;
}private Object saveOrderFail(int userId, int productId, HttpServletRequest request) {String saveOrderKey = "save-order";String saveValue = redisTemplate.opsForValue().get(saveOrderKey);String ip = request.getRemoteAddr();new Thread(() -> {if (StringUtils.isBlank(saveValue)) {// TODO 调用短信接口 ip服务器宕机，请尽快处理redisTemplate.opsForValue().set(saveOrderKey, "save-order-fail", 30, TimeUnit.SECONDS);} else {// TODO 30s内不再重发}}).start();Map<String, Object> msg = new HashMap<>();msg.put("code", -1);msg.put("msg", "抢购人数太多，您被寄出来了");return msg;
}

6-Feign结合Hystrix

6.1 对应的服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
</dependency>

6.2 启动类添加注解

@EnableCircuitBreaker
可以用@SpringCloudApplication替代Cloud中的多个注解

6.3 开启Feign支持Hystrix

feign:hystrix:enabled: true

6.4 在fallback包下创建ProductClientFallback

@Component
public class ProductClientFallback implements ProductClient {@Overridepublic String findById(int id) {System.out.println("异常处理：记录日志、发送短信或邮件");return null;}
}

6.5 在注解@FeignClient添加fallback类

@FeignClient(name = "product-service", fallback = ProductClientFallback.class)
public interface ProductClient {@GetMapping("/api/v1/product/find")String findById(@RequestParam("id") int id);
}

6.6 降级处理

1. @FeignClient(name = "product-service", fallback = ProductClientFallback.class)
2. @HystrixCommand(fallbackMethod = "saveOrderFail")

7-断路器Dashboard监控仪表盘

7.1 对应的服务中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix-dashboard</artifactId>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

7.2 启动类添加注解

@EnableHystrixDashboard

7.3 修改application.yml

management:endpoints:web:exposure:include: "*"

7.4 访问入口

http://localhost:8781/hystrix
http://localhost:8781/actuator/hystrix.stream

7.5 断路器图示

断路器close状态

graph LR
consumer-->断路器
断路器-->provider

断路器半开状态

graph LR
consumer-.->断路器
断路器-->provider

断路器open状态

graph LR
consumer-.X.->断路器
断路器-->provider

8-Zuul

8.1 新建beebee-zuul项目，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>

8.2 启动类添加注解

@EnableZuulProxy

8.3 访问

之前：http://localhost:8781/api/v1/order/save?userId=1&productId=1
现在：http://localhost:9000/order-service/api/v1/order/save?userId=1&productId=1
访问规则：http://ip:port/service-id/*
注意：order-service 注意大小写，需要和application.yml配置的一样

8.4 自定义路由

server:port: 9000
spring:application:name: beebee-api
zuul:routes:order-service: /beebee-api/order/**  # 自定义服务名称product-service: /beebee-api/product/**  # 此名称不要与上面冲突，否则会覆盖上面的ignored-services: product-service  # 忽略一个，忽略商品服务，不能通过 http://localhost:9000/product-service/... 访问ignored-patterns: /*-service/**  # 忽略多个，只能通过 http://localhost:9000/beebee-api/... 访问   访问方式：http://localhost:9000/beebee-api/api/v1/order/save?userId=1&productId=1

8.5 Http请求头过滤问题

@ConfigurationProperties("zuul")
public class ZuulProperties {// 默认以下三个敏感信息不传递到下游服务器private Set<String> sensitiveHeaders = new LinkedHashSet<>(Arrays.asList("Cookie", "Set-Cookie", "Authorization"));
}# 将此属性置为空
zuul:sensitive-headers:

8.6 zuul流程

过滤器order值越小，越优先执行

8.7 自定义zuul过滤器

在filter包下添加LoginFilter

@Component
public class LoginFilter extends ZuulFilter {/*** 过滤器类型，前置过滤器* @return*/@Overridepublic String filterType() {return PRE_TYPE;}/*** 过滤器执行顺序，越小越先执行* @return*/@Overridepublic int filterOrder() {return 4;}/*** 过滤器是否生效* @return*/@Overridepublic boolean shouldFilter() {RequestContext context = RequestContext.getCurrentContext();HttpServletRequest request = context.getRequest();// 或者ACL方式if ("/beebee-api/order/api/v1/order/save".equalsIgnoreCase(request.getRequestURI())) {return true;}return false;}/*** 业务逻辑* @return* @throws ZuulException*/@Overridepublic Object run() throws ZuulException {RequestContext context = RequestContext.getCurrentContext();HttpServletRequest request = context.getRequest();String token = request.getHeader("token");token = StringUtils.isEmpty(token) ? request.getParameter("token") : token;// 登录校验，实际使用改为JWTif (StringUtils.isBlank(token)) {context.setSendZuulResponse(false);context.setResponseStatusCode(HttpStatus.UNAUTHORIZED.value());}return null;}
}

8.8 订单服务限流

在filter包下创建OrderRateLimitFilter类

@Component
public class OrderRateLimitFilter extends ZuulFilter {// Guava:每秒产生1000个令牌，即每秒最多1000个请求private static final RateLimiter RATE_LIMITER = RateLimiter.create(1000);@Overridepublic String filterType() {return PRE_TYPE;}@Overridepublic int filterOrder() {return -4;}@Overridepublic boolean shouldFilter() {RequestContext context = RequestContext.getCurrentContext();HttpServletRequest request = context.getRequest();// 只对订单接口限流if ("/beebee-api/order/api/v1/order/save".equalsIgnoreCase(request.getRequestURI())) {return true;}return false;}@Overridepublic Object run() throws ZuulException {RequestContext context = RequestContext.getCurrentContext();if (!RATE_LIMITER.tryAcquire()) {context.setSendZuulResponse(false);context.setResponseStatusCode(HttpStatus.TOO_MANY_REQUESTS.value());}return null;}
}

9-Sleuth

9.1 对应的项目中，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-sleuth</artifactId>
</dependency>

9.2 XxxServiceImpl中使用

private final Logger logger = LoggerFactory.getLogger(getClass());
logger.info("order -- service");2019-01-16 17:45:51.507  INFO [order-service,4fdff23615ab2226,d8818e5c8e6e5ba5,false] 8446 --- [derController-2] c.z.o.service.impl.OrderServiceImpl : order -- service第一个值：order-service，spring.application.name的值
第二个值：4fdff23615ab2226，叫TraceID，用来标识一条请求链路，一条请求链路中包含一个TraceID，多个SpanID
第三个值：d8818e5c8e6e5ba5，叫SpanID，基本的工作单元，获取元数据，如发送一个http
第四个值：false，是否要将该信息输出到zipkin服务中来收集和展示。

10-Zipkin

10.1 web使用 Zipkin

docker run -d -p 9411:9411 openzipkin/zipkin
访问：http://localhost:9411/zipkin/

10.2 对应的服务中，添加pom依赖

这个依赖包含了 spring-cloud-starter-sleuth、spring-cloud-sleuth-zipkin
相应的服务都要添加以下依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-zipkin</artifactId>
</dependency>

10.3 修改application.yml

spring:application:name: order-servicezipkin:base-url: http://localhost:9411sleuth:sampler:probability: 1 # 采样百分比：开发环境=1即100%，生成环境用默认的=0.1即10%

11-Config

11.1 新建config-server项目，添加pom依赖

<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-config-server</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

11.2 启动类添加注解

@EnableConfigServer

11.3 修改application.yml

spring:application:name: config-server
server:port: 9100
eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/

11.4 码云建立config-cloud项目

https://gitee.com/zhangyimai/config-cloud.git

11.5 修改application.yml

spring:cloud:config:server:git:uri: https://gitee.com/zhangyimai/config-cloud username:password: timeout: 5

11.6 在码云config-cloud项目上，新建product-service.yml文件

11.7 访问方式

http://localhost:9100/product-service.yml
/{name}-{profiles}.properties
/{name}-{profiles}.yml
/{name}-{profiles}.json
/{label}/{name}-{profiles}.yml
name：服务器名称
profile：环境名称，开发、测试、生产
lable：仓库分支、默认master分支

11.8 config-client使用，product-service添加pom依赖

<!--配置中心客户端-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-config-client</artifactId>
</dependency>

11.9 修改application.yml为bootstrap.yml

# 服务名称
spring:application:name: product-service# 指定从哪个配置中心读取cloud:config:discovery:service-id: CONFIG-SERVER # 服务IDenabled: truelabel: dev # dev分支，建议用label区分配置文件的环境profile: dev # 配置文件后缀，不建议用profile区分配置文件的环境
# 注册中心
eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/此配置文件读取的路径：http://localhost:9100/dev/product-service-dev.yml

12-Bus

12.1 Docker安装启动RabbitMQ

docker pull rabbitmq:management
docker run -d --name="myrabbitmq" -p 5671:5671 -p 15672:15672 rabbitmq:management
访问：http://localhost:15672
用户名密码：guest

12.2 config-client添加pom依赖

<!--配置中心结合消息队列-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

12.3 添加RabbitMQ等配置

在码云config-cloud项目中，对应的配置文件添加如下配置# RabbitMQ连接信息
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest
#暴露全部的监控信息
management:endpoints:web:exposure:include: "*"

12.4 需要刷新配置的类上添加注解

如需动态刷新，需要配置以下注解
@RefreshScope

12.5 动态刷新配置

post方式请求：http://localhost:8773/actuator/bus-refresh
8773是当前项目的端口，如果是多个节点，其他节点也会刷新
注意：动态刷新配置，在开发和测试环境使用，尽量少在生产环境使用

13-微服务改造为配置中心总结

13.1 码云上创建cloud-config项目，并添加对应配置文件

微服务添加以下配置# RabbitMQ连接信息
spring:rabbitmq:host: localhostport: 5672username: guestpassword: guest
#暴露全部的监控信息
management:endpoints:web:exposure:include: "*"

13.2 微服务添加pom依赖

<!--配置中心客户端-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-config-client</artifactId>
</dependency>
<!--配置中心结合消息队列-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-bus-amqp</artifactId>
</dependency>

13.3 application.yml --> bootstrap.yml

# 服务名称
spring:application:name: product-service# 指定从哪个配置中心读取cloud:config:discovery:service-id: CONFIG-SERVER # 服务IDenabled: truelabel: dev # dev分支profile: dev # 配置文件后缀
# 注册中心
eureka:client:serviceUrl:defaultZone: http://localhost:8761/eureka/

13.4 各个项目启动顺序

1. 注册中心
2. 配置中心
3. 各个服务：商品服务、订单服务...
4. 启动网关

【Spring-Cloud】使用教程 基础篇 Eureka Ribbon Feign Hystrix Zuul Dashboard Sleuth Zipkin Config Bus相关推荐

1. Spring Cloud中五大神兽总结(Eureka/Ribbon/Feign/Hystrix/zuul)

   一.常用的模块 1.Eureka Eureka是Netflix的一个子模块,也是核心模块之一.Eureka是一个基于REST的服务,用于定位服务,以实现云端中间层服务发现和故障转移.服务注册与发现对于 ...

2. Spring Cloud第十二篇：断路器监控(Hystrix Dashboard)

   在我的第四篇文章断路器讲述了如何使用断路器,并简单的介绍了下Hystrix Dashboard组件,这篇文章更加详细的介绍Hystrix Dashboard. 一.Hystrix Dashboard简 ...

3. springcloud gateway ribbon使用_Github点赞接近 70k 的Spring Cloud学习教程+实战项目推荐！牛批！...

   这篇文章继续来推荐 Spring Cloud 的教程和实战项目了!想必不用不多说,大家都知道 Spring Cloud 的重要程度.几乎稍微有点规模的公司,一般都离不开要和微服务打交道.同时,Spri ...

4. Spring Cloud入门教程(二)：客户端负载均衡(Ribbon)

   对于大型应用系统负载均衡(LB:Load Balancing)是首要被解决一个问题.在微服务之前LB方案主要是集中式负载均衡方案,在服务消费者和服务提供者之间又一个独立的LB,LB通常是专门的硬件,如 ...

5. Github点赞接近 70k 的Spring Cloud学习教程+实战项目推荐！牛批！

   本文已经收录进:awesome-java (Github 上非常棒的 Java 开源项目集合) 这篇 Guide 来推荐 Spring Cloud 的教程和实战项目了!想必不用不多说,大家都知道 Sp ...

6. 告诉老默我想学Spring Cloud了（新手篇）：从0到1搭建Spring Cloud项目（实际项目开发的浓缩精华版）

   告诉老默我想学Spring Cloud了(新手篇):从0到1搭建Spring Cloud项目 一.前言 二.如何选择版本 2.1 SpringCloud 和 Spring Boot 版本选型 2.1. ...

7. 使用Nacos实现服务注册与发现(spring cloud 组件教程大全四)

   使用Nacos实现服务注册与发现(spring cloud 组件教程大全四) idea 创建maven父子工程(spring cloud 组件教程大全 一) windows下nacos的安装及Mysq ...

8. Spring Cloud Alibba教程：Sentinel的使用

   点击上方"方志朋",选择"置顶公众号" 技术文章第一时间送达! 什么是Sentinel Sentinel,中文翻译为哨兵,是为微服务提供流量控制.熔断降级的功能 ...

9. Spring Cloud Alibba教程：如何使用Nacos作为配置中心

   点击上方"方志朋",选择"置顶公众号" 技术文章第一时间送达! 在上一篇文章中讲解了如何使用Nacos作为服务注册中心注册.Nacos除了可以作为服务注册中心, ...

最新文章

1. FPGA异步时序和多时钟模块
2. [Arduino] 学习总结小合集(更新ING)
3. php robots.txt,robots.txt的写法
4. 图像无损、有损压缩方法调研
5. EL : Free Package of October
6. 随想录（lua源码学习）
7. Clean-Code: 有意义的名字
8. 超级强悍的PHP代码编辑器PHPstorm及配置
9. 使用MSAgent代替传统的MessageBox提示来增用客户端用户体验
10. html制作dnf,DNF教你如何不花一分钱制作90顶级史诗
11. 超哇塞的 SpringBoot性能优化长文
12. 07-小蜜蜂单片机中断系统
13. 基于hadoop的商品推荐系统_[零基础入门推荐系统(1)]基于用户和基于物品的协同过滤方法(python代码实现)...
14. Word中使用MathType批量调整文档公式的大小
15. 读书笔记：《启示录》
16. LCL型并网逆变器的功率控制研究
17. 项目：“表情包”制作---利用ffmpeg制作Gif动态图
18. 玩骰子的儿童（赫拉克利特）
19. 微信公众号接入智能聊（ga）天(liao)机器人
20. PaperWeekly 第38期 | SQuAD综述

热门文章

1. python中if语句求最大值_如何用if语句向量化numpy数组中的最大值？
2. mpf6_Time Series Data_quandl_更正kernel PCA_AIC_BIC_trend_log_return_seasonal_decompose_sARIMAx_ADFull
3. 精准助力中小微企业 京东惠寻的核心逻辑是什么
4. 西门子工业自动化资料大全 (2019年11月1日版)
5. word文档转html在线预览Demo
6. 修炼成C++高手必看的C++书单
7. easyuefi只能在基于uefi启动的_UEFI模式有什么优点？安装系统首选UEFI启动，电脑系统速度更流畅...
8. 基于MATLAB的LTEA载波聚合算法仿真
9. 【重拾Java系列】—— 八大常用类
10. SEO们，停下互点和伪原创，进来看下