SpringBoot 集成RbbitMQ队列2代码实现

待我称王封你为后i 2021-12-15 22:45 277阅读 0赞

源码[SpringBoot集成RbbitMQ][SpringBoot_RbbitMQ]

1、pom.xml依赖配置

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

2、自动创建消息队列

**
     * 消息队列配置类,创建消息队列
     * 路由秘钥为hello
     */
    @Configuration
    public class RbbitConfig {
    
        @Bean
        public Queue messageQueue(){
            return new Queue("hello");
        }
    }

除了使用代码自动创建队列以外，我么可以使用页面客户端创建修改或删除队列

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODE5Mzcy_size_16_color_FFFFFF_t_70][]

3、创建队列消息发送端（生产者）

@Component
    public class SendMessage {
    
        @Autowired
        private AmqpTemplate amqpTemplate;
    
        public void sendMessage(String message){
            message+= new Date();
            System.err.println("send message:"+message);
            //转换并发送消息  （队列名,消息体）
            amqpTemplate.convertAndSend("hello",message);
        }
    }

4、创建队列消息接收端（消费者）

@Component
    //队列名
    @RabbitListener(queues = "hello")
    public class ReceiveMessage {
        //接收到队列消息后的处理方法
        @RabbitHandler
        public void receiveMessage(String message){
            System.err.println("receive message："+message);
        }
    }

5、测试启动类

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class TestServiceTest {
    
        @Autowired
        private SendMessage sendMessage;
    
        @Test
        public void testSendMessage(){
            sendMessage.sendMessage("发送测试");
        }
    }

最终结果显示

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODE5Mzcy_size_16_color_FFFFFF_t_70 1][]

[SpringBoot_RbbitMQ]: https://github.com/2637977081/SpringBootDC/tree/master/service-rbbitmq-server
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODE5Mzcy_size_16_color_FFFFFF_t_70]: /images/20211215/59f00a7639cd4c839d12dbeb1af3ed10.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM0ODE5Mzcy_size_16_color_FFFFFF_t_70 1]: /images/20211215/c719c6c09e294861867a618e5b42bfb8.png