SpringCloud微服务实战之消息总线BUS-RabbitMQ

古城微笑少年丶 2022-06-03 07:45 230阅读 0赞

> Spring Cloud Bus支持两款消息中间件：RabbitMQ、Kafka。

**一、RabbitMQ实现消息总线**

1、RabbitMQ简介  
RabbitMQ是实现了高级消息对列协议（AMQP）的开源消息代理软件，它是用高性能、可伸缩而闻名的Erlang语言编写而成的，其集群和故障转移是构建在开放电信平台框架上的。

2、RabbitMQ的基本概念

*  Broker:可以理解为消息队列服务器实体，负责接收消息生产者的消息，然后将消息发送至消息接收者或者其他的Broker。
 *  Exchange:消息交换机，是消息第一个到达的地方，消息通过它指定的路由规则，分发到不同的消息队列中去。
 *  Queue:消息队列，消息通过发送和路由之后最终到达的地方。
 *  Binding:绑定，作用是吧Exchange和Queue按照路由规则绑定起来。
 *  Routing Key:路由关键字，Exchange根据这个关键字进行消息投递。
 *  Virtual host:虚拟主机，他是对Broker的虚拟划分，将消费者、生产这和他们依赖的AMQP相关结构进行隔离，一般是为了安全考虑。
 *  Connection:连接，代表生产者、消费者、Broker之间惊喜通信的物理网络。
 *  Channel:消息通道，用于连接生产者和消费者的逻辑结构。
 *  Producer:消息生产者
 *  Consumer:消息消费者

3、安装RabbitMQ  
[http://blog.csdn.net/u012343297/article/details/78874237][http_blog.csdn.net_u012343297_article_details_78874237]

4、RabbitMQ下创建user: springcloud/springcloud  
![这里写图片描述][SouthEast]

5、分配权限  
![这里写图片描述][SouthEast 1]

6、创建springboot项目SpringCloud-RabbitMq项目  
![这里写图片描述][SouthEast 2]

7、pom中添加依赖

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

8、创建消息发送类sender和消息接受类reciver

@Component
    public class Sender { 
    
        @Autowired
        private AmqpTemplate rabbitTemplate;
    
        public void send(){
    
            String context = "hello "+new Date();
            this.rabbitTemplate.convertAndSend("hello",context);
    
        }
    }

@Component
    @RabbitListener(queues="hello")
    public class Reciver { 
    
        @RabbitHandler
        public void process(String hello){
            System.out.print("reciver:"+hello);
        }
    }

9、创建主类RabbitApplication和测试类ApplicationTest

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

@RunWith(SpringJUnit4ClassRunner.class)
    @SpringApplicationConfiguration(classes=RabbitApplication.class)
    public class ApplicationTest { 
    
        @Autowired
        private Sender sender;
    
        @Test
        public void hello(){
            sender.send();
        }
    }

10、创建application.properties

spring.application.name=rabbitmq
    
    spring.rabbitmq.host=127.0.0.1
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=springcloud
    spring.rabbitmq.password=springcloud

11.启动项目，并运行测试类，登录[http://localhost:15672][http_localhost_15672]， springcloud/springcloud  
![这里写图片描述][SouthEast 3]

![这里写图片描述][SouthEast 4]

![这里写图片描述][SouthEast 5]

12、Spring Cloud中使用RabbitMq

a、在SpringCloud-ConfigClient项目的pom文件中添加依赖

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

b、在application.properties中添加

spring.rabbitmq.host=127.0.0.1
    spring.rabbitmq.port=5672
    spring.rabbitmq.username=springcloud
    spring.rabbitmq.password=springcloud

c、依次启动SpringCloud-EurakaServer、SpringCloud-Config，然后启动SpringCloud-ConfigClient两次（端口分别为9002、9003）

启动configClient时，控制台输出  
![这里写图片描述][SouthEast 6]

分别访问[http://localhost:9002/hello][http_localhost_9002_hello]、[http://localhost:9003/hello][http_localhost_9003_hello]

![这里写图片描述][SouthEast 7]  
![这里写图片描述][SouthEast 8]

d、修改demo-dev.properties

greeting=hello,RabbitMQ

e、发送post请求至：[http://localhost:9003/bus/refresh][http_localhost_9003_bus_refresh]  
![这里写图片描述][SouthEast 9]

此时9002和9003的控制台输出  
![这里写图片描述][SouthEast 10]

f、访问[http://localhost:9002/hello][http_localhost_9002_hello]、[http://localhost:9003/hello][http_localhost_9003_hello]，返回：hello,RabbitMQ  
![这里写图片描述][SouthEast 11]  
![这里写图片描述][SouthEast 12]

g、/bus/refresh接口可以指定服务，即使用”destination”参数，比如 “/bus/refresh?destination=customers:\*\*” 即刷新服务名为customers的所有服务，不管ip。

**原理：**

![这里写图片描述][SouthEast 13]

[http_blog.csdn.net_u012343297_article_details_78874237]: http://blog.csdn.net/u012343297/article/details/78874237
[SouthEast]: /images/20220603/ac241260d5174cfba5999bb8432c214d.png
[SouthEast 1]: /images/20220603/3a154810e198484eb2dcda514a14c10d.png
[SouthEast 2]: /images/20220603/7cb50dbf5c504ab5b1d363d1f58d2eca.png
[http_localhost_15672]: http://localhost:15672
[SouthEast 3]: /images/20220603/a4fd75b658e447e89ea348cf04658010.png
[SouthEast 4]: /images/20220603/83265870a2714d3799b71543349916b9.png
[SouthEast 5]: /images/20220603/7b2f9ced48a647d98fd3b2fcb81a98aa.png
[SouthEast 6]: /images/20220603/d617e087a22948518a0f5ccb601b1047.png
[http_localhost_9002_hello]: http://localhost:9002/hello
[http_localhost_9003_hello]: http://localhost:9003/hello
[SouthEast 7]: /images/20220603/950fe0197cba4e76a92135b926ad2727.png
[SouthEast 8]: /images/20220603/20749c36e2484991a467b832f38d736e.png
[http_localhost_9003_bus_refresh]: http://localhost:9003/bus/refresh
[SouthEast 9]: /images/20220603/3854795a8bab40989e278232d4db2b72.png
[SouthEast 10]: /images/20220603/c87c3a8b025e414e8812b74fb3b63dd1.png
[SouthEast 11]: /images/20220603/b507021005a949f9a85b124950180df1.png
[SouthEast 12]: /images/20220603/6b93e7e2c1cb48b2bb30729fcd1a358e.png
[SouthEast 13]: /images/20220603/8f8e8c954a2b4904bc359fdc7d09aac5.png