cppcmd=keepalive& RabbitMQ消费者代码 - wpsshop博客
devbox
很楠不爱3
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

RabbitMQ消费者代码

作者：很楠不爱3 | 2024-04-30 23:08:24

赞

踩

rabbitmq消费者代码

消息消费者

创建一个类作为消费者，消费 RabbitMQ 队列的消息

  1.  
  2. public class Consumer {
  3.  
  4.     //队列的名称
  5.     public static final String QUEUE_NAME="hello";
  6.     //接受消息
  7.     public static void main(String[] args) throws IOException, TimeoutException {
  8.         ConnectionFactory factory = new ConnectionFactory();
  9.         factory.setHost("192.168.91.200");
  10.         factory.setUsername("root");
  11.         factory.setPassword("123");
  12.         Connection connection = factory.newConnection();
  13.  
  14.         Channel channel = connection.createChannel();
  15.  
  16.         //声明接收消息
  17.         DeliverCallback deliverCallback = (consumerTag,message) -> {
  18.             System.out.println(new String(message.getBody()));
  19.         };
  20.         //取消消息时的回调
  21.         CancelCallback cancelCallback = consumerTag ->{
  22.             System.out.println("消息消费被中断");
  23.         };
  24.  
  25.         /**
  26.          * 消费者消费消息
  27.          * 1.消费哪个队列
  28.          * 2.消费成功之后是否要自动应答true：代表自动应答false:代表手动应答
  29.          * 3.消费者未成功消费的回调
  30.          * 4.消费者取消消费的回调
  31.          */
  32.         channel.basicConsume(QUEUE_NAME,true,deliverCallback,cancelCallback);
  33.     }
  34. }
  • 结果
  1. SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
  2. SLF4J: Defaulting to no-operation (NOP) logger implementation
  3. SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
  4. Hello,world

值得一提的是，basicConsume 的参数中，第三个和第四个参数都是接口，所以需要实现该接口的方法

channel.basicConsume(队列名字/String, 是否自动签收/boolean, 消费时的回调/接口类, 无法消费的回调/接口类);

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/515748
推荐阅读
相关标签