1基于Erlang开发的,所以先按照Erlang,
2按照rabbitMq
1
2添加host
3 host与用户进行关联
即产生关联:
测试:该用户已经创建好
==============================================================================
1生产这发送消息,入没有消费者接受。他一直在队列中
此时,队列中多了一条消息
2消费者接受(按发送的顺序)
=========
生产者代码
消费者代码: 一条路相当于一个连接。创建通道就相当于路上的多条马路。将消息发送到队列中
生产者与消费者代码对比
======
五种多种模式: 生产者模式,订阅模式,
订阅模式:
前几中模式,一个生产者只能对应一个消费者。不满足需求,现在要把一条消息发送给多个消费者。中间加交换机
生产者将消息发给交换机,交换机可以绑定多个队列。每一个队列对应一个消费者。
消费者只能监听队列的消息。这样就也可以实现一条消息发送多个用户。
订阅模式是所有的消费者都可以得到。但不是所有的消费者需要消息。======》精确的订阅:路由模式
注意: 先启动消费者,然后启动生产者。否则消息会丢失
========================================================================
路由模式:
消费者1:
消费者2:
生产者: