RabbitMQ代码操作之AmqpAdmin和RabbitListener

  • AmqpAdmin:RabbitMQ系统管理功能组件(可以创建exchange,queue,Binding)
@Test
public void createExchange(){
//创建交换器
//amqpAdmin.declareExchange(new DirectExchange("amqpadmin.exchange"));
//创建队列(如果存在同名,则不创建)
amqpAdmin.declareQueue(new Queue("amqpadmin.queue",true));
//创建绑定规则 new Binding(目的地,目的地类型,交换器名字,路由件,参数头)
//amqpAdmin.declareBinding(new Binding("amqpadmin.queue", Binding.DestinationType.QUEUE,"amqpadmin.exchange","amqp.haha",null));
//删除队列
//amqpAdmin.deleteQueue("amqpadmin.queue");
}

RabbitMQ代码操作之AmqpAdmin和RabbitListenerRabbitMQ代码操作之AmqpAdmin和RabbitListener文章来源地址https://www.yii666.com/article/754384.html文章地址https://www.yii666.com/article/754384.html网址:yii666.com<网址:yii666.com文章来源地址:https://www.yii666.com/article/754384.html


  • @EnableRabbit+@RabbitListener  监听消息队列的内容 
@Service
public class BookService { @RabbitListener(queues = "springbootTest")
public void receive(Book book){
System.out.println("收到的消息为:"+book.toString());
} @RabbitListener(queues = "springbootTest")
public void receive02(Message msg){
//字节内容对象
System.out.println(msg.getBody());
//头对象
System.out.println(msg.getMessageProperties()); }
}

版权声明:本文内容来源于网络,版权归原作者所有,此博客不拥有其著作权,亦不承担相应法律责任。文本页已经标记具体来源原文地址,请点击原文查看来源网址,站内文章以及资源内容站长不承诺其正确性,如侵犯了您的权益,请联系站长如有侵权请联系站长,将立刻删除

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信图片_20190322181744_03.jpg

微信扫一扫打赏

请作者喝杯咖啡吧~

支付宝扫一扫领取红包,优惠每天领

二维码1

zhifubaohongbao.png

二维码2

zhifubaohongbao2.png