尚硅谷2020周阳老师SpringCloud学习整理笔记第二部分

    
<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>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>undefined</dependencies>

yml文件配置

server:  port: 3344​
spring:  application:    
name: cloud-config-center  cloud:    config:      server:        git:          skipSslValidation: true # 跳过ssl认证          uri: https://github.com/Jiaru0314/springcloud-config.git          search-paths:            - springcloud-config      label: master​eureka:  client:    service-url:      defaultZone: http://eureka7001.com:7001/eureka

主启动类

@SpringBootApplication@EnableConfigServerpublic class MainConfigCenter3344 {    public static void main(String[] args) {        SpringApplication.run(MainConfigCenter3344.class, args);    }}

Spring Cloud Config 有它的一套访问规则，我们通过这套规则在浏览器上直接访问就可以。

/{application}/{profile}[/{label}]/{application}-{profile}.yml/{label}/{application}-{profile}.yml/{application}-{profile}.properties/{label}/{application}-{profile}.properties 

{application} 就是应用名称，对应到配置文件上来，就是配置文件的名称部分，例如我上面创建的配置文件。

{profile} 就是配置文件的版本，我们的项目有开发版本、测试环境版本、生产环境版本，对应到配置文件上来就是以 application-{profile}.yml 加以区分，例如application-dev.yml、application-sit.yml、application-prod.yml。

{label} 表示 git 分支，默认是 master 分支，如果项目是以分支做区分也是可以的，那就可以通过不同的 label 来控制访问不同的配置文件了。

访问：http://localhost:3344/config-dev.yml

结果：

config:  info: master branch,springcloud-config/config-dev.yml version=7 

配置成功，但是这样还存在一个问题，就是当我们github上更新配置后，我们的服务要重新启动才能使用新的配置，否则配置无法生效。解决方案就是动态的修改配置。

使用标签:@RefreshScope

步骤：

1. pom文件引入actuator依赖

2. 修改yml,暴露监控端口

   #暴露监控端点management:  endpoints:    web:      exposure:        include: "*" 
   

3. @RefreshScope修饰控制类

4. cmd下 执行

   curl -X POST "http://localhost:3355/actuator/refresh" 
   

   3355模块重新获取配置信息

十六、Bus消息中心

1、首先配置RabbitMQ

下载erlang 地址：http://erlang.org/download/otp_win64_21.3.exe 傻瓜式安装即可

下载RabbitMQ 地址：https://github.com/rabbitmq/rabbitmq-server/releases/download/v3.8.2/rabbitmq-server-3.8.2.exe 傻瓜式安装即可

进入rabbitmq安装目录下的sbin目录：输入

 rabbitmq-plugins enable rabbitmq_management

双击RabbitMQ service start

浏览器输入：localhost:15672 如果出现如下页面，则安装成功

输入账号和密码：guest、guest 可以看到RabbitMQ的主界面

2、参照3355模块新建3366模块

3344模块添加新依赖：

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

3344新添yml:

rabbitmq:  host: localhost  port: 5672  username: guest  password: guest  # 暴露bus刷新配置的端点management:  endpoints:    web:      exposure:        include: "bus-refresh" 

3355、3366yml新增：

rabbitmq: #rabbitmq相关配置，15672是web管理端口，5672是mq访问端口  port: 5672  host: localhost  username: guest  password: guest #暴露监控端点management:  endpoints:    web:      exposure:        include: "*" 

1、修改github中版本号

2、cmd 刷新3344

curl -X POST "http://localhost:3344/actuator/bus-refresh" 

**结果：**3355、3366 都已经改变，一次修改、广播通知、到处运行。

上面是全局通知，但如果我们想定点通知该如何做呢？

**定点通知：**只通知3355，不通知3366

实现方法：cmd 刷新3344

curl -X POST "http://localhost:3344/actuator/bus-refresh/config-client:3355" 

第十五章 SpringCloud Stream

**问题：**为什么要引入SpringCloud Stream

举例：对于我们Java程序员来说，可能有时要使用ActiveMQ,有时要使用RabbitMQ,甚至还有RocketMQ以及Kafka，这之间的切换似乎很麻烦，我们很难，也没有太多时间去精通每一门技术，那有没有一种新技术的诞生，让我们不再关注具体MQ的细节，自动的给我们在各种MQ内切换。

简介：Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于 Spring Boot 来创建独立的、可用于生产的 Spring 应用程序。Spring Cloud Stream 为一些供应商的消息中间件产品提供了个性化的自动化配置实现，并引入了发布-订阅、消费组、分区这三个核心概念。通过使用 Spring Cloud Stream，可以有效简化开发人员对消息中间件的使用复杂度，**让系统开发人员可以有更多的精力关注于核心业务逻辑的处理。**但是目前 Spring Cloud Stream 只支持 RabbitMQ 和 Kafka 的自动化配置。

**一句话：**屏蔽底层消息中间件的差异，降低切换成本，统一消息的编程模型。

Binder Implementations 绑定器

通过绑定器Binder作为中间件，实现了应用程序与消息中间件细节的解耦。

Input对应消息生产者

Output对应消息消费者

入门案例

1. 新建子模块

   cloud-stream-rabbitmq-provider8801 消息生产模块

2. pom

   <dependencies>    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-web</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-netflix-eureka-client</artifactId>    </dependency>    <dependency>        <groupId>org.springframework.cloud</groupId>        <artifactId>spring-cloud-starter-stream-rabbit</artifactId>    </dependency>    <dependency>        <groupId>org.projectlombok</groupId>        <artifactId>lombok</artifactId>        <optional>true</optional>    </dependency>    <dependency>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-test</artifactId>        <scope>test</scope>    </dependency></dependencies>
   

3. yml

   server:  port: 8801 spring:  application:    name: cloud-stream-provider  cloud:    stream:      binders: # 在此处配置要绑定的rabbitMQ的服务信息        defaultRabbit: # 表示定义的名称，用于binding的整合          type: rabbit # 消息中间件类型          environment: # 设置rabbitMQ的相关环境配置            spring:              rabbitmq:                host: localhost                port: 5672                username: guest                password: guest      bindings: # 服务的整合处理        output: # 这个名字是一个通道的名称          destination: studyExchange # 表示要使用的exchange名称定义          content-type: application/json # 设置消息类型，本次为json，文本则设为text/plain          binder: defaultRabbit # 设置要绑定的消息服务的具体设置 eureka:  client:    service-url:      defaultZone: http://eureka7001.com:7001/eureka  instance:    lease-renewal-interval-in-seconds: 2 # 设置心跳的间隔时间，默认30    lease-expiration-duration-in-seconds: 5 # 超过5秒间隔，默认90    instance-id: send-8801.com # 主机名    prefer-ip-address: true # 显示ip 
   

4. 业务类

   1. 主启动类

   2. IMessageProvider接口

   3. public interface IMessageProvider {    String send();}
      

   4. MessageProviderImpl实现类

      public class MessageProviderImpl implements IMessageProvider {@Overridepublic String send() {    return null;    }}
      

   5. 控制层

      @RestControllerpublic class SendMessageController {​    @Autowired    private IMessageProvider messageProvider;​    @GetMapping("/sendMessage")    public String send() {        return messageProvider.send();    }}
      

5. 启动rabbitMQ,7001,8801 访问localhost:8801/sendMessage

   返回结果：62b3cb3e-ca40-410e-a601-dc72dfd004b5

6. 

7. 新建子模块

   cloud-stream-rabbitmq-consumer8802 消息消费模块

8. pom文件同8801

9. yml文件

   server:  port: 8802​spring:  application:    name: cloud-stream-consumer  cloud:    stream:      binders: # 在此处配置要绑定的rabbitMQ的服务信息        defaultRabbit: # 表示定义的名称，用于binding的整合          type: rabbit # 消息中间件类型          environment: # 设置rabbitMQ的相关环境配置            spring:              rabbitmq:                host: localhost                port: 5672                username: guest                password: guest      bindings: # 服务的整合处理        input: # 这个名字是一个通道的名称          destination: studyExchange # 表示要使用的exchange名称定义          content-type: application/json # 设置消息类型，本次为json，文本则设为text/plain          binder: defaultRabbit # 设置要绑定的消息服务的具体设置          # group: spectrumrpcA​eureka:  client:    service-url:      defaultZone: http://eureka7001.com:7001/eureka  instance:    lease-renewal-interval-in-seconds: 2 # 设置心跳的间隔时间，默认30    lease-expiration-duration-in-seconds: 5 # 超过5秒间隔，默认90    instance-id: receive-8802.com #主机名    prefer-ip-address: true # 显示ip
   

10. 业务类

1.  主启动类
    
2.  服务类
    
    ```html
    /** * @ClassName: ReceiveMessageListenerController * @description: * @author: XZQ * @create: 2020/3/10 15:34 **/@Component@EnableBinding(Sink.class)public class ReceiveMessageListenerController {​    @Value("${server.port}")    private String serverPort;​    @StreamListener(Sink.INPUT)    public void input(Message<String> message) {        System.out.println("消费者1，-------" + message.getPayload() + "\t port:" + serverPort);    } }
    ```

11. 启动8802，8801发送消息，可以看到8802可以接受到消息，案例完成。

消息重复消费

不同的组存在重复消费，相同的组之间竞争消费。

1. 参照8802建立8803模块

2. 8802、8803yml加入组名 spectrumrpcA

   bindings: # 服务的整合处理        input: # 这个名字是一个通道的名称          destination: studyExchange # 表示要使用的exchange名称定义          content-type: application/json # 设置消息类型          binder: defaultRabbit # 设置要绑定的消息服务的具体设置          # group: spectrumrpcA 
   

3. 分别启动8802、8803

4. 8801发送消息、发现只有一个模块收到消息

第十六章 SpringCloud Sleuth

未完待更新