消息接收模块类图
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 条评论
下一页
为你推荐
查看更多