微服务架构 基础(六)

微服务架构 基础(六)

微服务架构 基础(六) 持续更新…

---

继续前面的基础五工程进行扩展

这里Spring Cloud Bus利用RabbitMQ作为消息代理，建议读者先了解RabbitMQ

消息总线

什么是总线?
在微服务架构中，通常会使用轻量级消息代理来构建一个共用的消息主题，并让系统中所有微服务实例都连接上来。由于该主题中产生的消息都会被所有实例监听和消费，所以称它为消息总线。在总线上的各个实例，都可以方便地广播一些需要让其它连接在该主题上的实例都被通知到的消息。
基本原理
ConfigClient实例(消息消费者)都监听MQ中的同一个Topic(默认是SpringCloudBus)。当一个服务刷新数据时(此时为消息生产者)，它会把这个消息放入Topic中，这样其它监听同一个Topic的服务器都能得到通知，然后去更新自身的配置信息。

Spring Cloud Bus 是用来将分布式系统的节点与轻量级消息系统链接起来的框架，它整合了Java的事件处理机制和消息中间件的功能。Sprng Cloud Bus目前支持RabbitMQ和Kafka。其配合Spring Cloud Config使用可以实现配置的动态刷新…

实现方式I基本框架结构：

通知某个配置客户端来达到动态更新的效果

实现方式II基本框架结构：

通过配置服务中心广播来达到所有的配置客户端的动态刷新的效果

但是方式I并不太合适，技术选型一般是选择方式II，其主要原因是以下几点…

• 打破了微服务的职责单一性，因为微服务本身是业务模块，它本身不应该承担刷新的职责
• 有一定的局限性。比如：微服务在迁移时，它的网络地址常常发生改变时，就会增加更多地修改
• 破坏了微服务节点的对等性

Spring Cloud Bus动态刷新全局广播

为了测试学习的需要，这里以config-client-11001作为模板，再添加新的子模块config-client-11002：

配置中心服务端添加消息总线依赖：

    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-client



    org.springframework.cloud
    spring-cloud-config-server



    org.springframework.cloud
    spring-cloud-starter-bus-amqp


    org.springframework.boot
    spring-boot-starter-actuator


    org.springframework.boot
    spring-boot-starter-web


    org.springframework.boot
    spring-boot-starter-test
    test
    
        
            org.junit.vintage
            junit-vintage-engine
        
    

客户端的依赖为：

 

    org.springframework.cloud
    spring-cloud-starter-bus-amqp



    org.springframework.cloud
    spring-cloud-starter-netflix-eureka-client



    org.springframework.cloud
    spring-cloud-starter-config


    org.springframework.boot
    spring-boot-starter-web


    org.springframework.boot
    spring-boot-starter-actuator


    org.springframework.boot
    spring-boot-devtools
    runtime
    true


    org.springframework.boot
    spring-boot-starter-test
    test
    
        
            org.junit.vintage
            junit-vintage-engine
        
    

修改配置中心服务端application.yml：

server:
  port: 10002
spring:
  application:
    name: config-center-10002
  cloud:
    config:
      server:
        git:
          uri: https://gitee.com/yiyexingchen/spring-cloud-config.git
          default-label: master
          search-paths:
            - SpringCloud
          username: ***
          password: ***
  rabbitmq:
    # RabbitMQ配置
    password: root
    host: 192.168.50.248
    port: 5672
    username: root

eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.cn:7001/eureka,http://eureka7002.cn:7002/eureka
    register-with-eureka: true # 注册到Eureka中心
    fetch-registry: true # 可以获取注册中心列表信息
# 暴露Bus刷新配置端点
management:
  endpoints:
    web:
      exposure:
        include: 'bus-refresh'

修改两个客户端bootstrap.yml：

server:
  port: 11001
spring:
  application:
    name:  config-client
  cloud:
    config:
      label: master # 分支名称
      name: config # 配置文件名称
      profile: dev # 开发环境的后缀
      uri: http://localhost:10002 # 配置中心地址
  rabbitmq:
    # RabbitMQ配置信息
    username: root
    password: root
    port: 5672
    host: 192.168.50.248


eureka:
  client:
    register-with-eureka: true # 注册
    fetch-registry: true # 获取注册列表信息
    service-url:
      defaultZone: http://eureka7001.cn:7001/eureka,http://eureka7002.cn:7002/eureka

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

配置中心服务端主启动类：

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

客户端控制层：

package cn.wu.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

// 这里有坑，一定要是@RefreshScope注解在@RestController注解之前
// @RefreashScope替代的Bean要在@RestController默认生成的Bean生成之前发生才有效
@RefreshScope // 添加热加载注解
@RestController
public class ConfigController {

    @Value("${server.port}")
    private String port;
    @Value("${config.info}")
    private String configInfo;

    @GetMapping("/config/info")
    public String getConfigInfo(){
        return "当前端口为: "+this.port+"，获取的配置信息为: "+this.configInfo;
    }
}

首先启动两个Eureke注册中心服务端，再启动配置中心服务端，然后启动两个配置中心服务端，结果如下：

Eureak服务注册中心

RabbitMQ队列

此时，修改Gitee仓库中的配置信息，然后通过POST请求(curl -X POST “http://192.168.50.186:10002/actuator/bus-refresh” )激活配置中心服务端(config-center-10002)即可，可以发现：

如果读者还是没有达到以上的效果，可以检查一下依赖是否齐全，yml文件是否对齐或拼写正确，是否在正确位置上添加注解，浏览器缓存等问题…

至此，以上就完成了一次修改，广播通知，处处通知的动态刷新效果…

Spring Cloud Bus动态刷新定点通知

如果需要差异化通知，并不想进行全局广播，此时就用到了 Bus 的定点通知功能。

有了上面的 *** 作之后，定点通知的 *** 作很简单…

只需要对相应客户端模块执行POST请求：

curl -X POST “http://192.168.50.186:10002/actuator/bus-refresh/config-client:11001”

结果：

下一个基础章节开始学习消息驱动以及分布式请求和链路跟踪…

---