一种基于内存数据库的多主机间消息交互方法.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN111522818A(43)申请公布日2020.08.11(21)申请号202010328878.3(22)申请日2020.04.23(71)申请人北京思特奇信息技术股份有限公司地址100086北京市海淀区中关村南大街6号14层(72)发明人黄汉宁(74)专利代理机构北京汇信合知识产权代理有限公司11335代理人王维新(51)Int.Cl.G06F16/22(2019.01)G06F16/28(2019.01)G06F16/27(2019.01)G06F9/54(2006.01)权利要求书1页说明书3页附图3页(54)发明名称一种基于内存数据库的多主机间消息交互方法(57)摘要本发明公开了一种基于内存数据库的多主机间消息交互方法，包括多个主机节点，所有主机节点均与内容数据库相连；多主机间消息交互方法包括：建立带有业务处理流程的内存数据库中间表；一主机节点将所需发送的消息和目的节点写入内存数据库中间表；所有主机节点定时轮询数据库中间表；若数据库中间表中存在发往本节点的消息或存在非本节点发出且未指定目的节点的消息，则读取消息并处理。本发明基于内存数据库实现分布式系统多主机间的消息交互，解决了分布式环境下多主机之间低速、高时延传递数据信息的难题，适用于消息体量小、数量多，有高时效、低时延要求的高性能实时业务处理系统。CN111522818ACN111522818A权利要求书1/1页1.一种基于内存数据库的多主机间消息交互方法，其特征在于，包括多个主机节点，所有所述主机节点均与内容数据库相连；所述多主机间消息交互方法包括：建立带有业务处理流程的内存数据库中间表；一所述主机节点将所需发送的消息和目的节点写入所述内存数据库中间表；所有所述主机节点定时轮询所述数据库中间表；若所述数据库中间表中存在发往本节点的消息或存在非本节点发出且未指定目的节点的消息，则读取消息并处理。2.如权利要求1所述的多主机间消息交互方法，其特征在于，所述数据库中间表包括：消息流水，所述消息流水为消息唯一标识，由源主机编号、时间戳和序列号组成；消息内容，所述消息内容为需要传递的消息内容主体；业务内容，所述业务内容为消息可携带的业务内容；目的节点，所述目的节点为需要发送的消息发往的目的节点主机编号，所述主机编号为带字节编号或空白编号，所述空白编号的解码为所有节点均可处理；消息失效时间。3.如权利要求1所述的多主机间消息交互方法，其特征在于，所述主机节点处理消息后，自行删除已处理的消息记录。4.如权利要求1所述的多主机间消息交互方法，其特征在于，主机节点X向主机节点Y发送消息的过程包括如下步骤：步骤11、主机节点X将要发送的消息和目的主机节点Y写入内存数据库中间表；步骤12、分布式系统内的所有主机节点定时轮询内存数据库中间表；步骤13、主机节点Y查到中间表中有发到自身节点的消息，取出进行处理，处理完成后删除记录。5.如权利要求1所述的多主机间消息交互方法，其特征在于，所述主机节点向全系统发送消息的过程包括如下步骤：步骤21、主机节点X将要发送的消息写入内存数据库中间表；步骤22、分布式系统内的所有主机节点定时轮询内存数据库中间表；步骤23、任一主机节点查到中间表中有非自身发出的、未指定目的节点的消息，则立即锁定表记录，取出进行处理，处理完成后删除记录。2CN111522818A说明书1/3页一种基于内存数据库的多主机间消息交互方法技术领域[0001]本发明涉及分布式系统的主机交互技术领域，具体涉及一种基于内存数据库的多主机间消息交互方法。背景技术[0002]目前通信行业应用系统中多为分布式系统，用于提供处理性能和系统的健壮性，而在分布式系统当中，各主机节点之间的消息通信尤为重要，如主节点与从节点之间的业务管控、分发和负载均衡等消息交互，通常缺乏高效和稳定的通信机制。[0003]内存数据库是一种基于内存的实现关系型数据库，支持使用SQL语言进行操作，而且访问速度是传统物理数据库的万倍以上，达到了微秒级，速度快、延迟低、符合分布式系统的主机节点间消息通信的要求。[0004]因此，如何基于内存数据库实现多主机间的消息交互是本发明研究的目的。发明内容[0005]针对现有技术中存在的上述问题，本发明提供一种基于内存数据库的多主机间消息交互方法。[0006]本发明公开了一种基于内存数据库的多主机间消息交互方法，包括多个主机节点，所有所述主机节点均与内容数据库相连；[0007]所述多主机间消息交互方法包括：[0008]建立带有业务处理流程的内存数据库中间表；[0009]一所述主机节点将所需发送的消息和目的节点写入所述内存数据库中间表；[0010]所有所述主机节点定时轮询所述数据库中间表；[0011]若所述数