发布订阅技术的消息队列实现
2024-03-16 09:42:53 2 举报
登录查看完整内容
发布订阅技术的消息队列实现
作者其他创作
大纲/内容
message =弹出消息消息标识=消息标识flag = truetimer 开始netty下发消息
falg=false msg !=replytimer 没有timer
True
423002
等待
CARD
flag = falsemessage = reply
falg=false msg =reply
存入队列 LIST/ZSET(score)
flag= falseclear(timer)message = reply
False
falg=true timer 未超时
falg=true timer超时
判断消息标识
结束
判断队列是否有消息
将当前消息存入队列message =弹出消息消息标识=弹出消息的消息标识flag = truetimer 开始netty下发消息
TAG001
投递
没有
有
423003
Producer
Consumer
Flag true
消息标识=消息标识flag = truetimer 开始netty下发消息
Netty 入口
![发布订阅技术的消息队列实现](https://www.processon.com/chart_image/template/thumb/65f4f91db267656fb678baad.png?tid=62e9480b637689072efb9b7f)
收藏
![Java面试题思维导图](https://www.processon.com/chart_image/template/thumb/628b808e7d9c08581699275c.png?tid=628b808e7d9c08581699275a)
收藏
0 条评论
回复 删除
下一页