一种基于redis存储作为消息中间件的数据传输方法
基本信息
申请号 | CN202110151703.4 | 申请日 | - |
公开(公告)号 | CN112882842A | 公开(公告)日 | 2021-06-01 |
申请公布号 | CN112882842A | 申请公布日 | 2021-06-01 |
分类号 | G06F9/54(2006.01)I | 分类 | 计算;推算;计数; |
发明人 | 吴松福;谢奉见 | 申请(专利权)人 | 厦门投融汇网络有限公司 |
代理机构 | 北京联瑞联丰知识产权代理事务所(普通合伙) | 代理人 | 郭堃 |
地址 | 361000福建省厦门市火炬高新区软件园华讯楼C区B1F-262 | ||
法律状态 | - |
摘要
摘要 | 本发明提出了一种基于redis存储作为消息中间件的数据传输方法,包括:生产者将消息数据发送到redis,redis向生产者确认接受到消息数据;redis从消息队列中读取生产者写入的消息数据,并向消费者确认消费数据;消费者从redis中读取消息数据,并将消息数据写入到消息队列,以使消费者从消息队列读取到消息数据,并向redis返回数据。本发明通过redis集群,保证数据存储在内存也不会应为单独服务器挂掉导致数据丢失;数据至少被消费一次,通过消息确认消费机制,保证每次消息消费都可以被消费,如果出现网络抖动或其他异常情况,可能导致消息确认机制没能及时传到中间件,导致重复消费情况,消费者需要在业务上处理消息幂等性问题。 |
