一种消息处理系统和消息处理方法
摘要:
本发明提供一种消息处理系统和消息处理方法,系统包括:消息生产端,向消息代理发送处于预发送状态的消息,执行本地业务操作并持久化到第一数据库,向消息代理发送业务操作结果;消息代理,包括:接收模块,接收处于预发送状态的消息;第二数据库,存储处于预发送状态的消息;处理模块,包括:预发送消息处理子模块,当确认信息指示业务操作成功时,则将消息的状态修改为发送中状态,并且向消息队列发送消息;反之删除处于预发送状态的消息;消息队列,对消息进行缓存;消息消费端,接收消息并处理本地业务;消息状态监控系统,对消息状态进行监控,当消息状态异常时,触发消息代理对状态异常的消息进行处理。该系统可确保消息的一致性。
公开/授权文献
0/0