rabbitmq入门

Posted 好大的月亮

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rabbitmq入门相关的知识,希望对你有一定的参考价值。

rabbitmq图形demo

生产者:就是发送消息一方
消费者:就是接受消息一方
broker:这里可以理解为rabbitmq服务,里面分了交换器和队列

消息的传递

队列(queue)

就是存放消息的容器。
多个消费者可以订阅同一个队列,队列中的消息会被轮询发给这些消费者,不会发生重复消费问题。

如果在direct模式下多个队列绑定了同一个exchange,然后routingKey和bindingKey都是一样的,这个时候就会发生消息广播的情况,和fanout模式一样。

交换器(exchange)

生产者发送消息后,这个消息首先是到达了exchange交换器中,然后交换器将消息按照路由规则转到一个或者多个队列中。如果找不到对应的队列,那么这个消息可能会返回给生产者或者直接丢弃(看具体配置)。

常用的交换器类型有四种
fanout:把消息路由到指定的exchange下面的所有队列中,即广播消息
direct:把消息路由到routingKey和bindingKey完全一致的队列中
topic:可以模糊匹配,2个'.'分隔开的称为一个单词,‘#’匹配一个单词,‘*’匹配多个单词(可以是零个),这个路由匹配规则要写在交换器和队列绑定的routingKey(bindingKey)中。
headers:用的比较少,而且性能不高,使用的时候需要匹配message里header里的参数,匹配形式在绑定交换机和队列的时候决定

生产者发送消息的时候会指定一个routingKey,它配合交换器绑定队列时指定的bindingKey来联合使用。这个bindingKey并不是在所有情况下都生效,比如交换器是fanout模式下,就会忽略这个bindingKey将消息路由到所有绑定这个交换器的队列里。

通常我们在发送消息时的routingKey和交换器绑定队列时的bindIngKey是一致的,因为我们一般默认用的direct模式。不过topic模式下routingKeybindIngKey就需要模糊匹配了.

springboot下的demo

maven依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

生产者

@GetMapping("sendTestNormalQueue")
public String sendTestNormalQueue(String msg) throws JsonProcessingException {
    Map<String,Object> map = new HashMap<>();
    map.put("msg", msg);


    rabbitTemplate.convertAndSend("normalExchange", "normalRoutingKey", map, new MessagePostProcessor() {
        @Override
        public Message postProcessMessage(Message message) throws AmqpException {
            //可以在消息后置处理器里设置消息超时时间,这个在死信队列可以实现延时消息
            message.getMessageProperties().setExpiration("5000");//时间单位是毫秒
            return message;
        }
    });
    log.info("发送消息");
    return msg;
}

消费者

以上是关于rabbitmq入门的主要内容,如果未能解决你的问题,请参考以下文章

RabbitMQ入门:工作队列(Work Queue)

RabbitMQ入门-理论

快速入门分布式消息队列之 RabbitMQ(下)

RabbitMQ系列:Windows下RabbitMQ安装及入门

rabbitmq 极速入门

RabbitMQ入门-发布订阅模式