Skip to content

majshr/mqnetty

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

2 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

生产者 连接broker,发送请求消息,获取响应消息 可能发送的消息没有被订阅,没有被消费,获得响应 可能消息被消费,获得响应

消费者 连接broker 发送订阅消息,订阅关注的主题 接收生产者生产的消息,发送给broker我消费了的确认消息 发送取消订阅消息,取消订阅

broker broker接收的都是请求消息,发给生产者、消费者的都是相应消息 启动服务,等待消费者,生产者的连接 1,响应生产者的生产消息 如果没有订阅,ack生产者:返回没有订阅信息 如果有订阅: 分发给消费者 ack生产者:消息被消费 2,broker响应消费者的消费信息 把消息从缓存中移除 3,broker响应消费者订阅消息 添加消费者信息,到消费者集群(由broker管理消费者集群信息) 4,broker响应消费者取消订阅消息: 从消费者集群移除消费者

About

No description, website, or topics provided.

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages