public class Consumer {// 隊列名稱public static final String QUEUE_NAME = "hello";// 接受消息public static void main(String[] args) throws IOException, TimeoutException {// 創(chuàng)建連接工廠ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.163.128");factory.setUsername("admin");factory.setPassword("123");Connection connection = factory.newConnection();Channel channel = connection.createChannel();// 聲明 接受消息DeliverCallback deliverCallback = (consumerTag,message) -> {System.out.println(new String(message.getBody()));};// 聲明 取消消息CancelCallback cancelCallback = consumer -> {System.out.println("消息消費被中斷");};/** 消費者接收消息* 參數(shù)1：表示消費哪個UI列* 參數(shù)2：消費成功之后，是否需要自動應答，true表示自動應答，false表示手動應答* 參數(shù)3：消費者成功消費的回調(diào)* 參數(shù)4：消費者取消消費的回調(diào)*/channel.basicConsume(QUEUE_NAME,true,deliverCallback,cancelCallback);} }

總結(jié)

以上是生活随笔為你收集整理的RabbitMQ消费者代码的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。