SpringCloud学习笔记（十、消息总线）
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> <!--对feign方式的支持--> </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> <!--用于访问路径：/actuator/bus-refresh--> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-bus-amqp</artifactId> <!--用于支持RabbitMQ--> </dependency> </dependencies>
</project>
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
bootstrap.yml
新增两个配置，
but总线配置：
bus: enabled: true trace: enabled: true
- 1
- 2
- 3
- 4
RabbitMQ配置：
包含rabbitmq的端口（非可视化工具端口），用户名，密码。
rabbitmq: host: localhost
port: 5672
username: guest
password: guest
- 1
- 2
- 3
- 4
- 5
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
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
启动类
启动类里添加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; }
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
- 58
- 59
- 60
- 61
- 62
- 63
- 64
- 65
- 66
- 67
- 68
- 69
- 70
- 71
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 完成"); }
}
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
改造至此完成。
启动访问
依次启动注册中心、配置服务器、数据服务、视图服务（配置客户端）。
访问地址：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 {
- 1
- 2
这个注解是干什么的：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
文章来源: blog.csdn.net，作者：三分恶，版权归原作者所有，如需转载，请联系作者。
原文链接：blog.csdn.net/sinat_40770656/article/details/96429651
- 点赞
- 收藏
- 关注作者
评论（0）