25rabbitMq

xiaoxiao2025-04-25  12

1基于Erlang开发的,所以先按照Erlang,

2按照rabbitMq

添加用户

1

2添加host

3 host与用户进行关联

即产生关联:

 

 

测试:该用户已经创建好

 

 

==============================================================================

1生产这发送消息,入没有消费者接受。他一直在队列中

此时,队列中多了一条消息

2消费者接受(按发送的顺序)

 

 

=========

生产者代码

消费者代码: 一条路相当于一个连接。创建通道就相当于路上的多条马路。将消息发送到队列中

 

生产者与消费者代码对比

 

 

======

五种多种模式: 生产者模式,订阅模式,

订阅模式:

前几中模式,一个生产者只能对应一个消费者。不满足需求,现在要把一条消息发送给多个消费者。中间加交换机

生产者将消息发给交换机,交换机可以绑定多个队列。每一个队列对应一个消费者。

消费者只能监听队列的消息。这样就也可以实现一条消息发送多个用户。

             

订阅模式是所有的消费者都可以得到。但不是所有的消费者需要消息。======》精确的订阅:路由模式

注意: 先启动消费者,然后启动生产者。否则消息会丢失

========================================================================

路由模式:

消费者1:

消费者2:

 

生产者:

 

 

转载请注明原文地址: https://www.6miu.com/read-5029139.html

最新回复(0)