分布式消息处理方法及系统
基本信息
| 申请号 | CN202010401681.8 | 申请日 | - |
| 公开（公告）号 | CN111611090A | 公开（公告）日 | 2020-09-01 |
| 申请公布号 | CN111611090A | 申请公布日 | 2020-09-01 |
| 分类号 | G06F9/54(2006.01)I | 分类 | 计算；推算；计数; |
| 发明人 | 张晨 | 申请（专利权）人 | 浙江创邻科技有限公司 |
| 代理机构 | 杭州裕阳联合专利代理有限公司 | 代理人 | 浙江创邻科技有限公司 |
| 地址 | 310012浙江省杭州市西湖区三墩镇紫萱路158号1幢801室 | ||
| 法律状态 | - | ||
摘要
| 摘要 | 本发明公开一种分布式消息处理方法及系统，其中方法包括以下步骤：接收客户端发送的消息发送请求，根据所述消息发送请求生成包含发送时间戳的消息，将所述消息加入相应的消息队列，所述发送时间戳在所述消息队列中具有唯一性，基于所述发送时间戳对消息队列中的消息进行排列；判断消息是否超时，根据判断结果标记超时消息并将所述超时消息备份至分布式文件系统；按照预设的清除时间，周期性的删除消息队列中的超时消息。本发明通过对发送时间戳的设计保证消息传递的顺序；通过对超时消息进行判断和清除步骤的设计，能够令分布式文件系统和消息队列相互配合，便于客户端查询消息的同时减轻消息队列带来的数据存储压力。 |
