SpringCloud学习笔记（十、消息总线）

it2022-05-05 182

RabbitMQ

前面虽然把视图微服务改造成了配置客户端，但是存在一个问题，每次git上修改配置的时候，必须重新启动配置服务器和配置客户端才能拿到。这样一来很不方便，所以就有了办法，通过RabbitMQ 来进行消息广播，以达到有配置信息发生改变的时候，广播给多个微服务的效果。配置消息总线前：配置消息总线后：

改造配置爱客户端

之前把product-view-service-feign改造成了消息客户端，现在在原有基础上继续改造。

pom.xml

1、添加spring-boot-starter-actuator 用于访问路径：/actuator/bus-refresh 2. 添加spring-cloud-starter-bus-amqp 用于支持 rabbitmq

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <parent> <artifactId>springcloud</artifactId> <groupId>edu.hpu.springcloud</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <artifactId>product-view-service-feign</artifactId> <dependencies> <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-openfeign</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-thymeleaf</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-zipkin</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-config</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> </dependencies> </project>

bootstrap.yml

新增两个配置， but总线配置：

bus: enabled: true trace: enabled: true

RabbitMQ配置：包含rabbitmq的端口（非可视化工具端口），用户名，密码。

rabbitmq: host: localhost port: 5672 username: guest password: guest spring: cloud: config: label: master profile: dev discovery: enabled: true serviceId: config-server bus: enabled: true trace: enabled: true client: serviceUrl: defaultZone: http://localhost:8761/eureka/ rabbitmq: host: localhost port: 5672 username: guest password: guest

启动类

启动类里添加RabbitMQ启动检测，

package edu.hpu.springcloud; import brave.sampler.Sampler; import cn.hutool.core.convert.Convert; import cn.hutool.core.thread.ThreadUtil; import cn.hutool.core.util.NetUtil; import cn.hutool.core.util.NumberUtil; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.boot.builder.SpringApplicationBuilder; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.netflix.eureka.EnableEurekaClient; import org.springframework.cloud.openfeign.EnableFeignClients; import org.springframework.context.annotation.Bean; import java.util.Scanner; import java.util.concurrent.ExecutionException; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; @SpringBootApplication @EnableEurekaClient @EnableDiscoveryClient @EnableFeignClients public class ProductViewServiceFeignApplication { public static void main(String[] args) { //判断 rabiitMQ 是否启动 int rabbitMQPort = 5672; if(NetUtil.isUsableLocalPort(rabbitMQPort)) { System.err.printf("未在端口%d 发现 rabbitMQ服务，请检查rabbitMQ 是否启动", rabbitMQPort ); System.exit(1); } int port = 0; int defaultPort = 8013; Future<Integer> future = ThreadUtil.execAsync(() ->{ int p = 0; System.out.println("请于5秒钟内输入端口号, 推荐 8012 、 8013 或者 8014，超过5秒将默认使用"+defaultPort); Scanner scanner = new Scanner(System.in); while(true) { String strPort = scanner.nextLine(); if(!NumberUtil.isInteger(strPort)) { System.err.println("只能是数字"); continue; } else { p = Convert.toInt(strPort); scanner.close(); break; } } return p; }); try{ port=future.get(5, TimeUnit.SECONDS); } catch (InterruptedException | ExecutionException | TimeoutException e){ port = defaultPort; } if(!NetUtil.isUsableLocalPort(port)) { System.err.printf("端口%d被占用了，无法启动%n", port ); System.exit(1); } new SpringApplicationBuilder(ProductViewServiceFeignApplication.class).properties("server.port=" + port).run(args); } @Bean public Sampler defaultSampler() { return Sampler.ALWAYS_SAMPLE; } }

FreshConfigUtil类

只能使用 post 的方式访问 http://localhost:8012/actuator/bus-refresh 地址，直接通过地址（get方式）访问的话会报405错误，所以要专门做一个 FreshConfigUtil 类用来做post方式访问。

package edu.hpu.springcloud.util; import cn.hutool.http.HttpUtil; import java.util.HashMap; public class FreshConfigUtil { public static void main(String[] args) { HashMap<String,String> headers =new HashMap<>(); headers.put("Content-Type", "application/json; charset=utf-8"); System.out.println("因为要去git获取，还要刷新config-server, 会比较卡，所以一般会要好几秒才能完成，请耐心等待"); String result = HttpUtil.createPost("http://localhost:8013/actuator/bus-refresh").addHeaders(headers).execute().body(); System.out.println("result:"+result); System.out.println("refresh 完成"); } }

改造至此完成。

启动访问

依次启动注册中心、配置服务器、数据服务、视图服务（配置客户端）。访问地址：http://localhost:8012/products 访问地址：http://localhost:8013/products 修改gitee上配置文件的version. 运行FreshConfigUtil类，refresh完成，再次访问。

重复几次，都可以刷新。

问题

1、视图微服务无法访问注册完端口为8012视图微服务后，接着注册端口为8013的微服务，发现端口8012微服务无法访问了。在注册中心事可以看到，但访问不了。 1.1、cmd -> netstat -ano 查看端口，发现似乎查不到8012端口，那么就不是端口占用的问题。 1.2、想了一会，查不到端口，似乎这个进程被结束了。第二次运行启动类，它有这么个提示，似乎是把之前的进程给停掉了，但是我之前用这种方式能启动两个可访问的微服务。查了一下，修改EditConfiguration,

允许重复启动。OK，两个端口都行了。 ——没想明白我之前是怎么回事。

2、修改git上的配置，运行刷新类，刷新类显示成功，但视图微服务一访问，还是没有刷新出来。 2.1、刚开始看到一个解决办法，在ProductController中加上一个注解，

@RefreshScope public class ProductController {

这个注解是干什么的：RefreshScope(org.springframework.cloud.context.scope.refresh)是spring cloud提供的一种特殊的scope实现，用来实现配置、实例热加载。加了，但是没有解决。来来回回重新启动了两三次，结果突然就就好了，这很玄学。

参考：【1】、http://how2j.cn/k/springcloud/springcloud-bus/2049.html#nowhere 【2】、https://www.fangzhipeng.com/springcloud/2018/08/06/sc-f6-config.html 【3】、https://www.fangzhipeng.com/springcloud/2018/08/08/sc-f8-bus.html 【4】、https://www.cnblogs.com/hfultrastrong/p/8547236.html

专利

最新回复(0)