消息接收模块类图
2017-04-06 09:53:16 0 举报消息接收模块类图主要展示了一个用于处理和解析传入消息的系统。图中包含以下几个关键组件：消息接收器（MessageReceiver），负责监听并接收外部发送的消息；消息解析器（MessageParser），用于将接收到的字节流数据解析成可读的消息对象；消息处理器（MessageHandler），根据消息类型执行相应的业务逻辑；以及消息存储库（MessageRepository），用于将处理后的消息存储到数据库或其他持久化存储介质中。整个系统通过这些组件之间的协作，实现了对外部消息的有效接收、解析和处理。
作者其他创作
大纲/内容
RequestContext
- id- sellerUid- timestamp- retry- data- bizId- from
AbstractReceiveGateWay
- logger- falconMetricService
- init()- execute()- abstract before()- abstract after()- abstract doExecute()
MessageDeadDao
- int insert()- delete()- List list()- int count()
ReceiverNotify
- JSONObject getData()
MessagePool
+ rocketMQConfig- falconMetricService+ messageDeadService- producer
- init()- routing()- retry()- destroy()
策略模式
TradeServiceOrderReceiveHandler
+ apiAnalytics
- init()- List analysis()
AbstractRocketMQReceiveHandler
- logger- appId- topic- tags- subscribeService
- init()- List handle()- abstract List analysis
AbstractAnalytic
- api
- abstract JSONObject getData()
RocketMQReceiveGateWay
+ rocketMQReceiveHandlers- consumers+ rocketMQConfig- messagePool
- init()- before()- doExecute()- log()- after()
StatusNotify
模板方法模式
MessageContext
- method- id- appId- timestamp- session- retry- data- bizId- from- uid- appId
CancelNotify
RocketMQConfig
- groupName- namesrvAddr- sharedTopic- retryTopic
MessageDeadService
+ messageDeadDao
- boolean add()
策略模式模板方法模式责任链模式
0 条评论
下一页
为你推荐
查看更多
