RabbitMQ常见Queue模式
简单模式
点对点模式,一个生产者一个消费者
生产者将消息发送到队列,消费者从队列中获取消息,队列是存储消息的缓冲区。
查看管理端效果
序列化解决方案
- 基于java序列化
- 基于Json
@Bean
public MessageConverter messageConverter() {
return new Jackson2JsonMessageConverter();
}
@Bean
public RabbitTemplate rabbitTemplate() {
RabbitTemplate rabbitTemplate = new RabbitTemplate(factory);
rabbitTemplate.setMessageConverter(messageConverter());
:
:
}
基于json
Work queues
工作队列模式:
一个生产者,多个消费者
- C1,C2 是否都收到
- 假设只有一个收到,谁收到(先)
结果: 只有一个消费者消费,轮训(负载均衡)的方式进行消费
@Bean
public Queue workQueue() {
return new Queue(RabbitMQConstants.WORK_QUEUE, DURABLE);
}
发布订阅/fanout模式
生产者通过fanout扇出交换机群发消息给消费者,同一条消息每一个消费者都可以收到。
@Bean
public Binding bindingFanoutA(){
return BindingBuilder
.bind(fanoutQueueA())
.to(fanoutExchange());
}
/**
* Fanout交换机和队列B绑定
* @return
*/
@Bean
public Binding bindingFanoutB(){
return BindingBuilder
.bind(fanoutQueueB())
.to(fanoutExchange());
}
routing模式
配置
@Bean
public Queue routingYellowQueue(){
return new Queue(RabbitMQConstants.ROUTING_YELLOW_QUEUE,DURABLE);
}
@Bean
public Queue routingBlueQueue(){
return new Queue(RabbitMQConstants.ROUTING_BLUE_QUEUE,DURABLE);
}
@Bean
public DirectExchange routingExchange(){
return new DirectExchange(RabbitMQConstants.ROUTING_EXCHANGE,DURABLE,AUTO_DELETE);
}
@Bean
public Binding routingYellowBinding(){
return BindingBuilder
.bind(routingYellowQueue())
.to(routingExchange())
.with(RabbitMQConstants.ROUTING_YELLOW_KEY);
}
@Bean
public Binding routingBlueBinding(){
return BindingBuilder
.bind(routingBlueQueue())
.to(routingExchange())
.with(RabbitMQConstants.ROUTING_BLUE_KEY);
}
生产者
@Override
public void routingOrder() {
Order order= new Order();
order.setBook(41L);
order.setStatus("未支付");
order.setTotal(5);
order.setTime(new Date());
rabbitTemplate.convertAndSend(
RabbitMQConstants.ROUTING_EXCHANGE,
RabbitMQConstants.ROUTING_YELLOW_KEY, //routing到yellow线路
order);
log.debug("[routing工作模式: ] 产生一个订单-->{}",order);
}
topic模式
* 任意个任意一字符串
# 0或一个任意字符串
cba.topic.abc
topic.* —只有一个字符串
- topic.orange
topic.# ----> 0个字符串或者多个字符串(用户点号分开的)
- topic
- topic.abc
- topic.abc.banana
@Bean
public Binding topicOrangeBinding(){
return BindingBuilder
.bind(topicOrangeQueue())
.to(topicExchange())
.with("*.fruit.*"); //*.fruit.*
}
@Bean
public Binding topicBananaBinding(){
return BindingBuilder
.bind(topicBananaQueue())
.to(topicExchange())
.with("#.fruit.*");
}