Spring Cloud Bus

╰半橙微兮° 2022-06-08 06:49 131阅读 0赞

在前面学习Spring Cloud Config的时候最后留了一个尾巴，当我们微服务结点的量级达到一定规模时，一个个维护和refresh服务结点动态更新最新配置信息将会成为一个很费精力的问题，所以Spring framework又推出个新套件Spring Cloud Bus消息总线。

Spring Cloud Bus需要依赖一种MQ，我们这里选择比较流行的RabbitMQ和Kafka。关于两者的原理我们前面博文有分析，在这里只是载体，我直接用docker方式简单安装一个。如果docker的原理和操作还不是很熟练，请从[Docker的原理和安装][Docker]开始练习。

我们的微服务搭建如下：

![Center][]

以RabbitMQ方式集成：

RabbitMQ的环境准备（[RabbitMQ][]）

Eureka-Server代码地址：https://github.com/yejingtao/forblog/tree/master/demo-eureka-register

Config-Server代码地址：https://github.com/yejingtao/forblog/tree/master/demo3-config-server

Config-Client代码地址：[https://github.com/yejingtao/forblog/tree/master/demo3-config-client][https_github.com_yejingtao_forblog_tree_master_demo3-config-client]

Config-ServerPom依赖：

<dependencies>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-config-server</artifactId>
    		</dependency>
    		<dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    	</dependencies>

Config-ClientPom依赖:

<dependencies>
        <dependency>
          <groupId>org.springframework.cloud</groupId>
    		<artifactId>spring-cloud-starter-config</artifactId>
        </dependency>
        <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-bus-amqp</artifactId>
            </dependency>
      </dependencies>

疑问：Server和Client的Actuator是否都是必须依赖的？

回答：向谁发起/bus/refresh就给谁依赖actuator，所以向config-server发起refresh的话，client的actuator不是必须的。

Config\_server的参数配置：

server:
      port: 8001
      
    spring:
      cloud:
        config:
          server:
            git:
              uri: https://github.com/yejingtao/forblog
              search-paths: /config
              username: username
              password: password
      application:
        name: config-server
      rabbitmq:
        host: 192.168.226.130
        port: 5672
        username: guest
        password: guest
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/
    
    management:
      security:
        enabled: false

Config-Client的参数配置：

spring.application.name=configtest
    spring.cloud.config.profile=dev
    spring.cloud.config.label=master
    server.port=7002
    
    #management.security.enabled=false
    
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka/
    
    spring.cloud.config.discovery.enabled=true
    spring.cloud.config.discovery.serviceId=config-server
    
    spring.rabbitmq.host=192.168.226.130
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

注：多了RabbitMq的配置，5672是rabbitMq的默认服务地址

Java代码没有变化，不再详解，验证步骤：

1）  启动Config-Server和Config-Client，GET请求client的/from，看到git上的old value；

2）  修改git上的内容

3）  POST 请求server的/bus/refresh，再GET请求client的/from看到git上的new value。

注：POST请求可以用curl

![Center 1][]

以Kafka方式集成：

Kafka的环境准备（[Kafka原理详解][Kafka]）

Eureka-Server代码地址：https://github.com/yejingtao/forblog/tree/master/demo-eureka-register

Config-Server代码地址：https://github.com/yejingtao/forblog/tree/master/demo4-config-server

Config-Client代码地址：[https://github.com/yejingtao/forblog/tree/master/demo4-config-client][https_github.com_yejingtao_forblog_tree_master_demo4-config-client]

Pom.xml的依赖稍作修改，用spring-cloud-starter-bus-kafka替换spring-cloud-starter-bus-amqp

参数配置稍作修改，用kafka的配置替换RabbitMQ的配置：

Config\_server的参数配置：

server:
      port: 8001
      
    spring:
      cloud:
        config:
          server:
            git:
              uri: https://github.com/yejingtao/forblog
              search-paths: /config
              username: username
              password: password
        stream:
          kafka:
            binder:
              brokers: 192.168.226.130
              defaultBrokerPort: 9092
              zkNodes: 192.168.226.130
              defaultZkPort: 2181
      application:
        name: config-server
    
    eureka:
      client:
        serviceUrl:
          defaultZone: http://peer1:1111/eureka/,http://peer2:1112/eureka/
    
    management:
      security:
        enabled: false

Config-Client的参数配置：

spring.application.name=configtest
    spring.cloud.config.profile=dev
    spring.cloud.config.label=master
    server.port=7002
    
    #management.security.enabled=false
    
    eureka.client.serviceUrl.defaultZone=http://peer1:1111/eureka/,http://peer2:1112/eureka/
    
    spring.cloud.config.discovery.enabled=true
    spring.cloud.config.discovery.serviceId=config-server
    
    spring.cloud.stream.kafka.binder.brokers=192.168.226.130
    spring.cloud.stream.kafka.binder.defaultBrokerPort=9092
    spring.cloud.stream.kafka.binder.zkNodes=192.168.226.130
    spring.cloud.stream.kafka.binder.defaultZkPort=2181

Java代码、验证步骤不存在变化，不再解释。

注：用kafka来做mq实现bus的时候，无论是config的server端还是client端在启动的时候都会打印出以下默认参数：

auto.commit.interval.ms = 100
    	auto.offset.reset = latest
    	bootstrap.servers = [192.168.226.130:9092]
    	check.crcs = true
    	client.id = 
    	connections.max.idle.ms = 540000
    	enable.auto.commit = false
    	exclude.internal.topics = true
    	fetch.max.bytes = 52428800
    	fetch.max.wait.ms = 500
    	fetch.min.bytes = 1
    	group.id = anonymous.73cf1d38-c6c1-4615-9361-0a314f34cbde
    	heartbeat.interval.ms = 3000
    	interceptor.classes = null
    	key.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer
    	max.partition.fetch.bytes = 1048576
    	max.poll.interval.ms = 300000
    	max.poll.records = 500
    	metadata.max.age.ms = 300000
    	metric.reporters = []
    	metrics.num.samples = 2
    	metrics.sample.window.ms = 30000
    	partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor]
    	receive.buffer.bytes = 65536
    	reconnect.backoff.ms = 50
    	request.timeout.ms = 305000
    	retry.backoff.ms = 100
    	sasl.kerberos.kinit.cmd = /usr/bin/kinit
    	sasl.kerberos.min.time.before.relogin = 60000
    	sasl.kerberos.service.name = null
    	sasl.kerberos.ticket.renew.jitter = 0.05
    	sasl.kerberos.ticket.renew.window.factor = 0.8
    	sasl.mechanism = GSSAPI
    	security.protocol = PLAINTEXT
    	send.buffer.bytes = 131072
    	session.timeout.ms = 10000
    	ssl.cipher.suites = null
    	ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
    	ssl.endpoint.identification.algorithm = null
    	ssl.key.password = null
    	ssl.keymanager.algorithm = SunX509
    	ssl.keystore.location = null
    	ssl.keystore.password = null
    	ssl.keystore.type = JKS
    	ssl.protocol = TLS
    	ssl.provider = null
    	ssl.secure.random.implementation = null
    	ssl.trustmanager.algorithm = PKIX
    	ssl.truststore.location = null
    	ssl.truststore.password = null
    	ssl.truststore.type = JKS
    	value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer

[Docker]: http://blog.csdn.net/yejingtao703/article/details/77938932
[Center]: /images/20220608/568d02da067648beb9301c13547fc5c1.png
[RabbitMQ]: http://blog.csdn.net/yejingtao703/article/details/77993010
[https_github.com_yejingtao_forblog_tree_master_demo3-config-client]: https://github.com/yejingtao/forblog/tree/master/demo3-config-client
[Center 1]: /images/20220608/059429f58f7f4990b0bcc103a98caa1e.png
[Kafka]: http://blog.csdn.net/yejingtao703/article/details/78020019
[https_github.com_yejingtao_forblog_tree_master_demo4-config-client]: https://github.com/yejingtao/forblog/tree/master/demo4-config-client