基于pg连接的kdp通用内部通信连接实现方法及系统_CN117149451A_上海沄熹科技有限公司.pdf
免费下载
(19)国家知识产权局
(12)发明专利申请
(10)申请公布号
(43)申请公布日
(21)申请号 202310661078.7
(22)申请日 2023 .06 .06
(71)申请人 上海沄熹科技有限公司
地址 200120 上海市浦东新区中国（上海）
自由贸易试验区张东路1158号、丹桂
路1059号2幢305-22室
(72)发明人 吴智勇
(74)专利代理机构 济南信达专利事务所有限公
司 37100
专利代理师 潘悦梅
(51)Int.Cl.
G06F
9/54
(2006 .01)
G06F
9/50
(2006 .01)
G06F
21/44
(2013 .01)
(54)发明名称
基于pg连接的kdp通用内部通信连接实现方
法及系统
(57)摘要
本发明公开了基于pg连接的kdp通用内部通
信连接实现方法及系统，属于软件系统内部通信
技术领域，要解决的技术问题为在原有pg安全认
证的基础上、如何实现kdp内部通信连接。包括如
下步骤：修改pg连接的连接字符串，在连接字符
串中添加connType关键字，用于确定kdp通用内
部通信连接的连接类型；对pg连接的收发接口进
行改进，得到接收接口和发送接口；基于接收接
口和发送接口封装kdp内部通信的实现流程，kdp
内部通信的实现流程遵循如下规则：服务器和节
点通过消息队列和A/Bbuffer保证通信性能，kdp
系统内每个模块从消息队列中读取信息，服务器
和节点之间的每个读写通过单独线程进行处理。
权利要求书2页 说明书6页 附图1页
CN 117149451 A
2023.12.01
CN 117149451 A
1 .一种基于pg连接的kdp通用内部通信连接实现方法，其特征在于，包括如下步骤：
基于kdp系统内部通信需求，修改pg连接的连接字符串，在连接字符串中添加connType
关键字，所述connType关键字用于确定kdp通用内部通信连接的连接类型；
基于kdp系统内部通信的需求看，对pg连接的收发接口进行改进，得到两个接口，分别
为接收接口和发送接口；
基于接收接口和发送接口封装kdp内部通信的实现流程，其中kdp内部通信的实现流程
遵循如下规则：服务器和节点通过消息队列和A/Bbuffer保证通信性能，kdp系统内每个模
块从消息队列中读取信息，服务器和节点之间的每个读写通过单独线程进行处理。
2 .根据权利要求1所述的基于pg连接的kdp通用内部通信连接实现方法，其特征在于，
kdp通用内部通信连接的连接类型包括三种，分别为pg通用连接、kdp内部通信的内部连接、
以及心跳感知连接。
3 .根据权利要求1或2所述的基于pg连接的kdp通用内部通信连接实现方法，其特征在
于，kdp内部通信的实现流程包括如下：
L100、服务器启动后，在其消息队列中注册各个模块的队列信息，并启动监听，等待客
户端请求；
L200、节点启动，在其消息队列中注册各模块的队列信息，并创建A/Bbuffer，通过
ConnectUri向服务器发起连接请求；
L300、服务器进行身份认证且认证通过后，创建处理node业务服务线程，所述处理node
业务服务线程阻塞在ReadCommand处，直至有数据写入；
L400、节点与服务器连接成功后，创建接收处理线程，通过接收处理线程处理服务器发
送回的消息；
L500、各模块根据A/B buffer选择向哪个buffer存储数据，当对应buffer达到发送门
限时，通过发送接口发送数据；
L600、服务器通过ReadCommand接口读取节点发送的业务请求，通过协议解析，将相关
payload发送到其消息队列中；
L700、消费完成服务器收到的消息队列结果后，服务器将消息队列结果发送回节点；
L800、节点通过接收处理线程接收服务器返回的消息队列结果后，通过协议解析，将相
关payload存储至其消息队列中；
L900、节点通过相关线程消费其消息队列中消息；
LA00、对于后续业务，执行步骤L500‑L900；
LB00、当节点发起断开连接时，服务器的处理node业务服务线程退出；
LC00、根据业务需求，节点线程选择是否释放A/B buffer操作。
4 .根据权利要求3所述的基于pg连接的kdp通用内部通信连接实现方法，其特征在于，
所述发送门限包括时间窗口和buffer负载。
5 .根据权利要求3所述的基于pg连接的kdp通用内部通信连接实现方法，其特征在于，
消费完服务器接收到的消息队列结果后，服务器通过处理node业务服务线程获取用于连接
节点的连接句柄或其它标识，基于连接句柄或其它标识、将将消息队列结果发送回节点。
6 .一种基于pg连接的kdp通用内部通信连接实现系统，其特征在于，用于通过如权利要
求1‑5任一项所述的基于pg连接的kdp通用内部通信连接实现方法实现kdp系统内部通信，
权 利 要 求 书
1/2 页
2
CN 117149451 A
2
of 10
免费下载
【版权声明】本文为墨天轮用户原创内容，转载时必须标注文档的来源（墨天轮），文档链接，文档作者等基本信息，否则作者和墨天轮有权追究责任。如果您发现墨天轮中有涉嫌抄袭或者侵权的内容，欢迎发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。
下载排行榜
评论