-
公开(公告)号：CN117033015A
公开(公告)日：2023-11-10
申请号：CN202310938499.X
申请日：2023-07-27
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
Abstract: 本申请公开了一种消息处理方法、装置、系统、设备及存储介质。其中，该方法包括：启用与所述消息消费者对应的第一消费服务；基于所述第一消费服务从消息队列中获取待处理消息；确定所述待处理消息的消息类型；获取所述消息消费者的消费者类型；基于所述消息类型和所述消费者类型，对所述待处理消息进行处理。通过本申请的技术方案，能够实现不同消息类型的待处理消息的隔离处理，以实现消息消费者的逻辑灰度，且实现成本较低。
-
公开(公告)号：CN114969112A
公开(公告)日：2022-08-30
申请号：CN202111154000.3
申请日：2021-09-29
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
Inventor： 林德煜 , 庄仁峰 , 胡文辉 , 郑敏 , 吴华挚 , 苏儒 , 孙立军 , 谭俊 , 宁志刚 , 江继针 , 阮晓军 , 梁照江 , 刘雄威 , 覃复慧 , 张子成 , 项华杰 , 刘哲 , 肖聪 , 梁祯夏 , 陈锦坤 , 江旭 , 杨金生 , 王磊 , 潘一佩
IPC: G06F16/2455 , G06F16/27
Abstract: 本发明提供一种针对分布式缓存系统的流控方法、装置及电子设备。方法包括：监控分布式缓存系统中第一应用接口的请求量。在指定时长内第一应用接口的请求量超出第一应用接口对应的流控阈值时，确定分布式缓存系统中具有流控阈值下调空间的第二应用接口，第二应用接口对应的应用级别低于所述第一应用接口，流控阈值用于表征指定时长内应用接口的请求量上限。调低所述第二应用接口的流控阈值，并基于所述第二应用接口的流控阈值的调低幅度，调高所述第一应用接口的流控阈值。本发明的方案能够根据各应用接口的实际请求量，对各应用接口的流控阈值进行适当幅度的上下调整，从而充分调度系统资源处理指向应用接口的请求，可提高系统资源的利率用。
-
公开(公告)号：CN119782002A
公开(公告)日：2025-04-08
申请号：CN202411829015.9
申请日：2024-12-12
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
Abstract: 本申请公开了一种基于Redis实现延迟队列的方法及装置。该基于Redis实现延迟队列的方法，应用于客户端，该方法包括：确定预设历史时长内的查询延迟队列的平均耗时和所述延迟队列中最早到期消息的剩余时间，所述延迟队列为使用Redis的zset集合；基于所述平均耗时和所述剩余时间，通过查询延迟队列开关控制所述工作线程的工作状态，所述工作状态包括执行任务和休眠状态。
-
公开(公告)号：CN119544651A
公开(公告)日：2025-02-28
申请号：CN202411752326.X
申请日：2024-11-29
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: H04L51/02 , H04L51/06 , H04L65/1016
Abstract: 本申请公开了一种数据传输的方法，应用于5G消息发送平台，具体技术方案包括：获取待处理数据和待处理数据对应的数据标识；确定待处理数据对应的目标聊天机器人chatbot；将待处理数据写入等待队列，等待队列中包括目标chatbot在预设查询周期内对应的至少一个待处理数据；合并等待队列中的至少一个待处理数据中数据标识相同的数据，得到至少一个目标数据；向目标chatbot发送目标数据。如此，可以减少调用chatbot接口的次数，从而降低chatbot接口压力。
-
公开(公告)号：CN117354202B
公开(公告)日：2024-09-06
申请号：CN202311284275.8
申请日：2023-09-28
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: H04L43/0852 , H04L47/22
Abstract: 本发明涉及同步延迟检测技术领域，尤其是指一种同步延迟检测方法及装置。本发明所述的基于滑动窗口的同步延迟检测方法，充分考虑了IO延迟等影响，通过设置目标节点三个连续时间窗口增量与源节点对应一个时间窗口增量的对比，确保如同步延迟出现一定程度的延迟后可以检测出来，方便业务运维团队及时定位问题，更好地保障平台业务的可用性。
-
Patent Agency Ranking
公开(公告)号：CN117354202A
公开(公告)日：2024-01-05
申请号：CN202311284275.8
申请日：2023-09-28
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: H04L43/0852 , H04L47/22
Abstract: 本发明涉及同步延迟检测技术领域，尤其是指一种同步延迟检测方法及装置。本发明所述的基于滑动窗口的同步延迟检测方法，充分考虑了IO延迟等影响，通过设置目标节点三个连续时间窗口增量与源节点对应一个时间窗口增量的对比，确保如同步延迟出现一定程度的延迟后可以检测出来，方便业务运维团队及时定位问题，更好地保障平台业务的可用性。
-
公开(公告)号：CN114979043A
公开(公告)日：2022-08-30
申请号：CN202110914667.2
申请日：2021-08-10
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
Inventor： 宁志刚 , 庄仁峰 , 胡文辉 , 郑敏 , 吴华挚 , 孙立军 , 谭俊 , 林德煜 , 江继针 , 肖聪 , 梁祯夏 , 阮晓军 , 江旭 , 刘哲 , 潘一佩 , 陈锦坤 , 李刚 , 李盛阁 , 苏儒 , 覃复慧 , 张子成 , 项华杰 , 梁照江 , 刘雄威 , 杨金生 , 卓彩霞 , 崔巧旭 , 贾思远 , 杨超 , 辛永超
Abstract: 本发明提供一种富媒体的群聊服务方法、服务器及消息即平台。方法包括：富媒体的群聊服务器获取待向目标富媒体聊天群组投送的目标群消息，群组的成员对象包括：富媒体用户和消息即平台的聊天机器人。若目标群消息指示定向投送，且定向投送的成员对象包括第一聊天机器人，则群聊服务器通过消息即平台将目标群消息投送至第一聊天机器人。本发明的方案在富媒体侧为MaaP聊天机器人配置作为聊天群组成员对象的功能，使富媒体聊天群组可以添加MaaP聊天机器人作为成员对象。同时，通过群聊服务器识别投送给群组内聊天机器人的群消息，并按照RCS对应MaaP聊天机器人的路由，将该群消息投送给聊天机器人，使得聊天机器人能够为群组中的正常富媒体用户提供消息服务。
-
公开(公告)号：CN119918660A
公开(公告)日：2025-05-02
申请号：CN202411913765.4
申请日：2024-12-24
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: G06N5/04
Abstract: 本申请公开了一种请求处理方法，所述方法包括：响应于接收到第一客户端发送的推理请求，获取与目标模型对应的映射实例表，其中，所述推理请求用于请求所述目标模型执行推理任务，所述映射实例表包括所述目标模型与至少一个第一候选服务实例的对应关系；从所述映射实例表中选择目标服务实例，并将所述推理请求转发至所述目标服务实例；响应于接收到所述目标服务实例针对所述推理请求返回的推理结果，将所述推理结果发送至所述第一客户端。
-
公开(公告)号：CN117332008B
公开(公告)日：2024-12-17
申请号：CN202311323896.2
申请日：2023-10-12
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: G06F16/27 , G06F16/2455 , G06F11/14
Abstract: 本发明涉及数据库双向同步技术领域，尤其涉及一种适合读写的缓存双向同步实现方法、装置、设备及存储介质，包括：获取NodeA请求数据，基于所述NodeA请求数据，利用lua脚本进行更新同步处理，获得请求参数，利用所述lua脚本将当前时间赋值至reqTime字段，基于所述reqTime字段，判断所述请求参数是否符合预设值，获得新请求参数，基于所述新请求参数，调用服务执行命令，将所述新请求数据存储至目标节点RedisA，若所述目标节点RedisA存在变化，则将所述目标节点RedisA同步至节点RedisB，基于RedisShake原生单向同步机制，架构逻辑上解决Redis双向同步回环问题的机制。
-
公开(公告)号：CN117332008A
公开(公告)日：2024-01-02
申请号：CN202311323896.2
申请日：2023-10-12
Applicant: 中移互联网有限公司 , 中国移动通信集团有限公司
IPC: G06F16/27 , G06F16/2455 , G06F11/14
Abstract: 本发明涉及数据库双向同步技术领域，尤其涉及一种适合读写的缓存双向同步实现方法、装置、设备及存储介质，包括：获取NodeA请求数据，基于所述NodeA请求数据，利用lua脚本进行更新同步处理，获得请求参数，利用所述lua脚本将当前时间赋值至reqTime字段，基于所述reqTime字段，判断所述请求参数是否符合预设值，获得新请求参数，基于所述新请求参数，调用服务执行命令，将所述新请求数据存储至目标节点RedisA，若所述目标节点RedisA存在变化，则将所述目标节点RedisA同步至节点RedisB，基于RedisShake原生单向同步机制，架构逻辑上解决Redis双向同步回环问题的机制。
-
-
-
-
-
-
-
-
-
Search Results
31
records
(took 0.052 seconds)
