24小时热线电话 0898-08980898
发布日期：2023-02-18 16:19:17 点击次数：
本发明涉及im通信技术领域，更具体地说，涉及一种基于路由寻址的分布式im通信方法及其装置。
即时通讯(instantmessaging，im)是目前internet上最为流行的通讯方式，各种各样的即时通讯软件也层出不穷；服务提供商也提供了越来越丰富的通讯服务功能。
现有的基于im开源解决方案的通信方法，均为基于云端进行数据中转交互，导致不能覆盖全终端IM电竞APP，无法满足跨境传输所要求的稳定性。
有鉴于此，本发明提供一种基于路由寻址的分布式im通信方法及其装置以解决现有技术的不足。
在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求；
所述路由服务端在接收到所述第一解析请求后，根据所述第一解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态；
若所述通信状态为跨境状态，所述路由服务端将所述收信端的ip地址和端口解析到专线境内端对应的ip地址和端口；
基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址。
优选地，所述“基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址”包括：
在所述专线境内端通过所述专线境内端对应的ip地址和端口接收到所述发信节点发送的所述消息数据后，所述专线境内端将所述消息数据转发至所述专线境外端；
所述路由服务端通过所述专线境外端将所述消息数据发送至所述收信端对应的所述当前收信地址。
优选地，所述“所述路由服务端通过所述专线境外端将所述消息数据发送至所述收信端对应的所述当前收信地址”包括：
在所述专线境内端将所述消息数据转发至所述专线境外端之后，所述路由服务端接收所述专线境外端发出的针对于所述收信端的所述收信节点对应的ip地址和端口的第二解析请求；
根据所述第二解析请求，所述路由服务端判断所述专线境外端和所述收信节点是否均处于境外；
若所述专线境外端和所述收信节点均处于境外，则所述路由服务端将所述收信端对应的ip地址和端口解析到所述收信节点对应的ip地址和端口；
基于所述收信节点对应的ip地址和端口，所述专线境外端将所述消息数据发送至所述收信节点；并且，基于所述收信节点将所述消息数据下发至所述收信端。
优选地，所述“在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求”之前，还包括：
在所述发送端基于所述发信节点登录后，获取所述发送端的当前用户地址；并且，获取所述收信端的当前收信地址；
所述发送端将所述消息数据上传至所述发信节点，并通过所述发信节点向所述路由服务端发送针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求。
优选地，所述“根据所述解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态”之后，还包括：
若所述通信状态为非跨境状态，则所述路由服务端将所述收信端的ip地址和端口解析到所述收信节点对应的ip地址和端口；
基于所述收信节点对应的ip地址和端口，所述路由服务端将所述消息数据通过所述发信节点发送至所述收信节点，并经所述收信节点下发至所述收信端对应的当前收信地址。
优选地，所述收信端为多个，并且，所述收信节点为多个所述收信端所在的群组对应的收信节点；
所述“根据所述解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态”之后，还包括：
若所述通信状态为非跨境状态，则所述路由服务端将所述收信端的ip地址和端口解析到所述群组对应的所述收信节点的ip地址和端口；
基于所述收信节点对应的ip地址和端口，所述路由服务端将所述消息数据通过所述发信节点发送至群组对应的所述收信节点；并经所述收信节点下发至所述群组中的每个所述收信端。
优选地，所述“基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址”之后，还包括：
若所述交互次数达到预设报错阈值，则所述路由服务端停止所述消息数据的发送；生成一数据交互错误信息，并通过所述发信节点将所述交互错误信息向所述发信端对应的当前发信地址。
此外，为解决上述问题，本发明还提供一种基于路由寻址的分布式im通信装置，包括：
请求模块，用于在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求；
判断模块，用于所述路由服务端在接收到所述第一解析请求后，根据所述第一解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态；
解析模块，用于在若所述通信状态为跨境状态时，所述路由服务端将所述收信端的ip地址和端口解析到专线境内端对应的ip地址和端口；
发送模块，用于基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址。
此外，为解决上述问题，本发明还提供一种计算机设备，所述计算机设备包括发信端、收信端和路由服务端；其中，所述发信端包括第一存储器以及第一处理器；所述收信端包括第二存储器以及第二处理器；所述路由服务端包括第三存储器以及第三处理器；
所述第一存储器、所述第二存储器和所述第三存储器均用于存储基于路由寻址的分布式im通信程序，所述第一处理器、所述第二存储器和所述第三存储器均运行所述基于路由寻址的分布式im通信程序以使所述计算机设备执行如上述所述基于路由寻址的分布式im通信方法。
此外，为解决上述问题，本发明还提供一种计算机可读存储介质，所述计算机可读存储介质上存储有基于路由寻址的分布式im通信程序，所述基于路由寻址的分布式im通信程序被处理器执行时实现如上述所述基于路由寻址的分布式im通信方法。
本发明提供的一种基于路由寻址的分布式im通信方法及其装置。在发信端与收信端进行消息数据的发送时，通过路由服务端接收第一解析请求，如果交互双方为跨境状态，则将收信端的ip地址和端口解析到专线境内端，并通过与该专线境内端连接的专线境外端将消息数据发送到收信端。从而实现了基于im节点的动态解析的收发双方的通信，在跨境im通讯场景中，大大提高了信息传输的稳定性。
图1为本发明基于路由寻址的分布式im通信方法实施例方案涉及的硬件运行环境的结构示意图；
图4为本发明基于路由寻址的分布式im通信方法第二实施例中步骤s420细化的流程示意图；
图6为本发明基于路由寻址的分布式im通信方法第三实施例的另一种实施方式的流程示意图；
图8为本发明基于路由寻址的分布式im通信方法第五实施例的点对点消息发送的流程示意图；
图9为本发明基于路由寻址的分布式im通信方法第五实施例的群消息发送的流程示意图；
图10为本发明基于路由寻址的分布式im通信方法第五实施例的路由、节点和专线之间的结构连接示意图；
下面详细描述本发明的实施例，其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。
此外，术语“第一”、“第二”仅用于描述目的，而不能理解为指示或暗示相对重要性或者隐含指明所指示的技术特征的数量。由此，限定有“第一”、“第二”的特征可以明示或者隐含地包括一个或者更多个该特征。在本发明的描述中，“多个”的含义是两个或两个以上，除非另有明确具体的限定。
在本发明中，除非另有明确的规定和限定，术语“安装”、“相连”、“连接”、“固定”等术语应做广义理解，例如，可以是固定连接，也可以是可拆卸连接，或成一体；可以是机械连接，也可以是电连接；可以是直接相连，也可以通过中间媒介间接相连，可以是两个元件内部的连通或两个元件的相互作用关系。对于本领域的普通技术人员而言，可以根据具体情况理解上述术语在本发明中的具体含义。
应当理解，此处所描述的具体实施例仅仅用以解释本发明，并不用于限定本发明。
如图1所示，图1是本发明实施例方案涉及的终端的硬件运行环境的结构示意图。
本发明实施例计算机设备均可以是的pc，也可以是智能手机、平板电脑或者便携计算机等可移动式终端设备。如图1所示，该计算机设备可以包括：处理器1001，例如cpu，网络接口1004，用户接口1003，存储器1005，通信总线。其中，通信总线用于实现这些组件之间的连接通信。用户接口1003可以包括显示屏、输入单元比如键盘、遥控器，可选用户接口1003还可以包括标准的有线接口、无线可选的可以包括标准的有线接口、无线接口(如wi-fi接口)。存储器1005可以是高速ram存储器，也可以是稳定的存储器，例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储装置。可选地，计算机设备还可以包括rf(radiofrequency，射频)电路、音频电路、wifi模块等等。此外，移动终端和待解锁端还可配置陀螺仪、气压计、湿度计、温度计、红外线传感器等其他传感器，在此不再赘述。
本领域技术人员可以理解，图1中示出的计算机设备并不构成对其的限定，可以包括比图示更多或更少的部件，或者组合某些部件，或者不同的部件布置。如图1所示，作为一种计算机可读存储介质的存储器1005中可以包括操作系统、数据接口控制程序、网络连接程序以及基于路由寻址的分布式im通信程序。
本发明提供的一种基于路由寻址的分布式im通信方法及其装置。其中，所述方法实现了基于im节点的动态解析的收发双方的通信，在跨境im通讯场景中，大大提高了信息传输的稳定性。
参照图2，本发明第一实施例提供一种基于路由寻址的分布式im通信方法，包括：
步骤s100，在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求；
上述，本技术使用分布式的im架构，引入路由寻址的方法，从im节点、im专线中，构造出一条稳定可靠的im通讯线路。
在路由服务中设置节点的初始数据，包括ip地址、端口、区域地址、带宽上限、节点id等数据。给路由服务配置相关的策略及算法，根据im节点实时上报的网络状况，来调度节点之间的数据传输。im数据采用二进制传输协议，rsa非对称加密算法加密。
上述，其中，发信端在登录后，设有一当前发信地址；收信端设有一当前收信地址。路由服务端用于进行数据交互路由。
上述，第一解析请求是发信端通过发信节点发送的请求，是用于请求解析收信端的对应的ip地址和端口。
步骤s200，所述路由服务端在接收到所述第一解析请求后，根据所述第一解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态；
步骤s300，若所述通信状态为跨境状态，所述路由服务端将所述收信端的ip地址和端口解析到专线境内端对应的ip地址和端口；
步骤s400，基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址。
本实施例，应用场景可以为跨境的信息交互。在接收到解析请求后，需判断消息数据交互双方是否为跨境交互，即其通信状态是否为跨境状态。为解决跨境数据交互时节点不统一、数据交互不稳定的问题，本实施例中通过在发信端和收信端之间设置专线，从而通过专线作为发信端和收信端之间的桥接载体，从而通过载体实现收发双方的稳定通信。
上述，发信端和收信端之间的信息交互载体，本实施例中设置为专线，并且在收信端为境外时，专线为专线境内端和与之进行连接的专线境外端，通过在数据交互过程中，分别对需要进行数据传输的结点进行解析，从而将发送结点的ip地址和端口解析到需要进行接收信息的结点的ip地址和端口，从而实现数据的转发。
在本实施例中，im在发信节点解析收信节点，不是直接解析到收信节点的ip地址，而是解析到专线的ip地址，是因为发信节点与收信节点是跨境的，它们之间不能联通。im的节点是动态解析的，在跨境im通讯场景，能极大提高传输的稳定性。此外，构成基本节点可以是点或专线，当两个网络直联不通时(例如境内境外)，可以在两个网络之间配置专线。只要点和专线足够，该im系统可以在任何网络中打通稳定的传输通道。
本实施例提供的一种基于路由寻址的分布式im通信方法。在发信端与收信端进行消息数据的发送时，通过路由服务端接收第一解析请求，如果交互双方为跨境状态，则将收信端的ip地址和端口解析到专线境内端，并通过与该专线境内端连接的专线境外端将消息数据发送到收信端。从而实现了基于im节点的动态解析的收发双方的通信，在跨境im通讯场景中，大大提高了信息传输的稳定性。
参照图3-4，本发明第二实施例提供一种基于路由寻址的分布式im通信方法，基于上述图2所示的第一实施例，所述步骤s400，“基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址”包括：
步骤s410，在所述专线境内端通过所述专线境内端对应的ip地址和端口接收到所述发信节点发送的所述消息数据后，所述专线境内端将所述消息数据转发至所述专线境外端；
上述，在路由服务端将收信端的地址解析到专线境内端的ip和端口后，发信节点将消息数据发送给专线境内端，专线境内端在收到消息数据后，转发该消息到专线，所述路由服务端通过所述专线境外端将所述消息数据发送至所述收信端对应的所述当前收信地址。
专线境外端为进行数据中转的结点之一，在接收到数据后，路由服务端通过该专线的境外端将消息数据进行发送，发送至收信端对应的当前收信地址。
此外，在某种实施方式下，所述步骤s420，“所述路由服务端通过所述专线境外端将所述消息数据发送至所述收信端对应的所述当前收信地址”包括：
步骤s421，在所述专线境内端将所述消息数据转发至所述专线境外端之后，所述路由服务端接收所述专线境外端发出的针对于所述收信端的所述收信节点对应的ip地址和端口的第二解析请求；
上述，第二解析请求，为用于专线境外端向路由服务端请求解析收信端对应的ip地址和端口。
步骤s422，根据所述第二解析请求，所述路由服务端判断所述专线境外端和所述收信节点是否均处于境外；
步骤s423，若所述专线境外端和所述收信节点均处于境外，则所述路由服务端将所述收信端对应的ip地址和端口解析到所述收信节点对应的ip地址和端口；
如果专线境外端和收信节点均处于境外，则可将收信端的地址解析到收信节点的ip地址和端口。
步骤s424，基于所述收信节点对应的ip地址和端口，所述专线境外端将所述消息数据发送至所述收信节点；并且，基于所述收信节点将所述消息数据下发至所述收信端。
在基于上述收信节点和对应的ip地址和端口，即已经解析后的地址，专线境外端将消息数据发送至收信节点，进而该收信节点进一步的将数据下发到收信端，即其所对应的地址。
IM电竞APP
所述步骤s100，“在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求”之前，还包括：
步骤s500，在所述发送端基于所述发信节点登录后，获取所述发送端的当前用户地址；并且，获取所述收信端的当前收信地址；
步骤s600，所述发送端将所述消息数据上传至所述发信节点，并通过所述发信节点向所述路由服务端发送针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求。
上述，用户从发信节点登录后，获取到当前的用户地址，进而用户作为发信端，需要发信息给收信端，向用户管理服务查询到收信端对应的当前地址。而发信端向收信端发送消息时，消息首先上传到发信节点处，并通过发信节点向路由服务端发送第一解析请求。
本实施例中，通过动态解析节点对应的名称到对应的ip地址中，在跨境im通讯场景，能极大提高传输的稳定性。
参照图5-6，本发明第三实施例提供一种基于路由寻址的分布式im通信方法，基于上述图2所示的第一实施例，所述步骤s200，“根据所述解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态”之后，还包括：
步骤s700，若所述通信状态为非跨境状态，则所述路由服务端将所述收信端的ip地址和端口解析到所述收信节点对应的ip地址和端口；
步骤s800，基于所述收信节点对应的ip地址和端口，所述路由服务端将所述消息数据通过所述发信节点发送至所述收信节点，并经所述收信节点下发至所述收信端对应的当前收信地址。
上述，如果当前的通信状态为非跨境状态，即为信息交互的双方均为境内的双方，则可进行对于收信端的地址和端口解析到收信节点处，并且基于解析后的收信节点，路由服务端将消息数据通过发信节点发送到收信节点，并进一步可下发到当前收信地址中，从而即完成了信息数据的由发信端到收信端的信息传递，中间数据传输时，通过动态解析ip地址和端口，从而实现了信息的高效稳定的传输。
此外，在另一种实施方式中，所述收信端为多个，并且，所述收信节点为多个所述收信端所在的群组对应的收信节点；在此情况下，所述步骤s200，“根据所述解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态”之后，还包括：
步骤s900，若所述通信状态为非跨境状态，则所述路由服务端将所述收信端的ip地址和端口解析到所述群组对应的所述收信节点的ip地址和端口；
步骤s1000，基于所述收信节点对应的ip地址和端口，所述路由服务端将所述消息数据通过所述发信节点发送至群组对应的所述收信节点；并经所述收信节点下发至所述群组中的每个所述收信端。
此外，群组，即为聊天群所在的房间，其中包括群众的所有收信端。当需要进行一对多的消息发送时，且该群组处于境内，则可进行对于群组所在的收信节点的解析后的ip地址和端口进行数据交互，进而再通过收信节点下发到每一个其中所包含的收信端IM电竞APP，从而实现了有一对多的信息数据交互。
参照图7，本发明第四实施例提供一种基于路由寻址的分布式im通信方法，基于上述图2所示的第一实施例，所述步骤s400，“基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址”之后，还包括：
步骤s1200，若所述交互次数达到预设报错阈值，则所述路由服务端停止所述消息数据的发送；生成一数据交互错误信息，并通过所述发信节点将所述交互错误信息向所述发信端对应的当前发信地址。
需要说明的是，数据在交互过程中，如果出现数据传输失败，则会出现数据不停的在端与端之间进行无线转发的情况，造成系统出现大量无用的数据传输，一方面造成系统运行的负担，另一方面产生大量的垃圾信息，造成系统冗余，从而大大降低了im数据交互的效率。
上述，交互次数，为数据每经过依次转发即记录一次交互次数，每次转发即进行交互次数的叠加。
上述，预设报错阈值，为用于对于交互次数进行比对的评价标准，当交互次数达到一定的报错阈值，则可判定当前im数据信息在出现多次转发，出现转发错误，则生成一进行报错的错误信息，并发送至发信放端进行报错，提示发信端进行排查或进行信息的重新发送。从而提高了im数据交互的效率，避免了信息交互错误造成的数据不停转发。
此外，为了更好的说明本发明所提供的方法，本实施例中提供一种基于路由寻址的分布式im通信方法，包括如下：
本实施例中，使用分布式的im架构IM电竞APP，引入路由寻址的方法，从im节点、im专线中，构造出一条稳定可靠的im通讯线路。
本实施例中，在路由服务中设置节点的初始数据，包括ip地址、端口、区域地址、带宽上限、节点id等数据。给路由服务配置相关的策略及算法，根据im节点实时上报的网络状况，来调度节点之间的数据传输。im数据采用二进制传输协议，rsa非对称加密算法加密。
参考图8，时序图中的组成的单元有：用户管理、用户1001、用户1002、sz节点(国内)、ph节点(国外)、专线(广州-香港)、路由。
步骤2、用户1001需要发消息给1002，向用户管理服务查询到1002的当前地址：；
步骤5、路由服务发现sz节点与ph节点处于跨境状态，把ph.user的地址解析到专线的境内端的ip地址和端口；
步骤8、专线境外端向路由服务请求解析ph.user对应的ip地址和端口；
步骤9、路由服务发现专线境外端与ph.user节点都属于境外，把ph.user解析到ph节点的ip地址和端口；
步骤2、用户1001需要发消息给房间(群)5000，向房间管理服务查询到5000的当前地址：；
步骤5、路由服务发现sz节点与sz.room服务都处于境内，把sz.room的地址解析到szroom服务的ip地址和端口；
步骤7、szroom服务转发消息给当前在房间中的其他用户，转发过程同样需要查询路由后转发，消息转发次数累加1。
1、图10im节点境内有5个，境外有4个，专线条，这些节点和专线的数量，可以从候补资源中补充，或者删除后归还给候补资源。im节点的数量可以根据网络使用率增减。
2、图10im境内节点有五个节点a、b、c、d、e，除了c-d之间没有直联外，其他节点都有直联。这是因为c-d之间此刻直联的效率不高，当达到直联的效率后c-d即可直联，而直联的效率判断是由路由给出判断的。节点间的连接由路由调配，很灵活。
3、图8步骤4-6，im在sz节点解析ph节点，不是直接解析到ph节点的ip地址，而是解析到专线的ip地址，是因为sz节点与ph节点是跨境的，它们之间不能联通。im节点是动态解析的，在跨境im通讯场景，能极大提高传输的稳定性。
4、构成基本节点可以是点或专线，当两个网络直联不通时(例如境内境外)，可以在两个网络之间配置专线。只要点和专线足够，该im系统可以在任何网络中打通稳定的传输通道。
此外，参考图11，本发明还提供一种基于路由寻址的分布式im通信装置，包括：
请求模块10，用于在发信端基于当前发信地址向收信端对应的当前收信地址进行消息数据发送时，路由服务端接收所述发信端基于发信节点发出的针对于所述收信端的收信节点对应的ip地址和端口的第一解析请求；
判断模块20，用于所述路由服务端在接收到所述第一解析请求后，根据所述第一解析请求判断所述发信节点和所述收信节点之间的通信状态是否处于跨境状态；
解析模块30，用于在若所述通信状态为跨境状态时，所述路由服务端将所述收信端的ip地址和端口解析到专线境内端对应的ip地址和端口；
发送模块40，用于基于所述专线境内端对应的ip地址和端口，所述路由服务端通过与所述专线境内端连接的专线境外端将所述消息数据经所述收信节点发送至所述收信端对应的所述当前收信地址。
此外，本发明还提供一种计算机设备，所述计算机设备包括发信端、收信端和路由服务端；其中，所述发信端包括第一存储器以及第一处理器；所述收信端包括第二存储器以及第二处理器；所述路由服务端包括第三存储器以及第三处理器；
所述第一存储器、所述第二存储器和所述第三存储器均用于存储基于路由寻址的分布式im通信程序，所述第一处理器、所述第二存储器和所述第三存储器均运行所述基于路由寻址的分布式im通信程序以使所述计算机设备执行如上述所述基于路由寻址的分布式im通信方法。
此外，本发明还提供一种计算机可读存储介质，所述计算机可读存储介质上存储有基于路由寻址的分布式im通信程序，所述基于路由寻址的分布式im通信程序被处理器执行时实现如上述所述基于路由寻址的分布式im通信方法。
通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到上述实施例方法可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件，但很多情况下前者是更佳的实施方式。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品存储在如上所述的一个存储介质(如rom/ram、磁碟、光盘)中，包括若干指令用以使得一台终端设备(可以是手机，计算机，服务器，或者网络设备等)执行本发明各个实施例所述的方法。以上仅为本发明的优选实施例，并非因此限制本发明的专利范围，凡是利用本发明说明书及附图内容所作的等效结构或等效流程变换，或直接或间接运用在其他相关的技术领域，均同理包括在本发明的专利保护范围内。
