一种消息处理装置和方法_专利查询-品牌网

热门行业
装修建材
家居生活
餐饮食品
母婴教育
电脑办公
服装首饰
汽车工具
家电数码
机械化工
休闲美容

热门行业

教育培训
板材
地板
涂料
家纺
集成吊顶
美缝剂
木门
硅藻泥
管材
指纹锁
橱柜
衣柜
床垫
电热水器
集成灶
暖气片
净水器
酒店
卫浴

返回上一页

专利状态

一种消息处理装置和方法

有效

专利申请进度

申请

2016-12-08

申请公布

2017-06-09

授权

2020-06-05

预估到期

2036-12-08

专利基础信息

申请号	CN201611123185.0	申请日	2016-12-08
申请公布号	CN106817295A	申请公布日	2017-06-09
授权公布号	CN106817295B	授权公告日	2020-06-05
分类号	H04L12/58
分类	电通信技术;
申请人名称	上海有孚网络股份有限公司
申请人地址	上海市杨浦区国定路323号1201-1室

专利法律状态

2020-06-05

授权

状态信息

授权
2020-05-22

专利申请权、专利权的转移

状态信息

专利申请权的转移；IPC(主分类):H04L12/58；登记生效日:20200507；变更事项:申请人；变更前:努比亚技术有限公司；变更后:上海有孚网络股份有限公司；变更事项:地址；变更前:518000 广东省深圳市南山区高新区北环大道9018号大族创新大厦A区6-8层、10-11层、B区6层、C区6-10层；变更后:200082 上海市杨浦区国定路323号1201-1室
2017-07-04

实质审查的生效

状态信息

实质审查的生效；IPC(主分类):H04L12/58；申请日:20161208
2017-06-09

公布

状态信息

公布

摘要

本发明公开了一种消息处理装置和方法，包括读取模块、备份模块、上报模块和处理模块；读取模块，用于读取消费者从服务器订阅的消息；复制读取的消息并存储至备份模块，并通知上报模块；上报模块，用于收到读取模块通知，上报偏移量信息，并通知处理模块；处理模块，用于收到上报模块的通知，读取备份模块中未处理的消息，创建多个子线程，将备份模块中未处理的消息分派到各个子线程中；通过各个子线程对分派的消息进行处理，并将处理结果存储至备份模块中。本发明还包括检测模块，用于每次消费者重启时，检测备份模块中的各条消息是否已经处理。本发明能够解决Kafka系统中消费者重复消费数据、重复提交或覆盖提交Offset的问题。

更多专利

全国服务热线：

在线客服

1211389656 咨询

商务合作

85926368 咨询

媒体合作

921888730 咨询

在线客服
客服微信号

品牌网官方客服微信

打开微信扫一扫

客服微信
商务合作微信

商务合作详谈

打开微信扫一扫

商务合作
回到顶部

在线客服

商务合作

媒体合作

客服微信号

商务合作微信