目录

Config 分布式配置中心

Config 概述

Config 快速入门

config server&＃xff1a;

config client&＃xff1a;

Config 客户端刷新

Config 集成Eureka

实验十

Bus 消息总线

Bus 概述

RabbitMQ 回顾

 RabbitMQ的结构

  RabbitMQ的工作模式

 RabbitMQ Windows安装

Bus 快速入门

实验十一

Stream 消息驱动

Stream 概述

 Stream 组件

Stream 消息生产者

Stream 消息消费者

实验十二

Sleuth&＃43;Zipkin 链路追踪

概述

Sleuth&＃43;Zipkin 快速入门

实验十三

Config 分布式配置中心

Config 概述

• Spring Cloud Config 解决了在分布式场景下多环境配置文件的管理和维护。
• 好处&＃xff1a;

1. 集中管理配置文件
2. 不同环境不同配置&＃xff0c;动态化的配置更新
3. 配置信息改变时&＃xff0c;不需要重启即可更新配置信息到服务

 外部配置文件&＃xff0c;放着A、B、C等服务的配置文件&＃xff0c;其放的位置&＃xff0c;可能是在本地目录或者云端&＃xff08;如gitee&＃xff09;

Config 快速入门

config server&＃xff1a;

1. 使用gitee创建远程仓库&＃xff0c;上传配置文件
2. 搭建 config server 模块
3. 导入 config-server 依赖
4. 编写配置&＃xff0c;设置 gitee 远程仓库地址
5. 测试访问远程配置文件

config client&＃xff1a;

1. 导入 starter-config 依赖
2. 配置config server 地址&＃xff0c;读取配置文件名称等信息
3. 获取配置值
4. 启动测试

Config 客户端刷新

外部配置文件发生了变更&＃xff0c;Config Server不需要更改&＃xff0c;可以直接访问获取&＃xff0c;但A、B和C等服务客服端想获取最新的配置信息&＃xff0c;必须要配置。

• 在 config 客户端引入 actuator 依赖
• 获取配置信息类上&＃xff0c;添加 &＃64;RefreshScope 注解
• 添加配置      

      management&＃xff1a;

           endpoints&＃xff1a;

                  web&＃xff1a;

                     exposure&＃xff1a;

                             include: refresh

• 使用curl工具发送post请求   在dos窗口中输入命令

      curl -X POST   http://localhost:8001/actuator/refresh

Config 集成Eureka

之前 A、B和C获取Config Server地址静态的&＃xff0c;若Config Server地址发生变更&＃xff0c;那么就要一个一个修改访问Config Server地址&＃xff0c;麻烦&＃xff01;可以有一个简单的方法&＃xff0c;就是把Config Server注册到Eureka上&＃xff0c;如上所示。

实验十

项目结构

 config-server模块

1、pom.xml引入config-server依赖

org.springframework.cloudspring-cloud-config-serverorg.springframework.cloudspring-cloud-starter-netflix-eureka-client

 2、application.yml 文件

server:port: 9527spring:application:name: config-server# spring cloud configcloud:config:server:# git 的 远程仓库地址git:uri: https://gitee.com/itheima_cch/itheima-configs.gitlabel: master # 分支配置# 将自己注册到ureka中
ureka:client:service-url:defaultZone: http://localhost:8761/eureka

 2、启动ConfigServerApp

&＃64;SpringBootApplication
&＃64;EnableConfigServer // 启用config server功能
&＃64;EnableEurekaClient
public class ConfigServerApp {public static void main(String[] args) {SpringApplication.run(ConfigServerApp.class,args);}
}


eureka-server-config模块

和实验九eureka-server-gateway模块一样

config-provider模块

1.pom.xml引入依赖

org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-netflix-hystrixorg.springframework.cloudspring-cloud-starter-config

2、application.yml和bootstrap.yml文件

server:port: 8002eureka:client:service-url:defaultZone: http://localhost:8761/eureka
spring:application:name: config-provider

# 配置config-server地址
# 配置获得配置文件的名称等信息
spring:cloud:config:#####下列两种方法获取config-server地址###### 配置config-server地址uri: http://localhost:9527# 配置获得配置文件的名称等信息name: config # 文件名profile: dev # profile指定&＃xff0c; config-dev.ymllabel: master # 分支#从注册中心去寻找config-server地址discovery:enabled: trueservice-id: config-servermanagement:endpoints:web:exposure:include: &＃39;*&＃39;


3、GoodsController类         &＃64;RefreshScope

&＃64;RestController
&＃64;RequestMapping("/goods")
&＃64;RefreshScope // 开启刷新功能
public class GoodsController {&＃64;Autowiredprivate GoodsService goodsService;&＃64;Value("${server.port}")private int port;&＃64;Value("${itheima}")private String itheima;/*** 降级&＃xff1a;* 1. 出现异常* 2. 服务调用超时* * 默认1s超时** &＃64;HystrixCommand(fallbackMethod &＃61; "findOne_fallback")* fallbackMethod&＃xff1a;指定降级后调用的方法名称*/&＃64;GetMapping("/findOne/{id}")&＃64;HystrixCommand(fallbackMethod &＃61; "findOne_fallback",commandProperties &＃61; {//设置Hystrix的超时时间&＃xff0c;默认1s&＃64;HystrixProperty(name&＃61;"execution.isolation.thread.timeoutInMilliseconds",value &＃61; "3000"),//监控时间 默认5000 毫秒&＃64;HystrixProperty(name&＃61;"circuitBreaker.sleepWindowInMilliseconds",value &＃61; "5000"),//失败次数。默认20次&＃64;HystrixProperty(name&＃61;"circuitBreaker.requestVolumeThreshold",value &＃61; "20"),//失败率 默认50%&＃64;HystrixProperty(name&＃61;"circuitBreaker.errorThresholdPercentage",value &＃61; "50")})public Goods findOne(&＃64;PathVariable("id") int id){//如果id &＃61;&＃61; 1 &＃xff0c;则出现异常&＃xff0c;id !&＃61; 1 则正常访问if(id &＃61;&＃61; 1){//1.造个异常int i &＃61; 3/0;}/*try {//2. 休眠2秒Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}*/Goods goods &＃61; goodsService.findOne(id);goods.setTitle(goods.getTitle() &＃43; ":" &＃43; port&＃43;":"&＃43;itheima);//将端口号&＃xff0c;设置到了 商品标题上return goods;}/*** 定义降级方法&＃xff1a;* 1. 方法的返回值需要和原方法一样* 2. 方法的参数需要和原方法一样*/public Goods findOne_fallback(int id){Goods goods &＃61; new Goods();goods.setTitle("降级了~~~");return goods;}}


4、Goods、GoodsService和GoodsDao

和实验一 一样

5、ProviderApp启动类

&＃64;EnableEurekaClient //该注解 在新版本中可以省略
&＃64;SpringBootApplication
&＃64;EnableCircuitBreaker // 开启Hystrix功能
public class ProviderApp {public static void main(String[] args) {SpringApplication.run(ProviderApp.class,args);}
}


config-consumer 模块

1、pom.xml文件

org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-openfeign

2、application.yml 文件

server:port: 9000eureka:instance:hostname: localhost # 主机名client:service-url:defaultZone: http://localhost:8761/eureka
spring:application:name: config-consumer# 开启feign对hystrix的支持
feign:hystrix:enabled: true

3、GoodsFeignClient类

&＃64;FeignClient(value &＃61; "CONFIG-PROVIDER",fallback &＃61; GoodsFeignClientFallback.class)
public interface GoodsFeignClient {&＃64;GetMapping("/goods/findOne/{id}")public Goods findGoodsById(&＃64;PathVariable("id") int id);}


其他和实验七 hystrix-consumer 模块 一样

运行结果&＃xff1a;

Bus 消息总线

Bus 概述

• Spring Cloud Bus 是用轻量的消息中间件将分布式的节点连接起来&＃xff0c;可以用于广播配置文件的更改或者服务的监控管理。关键的思想就是&＃xff0c;消息总线可以为微服务做监控&＃xff0c;也可以实现应用程序之间相通信。
• Spring Cloud Bus 可选的消息中间件包括 RabbitMQ 和  Kafka 。

 运维人员输入&＃xff1a;/actuator/bus-refresh命令&＃xff0c;Config Server会发出消息给Bus&＃xff0c;接着Bus会广播配置文件的更改。

curl -X POST   http://localhost:9527/actuator/refresh

RabbitMQ 回顾

A服务将消息给消息队列&＃xff0c;B服务从消息队列中拿消息。

 RabbitMQ的结构

  RabbitMQ的工作模式

RabbitMQ 提供了 6 种工作模式&＃xff1a;简单模式、work queues、Publish/Subscribe 发布与订阅模式、Routing 路由模式、Topics 主题模式、RPC 远程调用模式&＃xff08;远程调用&＃xff0c;不太算 MQ&＃xff1b;暂不作介绍&＃xff09;。

 RabbitMQ Windows安装

详细看资料

Bus 快速入门

bus组件不需要你创建任何模块&＃xff0c;它就是RabbitMQ代码的封装。config-server要发消息&＃xff0c;config-client要收消息。

• 分别在 config-server 和 config-client中引入bus依赖&＃xff1a;bus-amqp
• 分别在 config-server 和 config-client中配置 RabbitMQ
• 在config-server中设置暴露监控断点&＃xff1a;bus-refresh
• 启动测试

实验十一

项目结构

 config-server-1模块

 1、pom.xml 引入相关依赖

org.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-config-serverorg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-bus-amqp

2、application.yml文件

server:port: 9527spring:application:name: config-server# spring cloud configcloud:config:server:# git 的 远程仓库地址git:uri: https://gitee.com/itheima_cch/itheima-configs.gitlabel: master # 分支配置#配置rabbitmq信息rabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: /# 将自己注册到eureka中
eureka:client:service-url:defaultZone: http://localhost:8761/eureka# 暴露bus的刷新端点
management:endpoints:web:exposure:include: &＃39;bus-refresh&＃39;

3、ConfigServerApp启动类

&＃64;SpringBootApplication
&＃64;EnableConfigServer // 启用config server功能
&＃64;EnableEurekaClient
public class ConfigServerApp {public static void main(String[] args) {SpringApplication.run(ConfigServerApp.class,args);}
}


eureka-server-config-1模块

和实验九 eureka-server-gateway模块  一样

config-provider-1模块

1、pom.xml模块

org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-netflix-hystrixorg.springframework.cloudspring-cloud-starter-configorg.springframework.cloudspring-cloud-starter-bus-amqpjavax.xml.bindjaxb-api2.3.1

2、application.yml和bootstrap.yml文件

server:port: 8002eureka:client:service-url:defaultZone: http://localhost:8761/eureka
spring:application:name: config-provider


# 配置config-server地址
# 配置获得配置文件的名称等信息
spring:cloud:config:# 配置config-server地址# uri: http://localhost:9527# 配置获得配置文件的名称等信息name: config # 文件名profile: dev # profile指定&＃xff0c; config-dev.ymllabel: master # 分支# 从注册中心去寻找config-server地址discovery:enabled: trueservice-id: CONFIG-SERVER#配置rabbitmq信息rabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: /management:endpoints:web:exposure:include: &＃39;*&＃39;

3、GoodsDao、GoodsService、Goods、GoodsController和ProviderApp

看实验十模块

config-consumer-1模块

1、pom.xml文件依赖

org.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-actuatororg.springframework.cloudspring-cloud-starter-netflix-eureka-clientorg.springframework.cloudspring-cloud-starter-openfeignorg.springframework.cloudspring-cloud-starter-configorg.springframework.cloudspring-cloud-starter-bus-amqp

2.application.yml  文件、bootstrap.yml文件

server:port: 9001eureka:instance:hostname: localhost # 主机名client:service-url:defaultZone: http://localhost:8761/eureka
spring:application:name: config-consumer# 开启feign对hystrix的支持
feign:hystrix:enabled: true

# 配置config-server地址
# 配置获得配置文件的名称等信息
spring:cloud:config:# 配置config-server地址# uri: http://localhost:9527# 配置获得配置文件的名称等信息name: config # 文件名profile: dev # profile指定&＃xff0c; config-dev.ymllabel: master # 分支# 从注册中心去寻找config-server地址discovery:enabled: trueservice-id: CONFIG-SERVER#配置rabbitmq信息rabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: /management:endpoints:web:exposure:include: &＃39;*&＃39;


3、其余模块看实验十

运行结果

Stream 消息驱动

Stream 概述

• Spring Cloud Stream 是一个构建消息驱动微服务应用的框架。如左图
• Stream 解决了开发人员无感知的使用消息中间件的问题&＃xff0c;因为Stream对消息中间件的进一步封装&＃xff0c;可以做到代码层面对中间件的无感知&＃xff0c;甚至于动态的切换中间件&＃xff0c;使得微服务开发的高度解耦&＃xff0c;服务可以关注更多自己的业务流程。类似于右图
• Spring Cloud Stream目前支持两种消息中间件RabbitMQ和Kafka

 Stream 组件

•  Spring Cloud Stream 构建的应用程序与消息中间件之间是通过绑定器 Binder 相关联的。绑定器对于应用程序而言起到了隔离作用&＃xff0c; 它使得不同消息中间件的实现细节对应用程序来说是透明的。
• binding 是我们通过配置把应用和spring cloud stream 的 binder 绑定在一起
• output&＃xff1a;发送消息 Channel&＃xff0c;内置 Source接口
• input&＃xff1a;接收消息 Channel&＃xff0c;内置 Sink接口

Stream 消息生产者

1. 创建消息生产者模块&＃xff0c;引入依赖 starter-stream-rabbit
2. 编写配置&＃xff0c;定义 binder&＃xff0c;和 bingings
3. 定义消息发送业务类。添加 &＃64;EnableBinding(Source.class)&＃xff0c;注入MessageChannel output &＃xff0c;完成消息发送
4. 编写启动类&＃xff0c;测试

Stream 消息消费者

1. 创建消息消费者模块&＃xff0c;引入依赖 starter-stream-rabbit
2. 编写配置&＃xff0c;定义 binder&＃xff0c;和 bingings
3. 定义消息接收业务类。添加 &＃64;EnableBinding(Sink.class)&＃xff0c;使用&＃64;StreamListener(Sink.INPUT)&＃xff0c;完成消息接收。
4. 编写启动类&＃xff0c;测试

实验十二

项目结构

 stream-producer模块

1、pom.xml 文件引入依赖

org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-stream-rabbit

2、application.yml文件

server:port: 8000spring:cloud:stream:# 定义绑定器&＃xff0c;绑定到哪个消息中间件上binders:itheima_binder: # 自定义的绑定器名称type: rabbit # 绑定器类型environment: # 指定mq的环境spring:rabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: /bindings:output: # channel名称binder: itheima_binder #指定使用哪一个binderdestination: itheima_exchange # 消息目的地

3、MessageProducer类、ProducerController类

&＃64;Component
&＃64;EnableBinding(Source.class)
public class MessageProducer {&＃64;Autowiredprivate MessageChannel output;public void send(){String msessage &＃61; "hello stream~~~";//发送消息output.send(MessageBuilder.withPayload(msessage).build());System.out.println("消息发送成功~~~");}
}


&＃64;RestController
public class ProducerController {&＃64;Autowiredprivate MessageProducer producer;&＃64;RequestMapping("/send")public String sendMsg(){producer.send();return "success";}
}


4、启动类ProducerApp

&＃64;SpringBootApplication
public class ProducerApp {public static void main(String[] args) {SpringApplication.run(ProducerApp.class,args);}
}


stream-consumer 模块

1、pom.xml 文件

org.springframework.bootspring-boot-starter-weborg.springframework.cloudspring-cloud-starter-stream-rabbit

2.application.yml文件

server:port: 9001spring:cloud:stream:# 定义绑定器&＃xff0c;绑定到哪个消息中间件上binders:itheima_binder: # 自定义的绑定器名称type: rabbit # 绑定器类型environment: # 指定mq的环境spring:rabbitmq:host: localhostport: 5672username: guestpassword: guestvirtual-host: /bindings:input: # channel名称binder: itheima_binder #指定使用哪一个binderdestination: itheima_exchange # 消息目的地


3.MessageListener类

*** 消息接收类*/
&＃64;EnableBinding({Sink.class})
&＃64;Component
public class MessageListener {&＃64;StreamListener(Sink.INPUT)public void receive(Message message){System.out.println(message);System.out.println(message.getPayload());}
}

4.启动类ConsumerApp

&＃64;SpringBootApplication
public class ConsumerApp {public static void main(String[] args) {SpringApplication.run(ConsumerApp.class,args);}
}


运行结果&＃xff1a;

Sleuth&＃43;Zipkin 链路追踪

概述

Spring Cloud Sleuth 其实是一个工具,它在整个分布式系统中能跟踪一个用户请求的过程&＃xff0c;捕获这些跟踪数据&＃xff0c;就能构建微服务的整个调用链的视图&＃xff0c;这是调试和监控微服务的关键工具。

1. 耗时分析
2. 可视化错误
3. 链路优化

• Zipkin 是 Twitter 的一个开源项目&＃xff0c;它致力于收集服务的定时数据&＃xff0c;以解决微服务架构中的延迟问题&＃xff0c;包括数据的收集、存储、查找和展现。

Sleuth&＃43;Zipkin 快速入门

• 安装启动zipkin。
• java –jar zipkin.jar 访问zipkin web界面。
• http://localhost:9411/
• 在服务提供方和消费方分别引入  sleuth 和 zipkin 依赖
• 分别配置服务提供方和消费方。
• 启动&＃xff0c;测试

启动zipkin,就是有该jar包的目录下&＃xff0c;运行命令&＃xff1a;java  -jar   .\zipkin-server-2.12.9-exec.jar

实验十三

略