[大数据]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模式下routingKey和bindIngKey就需要模糊匹配了.

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;
}

消费者