AI 助理
备案控制台
开发者社区 云计算 文章 正文

AMQP-RabbitMQ/4/路由模式

2019-06-08 893
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： 4. 路由模式 Routing图示个人理解生产者定义Exchange，设置类型为direct。将消息发送给Exchange之前，为每条消息指定路由键消费者定义队列Queue，并将队列与Exchange进行绑定，在绑定的时候需要告诉Exchange，当前这个Queue接受的路由键。

4. 路由模式 Routing

  • 图示
    路由模式

个人理解

  • 生产者定义Exchange，设置类型为direct。将消息发送给Exchange之前，为每条消息指定路由键
  • 消费者定义队列Queue，并将队列与Exchange进行绑定，在绑定的时候需要告诉Exchange，当前这个Queue接受的路由键。
  • 消息由Exchange发送给Queue时，消息的routingKey必须与该队列订阅的routingKey完全匹配。
  • 即：相对于Exchange为fanout模式的全量接受，direct模式只是根据路由键部分接收Exchange中的消息
  • 生产者
package com.futao.springmvcdemo.mq.rabbit.routing;

import com.futao.springmvcdemo.mq.rabbit.ExchangeTypeEnum;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqConnectionTools;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import lombok.Cleanup;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

/**
 * 路由模式-生产者
 *
 * @author futao
 * Created on 2019-04-22.
 */
@Slf4j
public class Producer {
    @SneakyThrows
    public static void main(String[] args) {
        @Cleanup
        Connection connection = RabbitMqConnectionTools.getConnection();
        @Cleanup
        Channel channel = connection.createChannel();
        //定义交换器类型
        channel.exchangeDeclare(ExchangeTypeEnum.DIRECT.getExchangeName(), BuiltinExchangeType.DIRECT);
        String msg = "Hello RabbitMq!";
      //向名为为`myExchangeType-direct`，类型为`direct`的Exchange发送20条routingKey为`log.info`的消息
        for (int i = 0; i < 20; i++) {
            channel.basicPublish(ExchangeTypeEnum.DIRECT.getExchangeName(), "log.info", null, (msg + i + "log.info").getBytes());
            log.info("Send msg:[{}] ,routingKey:[{}] success", (msg + i + "log.info"), "log.info");
        }
 //向名为为`myExchangeType-direct`，类型为`direct`的Exchange发送20条routingKey为`log.error`的消息
        for (int i = 0; i < 10; i++) {
            channel.basicPublish(ExchangeTypeEnum.DIRECT.getExchangeName(), "log.error", null, (msg + i + "log.error").getBytes());
            log.info("Send msg:[{}] ,routingKey:[{}] success", (msg + i + "log.error"), "log.error");
        }
    }
}
  • 消费者1(同时订阅路由key为"log.info"和"log.error"的消息)
package com.futao.springmvcdemo.mq.rabbit.routing;

import com.futao.springmvcdemo.mq.rabbit.ExchangeTypeEnum;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqConnectionTools;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqQueueEnum;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

/**
 * 路由模式-消费者1
 *
 * @author futao
 * Created on 2019-04-22.
 */
@Slf4j
public class ConsumerOne {
    @SneakyThrows
    public static void main(String[] args) {
        Channel channel = RabbitMqConnectionTools.getChannel();
        //开启持久化队列
        boolean durable = true;
        channel.queueDeclare(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_ONE.getQueueName(), durable, false, false, null);
        //定义交换器类型
        channel.exchangeDeclare(ExchangeTypeEnum.DIRECT.getExchangeName(), BuiltinExchangeType.DIRECT);
        //将消息队列与Exchange交换器与路由键绑定（同时订阅路由key为"log.info"和"log.error"的消息）
        channel.queueBind(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_ONE.getQueueName(), ExchangeTypeEnum.DIRECT.getExchangeName(), "log.error");
        channel.queueBind(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_ONE.getQueueName(), ExchangeTypeEnum.DIRECT.getExchangeName(), "log.info");
        //告诉rabbitmq一次只发送一条消息，并且在前一个消息未被处理或者消费之前，不继续发送下一个消息
        channel.basicQos(1);
        log.info("Waiting for message...");
        DeliverCallback deliverCallback = ((consumerTag, message) -> {
            log.info("收到消息:[{}],routingKey：[{}],tag:[{}]", new String(message.getBody()), message.getEnvelope().getRoutingKey(), consumerTag);
            //acknowledgment应答
            channel.basicAck(message.getEnvelope().getDeliveryTag(), false);
            try {
                Thread.sleep(1000);
            } catch (Exception e) {

            }
        });
        //关闭自动应答
        boolean autoAck = false;
        channel.basicConsume(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_ONE.getQueueName(), autoAck, deliverCallback, consumerTag -> {
        });
    }
}
  • 消费者2(只订阅路由key为"log.error"的消息)
package com.futao.springmvcdemo.mq.rabbit.routing;

import com.futao.springmvcdemo.mq.rabbit.ExchangeTypeEnum;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqConnectionTools;
import com.futao.springmvcdemo.mq.rabbit.RabbitMqQueueEnum;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;

/**
 * 路由模式-消费者2
 *
 * @author futao
 * Created on 2019-04-22.
 */
@Slf4j
public class ConsumerTwo {
    @SneakyThrows
    public static void main(String[] args) {
        Channel channel = RabbitMqConnectionTools.getChannel();
        //开启持久化队列
        boolean durable = true;
        channel.queueDeclare(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_TWO.getQueueName(), durable, false, false, null);
        //定义交换器类型
        channel.exchangeDeclare(ExchangeTypeEnum.DIRECT.getExchangeName(), BuiltinExchangeType.DIRECT);
        //将消息队列与Exchange交换器进行绑定(只订阅路由key为"log.error"的消息)
        channel.queueBind(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_TWO.getQueueName(), ExchangeTypeEnum.DIRECT.getExchangeName(), "log.error");
        //告诉rabbitmq一次只发送一条消息，并且在前一个消息未被处理或者消费之前，不继续发送下一个消息
        channel.basicQos(1);
        log.info("Waiting for message...");
        DeliverCallback deliverCallback = ((consumerTag, message) -> {
            log.info("收到消息:[{}],routingKey：[{}],tag:[{}]", new String(message.getBody()), message.getEnvelope().getRoutingKey(), consumerTag);
            //acknowledgment应答
            channel.basicAck(message.getEnvelope().getDeliveryTag(), false);
            try {
                Thread.sleep(2000);
            } catch (Exception e) {

            }
        });
        //关闭自动应答
        boolean autoAck = false;
        channel.basicConsume(RabbitMqQueueEnum.EXCHANGE_QUEUE_DIRECT_TWO.getQueueName(), autoAck, deliverCallback, consumerTag -> {
        });
    }
}
  • 测试
>>> 生产者
17:35:22.151 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!0log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!1log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!2log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!3log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!4log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!5log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!6log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!7log.info] ,routingKey:[log.info] success
17:35:22.156 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!8log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!9log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!10log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!11log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!12log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!13log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!14log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!15log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!16log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!17log.info] ,routingKey:[log.info] success
17:35:22.157 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!18log.info] ,routingKey:[log.info] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!19log.info] ,routingKey:[log.info] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!0log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!1log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!2log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!3log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!4log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!5log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!6log.error] ,routingKey:[log.error] success
17:35:22.158 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!7log.error] ,routingKey:[log.error] success
17:35:22.159 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!8log.error] ,routingKey:[log.error] success
17:35:22.159 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.Producer - Send msg:[Hello RabbitMq!9log.error] ,routingKey:[log.error] success
Disconnected from the target VM, address: '127.0.0.1:58582', transport: 'socket'

> 消费者1-同时订阅了路由键为`log.info`和`log.error`的消息

17:35:15.737 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - Waiting for message...
17:35:22.153 [pool-1-thread-4] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!0log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:23.157 [pool-1-thread-5] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!1log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:24.162 [pool-1-thread-6] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!2log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:25.167 [pool-1-thread-7] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!3log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:26.173 [pool-1-thread-8] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!4log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:27.176 [pool-1-thread-9] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!5log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:28.179 [pool-1-thread-10] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!6log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:29.184 [pool-1-thread-11] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!7log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:30.190 [pool-1-thread-12] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!8log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:31.191 [pool-1-thread-13] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!9log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:32.195 [pool-1-thread-14] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!10log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:33.201 [pool-1-thread-15] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!11log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:34.203 [pool-1-thread-16] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!12log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:35.208 [pool-1-thread-17] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!13log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:36.211 [pool-1-thread-18] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!14log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:37.215 [pool-1-thread-19] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!15log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:38.222 [pool-1-thread-20] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!16log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:39.226 [pool-1-thread-21] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!17log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:40.229 [pool-1-thread-22] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!18log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:41.233 [pool-1-thread-23] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!19log.info],routingKey：[log.info],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:42.239 [pool-1-thread-24] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!0log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:43.243 [pool-1-thread-25] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!1log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:44.248 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!2log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:45.253 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!3log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:46.258 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!4log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:47.259 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!5log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:48.259 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!6log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:49.261 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!7log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:50.262 [pool-1-thread-26] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!8log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]
17:35:51.262 [pool-1-thread-9] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerOne - 收到消息:[Hello RabbitMq!9log.error],routingKey：[log.error],tag:[amq.ctag-69-YK4fbdRWsRxpVYI280A]

> 消费者2-只订阅了路由键为`log.error`的消息
17:35:18.722 [main] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - Waiting for message...
17:35:22.161 [pool-1-thread-4] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!0log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:24.164 [pool-1-thread-5] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!1log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:26.167 [pool-1-thread-6] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!2log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:28.173 [pool-1-thread-7] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!3log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:30.179 [pool-1-thread-8] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!4log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:32.184 [pool-1-thread-9] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!5log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:34.189 [pool-1-thread-10] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!6log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:36.191 [pool-1-thread-11] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!7log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:38.192 [pool-1-thread-12] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!8log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
17:35:40.195 [pool-1-thread-13] INFO com.futao.springmvcdemo.mq.rabbit.routing.ConsumerTwo - 收到消息:[Hello RabbitMq!9log.error],routingKey：[log.error],tag:[amq.ctag-IkbrVC8PYMJLwVuD8k6vSg]
文章标签：
云消息队列 MQ
关键词：
云消息队列 MQ模式
云消息队列 MQ路由
相关实践学习
消息队列RocketMQ版：基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能，涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列：消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验：基于MNS，0基础轻松构建 Web Client 本节课带您一起基于MNS，0基础轻松构建 Web Client
futaosmile
目录
相关文章
秋夜雨巷
|
5天前
|
消息中间件
RabbitMQ广播模式
RabbitMQ广播模式
秋夜雨巷
14 1
monGyrate
|
1天前
|
消息中间件 Java Maven
RabbitMQ通配符模式
RabbitMQ通配符模式
monGyrate
9 0
三分钟热度的鱼
|
22天前
|
消息中间件 传感器 负载均衡
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
三分钟热度的鱼
21 0
消息队列 MQ使用问题之如何配置一主一从的同步复制模式
萝卜丝丸子
|
27天前
|
消息中间件 存储 Kafka
MetaQ/RocketMQ 原理问题之RocketMQ DLedger融合模式的问题如何解决
MetaQ/RocketMQ 原理问题之RocketMQ DLedger融合模式的问题如何解决
萝卜丝丸子
33 2
不吃核桃
|
27天前
|
消息中间件 Kafka
面试题Kafka问题之RabbitMQ的路由配置工作如何解决
面试题Kafka问题之RabbitMQ的路由配置工作如何解决
不吃核桃
37 1
三分钟热度的鱼
|
22天前
|
消息中间件 Java Apache
消息队列 MQ使用问题之如何在内外网环境下使用单组节点单副本模式
消息队列（MQ）是一种用于异步通信和解耦的应用程序间消息传递的服务，广泛应用于分布式系统中。针对不同的MQ产品，如阿里云的RocketMQ、RabbitMQ等，它们在实现上述场景时可能会有不同的特性和优势，比如RocketMQ强调高吞吐量、低延迟和高可用性，适合大规模分布式系统；而RabbitMQ则以其灵活的路由规则和丰富的协议支持受到青睐。下面是一些常见的消息队列MQ产品的使用场景合集，这些场景涵盖了多种行业和业务需求。
三分钟热度的鱼
34 0
萝卜丝丸子
|
27天前
|
消息中间件 负载均衡 RocketMQ
MetaQ/RocketMQ 原理问题之在广播模式下，RebalanceService工作的问题如何解决
MetaQ/RocketMQ 原理问题之在广播模式下，RebalanceService工作的问题如何解决
萝卜丝丸子
14 0
米诺斯
|
2月前
|
消息中间件
RabbitMQ配置单活模式队列
RabbitMQ配置单活模式队列
米诺斯
39 0
weixin_836869520
|
2月前
|
消息中间件 缓存 数据库
rabbitmq系列（二）几种常见模式的应用场景及实现
rabbitmq系列（二）几种常见模式的应用场景及实现
weixin_836869520
22 0
花开富贵111
|
2月前
|
消息中间件 Apache C语言
消息队列 MQ产品使用合集之在Cluster部署模式下，使用dashboard无法查询到消费组信息，一般是什么导致的
阿里云消息队列MQ（Message Queue）是一种高可用、高性能的消息中间件服务，它允许您在分布式应用的不同组件之间异步传递消息，从而实现系统解耦、流量削峰填谷以及提高系统的可扩展性和灵活性。以下是使用阿里云消息队列MQ产品的关键点和最佳实践合集。
花开富贵111
80 0

热门文章

最新文章

  • 1
    信用算力基于 RocketMQ 实现金融级数据服务的实践
  • 2
    WebAPi的可视化输出模式(RabbitMQ、消息补偿相关)所有webapi似乎都缺失的一个功能
  • 3
    MQ是如何保证消息不丢失的,你这样回答面试官一定说I Want U
  • 4
    RabbitMQ 消费端限流、TTL、死信队列
  • 5
    python rabbitmq send messages
  • 6
    RocketMQ 5.0: 存储计算分离新思路
  • 7
    RabbitMQ入门指南：初学者也能读懂的教程（一）
  • 8
    rabbit.bat server启动闪退，rabbitmq (ArgumentError) argument error，rabbitmq页面无法开启解决方案
  • 9
    RocketMQ在面试中那些常见问题及答案+汇总
  • 10
    Spring boot + RabbitMQ延迟队列实战
  • 1
    Spring Cloud RocketMQ：构建可靠消息驱动的微服务架构
    144
  • 2
    RabbitMQ组件介绍
    54
  • 3
    SpringBoot基于RabbitMQ实现消息可靠性
    69
  • 4
    SpringBoot实现RabbitMQ的通配符交换机(SpringAMQP 实现Topic交换机)
    29
  • 5
    MQTT：通信协议的三位主角
    186
  • 6
    SpringBoot实现RabbitMQ的定向交换机(SpringAMQP 实现Direct定向交换机)
    44
  • 7
    SpringBoot实现RabbitMQ的广播交换机(SpringAMQP 实现Fanout广播交换机)
    37
  • 8
    SpringBoot实现RabbitMQ的WorkQueue(SpringAMQP 实现WorkQueue)
    43
  • 9
    Docker安装部署RabbitMQ(单机版)
    197
  • 10
    RabbitMQ使用教程
    77

    • 相关课程

    更多
  • 消息队列 RocketMQ 消息集成
  • 消息队列 MNS 入门课程
  • RocketMQ知识精讲与项目实战（第一阶段）
  • RocketMQ知识精讲与项目实战（第二阶段）
  • RocketMQ知识精讲与项目实战（第三阶段）
  • 微服务实战-RocketMQ Binder

    • 相关电子书

    更多
  • RocketMQ Client-GO 介绍
  • RocketMQ Prometheus Exporter 打造定制化 DevOps 平台
  • 基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台

    • 相关实验场景

    更多
  • 快速学会使用云消息队列RabbitMQ版
  • 消息队列RocketMQ版：定时消息通知功能体验
  • 消息队列RocketMQ版：基础消息收发功能体验
  • 部署RabbitMQ
  • RocketMQ中使用Java客户端发送消息和消费的应用
  • RocketMQ一站式入门使用
    • 下一篇
    【案例实战】SpringBoot整合阿里云文件上传OSS