来源: blog.csdn.net/yt812100/article/details/111785839
作者: 杨桃桃

Part1CRT创建RabbitMQ容器

CRT容器自带RabbitMQ消息中间件，只需要在CRT中输入如下命令：

docker run -id --name=tensquare_rabbit -p 5671:5671 -p 5672:5672 -p 4369:4369 -p 15672:15672 -p 25672:25672 rabbitmq:management

（注：tensquare_rabbit为RabbitMQ中的名称，可以改变。网页启动端口为15672）

启动之后，输入docker ps命令查看是否创建成功

Part2登录RabbitMQ

创建成功之后进入网页，访问15672端口。（注：安装在虚拟机则填虚拟机地址，否则则为本机地址）用户名和密码都为guest看到如下页面则为RabbitMQ安装登录成功。

Part3依赖注入

导入依赖坐标

Part4配置yaml文件

配置yaml配置文件 （注：host为地址，如果安装在虚拟机则为虚拟机地址，安装在本机则本机地址。port为端口号，务必注意的是配置文件里写的是5672，而网页访问的是15672）

Part5添加业务层代码

这里的业务逻辑其实很简单。本文的业务环境是用户订阅作者，之后作者发文章，他的粉丝都能够收到消息中间件发送的消息。而本文实现的是，将消息发送至消息中间件中，后续文章将介绍如何将消息中间件中的消息发送给用户

业务层添加rabbit模板

订阅部分，也就是发送消息给消息中间件的前提：创建好交换机，路由键，以及队列,并且用户订阅作者，就相当于将队列绑定到交换机上，并且有路由键作为关联

实现以上业务逻辑之后，粉丝与作者就已经绑定好了，那么当作者发文章之后，程序就像消息中间件发送消息，因此在作者发送文章的方法内，添加如下代码即可

Part6测试

首先用户关注某个作者，在用作者的账号发送文章。在消息中间件中即可收到发送的消息

结语：此处难点为发送消息之前需要先创建交换机，之后将队列绑定给交换机，并且关联路由键。

-  | 更多精彩文章 -

---

• 序列化我选择Protobuf，因为Java自带序列化这个缺点太致命
  

• 真心话，这九种设计模式，熬夜都要肝完

• 怎么关闭程序? 是用kill -9吗?

• @PostConstruct注解会用指南

• 并发容器详解,深入底层的透彻剖析
  

   

    

     

      

       

        

         
          

           

            

             

              

               

                

                 

                  

                   

                    

                     ▽加我微信,交个朋友
                    
                   
                  
                 
                
               
              
             
            
           
          
         

        
        
         

          

           

            

             

              

               

                

                 

                  

                   

                    

                     

                      长按/扫码添加↑↑↑