RabbitMQ的简单模式怎么实现
更新:HHH   时间:2023-1-7


这篇文章主要介绍了RabbitMQ的简单模式怎么实现的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇RabbitMQ的简单模式怎么实现文章都会有所收获,下面我们一起来看看吧。

Springboot RabbitMQ 简单模式

生产者声明队列并向队列发送消息

导入 com.example.rabbitmq.constant.RabbitConstant;
导入 org.springframework.amqp.core.Queue;
导入 org.springframework.context.annotation.Bean;
导入 org.springframework.context.annotation.Configuration;
@Configuration public class RabbitSimpleProvider { 
    @Bean 
    public Queue simpleQueue() { 
        return new Queue(RabbitConstant.SIMPLE_QUEUE_NAME); 
    } 
}

消费者监听队列并消费消息

导入 com.example.rabbitmq.constant.RabbitConstant;
导入 org.springframework.amqp.rabbit.annotation.RabbitHandler;
导入 org.springframework.amqp.rabbit.annotation.RabbitListener;
导入 org.springframework.stereotype.Component;
@Component public class RabbitSimpleConsumer { 
    @RabbitHandler 
    @RabbitListener(queues = RabbitConstant.SIMPLE_QUEUE_NAME) 
    public void simpleListener(String context) { 
        System.out.println("rabbit receiver: " + context); 
    } 
}

单元测试

@Test public void simple() { 
    rabbitTemplate.convertAndSend(RabbitConstant.SIMPLE_QUEUE_NAME, "hello world!"); 
}

响应结果

关于“RabbitMQ的简单模式怎么实现”这篇文章的内容就介绍到这里,感谢各位的阅读!相信大家对“RabbitMQ的简单模式怎么实现”知识都有一定的了解,大家如果还想学习更多知识,欢迎关注天达云行业资讯频道。

返回开发技术教程...