CN102420861A - 服务器的消息监听方法、装置及系统 - Google Patents

Abstract

本发明公开了一种服务器的消息监听方法、装置及系统。该方法包括：设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行;所述监听服务进程获取到预设消息时，通过与客户端建立的会话连接向所述客户端发送警示消息。采用本发明，可以通过与web服务进程同级的监听进程获取到预设的报警信息后，实时主动地发送给客户端，能够在客户端的浏览器上及时通知到管理员。由于设置了与web服务相对独立的web级别监听服务线程，使得原有web服务其他功能不受监听的阻塞。另外，开创了一种服务器主动推送消息机制，无需通过客户端的请求。故此增强了B/S（浏览器/服务器）跨平台信息通讯和服务器主动推送消息到浏览器的实时性和效率性。

Description

服务器的消息监听方法、装置及系统

技术领域

本发明涉及实时通讯技术，尤其涉及服务器的消息监听方法、装置及系统。

背景技术

目前跨平台实时通讯的实现技术方案有两种，一种是在web服务器端启动socket（套接字）监听服务线程，例如web socket通讯技术可以实现该功能，但是还没有成为W3C（World Wide Web Consortium，万维网联盟）标准，只有部分浏览器予以支持；另一种是在浏览器客户端主要基于轮询刷新技术来实现。受限制于网络平台的请求-响应机制，服务器端获取到报警信息后，需要在服务器端缓存，无法主动及时通知到客户浏览器。客户浏览器只有每次间隔一定时间向服务器请求询问报警信息，服务器才能被动响应浏览器的请求，把报警信息发送给请求的客户端浏览器。

socket通讯在B/S结构中，web端启用该监听线程后会阻塞浏览器客户端对其他功能的使用；目前的web socket技术并没成为W3C标准，所以浏览器的兼容性存在问题。

对于浏览器轮询技术，其最大的缺陷是由于浏览器是每隔一定时间去请求服务器来获得服务器的响应，服务器发出的报警信息并不能实时地通知到浏览器客户端。而且，不管服务器有没有报警信息，浏览器客户端都会定时轮询，资源浪费大，效率差。并且，服务器只响应请求的浏览器客户端，其他浏览器客户必须自己再次请求才能得到响应。

发明内容

为了解决上述技术问题，本发明提供了服务器的消息监听方法、装置及系统，能够实现同级进程的实时监听，将监听消息及时发送给客户端。

本发明提供了一种服务器的消息监听方法，包括：

设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行;

所述监听服务进程获取到预设消息时，通过与客户端建立的会话连接向所述客户端发送警示消息。

相应地，本发明还提供了一种服务器的消息监听装置，包括：

与主进程服务单元相连的监听服务单元，用于设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行；

与所述监听服务单元相连的消息捕获单元，用于获取预设消息；

与所述消息捕获单元相连的消息发送单元，用于通过与客户端建立的会话连接向所述客户端发送警示消息。

相应地，本发明还提供了一种服务器的消息监听系统，包括至少一个客户端和与所述客户端相连的服务器，以及与该服务器相连的外部信息系统，

所述服务器包括如前所述服务器的消息监听装置，以及与所述消息监听装置相连的主进程服务单元；所述主进程服务单元，用于执行web服务进程，管理web服务资源；

所述外部信息系统，用于发出报警信息；

所述客户端包括如前所述的消息接收单元和前端显示单元。

实施本发明，具有如下有益效果：

本发明通过与web服务进程同级的监听进程获取到预设的报警信息后，实时主动地发送给客户端，能够在客户端的浏览器上及时通知到管理员。由于设置了与web服务相对独立的web级别监听服务线程，使得原有web服务其他功能不受监听的阻塞。另外，开创了一种服务器主动推送消息机制，无需通过客户端的请求。当服务器socket监听到报警信息时，直接发送到已经登录的指定的一个或多个浏览器客户端显示，客户端基于extjs技术，无需刷新界面。本发明增强了B/S（浏览器/服务器）跨平台信息通讯和服务器主动推送消息到浏览器的实时性和效率性。

附图说明

图1是本发明一种服务器的消息监听方法的流程图；

图2是本发明一种服务器的消息监听方法的实施例流程图；

图3是本发明一种服务器的消息监听装置的示意图；

图4是本发明一种服务器的消息监听装置的实施例示意图；

图5是本发明一种服务器的消息监听系统的示意图。

具体实施方式

为使本发明的目的、技术方案和优点更加清楚，下面将结合附图对本发明作进一步地详细描述。

图1是本发明一种服务器的消息监听方法的流程图，包括：

S101：设置监听服务进程，在应用服务器启动web服务进程的时候同时启动所述监听服务进程；

S102：所述监听服务进程获取到预设消息时，通过与客户端的会话连接向所述客户端发送警示消息。

现有技术中，在web服务端创建报警信息的监听进程，通常我们会创建一个socket服务的监听进程作为web的一个功能模块，然后在web的某个按钮或其他事件中触发启动socket监听进程。它强调的是监听web页面的操作事件，然后根据操作事件的类型服务器做出相应的响应。这种请求响应模式，由前台操作员作为动作发起者，后台提供相应的服务。这样做需要用到web服务主线程来创建socket监听服务的新进程，而在创建的socket监听服务进程通常会进入一个无限循环等待socket客户端的连接，故此不能返回主线程。这个时候web服务就会被阻塞，而导致用户无法使用web的其他功能服务。

针对上述现有的技术问题，本发明对监听进程进行创造性的设计。监听服务进程并不作为web服务的一个子功能，不再由web服务触发创建，设置监听服务进程作为与web服务进程的监听守护进程，即一个进程同服务主进程并行运行，监控web服务进程的信息和状态。故此，避免阻塞web服务的弊端出现。监听服务进程作为和web服务主进程同级别的进程，避免了监听服务进程的循环阻塞web服务，并且达到了监听服务进程共享web服务资源（request，session等监听服务进程和web服务处于同一个工程服务，因此可以通过servelet框架共享所有web资源）的目的。

另外，现有的B/S（浏览器/服务器）结构中，web服务都是基于请求-响应机制实现。只有浏览器客户端发出请求，web服务器才会响应发送信息到浏览器，web服务器并不会主动发送信息到浏览器。所以，传统的消息通讯机制采用了浏览器轮询的技术，即每隔一定时间浏览器发送请求询问客户端是否有信息返回。这种方法，资源开销大，不管服务器有没有消息客户端都要定时询问，浪费资源。当存在信息延时，服务器获取信息后并不能主动立即发送到浏览器，要等到浏览器询问请求到来才能响应，不利于实时通讯。目前有一种基于socket的新技术web socket，可以在脚本上创建和服务器的连接通讯。但是同样存在阻塞web服务等问题，并且web socket并没成为W3C标准存在浏览器的兼容问题。

为了解决服务器主动向浏览器推送信息实现实时通讯问题。我们在web服务端建立起和浏览器前台脚本的直接的会话连接，使得可以在web服务器端可以直接设置浏览器脚本函数参数并直接调用，甚至可以直接在web服务器端直接创建脚本函数并在前台浏览器执行。这些功能都是基于scriptsession技术实现的。Scriptsession类似于session的一个和客户端的连接，但是粒度更细，具体指向了某个页面的连接，并保留了此页面的相关信息包括脚本，因此通过sscriptsession可以使用后台参数直接调用页面脚本执行，甚至在后台服务创建函数后直接在页面执行。从而达到了后台web服务直接向前台浏览器推送信息并显示的目的。当所述监听服务进程获取到预设消息时，通过与客户端建立的会话连接向所述客户端发送警示消息。

图2是本发明一种服务器的消息监听方法的实施例流程图，包括：

S201：在应用服务器启动web服务进程的时候同时启动所述监听服务进程。

S202：设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行;

S203：所述监听服务进程接收外部信息系统与所述服务器的通讯信息，并将该通信消息转发给所述web服务进程。

S204：所述监听服务进程获取到预设消息时，通过与客户端建立的会话连接向所述客户端发送警示消息。

S205：在所述客户端创建前端用户界面，显示所述警示消息。

在应用服务器（如：tomcat，weblogic等）启动web服务的时候同时启动所述监听服务进程，这样，监听服务进程就成为了和web服务主进程同级别的进程，避免了监听服务进程的循环阻塞web服务，并且达到了监听服务进程共享web服务资源。有利于及时对web服务进程进行监听。

设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行，有利于监听服务进程共享web服务资源，所述web服务资源主要包括request，session。监听服务进程和web服务处于同一个工程服务，还可以通过servelet框架共享所有web资源。

具体的软件实施方案包括：首先，编写监听服务进程功能模块。功能模块主类继承ServletContextListener（此接口是Servlet架构提供的一个基础接口类，作为一个入口用于实现服务器级别的监听进程）接口，并实现接口的contextInitialized方法（此方法是ServletContextListener类里的一个抽象方法，通过这个方法实现监听服务进程的具体逻辑功能）。在此方法中实现监听服务进程的创建。然后，在web服务工程的web.xml文件中配置监听listener参数为监听服务进程的主类。并可以设置context-param参数（这个参数用于提供ServletContextListener需要使用到的一些技术参数指标值：比如说端口号等）供主类使用。这样，在应用服务器（例如tomcat）启动的时候，web服务进程和监听服务进程就会同时启动，并能相互通讯共享资源。上述软件实现方式只是一个具体实例，不能用于限定本发明的保护范围，所有基于本发明思路做出的类似变换和等同替换均应在本发明的保护范围之内。

所述监听服务进程除了监控Web服务进程的信息和状态。所述信息包括接收外部信息系统与所述服务器的通讯信息，并将该通信消息转发给所述web服务进程。所述状态包括，web服务进程是否发生阻塞。

当所述web服务进程发生信息阻塞时，所述监听服务进程检测发生该阻塞的原因，暂缓转发所述外部消息系统的信息。

在所述客户端创建前端用户界面，显示所述警示消息。

具体的软件实施方案包括：首先，在浏览器用户登录的时候，获取到系统主框架页面的Scriptsession（所述Scriptsession是针对javascript脚本级的会话标致，主要用于在web服务中标示定位到具体页面）和用户名等相关信息，维护一张hashmap（所述hashmap相当于一张记录了属性名key和属性值value的二维表，具有快速存取的优点），把用户名作为hashmap的key值，Scriptsession 对象作为hashmap的value值保存在系统变量中，以供消息发送使用。其次，当监听服务进程获取到云平台的报警信息后，获取hashmap里的信息，并利用scriptsession向对用用户的浏览器客户端发送报警信息。最后，由于scriptsession是脚本级的调用，前台采用extjs等技术想结合，达到无刷新显示，左下角弹出消息框等表现效果。所述ExtJS是一个用javascript写的，主要用于创建前端用户界面，它是一个与后台技术无关的前端ajax框架。上述软件实现方式只是一个具体实例，不能用于限定本发明的保护范围，所有基于本发明思路做出的类似变换和等同替换均应在本发明的保护范围之内。

图3是本发明一种服务器的消息监听装置的示意图，包括：

与主进程服务单元相连的监听服务单元，用于设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行；

与所述监听服务单元相连的消息捕获单元，用于获取预设消息；

与所述消息捕获单元相连的消息发送单元，用于通过与客户端建立的会话连接向所述客户端发送警示消息。

图3与图1相对应，上述各单元的运行方式和方法中的相同。

图4是本发明一种服务器的消息监听装置的实施例示意图；

如图4所示，所述监听服务单元具体包括：

与应用服务器相连的监听启动单元，用于在应用服务器启动web服务进程的时候同时启动所述监听服务进程；

连接在外部信息系统和所述主进程服务单元之间的信息转发单元，用于接收外部信息系统与所述服务器的通讯信息，并将该通信消息转发给所述web服务进程。

如图4所示，所述监听服务单元，还包括：

与所述信息转发单元相连的阻塞处理单元，用于检测所述web服务进程发生阻塞的原因，暂缓转发所述通信消息给所述web服务进程。

图4与图2相对应，上述各单元的运行方式与方法中的相同。

图5是本发明一种服务器的消息监听系统的示意图，包括至少一个客户端和与所述客户端相连的服务器，以及与该服务器相连的外部信息系统，

所述服务器包括如权利要求5至7任一项所述服务器的消息监听装置，以及与所述消息监听装置相连的主进程服务单元；所述主进程服务单元，用于执行web服务进程，管理web服务资源；

所述外部信息系统，用于发出报警信息；

所述客户端包括：与所述消息发送单元相对应的消息接收单元，用于接收所述警示消息；与所述消息接收单元相连的前端显示单元，用于在所述客户端创建前端用户界面，显示所述警示消息。

所述服务器可以作为云控制台；所述外部信息系统可以作为云平台，该系统可以有unix或linux系统予以实现；所述客户端可以作为浏览器端。通过上述的解决方案，可以实现了云平台、云控制台和浏览器端的报警信息跨平台系统的无阻塞，实时传递效果。系统通讯的有效性、实时性和稳定性得到了提升。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到本发明可借助软件加必需的硬件平台的方式来实现，当然也可以全部通过硬件来实施。基于这样的理解，本发明的技术方案对背景技术做出贡献的全部或者部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在存储介质中，如ROM/RAM、磁碟、光盘等，包括若干指令用以使得一台计算机设备（可以是个人计算机，服务器，或者网络设备等）执行本发明各个实施例或者实施例的某些部分所述的方法。

以上所述的本发明实施方式，并不构成对本发明保护范围的限定。任何在本发明的精神和原则之内所作的修改、等同替换和改进等，均应包含在本发明的权利要求保护范围之内。

Claims (10)

1.一种服务器的消息监听方法，其特征在于，包括：

设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行;

所述监听服务进程获取到预设消息时，通过与客户端建立的会话连接向所述客户端发送警示消息。

2.根据权利要求1所述的服务器的消息监听方法，其特征在于，所述监听服务进程和所述web服务进程并行运行的步骤之前，包括：

在应用服务器启动web服务进程的时候同时启动所述监听服务进程。

3.根据权利要求2所述的服务器的消息监听方法，其特征在于，所述监听服务进程和所述web服务进程并行运行的步骤之后，所述监听服务进程获取到预设消息的步骤之前，还包括：

所述监听服务进程接收外部信息系统与所述服务器的通讯信息，并将该通信消息转发给所述web服务进程。

4.根据权利要求3所述的服务器的消息监听方法，其特征在于：

当所述web服务进程发生信息阻塞时，所述监听服务进程检测发生该阻塞的原因，暂缓转发所述通信消息给所述web服务进程。

5.根据权利要求1至4任一项所述的消息监听方法，其特征在于，所述通过与客户端的会话连接向所述客户端发送警示消息的步骤之后，包括：

在所述客户端创建前端用户界面，显示所述警示消息。

6.一种服务器的消息监听装置，其特征在于，包括：

与主进程服务单元相连的监听服务单元，用于设置与web服务进程同级的监听服务进程，所述监听服务进程和所述web服务进程并行运行；

与所述监听服务单元相连的消息捕获单元，用于获取预设消息；

与所述消息捕获单元相连的消息发送单元，用于通过与客户端建立的会话连接向所述客户端发送警示消息。

7.根据权利要求6所述的服务器的消息监听装置，其特征在于，所述监听服务单元具体包括：

与应用服务器相连的监听启动单元，用于在应用服务器启动web服务进程的时候同时启动所述监听服务进程；

连接在外部信息系统和所述主进程服务单元之间的信息转发单元，用于接收外部信息系统与所述服务器的通讯信息，并将该通信消息转发给所述web服务进程。

8.根据权利要求7所述的服务器的消息监听装置，其特征在于，所述监听服务单元，还包括：

与所述信息转发单元相连的阻塞处理单元，用于检测所述web服务进程发生阻塞的原因，暂缓转发所述通信消息给所述web服务进程。

9.根据权利要求6至8任一项所述的服务器的消息监听装置，其特征在于，所述客户端包括：

与所述消息发送单元相对应的消息接收单元，用于接收所述警示消息；

与所述消息接收单元相连的前端显示单元，用于在所述客户端创建前端用户界面，显示所述警示消息。

10.一种服务器的消息监听系统，包括至少一个客户端和与所述客户端相连的服务器，以及与该服务器相连的外部信息系统，其特征在于：

所述服务器包括如权利要求5至7任一项所述服务器的消息监听装置，以及与所述消息监听装置相连的主进程服务单元；所述主进程服务单元，用于执行web服务进程，管理web服务资源；

所述外部信息系统，用于发出报警信息；

所述客户端包括如权利要求8所述的消息接收单元和前端显示单元。

Images