[发明专利]一种基于消息队列实现消息接收与转发的方法及系统

摘要

本发明公开了一种基于消息队列实现消息接收与转发的方法及系统，涉及数据通讯领域。该方法首先通过数据交换服务器将待转发消息保存到消息接收端所对应的外存消息队列中，然后将待转发消息存放到消息接收端所对应的内存消息队列中，最后将内存消息队列中待转发消息转发到其所对应的消息接收端。在将内存消息队列中的待转发消息转发到消息接收端后，将外存消息队列中对应的发送成功的消息删除。通过本发明所述的方法及系统，数据交换服务器可异步并行进行消息的接收和转发，提高消息传送的实时性，通过两个消息队列协同工作，数据交换服务器即使在大量接收、转发消息的情况下，也能保证数据高效、可靠的传输。

主权项

一种基于消息队列实现消息接收与转发的方法，包括以下步骤：(1)消息发送端将消息发送到数据交换服务器；(2)数据交换服务器接收到消息发送端的消息后，根据消息的路由配置信息，确定所述消息的消息接收端；所述消息接收端为一个或者多个；(3)数据交换服务器将接收到的待转发消息分别保存到每个消息接收端所对应的外存消息队列中；所述外存消息队列保存在外部非易失性存储设备上；(4)数据交换服务器将所述待转发消息存放到消息接收端所对应的内存消息队列中；(5)提取内存消息队列中的待转发消息，并将所述待转发消息转发给内存消息队列所对应的消息接收端；将所述待转发消息转发给内存消息队列所对应的消息接收端的具体方式为：1)将内存消息队列中的所有消息提取到消息列表中，并从内存消息队列中删除已经提取过的消息；2)查看所述消息列表是否为空，若否则进入步骤3)，若是则查看该内存消息队列的消息接收端所对应的外存消息队列是否为空，若是则处理结束，若否则读取外存消息队列中的待转发消息并将所述待转发消息保存到该消息接收端所对应的内存消息队列中并返回步骤1)；3)获取消息列表中的消息，数据交换服务器将所获取的消息逐条转发给内存消息队列所对应的消息接收端。