一种消息发送系统的制作方法.docx

一种消息发送系统的制作方法
专利名称：一种消息发送系统的制作方法
技术领域：
本发明涉及一种消息发送系统。
背景技术：
在使用计算机进行信息处理的各种领域中，常常需要在异构的系统之间进行消息的发送，例如A系统向B系统发送订单消息，的消息；成功发送单元112用于保存发送成功的消息；失败发送单元113用于保存发送失败的消息。消息处理模块12包括:获取子模块121、发送子模块122、扫描子模块123。获取子模块121用于从数据库模块11中获取待发送的消息并且按预设的消息类型分为多个消息队列。发送子模块122用于将消息队列中的消息向系统B发送，并根据系统B返回的表示消息是否发送成功的信息，将发送成功的消息转发给成功发送单元112，将发送失败的消息转发给失败发送单元113。扫描子模块123用于从数据库模块11中获取发送失败的消息然后放入获取子模块121中，可按预设的时间间隔来轮询获取。数据库模块11中的待发送单元111还可用于删除发送子模块122发送过的消息。图1B同时示出了获取子模块121的一种可选结构，其包括消息读取单元1211和队列管理单元1212。消息读取单元1211用于从待发送单元112中读取消息并且按预设的消息类型对读取的消息进行分类，可按预设的时间间隔进行轮询读取；队列管理单元1212用于将消息读取单元1211分类得到的多组消息各自形成消息队列。图中示出了 3个队列的情形。在实际中可以根据预设方式控制消息队列的长度以保证系统的稳定性，例如可以根据计算机的内存大小来调整队列长度。发送子模块122在发送消息时可以根据消息队列来相应地组成线程池，可以采用先入先出的方式来管理发送时序。失败发送单元113还可以用于记录各条消息发送失败的次数，该次数根据发送子模块122提供的发送失败信息来得出，每当收到发送子模块122提供的发送失败信息时，失败发送单元123将发送失败的信息的发送失败的次数加I。或者可以由发送子模块122来统计各条信息发送失败的次数然后将该次数提供给失败发送单元113。扫描子模块123还可用于在发送失败的消息的被发送次数小于预设值，并且当前时间已达到为该消息设定的下次发送时间的情况下，从数据库模块11中获取该发送失败的消息。扫描子模块123也可用于在发送失败的消息的被发送次数达到预设值，并且当前时间未达到为该消息设定的下次发送时间之前的情况下，输出提示信息，这样系统管理员可以进行后续的处理。以下结合图2和图3对本发明实施例的消息发送系统的运行过程做出说明。图2是根据本发明实施例的消息发送系统基本流程的示意图。图3是根据本发明实施例的发送失败消息处理的一种可选流程的示意图。在本实施例的消息发送系统进行消息发送时，首先从系统A中获取要发送的消息，以数据库11的规定格式进行保存。然后由获取子模块121扫描待发送单元(步骤S21)，然后形成消息队列(步骤S22)，再交由发送子模块122进行消息发送(步骤S23)，然后根据系统B反馈的发送是否成功的信息判断发送是否成功(步骤S24)，若是，则从待发送单元中删除已发送的消息(步骤S25)，并进行消息转发(步骤S26)，将消息转发给成功发送单元111 ;否则判断是否需要重新发送(步骤S27)。在需要重新发送的情况下转入发送失败消息处理的流程(步骤S28)，否则转入步骤S25。在本发明实施例的发送失