本发明公开了一种信息传输方法，包括：发送端消息通讯器接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器。还提供了信息传输装置及系统，所述方法、装置和系统能够降低成本和技术难度，且能够提高信息的传输效率。
发送端消息通讯器接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器；
所述预设的消息格式包括：任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；
发送端确定所需执行的任务以及任务内容；根据所述任务确认任务对应的任务编码；
将所述任务编码和任务内容作为消息参数发送给所述发送端消息通讯器。
2.根据权利要求1所述的方法，其特征在于，所述根据消息参数使用预设的消息格式生成第一消息包括：将所述任务编码和消息内容分别填充到消息格式的对应位置。
3.根据权利要求1或2所述的方法，其特征在于，所述根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接包括：发送端消息通讯器根据所述地址信息和通讯端口信息向接收端消息通讯器发送连接请求；
判断在预设时间内接收到接收端消息通讯器返回的连接响应时，连接建立成功。
在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；
接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
5.根据权利要求4所述的方法，其特征在于，接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息包括：将所述执行结果填充到消息格式的消息内容部分。
接收单元，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
第一建立单元，用于根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
第一发送单元，用于连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器；
所述预设的消息格式包括：任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；
所述消息参数是由发送端确定所需执行的任务以及任务内容、根据所述任务确认任务对应的任务编码、将所述任务编码和任务内容作为消息参数发送给所述接收单元的。
7.根据权利要求6所述的装置，其特征在于，第一发送单元包括：第一生成子单元，用于连接建立成功时，将所述任务编码和消息内容分别填充到消息格式的对应位置以生成所述第一消息；
第一发送子单元，用于将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
8.根据权利要求6或7所述的装置，其特征在于，第一建立单元包括：第二发送子单元，用于根据所述地址信息和通讯端口信息向接收端消息通讯器发送连接请求；
第一接收子单元，用于判断在预设时间内接收到接收端消息通讯器返回的连接响应时，判断连接建立成功。
第二建立单元，用于与发送端消息通讯器之间建立连接；
解析单元，用于在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；
接收单元，用于接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
第二发送单元，用于根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
10.根据权利要求9所述的装置，其特征在于，第二发送单元包括：第二生成子单元，用于将所述执行结果填充到消息格式的消息内容部分，以生成所述第二消息；
第三发送子单元，用于将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
发送端消息通讯器，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器；所述预设的消息格式包括：任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；相应的，所述消息参数包括：任务编码；所述消息参数是由发送端确定所需执行的任务以及任务内容、根据所述任务确认任务对应的任务编码、将所述任务编码和任务内容作为消息参数发送给所述发送端消息通讯器的；
接收端消息通讯器，用于与发送端消息通讯器之间建立连接；在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
信息传输方法、装置及系统
技术领域
[0001] 本发明涉及通信领域，尤其涉及信息传输方法、装置及系统。
背景技术
[0002] 随着企业信息化系统日益庞大，模块分工越来越细化。系统各个节点间的同步或者异步信息交换必不可少的需要一种通讯机制的支持。消息机制就是程序之间通过创建、发送和接受消息来进行通信的处理过程。系统内部通讯机制除提供基本的网络通讯功能外，还要尽可能的保证接口程序简单，消息格式内容的灵活，消息传递的稳定性，消息语义的准确表达。
[0003] 现有技术中，在进行两节点之间的信息传输时，客户端向服务器发送的消息是客户端自主定义的，不同的客户端可能消息的格式各不相同，因此，需要在客户端和服务器侧分别根据消息的不同，进行不同的消息传输程序的开发；而且，一般客户端和服务器之间进行消息传输的连接需要用户手动建立
[0004] 但是，发明人发现：这种信息传输方法需要分别开发，成本和技术难度较大；而且，需要用户手动建立连接，信息传输效率低。
发明内容
[0005] 有鉴于此，本发明要解决的技术问题是，提供一种信息传输方法、装置及系统，能够降低成本和技术难度，且能够提高信息的传输效率。
[0006] 为此，本发明实施例采用如下技术方案：
[0007] 本发明实施例提供一种信息传输方法，包括：
[0008] 发送端消息通讯器接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
[0009] 根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
[0010] 连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0011] 所述预设的消息格式包括：任务编码和消息内容；所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容；
[0012] 相应的，所述消息参数包括：任务编码。
[0013] 所述发送端消息通讯器接收所述信息之前进一步包括：
[0014] 发送端确定所需执行的任务以及任务内容；根据所述任务确认任务对应的任务编码；
[0015] 将所述任务编码和任务内容作为消息参数发送给所述发送端消息通讯器。
[0016] 所述根据消息参数使用预设的消息格式生成第一消息包括：
[0017] 将所述任务编码和消息内容分别填充到消息格式的对应位置。
[0018] 所述根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接包括：
[0019] 发送端消息通讯器根据所述地址信息和通讯端口信息向接收端消息通讯器发送连接请求；
[0020] 判断在预设时间内接收到接收端消息通讯器返回的连接响应时，连接建立成功。
[0021] 本发明实施例还提供一种信息传输方法，包括：
[0022] 接收端消息通讯器与发送端消息通讯器之间建立连接；
[0023] 在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；
[0024] 接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
[0025] 接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0026] 接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息包括：
[0027] 将所述执行结果填充到消息格式的消息内容部分。
[0028] 本发明实施例还提供一种信息传输装置，包括：
[0029] 接收单元，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
[0030] 第一建立单元，用于根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
[0031] 第一发送单元，用于连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0032] 第一发送单元包括：
[0033] 第一生成子单元，用于连接建立成功时，将所述任务编码和消息内容分别填充到消息格式的对应位置以生成所述第一消息；
[0034] 第一发送子单元，用于将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0035] 第一建立单元包括：
[0036] 第二发送子单元，用于根据所述地址信息和通讯端口信息向接收端消息通讯器发送连接请求；
[0037] 第一接收子单元，用于判断在预设时间内接收到接收端消息通讯器返回的连接响应时，判断连接建立成功。
[0038] 本发明实施例提供一种信息传输装置，包括：
[0039] 第二建立单元，用于与发送端消息通讯器之间建立连接；
[0040] 解析单元，用于在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；
[0041] 接收单元，用于接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
[0042] 第二发送单元，用于根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0043] 第二发送单元包括：
[0044] 第二生成子单元，用于将所述执行结果填充到消息格式的消息内容部分，以生成所述第二消息；
[0045] 第三发送子单元，用于将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0046] 本发明实施例还提供一种信息传输系统，包括：
[0047] 发送端消息通讯器，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器；
[0048] 接收端消息通讯器，用于与发送端消息通讯器之间建立连接；在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0049] 对于上述技术方案的技术效果分析如下：
[0050] 在发送端和接收端分别设置消息通讯器，并在消息通讯器中预设消息格式，由消息通讯器进行与对端消息通讯器之间的连接建立，并根据消息参数按照预设的消息格式生成第一消息发送给接收端的消息通讯器，从而使得发送端和接收端之间能够自动建立连接，提高了传输效率；并且，消息通讯器中预设消息格式，直接按照相应的流程进行消息的发送，从而使得消息的格式和发送过程标准化，只需要进行一次消息通讯器的程序开发即可，从而降低了开发成本和技术难度。
附图说明
[0051] 图1为本发明实施例一种信息传输方法流程示意图；
[0052] 图2为本发明实施例另一种信息传输方法流程示意图；
[0053] 图3为本发明实施例第三种信息传输方法流程示意图；
[0054] 图3a为本发明实施例消息格式的结构示例图；
[0055] 图4为本发明实施例一种信息传输装置结构示意图；
[0056] 图5为本发明实施例另一种信息传输装置结构示意图；
[0057] 图6为本发明实施例一种信息传输系统结构示意图。
具体实施方式
[0058] 以下，结合附图详细说明本发明实施例信息传输方法及装置的实现。
[0059] 图1为本发明实施例一种信息传输方法流程示意图，可以应用于发送端消息通讯器中，如图1所示，该方法包括：
[0060] 步骤101：发送端消息通讯器接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
[0061] 步骤102：根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
[0062] 步骤103：连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0063] 如图2所示，本发明实施例还提供另一种信息传输方法，适用于接收端消息通讯器，该方法包括：
[0064] 步骤201：接收端消息通讯器与发送端消息通讯器之间建立连接；
[0065] 步骤202：在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；
[0066] 步骤203：接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
[0067] 步骤204：接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0068] 图1和图2所示的方法中，在发送端和接收端分别设置消息通讯器，并在消息通讯器中预设消息格式，由消息通讯器进行与对端消息通讯器之间的连接建立，并根据消息参数按照预设的消息格式生成第一消息发送给接收端的消息通讯器，从而使得发送端和接收端之间能够自动建立连接，提高了传输效率；并且，消息通讯器中预设消息格式，直接按照相应的流程进行消息的发送，从而使得消息的格式和发送过程标准化，只需要进行一次消息通讯器的程序开发即可，从而降低了开发成本和技术难度。
[0069] 在图1和图2的基础上，通过图3对本发明实施例信息传输方法进行更为详细的说明。如图3所示，该方法包括：
[0070] 步骤301：发送端确定所需执行的任务以及任务内容；根据所述任务确定任务对应的任务编码；并确定接收端的地址信息和通讯端口信息，将确定的上述信息发送给发送端的消息通讯器。
[0071] 所述任务编码用于指示接收端所需执行的任务；所述消息内容用于指示接收端所述任务的内容。
[0072] 其中，在发送端和接收端中预先存储有每一任务所对应的任务编码，从而本步骤中发送端直接查找所述对应关系即可得到所述任务对应的任务编码。
[0073] 其中，所述任务编码以及任务内容可以作为消息参数。
[0074] 步骤302：发送端消息通讯器根据所述接收端地址信息以及通讯端口向所述接收端的消息通讯器发送连接请求，并开始计时；接收端消息通讯器接收到所述连接请求后，判断本地的所述通讯端口是否空闲，如果空闲，向发送端消息通讯器返回连接响应，否则，不发送所述连接响应。
[0075] 步骤303：发送端消息通讯器判断在预设时间内接收到所述接收端消息通讯器的连接响应时，确定发送端消息通讯器和接收端消息通讯器之间的连接建立成功，则根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息使用建立的所述连接发送给接收端消息通讯器。
[0076] 其中，在发送端消息通讯器和接收端消息通讯器中可以预先设置对应的消息格式，具体的格式可以根据实际应用环境适应性变化，这里不限定。
[0077] 例如，所述消息格式可以使用如下表1所示的结构，可以包括消息头和消息体两部分；消息头可以包括七个部分，分别为版本编码、压缩编码、加密编码、消息类型编码、模块编码、功能编码和错误码。其中所述版本编码、压缩编码、加密编码、消息类型编码和错误码一般是各个消息中都包括的字段。其中，模块编码和功能编码即对应所述任务编码。在这里，可以将任务划分为大类，由模块编码标识，而每一大类中的具体功能则通过功能编码进行标识。
[0078] 当然，在实际应用中，所述模块编码和功能编码也可以合并为一个字段，这里并不限制。
[0079] 所述消息体即对应所述消息内容。
[0080] 以上消息的各个部分的具体长度可以自主设定，也并不限制。例如，在图3a所示的结构中，所述版本编码为4个二进制位，压缩编码为4个二进制位，所述加密编码为4个二进制位，所述消息类型编码为4个二进制位，所述模块编码为8个二进制位，所述功能编码为8个二进制位，所述错误码为8个二进制位，而消息体的长度并未规定，可以通过具体的消息内容长度决定。
[0081] 此时，本步骤中所述根据消息参数使用预设的消息格式生成第一消息可以包括：
[0082] 将相应的字段内容添加到对应的字段位置，具体的，将所述任务编码和消息内容分别填充到消息格式的对应位置，从而生成所述第一消息。
[0083] 步骤304：接收端消息通讯器接收所述第一消息，从所述第一消息中解析出所述任务编码。
[0084] 其中，由于接收端消息通讯器中设置了同样的消息格式，则本步骤中可以根据所述消息格式相应解析出第一消息中的所述任务编码。
[0085] 步骤305：接收端根据所述任务编码确定自身中是否存在该任务编码所对应的任务，如果存在，执行步骤306；否则，执行步骤307。
[0086] 其中，接收端中预先存储任务编码与自身所能执行的任务之间的对应关系，从而本步骤中直接查找所述对应关系，如果查找到对应的任务编码以及任务编码对应的任务，则表明该任务存在，接收端可以执行该任务编码对应的任务，执行步骤306；否则，表明接收端并无法执行该任务编码指示的任务，执行步骤307。
[0087] 步骤306：接收端执行所述任务编码指示的任务，将任务编码对应的任务执行结果返回给接收端消息通讯器；执行步骤308。
[0088] 步骤307：接收端返回任务查询失败信息给接收端消息通讯器；执行步骤308。
[0089] 其中，任务查询失败信息可以使用不同的标识来表示，这可以由实际应用中自主设定。例如，可以向接收端消息通讯器返回空值以表示没有查找到对应的任务得到对应的任务执行结果。
[0090] 步骤308：接收端消息通讯器根据接收到的所述任务执行结果或所述任务查询失败信息使用所述预设的消息格式生成第二消息，将所述第二消息在建立的所述连接上返回给发送端消息通讯器。
[0091] 其中，本步骤中的所述接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息包括：将所述执行结果或所述任务查询失败信息填充到消息格式的消息内容部分，以生成所述第二消息。
[0092] 步骤309：发送端消息通讯器接收并解析所述第二消息，得到所述任务执行结果或所述任务查询失败信息，将得到的信息返回发送端。
[0093] 通过以上的步骤即可实现了发送端和接收端之间的信息传输，其中，在发送端和接收端为任务进行对应任务编码的设置，在所述消息格式中将任务执行内容和任务编码分开，将任务编码划分于消息头中，而任务执行内容放置于消息内容部分，从而使得接收到所述消息的消息通讯器能够更方便的进行消息的解析，并且，使得任务的扩展更为方便和简单。
[0094] 而且，通过消息通讯器实现了消息传输的标准化，通过依次消息通讯器的开发后，可以在实际应用中自主进行消息格式的设置，使得信息的传输更为灵活和方便，降低了信息传输中的开发成本和技术难度。
[0095] 与以上的方法相对应的，本发明实施例还提供一种信息传输装置，如图4所述，该装置可以设置于发送端中作为所述消息通讯器，该装置包括：
[0096] 第一接收单元410，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；
[0097] 第一建立单元420，用于根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；
[0098] 第一发送单元430，用于连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0099] 优选地，第一发送单元430可以包括：
[0100] 第一生成子单元，用于连接建立成功时，将所述任务编码和消息内容分别填充到消息格式的对应位置以生成所述第一消息；
[0101] 第一发送子单元，用于将所述第一消息在建立的所述连接上发送给接收端消息通讯器。
[0102] 第一建立单元420可以包括：
[0103] 第二发送子单元，用于根据所述地址信息和通讯端口信息向接收端消息通讯器发送连接请求；
[0104] 第一接收子单元，用于判断在预设时间内接收到接收端消息通讯器返回的连接响应时，判断连接建立成功。
[0105] 如图5所示，本发明实施例还提供另一种信息传输装置，可以设置于接收端作为所述接收端消息通讯器，如图5所示，该装置可以包括：
[0106] 第二建立单元510，用于与发送端消息通讯器之间建立连接；
[0107] 解析单元520，用于在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；
[0108] 第二接收单元530，用于接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；
[0109] 第二发送单元540，用于根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0110] 优选地，第二发送单元540可以包括：
[0111] 第二生成子单元，用于将所述执行结果填充到消息格式的消息内容部分，以生成所述第二消息；
[0112] 第三发送子单元，用于将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0113] 另外，本发明实施例还提供了一种信息传输系统，如图6所示，该系统可以包括：
[0114] 发送端消息通讯器610，用于接收所需发送消息的消息参数以及该消息的地址信息和通讯端口信息；根据所述地址信息和通讯端口信息与接收端消息通讯器之间建立连接；连接建立成功时，根据所述消息参数使用预设的消息格式生成第一消息，将所述第一消息在建立的所述连接上发送给接收端消息通讯器；
[0115] 接收端消息通讯器620，用于与发送端消息通讯器之间建立连接；在建立的连接上接收发送端消息通讯器发来的第一消息，从所述第一消息中解析得到任务编码和消息内容；接收所述任务编码指示任务的执行结果，所述任务的执行结果由接收端使用所述消息内容执行所述任务编码指示的任务得到；接收端消息通讯器根据所述执行结果使用预设的消息格式生成第二消息，将所述第二消息在建立的连接上发送给所述发送端消息通讯器。
[0116] 图4～图6所示的装置和系统中，在发送端和接收端分别设置消息通讯器，并在消息通讯器中预设消息格式，由发送端消息通讯器进行与接收端消息通讯器之间的连接建立，并根据消息参数按照预设的消息格式生成第一消息发送给接收端的消息通讯器，从而使得发送端和接收端之间能够自动建立连接，提高了传输效率；并且，消息通讯器中预设消息格式，直接按照相应的流程进行消息的发送，从而使得消息的格式和发送过程标准化，只需要进行一次消息通讯器的程序开发即可，从而降低了开发成本和技术难度。
[0117] 本领域普通技术人员可以理解，实现上述实施例的方法的过程可以通过程序指令相关的硬件来完成，所述的程序可以存储于可读取存储介质中，该程序在执行时执行上述方法中的对应步骤。所述的存储介质可以如：ROM/RAM、磁碟、光盘等。
[0118] 以上所述仅是本发明的优选实施方式，应当指出，对于本技术领域的普通技术人员来说，在不脱离本发明原理的前提下，还可以做出若干改进和润饰，这些改进和润饰也应视为本发明的保护范围。
