NOTE

3.1 RabbitMQ使用

1. 数据传输流程 生产者发送消息- rabbitmq的exchange,通过routing key路由到相应的queue上- 消费者接收消息 2. 工作模式 发送消息的代码 - 工作队列,交换机为空 这种模式会把消息发送到QUEUE NAME的队列上 - 发布订阅,fanout交换机 这种模式会广

Message Queue更新于 约 1 分钟读完historical

这是历史学习笔记,可能存在过时或不完整的理解。

1. 数据传输流程

生产者发送消息->rabbitmq的exchange,通过routing key路由到相应的queue上->消费者接收消息

2. 工作模式

发送消息的代码

void basicPublish(String exchange, String routingKey, BasicProperties props, byte[] body)
  • 工作队列,交换机为空 这种模式会把消息发送到QUEUE_NAME的队列上
("",  "QUEUE_NAME", ...)
  • 发布订阅,fanout交换机 这种模式会广播所有消息到绑定了fanout交互机的队列上
("fanout",  "",  ...)
  • 发布订阅,direct交换机 这种模式会按照条件路由消息,把direct交互机上的消息一部分丢给队列1,另一部分丢给队列2
("direct",  "routing_key",  ...)
  • 发布订阅,topic交换机,比direct更加细化,把direct交互机上的消息一部分丢给队列1,另一部分丢给队列2 这种模式会按照条件路由消息
("topic",  "routing_key",  ...)
正在加载有帮助数量