友情链接

友情链接

那些人，那些事

Hexo

快速、简单且强大的网志框架

网站

值得推荐的网站

Youtube

视频网站

Weibo

中国最大社交分享平台

Twitter

社交分享平台

代码块

/**
 * @author 75654
 * @date 2023/3/8 15:14
 *
 * RabbitMQ 消费者
 */
@Slf4j
public class MyConsumer {
    public static final String QUEUE_NAME = "hello";
    public static void main(String[] args) throws Exception{
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.168.81.100");
        factory.setUsername("root");
        factory.setPassword("root");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();
        //声明：接收消息
        DeliverCallback deliverCallback = (var1, var2) -> {
            log.debug("var1:{}", var1);
            log.debug("var2:{}", new String(var2.getBody()));
        };
        //消息中断
        CancelCallback cancelCallback = (var1) -> {
            log.error("消息被中断");
        };
        try {
            /**
             * 消费者消费消息
             * 1.队列名称
             * 2.消费成功之后，是否自动应答，true，自动，false，手动
             * 3.未成功消息回调
             * 4.取消消息回调
             */
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, cancelCallback);
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            log.debug("Consumer 消费者消费消息 成功！");
            channel.close();
            connection.close();
        }
    }
}