公开(公告)号：CN118509298A

公开(公告)日：2024-08-16

申请号：CN202310133430.X

申请日：2023-02-16

申请人： 浙江宇视科技有限公司

发明人： 祝玉磊

IPC分类号： H04L41/026 ,  H04L41/50

摘要： 本发明提供一种消息推送方法、装置、客户端设备和系统，涉及数据处理技术领域，该方法包括：获取当前时刻服务端设备的消息推送速率和客户端缓存队列的队列长度，该客户端缓存队列用于缓存服务端设备推送的待处理消息；确定客户端设备在当前时刻的消息处理速率；基于消息处理速率和队列长度确定下一时刻的目标消息推送速率；在目标消息推送速率相对于消息推送速率发生变化的情况下，将目标消息推送速率发送给服务端设备，以使服务端设备按照目标消息推送速率向客户端设备推送待处理消息。本发明提供的技术方案能够在客户端设备尽最大消息处理能力处理消息的同时，不会因消息的过量推送而出现响应慢、卡顿或崩溃的现象。

公开(公告)号：CN116132248B

公开(公告)日：2024-05-24

申请号：CN202211241449.8

申请日：2022-10-11

申请人： 马上消费金融股份有限公司

发明人： 张松 ,  郭剑霓 ,  吴海英 ,  郭江 ,  刘磊

IPC分类号： H04L41/026 ,  H04L41/50 ,  H04L51/04 ,  H04L51/046

摘要： 本公开提供了一种信息推送方法及计算机可读存储介质。其中，信息推送方法，应用于服务端，包括：响应于客户端发送的信息获取请求，构造异步返回对象，并执行信息获取请求所对应的目标信息的获取操作；信息获取请求是在接收到服务端针对前一次信息获取请求，通过为上一次信息获取请求构造的历史异步返回对象，返回历史获取结束通知后发起的；或者，信息获取请求是客户端首次向服务端发起的；确定预先为执行获取操作设置的预设时长；如果在预设时长内获取操作执行成功，则基于异步返回对象向客户端推送获取结束通知，获取结束通知中携带目标信息。本公开可以提高信息推送的效果。

公开(公告)号：CN117956026A

公开(公告)日：2024-04-30

申请号：CN202410133482.1

申请日：2024-01-31

申请人： 苏州创旅天下信息技术有限公司

发明人： 苏杰

IPC分类号： H04L67/55 ,  H04L41/026 ,  H04L51/04 ,  H04L47/125 ,  H04L67/10 ,  H04L41/042

摘要： 本发明提供了一种基于分布式的实时消息推送系统及方法，包括：客户端子系统、业务应用子系统、云存储子系统和消息中心子系统；其中，客户端子系统与业务应用子系统连接，消息中心子系统分别与客户端子系统、业务应用子系统和云存储子系统连接；消息中心子系统用于通过分布式消息队列集群通信获取业务应用子系统待推送的消息，并通过WebSocket协议和实时的消息推送机制将待推送的消息发送至目标客户端，以及将待推送的消息保存至云存储子系统。本发明能够实现实时的消息传递和即时通信，满足了用户对快速响应和实时交互的需求。

公开(公告)号：CN117914672A

公开(公告)日：2024-04-19

申请号：CN202410058979.1

申请日：2024-01-15

申请人： 上海电气分布式能源科技有限公司

发明人： 黄超 ,  关瑞丰 ,  顾潇 ,  杨杰

IPC分类号： H04L41/026 ,  H04L41/50 ,  H04L69/16

摘要： 本申请提供一种消息传输方法、装置及服务器，其中，可以在获取电力系统中多个电力设备的运行参数的信息之后，根据预存的各个终端设备的订阅信息，分别确定各个终端设备所需的运行参数的信息，将各个终端设备所需的运行参数的信息转换为数据流，并通过长连接的传输控制协议TCP通道将得到的数据流分别传输至对应的终端设备。其中，利用数据流进行传输相较于直接传输数据的传输速率更快，通过长连接的TCP通道进行传输也可以避免每次传输数据都需要重新进行TCP连接，同样提升了传输数据的速率，根据终端设备对数据的订阅信息，可以为不同的终端设备提供所需的运行参数的信息，提升了数据显示的时效性以及针对电力系统的监控效率。

公开(公告)号：CN117914671A

公开(公告)日：2024-04-19

申请号：CN202211247736.X

申请日：2022-10-12

申请人： 马上消费金融股份有限公司

发明人： 陈波 ,  蒋宁 ,  吴海英 ,  王思远 ,  鹿凌华 ,  张永辉

IPC分类号： H04L41/026 ,  H04L41/50 ,  H04L51/043

摘要： 本发明提供一种消息处理方法、装置及电子设备，该方法包括：在接收到待消费的第一消息的情况下，对第一消息进行消费；在第一消息消费失败的情况下，确定目标异常的类型，其中，目标异常为导致第一消息消费失败的异常；采用与目标异常的类型对应的处理策略对第一消息进行处理。通过本发明提供的消息处理方法，针对于导致消息消费失败的不同类型的异常，可以采用不同的处理策略对消费失败的消息进行处理，进而可以提高消息处理方式的灵活性。

公开(公告)号：CN117411762A

公开(公告)日：2024-01-16

申请号：CN202311395848.4

申请日：2023-10-25

申请人： 中国科学院空天信息创新研究院

发明人： 林道玉 ,  项天远 ,  廉婷 ,  王之升 ,  范黎 ,  尹超 ,  金晶 ,  许光銮

IPC分类号： H04L41/026 ,  H04L41/042 ,  H04L47/783

摘要： 本公开提供了一种分布式消息传输方法，包括：在消息服务集群中的消息服务器上启用gateway通信，建立跨域的消息服务集群之间的网关节点的连接；在跨域的消息服务集群的消息服务器中内置预设端口，在跨域的消息服务集群之间传输分布式消息，预设端口获得防火墙的允许；其中，建立消息服务集群跨域的网关节点的连接时，消息服务集群中的每个网关节点都仅连接跨域的远程消息服务集群中的单个网关节点。该方法具备在安全隔离的环境下进行跨域传输的能力，通过异步传输的方式减少了应用软件的耦合度，大大提供了传输能力，具有通过最小网络连接组成超级集群的能力。

公开(公告)号：CN116827746A

公开(公告)日：2023-09-29

申请号：CN202310790515.5

申请日：2023-06-29

申请人： 广州文远知行科技有限公司

发明人： 李靖炫

IPC分类号： H04L41/026 ,  G06N3/044 ,  G06N20/00 ,  H04L51/02 ,  H04L67/133

摘要： 本申请提供的运维消息处理方法、装置、存储介质及智能机器人，用户可以选择任意的集成有机器人服务的聊天软件来发送运维消息，当智能机器人在接收到用户输入的运维消息后，可以将该运维消息发送给消息服务器，并通过消息服务器来根据该运维消息的消息类型，将该运维消息发送至相应的API服务中进行处理，这样既可以保证不同类型的运维消息能够及时得到处理，还可以通过不同的API服务来处理不同类型的运维消息，这样无论是组织外部还是组织内部的运维消息，都可以通过相应的API服务来进行调用；当API服务处理完该运维消息后可以通过消息服务器将该处理结果发送给智能机器人进行展示，以此来为用户解答相应的运维问题。

公开(公告)号：CN116800857A

公开(公告)日：2023-09-22

申请号：CN202211686463.9

申请日：2022-12-26

申请人： 慧之安信息技术股份有限公司

发明人： 兰雨晴 ,  余丹 ,  刘一凡 ,  王丹星 ,  唐霆岳

IPC分类号： H04L69/08 ,  H04L67/12 ,  H04L12/66 ,  H04L41/026 ,  H04L41/50

摘要： 本发明提供基于MQTT的物联网网关双向通信方法和系统，基于MQTT协议，构建物联网平台与网关之间的双向通信通道，当客户端接入到网关后，物联网平台与客户端之间能够进行双向通信，保证物联网平台与客户端之间的双向通信可持续性和稳定性。

公开(公告)号：CN116467070A

公开(公告)日：2023-07-21

申请号：CN202310282173.6

申请日：2023-03-21

申请人： 青岛海尔科技有限公司 ,  海尔优家智能科技(北京)有限公司 ,  海尔智家股份有限公司

发明人： 薛雄伟

IPC分类号： G06F9/50 ,  G06F9/48 ,  H04L41/026

摘要： 本申请公开了一种任务处理方法、装置、存储介质及电子装置，涉及智慧家庭技术领域，该任务处理方法包括：获取预设任务事件发生时所生成的第一触发消息；根据所述第一触发消息控制状态机从当前的第一状态切换至第二状态，并确定所述第二状态对应的第二触发消息；将所述第二触发消息对应的待处理任务加入已创建的待处理任务队列，对加入有所述待处理任务的已创建的待处理任务队列内的待处理任务进行处理，采用上述技术方案，解决了如何在系统资源受限的情况下及时进行任务处理的技术问题。

公开(公告)号：CN116389218A

公开(公告)日：2023-07-04

申请号：CN202310109239.1

申请日：2023-02-10

申请人： 浪潮思科网络科技有限公司

发明人： 郑宏彬

IPC分类号： H04L41/0246 ,  H04L41/0803 ,  H04L41/28 ,  H04L41/06 ,  H04L41/026

摘要： 本申请实施例公开了一种网元设备监控方法、设备及介质。包括，获取网元设备纳管请求信息；其中，网元设备纳管请求信息中至少包括待纳管网元设备的IP，纳管口令以及待纳管网元设备对应的设备信息；在网元设备纳管请求信息验证通过的情况下，对待纳管网元设备下发设备配置；对待纳管网元设备进行绑定处理，并将绑定信息同步发送至zabbix监控平台，以通过zabbix监控平台对待纳管网元设备进行实时监控；接收zabbix监控平台发送的监控数据，在监控数据存在异常的情况下，发送告警信息。通过上述方法，提高运维效率，降低运维成本。