Spring Cloud Bus 消息总线

Spring Cloud Bus 消息总线

安装RabbitMQ

下载并安装Erlang和RabbitMQ

rabbitmq自带管理后台，安装后需要配置开启

进入rabbitmq安装目录中的sbin目录执行

rabbitmq-plugins enable rabbitmq_management

重启rabbitmq服务生效

打开http://localhost:15672/即可看到管理后台

用户名密码均为guest 【此用户只能本地使用】

测试RabbitMQ栗子：

创建新的RabbitMQ用户 【springcloud，123456】

创建项目：rabbitmq-hello

依赖：

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

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>

配置：

spring.application.name=rabbitmq-hello
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=springcloud
spring.rabbitmq.password=123456

配置类：

@Configuration
public class RabbitConfig {
@Bean
public Queue helloQueue(){
return  new Queue("hello");
}
}

消息生产类：

@Component
public class Sender {
/*消息生产者*/
@Autowired
private AmqpTemplate rabbitTemplate;

public void send(){
String context = "hello " + new Date();
System.out.println("Sender:"+context);
this.rabbitTemplate.convertAndSend("hello",context);
}
}

消息消费类：

@Component
@RabbitListener(queues = "hello")
public class Receiver {
/*消息消费者*/
@RabbitHandler
public void process(String hello){
System.out.println("Receiver:"+hello);
}
}

测试类：

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = RabbitmqHelloApplication.class)
public class RabbitmqHelloApplicationTests {
@Autowired
public Sender sender;

@Test
public void hello() throws Exception {
sender.send();
}
}

测试

确定RabbitMQ服务开启

启动应用主类【可以发现在RabbitMQ控制页面发现多了东东】

启动测试类进行测试【消息消费类会被执行，打印出信息】

完成栗子

整合Bus【整合到整个Cloud里面】

整合到一起，目前所知的只是用来做Config组件配置信息的自动刷新

在config-server，config-client，Eureka 添加依赖与配置

依赖：

<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>

配置：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=springcloud
spring.rabbitmq.password=123456

完成咯。。。。。【对，就是这么简单。。】

测试

启动所有项目

访问配置【git-config-dev-5.0】

修改Git配置【git-config-dev-6.0】

使用任意端点刷新【localhost：7002/bus/refresh】

访问所有服务【config-client：7002/7003】，配置都更新为最新【git-config-dev-6.0】

这个还有局部刷新的参数：/bus/refresh?destination=customers:9000

感觉没什么球用 ╮(╯_╰)╭

遇到的问题：

RabbitMQ新创建的用户，在使用前要求去授权页面点点，然后重启！

这里的自动刷新，还是必须手动发送一个/bus/refresh 才行 (ノ｀Д)ノ

如果使用/refresh 的话，依旧只是更新单个服务

参考：

https://www.linuxidc.com/Linux/2014-10/107917.htm

http://www.60kb.com/post/87.html

小杭 20180319