springboot使用高级消息队列RabbitMQ

雨点打透心脏的1/2处 2021-12-03 11:45 372阅读 0赞

使用工具idea，springboot版本2.0+，RabbitMQ我已经在自己的云服务器Linux上面安装了，你们要测试的话，自己可以在本地安装RabbitMQ

github地址是[https://github.com/samdidemo/springboot-rabbitMQ.git][https_github.com_samdidemo_springboot-rabbitMQ.git]

第一步，创建新工程

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70][]

第二步，引进相应的依赖

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70 1][]

然后，在application.properties中添加配置，服务器地址，就是你安装RabbitMQ的ip地址，如果你是安装在本地，那么你直接写localhost就行，用户名和密码默认是guest

![20190719012030270.png][]

在主类中添加@EnableRabbit注解，开启RabbitMQ

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70 2][]

新建一个类，其中新建一个方法，比如在这个方法开头添加注解@RabbitListener(queues = "lin")，它便会监听消息队列lin,一旦里面有消息，便会进行接收

public class rabbitService {
        @RabbitListener(queues = "lin")
        public void recieve(Map<String, Object> map){
            System.out.println(map.toString());
        }
    }

我们可以在测试类中自动注入RabbitTemplate template; 然后使用template.convertAndSend("linyongbin","lin",map)发送消息到队列中，测试是否接收到了消息

其中“linyongbin”是交换机的名字，“lin”是路由键，map是要传送的东西

@Autowired
        RabbitTemplate template;
        @Test
        public void contextLoads() {
            Map<String,Object> map=new HashMap<>();
            map.put("msg","林阳光发送消息");
            map.put("name","linyongbin");
            template.convertAndSend("linyongbin","lin",map);
        }

[https_github.com_samdidemo_springboot-rabbitMQ.git]: https://github.com/samdidemo/springboot-rabbitMQ.git
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70]: /images/20211203/14f7a7f98f7d41378a6f3a6144dff10a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70 1]: /images/20211203/157178aa7eb348aca0be797d1acf84e5.png
[20190719012030270.png]: /images/20211203/92ba6911f5554cd883ce90ae473d85a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FiY18xMjM0NTZfX18_size_16_color_FFFFFF_t_70 2]: /images/20211203/b0cb58d6447b4ec5a4c8e8f8963d6b64.png