CN114448962A - Web应用即时消息通知系统、方法及服务器 - Google Patents

Abstract

本发明公开了一种Web应用即时消息通知系统、方法及服务器，其中该系统包括消息分发平台、数据传输控制通道和若干通信服务端；通信服务端用于基于Web Socket协议与其所对应的用户端进行双向数据传输；消息分发平台，用于以广播的形式将接收到的消息通过数据传输控制通道分发到每一通信服务端；数据传输控制通道，用于通过自定义的第一数据传输策略控制消息分发平台分发的消息定向广播给所指定的某一或多个通信服务端；通过上述即时消息通知系统，可实现Web应用的应用后端与应用前端的双向数据传输，允许应用后端主动向应用前端发送数据，另外，使得应用后端的消息定向广播给所指定的用户端，满足不同Web应用的多样化需求。

Description

Web应用即时消息通知系统、方法及服务器

技术领域

本发明涉及Web应用中的前后端通信技术领域，尤其涉及一种Web应用即时消息通知系统、方法及服务器。

背景技术

随着互联网技术发展，Web应用也逐渐流行。Web应用由一个运行于浏览器的前端和一个运行于服务器上的后端程序组成。Web应用带来了诸多好处，但也存在缺陷。Web应用的前端和后端之间采用HTTP协议进行通信，HTTP请求由前端发起，后端收到请求后执行预设程序逻辑。HTTP请求必须由前端发起，这一约束与某些程序的执行逻辑存在冲突。对此，在一些需要后端主动发起请求的Web应用中，使用Web Socket协议进行前后端之间的通信。Web Socket是一种全双工通信协议，可以实现由后端主动向前端推送数据。首先由前端发起请求建立Web Socket连接，然后前端和后端可以进行双向数据传输。Web Socket实现了前后端双向数据传输的功能，但是，却不能根据用户需求对数据传输以及处理策略进行控制。

以用于LED灯测试服务器为例，测试程序通过Web Socket向前端发送请求显示一个窗口，假设此时有多个用户打开浏览器查看测试情况，即存在多个前端，那么测试程序应该向哪些前端发送数据，并非所有用户都有权限查看本次测试，不应该将数据发送到所有前端。另外，当有两个用户同时处理页面的窗口，其中一人反馈LED灯没有点亮，另一人反馈LED灯已经点亮，测试程序应该使用哪个反馈信息，Web应用不但要在前后端之间传输数据，还需要正确传输数据和处理数据。

综上，Web Socket解决了Web应用中前后端的数据传输问题，即如何由后端向前端传输数据，但是Web Socket没有管理数据传输以及处理策略，不能根据用户需求将消息传输到正确对象。

发明内容

本发明的目的是提供一种基于Web Socket协议实现Web应用前后端双向数据传输且可根据用户需求对数据传输对象进行管理的Web应用即时消息通知系统、方法及服务器。

为了实现上述目的，本发明公开了一种Web应用即时消息通知系统，其包括消息分发平台、数据传输控制通道和若干通信服务端；

若干所述通信服务端，分别与若干用户端对应，所述通信服务端用于基于WebSocket协议与其所对应的所述用户端进行双向数据传输；

所述消息分发平台，用于以广播的形式将接收到的消息通过所述数据传输控制通道分发到每一所述通信服务端；

所述数据传输控制通道，用于通过自定义的第一数据传输策略控制所述消息分发平台分发的消息定向广播给所指定的某一或多个所述通信服务端。

较佳地，所述数据传输控制通道包括一信道选择器，所述信道选择器内具有若干分别与每一所述通信服务端相对应的信道开关，所述信道开关用于根据所述第一数据传输策略打开或关闭与其所对应的所述通信服务端与所述消息分发平台之间的数据通道。

较佳地，所述数据传输控制通道还包括若干分别连接在每一所述通信服务端和与该通信服务器所对应的所述信道开关之间的数据筛选器，所述数据筛选器用于以自定义的第二数据传输策略分别对分发向每一所述通信服务端的消息中的数据进行筛选。

较佳地，还包括数据处理模块，所述数据处理模块中设置有对所述消息分发平台的工作机制进行控制的自定义事务协议，所述自定义事务协议用于对所述消息分发平台所分发消息的报文结构和并发处理策略进行自定义控制，以使得应用后端可与应用前端进行多步骤的交换。

较佳地，还包括与所述消息分发平台通信连接的数据库，所述数据库用于存储经过所述消息分发平台的数据，且所述消息分发平台可从所述数据库中调取数据。

较佳地，还包括与所述消息分发平台通信连接的支持跨编程语言的数据接口，所述数据接口用于使得所述消息分发平台与不同形式的业务模块进行数据交互。

本发明还公开一种Web应用即时消息通知方法，其包括：

生成若干分别与若干用户端一一对应的通信服务端，所述通信服务端与所述用户端通过Web Socket协议进行双向数据传输；

通过消息分发平台接收来自外部业务模块或所述通信服务端的消息，并将接收到的消息以广播形式分发到若干所述通信服务端，且，

通过自定义的第一数据传输策略控制所述消息分发平台的分发策略，以将当前消息定向广播给所指定的某一或多个所述通信服务端。

较佳地，所述消息分发平台向外广播消息时，还通过自定义的第二数据传输策略对所述消息中的数据进行筛选。

较佳地，还通过自定义事务协议对所述消息分发平台所分发消息的报文结构和并发处理策略进行自定义控制，以使得应用后端可与应用前端进行多步骤的交换。

本发明还公开一种服务器，其包括：

一个或多个处理器；

存储器；

以及一个或多个程序，其中一个或多个程序被存储在所述存储器中，并且被配置成由所述一个或多个处理器执行，所述程序包括用于执行如上所述的Web应用即时消息通知方法的指令。

与现有技术相比，本发明Web应用即时消息通知系统，首先，每一通信服务端基于Web Socket协议与位于应用前端的相对应的用户端进行通信，从而实现Web应用的应用后端与应用前端的双向数据传输，允许应用后端主动向应用前端发送数据；另外，由于在通信服务端与消息分发平台之间设置数据传输控制通道，且通过自定义的第一数据传输策略控制该数据传输控制通道的工作，从而使得消息分发平台分发的消息定向广播给所指定的通信服务端，进而定向广播给所指定的用户端，满足不同Web应用的多样化需求。

附图说明

图1为本发明实施例中Web应用即时消息通知系统的系统架构图。

图2为本发明实施例中Web应用即时消息通知系统处理协议报文的时序图。

图3为本发明实施例中Web应用即时消息通知系统处理事务并发处理流程图。

具体实施方式

为详细说明本发明的技术内容、构造特征、所实现目的及效果，以下结合实施方式并配合附图详予说明。

如图1，本实施例公开了一种Web应用即时消息通知系统，以用于Web应用中的应用后端2与应用前端1之间的消息传递，该即时消息通知系统包括位于应用后端2的消息分发平台20、数据传输控制通道21和若干通信服务端22。

若干通信服务端22，分别与位于应用前端1的若干用户端10对应，通信服务端22用于基于Web Socket协议与其所对应的用户端10进行双向数据传输。

消息分发平台20，用于实现数据广播，用于以广播的形式将接收到的消息通过数据传输控制通道21分发到每一通信服务端22。本实施例中，一个消息分发平台20管理多对通信服务端22与用户端10的连接。消息分发平台20实现广播功能，当一条消息发送到消息分发平台20，消息被同时分发到消息分发平台20上的所有通信服务端22，最后传输到用户端10。反之亦然，任何一个用户端10向对应的通信服务端22传输数据，该通信服务端22将数据传输给消息分发平台20，然后消息分发平台20将数据广播到其它通信服务端22。

数据传输控制通道21，用于通过自定义的第一数据传输策略控制消息分发平台20分发的消息定向广播给所指定的某一或多个通信服务端22。消息分发平台20广播数据时，向所有已注册的通信服务端22发送数据，但应用程序有时只希望将数据发送到特定的应用前端1，例如，只希望发送给应用前端1的其中两个用户端10，用户端一和用户端二，那么通过数据传输控制通道21和第一数据传输策略，消息分发平台20广播消息时，只将该消息广播给与该两个用户端10对应的通信服务端22，从而实现组播功能。

数据传输控制通道21包括一信道选择器210，信道选择器210内具有若干分别与每一通信服务端22相对应的信道开关211，信道开关211用于根据第一数据传输策略打开或关闭与其所对应的通信服务端22与消息分发平台20之间的数据通道。本实施例中，信道选择器210的控制策略可根据应用需要自定义，比如基于用户访问权限制定策略控制信道开关211，避免数据被发送给无权访问数据的用户，为信息安全提供保障。

数据传输控制通道21还包括若干分别连接在每一通信服务端22和与该通信服务器所对应的信道开关211之间的数据筛选器212，数据筛选器212用于以自定义的第二数据传输策略分别对分发向每一通信服务端22的消息中的数据进行筛选。本实施例中，通过该数据筛选器212来筛选消息分发平台20发送的数据，以减少数据流量，并提升数据传输效率。例如一次消息广播中，消息分发平台20广播10个事件，信道选择器210打开两个信道，两个信道各自有一个数据筛选器212。其中一个信道的数据筛选器212从10个事件中筛选出5个事件，另一个信道的数据筛选器212筛选出7个事件。最终，应用前端1中的两个用户端10收到消息，其中一个用户端10收到的消息中包含5个事件，另一个用户端10收到的消息中包含7个事件。数据筛选器212的筛选策略可根据应用程序的逻辑自定义，比如筛选已经发送过的事件，如果应用前端1已经接收过某条事件，则不需要重复发送该事件。数据筛选器212让每个用户端10只接受必要的数据，减少数据传输量，提升数据传输效率。

本发明即时消息通知系统另一较佳实施例中，还设置有数据处理模块23，数据处理模块23中设置有对消息分发平台20的工作机制进行自定义控制的自定义事务协议，自定义事务协议用于对消息分发平台20所分发消息的报文结构和并发处理策略进行自定义控制，以使得应用后端2可与应用前端1进行多步骤的交换。本实施例中，通过数据处理模块23的设置，可根据用户需求，通过自定义事务协议对消息分发平台20分发的消息进行处理，然后将处理后的消息分发出去。

具体地，上述自定义事务协议的职责包含两部分，一是定义协议报文，二是定义并发处理策略。

对于定义协议报文，如图2，为一个包含三个协议报文的自定义协议时序图，根据该自定义协议，请结合参阅图1和图2，即时消息通知系统的工作过程为：

1.发送“请求报文”

a)应用后端2开始一个事务，根据事务类型创建“请求报文”。

b)应用后端2通过消息分发平台20和通信服务端22向应用前端1发送“请求报文”。

c)应用前端1解析“请求报文”显示请求内容。

2.返回“响应报文”

a)用户处理请求。

b)应用前端1获取用户反馈数据，创建“响应报文”。

c)应用前端1将“响应报文”返回给应用后端2。

3.广播“终止报文”

a)应用后端2解析“响应报文”获得用户反馈数据。

b)应用后端2将用户反馈数据传输给业务模块26。业务模块26，是指实现Web应用主要业务功能的程序模块，比如服务器LED灯测试中根据预定义的测试流程实现测试逻辑的程序模块。

c)应用后端2向应用前端1的所有用户端10广播“终止报文”，通知应用前端1当前事务已经结束。

请参阅下表一展示的报文示例，用户可根据当前Web应用的需求，自定义报文结构。

字段	类型	描述	示例
				Header	map	协议头
ID	string	事务编码	6061ff6e
				Type	string	报文类型	ShowMessage
Step	string	执行步骤	0
				Client	string	客户端编码	0004ae6f0
Body	map	协议体
				Message	string	需要显示的消息	LED灯是否点亮？

表一

对于定义并发处理策略：由于本实施例中的消息分发平台20支持广播功能，即能够同时向多个用户端10发送“请求报文”，多个用户端10可能同时收到“请求报文”，然后同时返回“响应报文”给应用后端2，因此自定义事务协议需制定并发处理策略。如图3，为一种并发处理策略的流程图，并结合参阅图1和图3，该流程图所执行的事务为：应用后端2广播一个“请求报文”到应用前端1的3个用户端10，用户端一最先返回“响应报文”，应用后端2成功处理用户端一的“响应报文”，用户端二等待用户处理，没有返回“响应报文”，用户端三返回“响应报文”时间晚于用户端一，用于后端返回“异常终止报文”，通知用户端三发生异常的原因。具体地，图3所示的并发处理流程的详细执行步骤如下：

1.应用后端2通过消息分发平台20广播“请求报文”到用户端一、用户端二和用户端三。

2.用户端一执行下述流程a～g

a)用户端一处理“请求报文”；

b)用户处理请求；

c)用户端一返回“响应报文”；

d)应用后端2检查当前事务的“响应报文”是否已经被处理；

e)当前事务“响应报文”未被处理，则应用后端2处理“响应报文”；

f)应用后端2解析“响应报文”，获得用户反馈数据，然后向业务模块26传输用户反馈数据；

g)应用后端2广播“终止报文”，通知所有接收过该事件的用户端10，当前事务已经被处理；

h)用户端一收到“终止报文”，得知事务已经结束。

3.用户端二执行下述流程a～e

a)用户端二处理“请求报文”；

b)用户端二等待用户处理请求；

c)在用户端二等待用户处理请求时，用户端一已经返回了“响应报文”；

d)应用后端2广播“终止报文”；

e)用户端二收到“终止报文”，得知事务已经结束。

4.用户端三执行下述流程a～g

a)用户端三处理“请求报文”；

b)用户处理请求；

c)用户端三返回“响应报文”；

d)应用后端2检查当前事务的“响应报文”是否已经被处理；

e)当前事务“响应报文”已被处理，抛弃用户端三返回的“响应报文”；

f)应用后端2返回“异常终止报文”，通知用户端三当前事务已经收到过“响应报文”，用户端三返回的“响应报文”不会被使用；

g)用户端三收到“异常终止报文”，得知发生异常的原因，事务结束。

5.应用后端2广播“终止报文”，结束本次事务。

如图1，本发明即时消息通知系统另一较佳实施例中，还包括与消息分发平台20通信连接的数据库24，数据库24用于存储经过消息分发平台20的数据，且消息分发平台20可从数据库24中调取数据。本实施例中，通过数据库24的设置，建立数据持久化机制，在服务器宕机等异常情况发生时能够恢复数据，改善服务可用性。

再者，还可设置与消息分发平台20通信连接的支持跨编程语言的数据接口25，数据接口25用于使得消息分发平台20与不同形式的业务模块26进行数据交互。较佳地，本实施例中地数据接口25为RESTful API，通过RESTful API封装功能，隐藏消息分发平台20的内部实现，业务模块26不需要直接处理数据传输和处理策略，降低了业务模块26的复杂度，有利于业务模块26开发，简化业务模块26与消息分发平台20的集成工作。

综上，上述实施例公开了一种Web应用即时消息通知系统，用于Web应用中的应用后端2和应用前端1之间的消息传递，其包括位于应用后端2的消息分发平台20、数据传输控制通道21、若干通信服务端22、数据处理模块23、数据库24和数据接口25。其中，应用前端1包括用户端10和与用户端10相对应的前端页面。

首先，通信服务端22与用户端10之间通过Web Socket协议进行通信，实现应用后端2和应用前端1之间的双向数据传输。通过消息分发平台20管理多个基于Web Socket协议的通信连接，根据需求实现组播功能。

其次，数据传输控制通道21包括设置在每一对通信服务端22和用户端10之间的信道选择器210和数据筛选器212。通过该信道选择器210控制信道选择策略，只将数据发送到特定的用户端10，屏蔽其他用户端10。增加信道选择器210后，消息分发平台20的广播功能变为组播功能。数据筛选器212过滤传输的数据内容，减少非必要数据传输，提高数据传输效率。信道选择器210和数据筛选器212提供了可控制的数据传输策略，应用程序可根据程序逻辑配置数据传输策略，从而使得用户可能够根据应用程序要求灵活定制传输策略。

再者，通过数据处理模块23中的自定义事务协议，可根据需求定义协议报文和并发处理策略，从而实现复杂事务处理能力，具体为，允许应用前端1和应用后端2端实现包含多个步骤的交互过程，使得应用程序能够实现复杂数据处理需求。另外，自定义事务协议实现并发处理策略，并发处理中遇到的复杂问题被隐藏在自定义事务协议中，避免业务模块26直接处理并发问题，降低业务模块26实现难度。

另外，通过具有上述结构的即时消息通知系统，将Web Socket协议处理功能、数据传输策略控制功能、数据处理策略控制功能和业务逻辑功能分解到多个系统组件中，降低模块之间的耦合程度。

本发明还公开另一种服务器，其包括一个或多个处理器、存储器以及一个或多个程序，其中一个或多个程序被存储在存储器中，并且被配置成由一个或多个处理器执行，程序包括用于执行如上所述的即时消息通知系统工作方法的指令。处理器可以采用通用的中央处理器(Central Processing Unit，CPU)，微处理器，应用专用集成电路(ApplicationSpecific Integrated Circuit，ASIC)，或者一个或多个集成电路，用于执行相关程序，以实现本申请实施例的即时消息通知系统中的机构所需执行的功能，或者执行本申请即时消息通知系统所具有的工作方法。

本发明还公开一种计算机可读存储介质，其包括计算机程序，计算机程序可被处理器执行以完成如上所述的即时消息通知系统的工作方法。该计算机可读存储介质可以是计算机能够存取的任何可用介质或者是包含一个或多个可用介质集成的服务器、数据中心等数据存储设备。该可用介质可以是只读存储器(read-onlymemory，ROM)，或随机存取存储器(random access memory，RAM)，或磁性介质，例如，软盘、硬盘、磁带、磁碟、或光介质，例如，数字通用光盘(digital versatile disc，DVD)、或者半导体介质，例如，固态硬盘(solid state disk，SSD)等。

以上所揭露的仅为本发明的优选实施例而已，当然不能以此来限定本发明之权利范围，因此依本发明申请专利范围所作的等同变化，仍属本发明所涵盖的范围。

Claims (10)

1.一种Web应用即时消息通知系统，其特征在于，包括消息分发平台、数据传输控制通道和若干通信服务端；

若干所述通信服务端，分别与若干用户端对应，所述通信服务端用于基于Web Socket协议与其所对应的所述用户端进行双向数据传输；

所述消息分发平台，用于以广播的形式将接收到的消息通过所述数据传输控制通道分发到每一所述通信服务端；

所述数据传输控制通道，用于通过自定义的第一数据传输策略控制所述消息分发平台分发的消息定向广播给所指定的某一或多个所述通信服务端。

2.根据权利要求1所述的Web应用即时消息通知系统，其特征在于，所述数据传输控制通道包括一信道选择器，所述信道选择器内具有若干分别与每一所述通信服务端相对应的信道开关，所述信道开关用于根据所述第一数据传输策略打开或关闭与其所对应的所述通信服务端与所述消息分发平台之间的数据通道。

3.根据权利要求2所述的Web应用即时消息通知系统，其特征在于，所述数据传输控制通道还包括若干分别连接在每一所述通信服务端和与该通信服务器所对应的所述信道开关之间的数据筛选器，所述数据筛选器用于以自定义的第二数据传输策略分别对分发向每一所述通信服务端的消息中的数据进行筛选。

4.根据权利要求1所述的Web应用即时消息通知系统，其特征在于，还包括数据处理模块，所述数据处理模块中设置有对所述消息分发平台的工作机制进行控制的自定义事务协议，所述自定义事务协议用于对所述消息分发平台所分发消息的报文结构和并发处理策略进行自定义控制，以使得应用后端可与应用前端进行多步骤的交换。

5.根据权利要求1所述的Web应用即时消息通知系统，其特征在于，还包括与所述消息分发平台通信连接的数据库，所述数据库用于存储经过所述消息分发平台的数据，且所述消息分发平台可从所述数据库中调取数据。

6.根据权利要求1所述的Web应用即时消息通知系统，其特征在于，还包括与所述消息分发平台通信连接的支持跨编程语言的数据接口，所述数据接口用于使得所述消息分发平台与不同形式的业务模块进行数据交互。

7.一种Web应用即时消息通知方法，其特征在于，包括：

生成若干分别与若干用户端一一对应的通信服务端，所述通信服务端与所述用户端通过Web Socket协议进行双向数据传输；

通过消息分发平台接收来自外部业务模块或所述通信服务端的消息，并将接收到的消息以广播形式分发到若干所述通信服务端，且，

通过自定义的第一数据传输策略控制所述消息分发平台的分发策略，以将当前消息定向广播给所指定的某一或多个所述通信服务端。

8.根据权利要求7所述的Web应用即时消息通知方法，其特征在于，所述消息分发平台向外广播消息时，还通过自定义的第二数据传输策略对所述消息中的数据进行筛选。

9.根据权利要求1所述的Web应用即时消息通知方法，其特征在于，还通过自定义事务协议对所述消息分发平台所分发消息的报文结构和并发处理策略进行自定义控制，以使得应用后端可与应用前端进行多步骤的交换。

10.一种服务器，其特征在于，包括：

一个或多个处理器；

存储器；

以及一个或多个程序，其中一个或多个程序被存储在所述存储器中，并且被配置成由所述一个或多个处理器执行，所述程序包括用于执行如权利要求7至9任一项所述的Web应用即时消息通知方法的指令。

Images