RabbitMQ应用Demo:使用queue点对点通知消息

Posted Neo Yang

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了RabbitMQ应用Demo:使用queue点对点通知消息相关的知识,希望对你有一定的参考价值。

环境准备

安装RabbitMq: 个人是先在Win10便携机上安装VMWare Workstation, 再安装Cent OS 操作系统,在此基础上安装RabbitMQ。

安装过程可以参考这篇博客: https://blog.csdn.net/hsxy123123/article/details/104006744

需要注意RabbitMQ官网提供的erlang与RabbitMQ的配套版本,按版本安装。

消息生产者Demo代码

    private final static String QUEUE_NAME = "elon_queue";
 
    /**
     * 生产消息发送到队列
     *
     * @param messageBody 消息体
     * @author elon
     */
    public void produceMessage(String messageBody) 
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.*.*.*");
        factory.setPort(5672);
        factory.setUsername("***");
        factory.setPassword("*******");

        try 
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            channel.basicPublish("", QUEUE_NAME, null, messageBody.getBytes());
            LOGGER.info("Sent ", messageBody);
         catch (Exception e) 
            LOGGER.info("Produce message fail.", e);
        
    

发送消息使用默认交换器 “” ,指定队列名称elon_queue。

消息消费者Demo代码

    private final static String QUEUE_NAME = "elon_queue";

    /**
     * 消费消息
     */
    public void consumeMessage() 
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("192.*.*.*");
        factory.setPort(5672);
        factory.setUsername("***");
        factory.setPassword("*******");

        try 
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);

            DeliverCallback deliverCallback = (consumerTag, delivery) -> 
                String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
                LOGGER.info("Receive message from queue:", message);
            ;

            channel.basicConsume(QUEUE_NAME, true, deliverCallback, tag->);
         catch (Exception e) 
            LOGGER.error("Consume message exception.", e);
        
    

消费者增加 channel.queueDeclare(QUEUE_NAME, false, false, false, null) 这行代码是考虑消费者进程可能先于生产者進程启动的情况。队列不存在的情况下调用basicConsume报错。

可以启动多个消费者进程接收队列elon_queue的消息,但只要有一个消费者收到消息应答后其它消费者将不会再收到该消息。这样做的目的是提升系统的可靠性,单个消费者进程挂了,其它消费者能正常处理业务,消息也不会重复消费。

以上是关于RabbitMQ应用Demo:使用queue点对点通知消息的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ应用Demo:使用queue点对点通知消息

C#利用RabbitMQ实现点对点消息传输

3.RabbitMQ 第一个程序

消息队列两种模式:点对点与发布订阅

RabbitMQ研究安装与入门

rabbitMQ 点对点 一个队列可以多个消费者吗?