买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网恭喜天翼云科技有限公司申请的专利一种支持送达确认的消息订阅通知方法和系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN117834721B 。

龙图腾网通过国家知识产权局官网在2025-04-08发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202311731392.4，技术领域涉及：H04L67/55；该发明授权一种支持送达确认的消息订阅通知方法和系统是由王小威;蔡立雄;薛强;白杨设计研发完成，并于2023-12-15向国家知识产权局提交的专利申请。

本一种支持送达确认的消息订阅通知方法和系统在说明书摘要公布了：本发明涉及一种支持送达确认的消息订阅通知方法和系统，所述方法包括：设置订阅客户端Watch_Client、发布客户端Notify_Client与服务端Server间进行订阅和消息发布通信的关键字段；依据所述关键字段对Client与Server端分别建立支持送达确认的订阅通道管理机制；基于所述订阅通道管理机制进行Watch_Client、Notify_Client与Server间的订阅和消息发布。本发明支持消息发布的送达确认，支持并发发布，并发等待送达确认，采用高可用的WatchChannel机制，支持临时故障场景的消息成功发布，具有高故障容错性，故障场景支持超时重连等待。

本发明授权一种支持送达确认的消息订阅通知方法和系统在权利要求书中公布了：1.一种支持送达确认的消息订阅通知方法，其特征在于，包括：步骤1：设置订阅客户端Watch_Client、发布客户端Notify_Client与服务端Server间进行订阅和消息发布通信的关键字段；步骤2：依据所述关键字段对Client与Server端分别建立支持送达确认的订阅通道管理机制；步骤3：基于所述订阅通道管理机制进行Watch_Client、Notify_Client与Server间的订阅和消息发布；步骤1设置的关键字段包括：watch_id：客户端内部唯一的订阅通道标记；WatchStream：关联订阅回调函数WatchCallback与订阅关键字Key，其在客户端内部拥有一个唯一的watch_id；WatchKey：用于发送订阅请求，携带watch_id、cookie、Key，其中cookie为客户端全局唯一标记；NotifyCallback：为消息确认函数；WatchChannel：用于服务端Server管理一个订阅关键字Key的所有订阅客户端Watch_Client以及管理发布事件Notify_Handler；WatchClient：用于服务端Server管理一个客户端对一个关键字的订阅状态；NotifyMessage：为Server收到发布消息后为WatchChannel内的所有订阅者组装的发送消息，携带Key、cookie、seq、value，其中seq为一次消息发布事件的标记；NotifyHandler：用于记录一次发布事件，收集送达确认，由Server端收到Notify请求时生成，发布完成后释放；步骤2中，Client端的订阅通道管理机制包括：1每个Client客户端申请一个全局唯一的cookie标记客户端；2客户端对自己发起订阅的每个Key申请一个watch_id标记一个订阅通道，并构造一个WatchStream关联WatchCallback与Key，WatchStream在客户端内部拥有一个唯一的watch_id，Client收到NotifyMessage时，通过消息中携带的watch_id查找到WatchStream，执行其中的WatchCallback；3取消订阅时，删除WatchStream释放watch_id；步骤2中，Server端的订阅通道管理机制包括如下并发发布机制：Server端对每一个Key的订阅使用WatchChannel进行管理，所有订阅同一Key的Client都关联到对应WatchChannel；WatchChannel内部使用自增的seq标记每一次消息发布，并使用seq查询所有正在处理中的发布；在发布完成或超时后释放seq对应的handler；每一次发布消息时，WatchChannel遍历自己关联的所有WatchClient，向所有avariable的Client发送NotifyMessage，而idle状态的Client则标记等待，同时删除已超时失效的WatchClient；步骤2中，Server端的订阅通道管理机制包括如下订阅通道的自动重连机制：Server端为所有订阅的客户端Watch_Client生成一个WatchClient，记录一个Client和Key的watch通道，并把该WatchClient加入到该Key所属的WatchChannel；WatchClient以Key|cookie为Key，并记录Client的发布记录，使用seq标记Client已经完成消费的seqheader,作为故障重连时重发的起始消息；WatchClient使用status标记订阅通道的状态，在Client心跳丢失或超时没有响应NotifyAck时，把Client标记为idle，等待Client重连成功后再重置为avariable；WatchClient在重连成功后，会重发还在处理中的NotifyMessage，收到ack后再加入到NotifyHandler中；WatchClient中记录Client下发的watch_id,关联状态可用的订阅通道，在消息发布时携带watch_id在NotifyMessage中；通信故障或Client失联时，watch_id会失效，重连成功后更新为新的watch_id。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人天翼云科技有限公司，其通讯地址为：100010 北京市东城区青龙胡同甲1号、3号2幢2层205-32室；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。