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
模式下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;
}
消费者
以上是关于rabbitmq入门的主要内容,如果未能解决你的问题,请参考以下文章