系统数据库通过与EQIM地震事件数据库同步的方式获取地震数据。由于两个EQIM系统和移动互联网服务系统在部署环境、数据库技术、数据结构等方面都有所不同,因此,如何跨系统平台、跨数据库产品以及数据结构下解决实施同步问题显得尤为关键。

由于EQIM与移动互联网服务系统存在操作系统、数据库技术等诸多底层差异性,因此放弃前期计划使用的触发器技术来实现实时同步,而是改用第三方同步算法实现。

首先在EQIM数据库地震事件数据表中添加INT型FLAG字段,设置初始值为0,并且定义FLAG如表1所示。

表1 数据同步状态标识表
Tab.1 Data synchronization status marker

1.连接移动互联网服务系统数据库;

2.EQIM新地震事件数据封装;

3.同步至移动互联网服务系统MySQl数据库;

4.MySQl数据检查;

5.更新EQIM数据库Flag至为1;

6.数据更新成功。

如果上述步骤中出现更新失败情况,则FLAG标记为3,并且按照逻辑规划重新进行数据同步。

传统的数据推送模式为系统以客户端发出请求、服务器端响应的方式工作。这种方式并不能满足本系统的实时数据刷新的业务需求。

目前信息推送的实现方式主要分为消息推送、代理推送和频道推送3种推送方式。其中消息推送是根据用户提交的需求信息,通过电子邮件系统或其它消息发送系统将有关信息发送到用户端。代理推送是使用代理服务器定期地或按照用户指定的时间间隔在网上搜寻用户感兴趣的信息,并将搜寻结果发送给用户。频道推送则需要提供一整套推送服务器、客户端部件及开发工具等组成的集成应用环境,通过将某些网络站点定义为浏览器的频道,推送服务器则负责将收集到的信息形成频道内容后推送到用户端(亓东霞,2012)。

信息推送模式的主要优点在于及时性好、应用面广,对用户没有技术上的要求(亓东霞,2012)。信息推送的方式,分为基于Internet的信息和基于智能数据库系统的信息推送方式,后者又包括客户式推送和服务器推送(吴剑霞,2004),本系统采用信息推送模式实现服务器能实时地将更新的信息传送到客户端,而无须客户端发出请求,即服务器端实时推送。本系统通过在移动客户端进行Socket接口的定义,通过其与服务器端进行通讯同步。

通讯同步通过Heartbeat模型实现,Heartbeat模型在服务器端与客户端之间建立,协议采用HTTP长连接。具体工作流程如图2所示。

设置Heartbeat周期T=15 min,在Heartbeat周期内,服务器端如果有活动,其触发器发出推送指令,则通过HTTP长连接反馈到客户端,客户端接到推送指令后开始与服务器段进行数据通讯,完成数据推送的全过程; 如果服务器端在Heartbeat周期内,无触发器动作,则向客户端发送OK包,客户端收到OK包后,对服务器做出反馈。

图2 推送业务流程图
Fig.2 System architecture of push service

整个通讯过程中的数据包通过SSL协议进行封装,有效提高了数据传输安全性。部分代码如下:

package com.ibcio;

import javax.servlet.annotation.WebServlet;

import javax.servlet.http.HttpServletRequest;

import org. apache. catalina. websocket. StreamInbound;

@WebServlet(urlPatterns = { "/message"})

public class WebSocketMessageServlet

extends org. apache. catalina. websocket. WebSocketServlet

{

private static final long serialVersionUID = 1L;

public static int ONLINE_USER_COUNT = 1;

public String getUser(HttpServletRequest request)

{

return(String)request.getSession(). getAttribute("user");

}

@Override

protected StreamInbound createWebSocketInbound(String subProtocol,HttpServletRequest request)

{

return new WebSocketMessageInbound(this. getUser(request)); ……

“感知地震”为本系统重要的功能模块之一,本模块使用C/S结构进行开发,并且通过HTTP协议实现。用户填写完成表单后,客户端自动将表单内容通过XML格式进行包封装,封装后的XML通过HTTP协议簇中的POST请求流程完成数据的传输作业。数据传输过程如图3所示。

图3 交互业务流程图
Fig.3 System architecture of interactive service