发布订阅技术的消息队列实现

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 入口