一种行情流处理系统及方法

摘要

本发明公开了一种行情流处理系统及方法，包括，客户端、应用服务器及字典服务器；所述客户端与所述应用服务器相连接，所述客户端能够将所述客户端的客户控制信息传输至所述应用服务器；所述应用服务器能够接收所述客户控制信息并将所述客户控制信息传输至所述字典服务器；所述字典服务器与所述应用服务器相连接，所述字典服务器能够存储所述客户控制信息。采用本发明的一种行情流处理系统及方法，利用多协议行情接口，对接多种格式、各种协议的行情源数据；将大量计算及存储放置在服务器端，可实时处理各种行情数据，灵活扩展业务服务；能够广泛应用于各种金融机构，提供各种行情服务。

权利要求

1.一种行情流处理系统，其特征在于，包括：客户端、应用服务器、计算服务器及字典服务器；

所述客户端与所述应用服务器相连接，所述客户端能够将所述客户端的客户控制信息传输至所述应用服务器、能够向所述应用服务器发送监听请求、能够向所述应用服务器发送具体股票的行情数据请求；

所述应用服务器能够接收所述客户控制信息并将所述客户控制信息传输至所述字典服务器、能够验证所述客户端的身份信息、根据所述监听请求监听行情数据、能够将所述具体股票的第一行情数据传输至所述客户端、将所述具体股票的第二行情数据传输至所述计算服务器、并将所述具体股票的订阅信息存储至所述字典服务器、能够接收第二分析数据，并将所述第二分析数据传输至所述客户端；

所述计算服务器与所述应用服务器相连接、能够分析所述第二行情数据，生成第二分析数据、并将所述第二分析数据传输至所述应用服务器；

所述字典服务器与所述应用服务器相连接，所述字典服务器能够存储所述客户控制信息、能够存储所述订阅信息。

2.如权利要求1所述的行情流处理系统，其特征在于，所述客户端还能够分析所述第一行情数据，并生成第一分析数据。

3.一种行情流处理方法，其特征在于，所述方法包括以下步骤：客户端将客户控制信息传输至应用服务器；

所述应用服务器接收所述客户控制信息并将所述客户控制信息传输至字典服务器；

所述字典服务器接收并存储所述客户控制信息；

所述客户端向所述应用服务器发送监听请求；

所述应用服务器将所述客户端的身份信息与所述字典服务器中存储的所述客户控制信息相比对；

若一致，则所述应用服务器根据所述监听请求监听行情数据；

所述客户端向所述应用服务器发送具体股票的行情数据请求；

所述应用服务器将所述具体股票的第二行情数据传输至计算服务器；

所述计算服务器分析所述第二行情数据，生成第二分析数据，并将所述第二分析数据传输至所述应用服务器；

所述应用服务器将所述第二分析数据传输至所述客户端。

4.如权利要求3所述的行情流处理方法，其特征在于，在所述应用服务器根据所述监听请求监听行情数据之后，还包括以下步骤：所述客户端向所述应用服务器发送具体股票的行情数据请求；

所述应用服务器将所述具体股票的第一行情数据传输至所述客户端。

5.如权利要求4所述的行情流处理方法，其特征在于，在所述应用服务器将所述具体股票的第一行情数据传输至所述客户端之后，还包括以下步骤：所述客户端分析所述第一行情数据，并生成第一分析数据。

6.如权利要求3所述的行情流处理方法，其特征在于，在所述应用服务器根据所述监听请求监听行情数据之后，还包括以下步骤：所述客户端向所述应用服务器发送具体股票的行情数据请求；

所述应用服务器将所述具体股票的订阅信息存储至所述字典服务器；

所述字典服务器接收并存储所述订阅信息。

说明书

一种行情流处理系统及方法

技术领域

[0001] 本发明涉及通信领域，尤其涉及一种行情流处理系统及方法。

背景技术

[0002] 目前，传统Flash行情交易需要IBM小型机，甲骨文数据库，EMC存储设备化等大量硬件结合应用而成，成本大，且页面数据传输和加载渲染的性能开销大，系统的响应速度也很慢。

[0003] 针对现有技术中所存在的问题，提供一种行情流处理系统及方法具有重要意义。

发明内容

[0004] 为解决上述问题，本发明提供一种行情流处理系统及方法。

[0005] 为实现上述目的，本发明的一种行情流处理系统，包括：客户端、应用服务器、计算服务器及字典服务器；所述客户端与所述应用服务器相连接，所述客户端能够将所述客户端的客户控制信息传输至所述应用服务器、能够向所述应用服务器发送监听请求、能够向所述应用服务器发送具体股票的行情数据请求；所述应用服务器能够接收所述客户控制信息并将所述客户控制信息传输至所述字典服务器、能够验证所述客户端的身份信息、根据所述监听请求监听行情数据、能够将所述具体股票的第一行情数据传输至所述客户端、将所述具体股票的第二行情数据传输至所述计算服务器、并将所述具体股票的订阅信息存储至所述字典服务器、能够接收所述第二分析数据，并将所述第二分析数据传输至所述客户端；所述计算服务器与所述应用服务器相连接、能够分析所述第二行情数据，生成第二分析数据、并将所述第二分析数据传输至所述应用服务器；所述字典服务器与所述应用服务器相连接，所述字典服务器能够存储所述客户控制信息、能够存储所述订阅信息；

[0006] 进一步地，所述客户端还能够分析所述第一行情数据，并生成第一分析数据；

[0007] 本发明还提供了一种行情流处理方法，所述方法包括以下步骤：客户端将客户控制信息传输至应用服务器；所述应用服务器接收所述客户控制信息并将所述客户控制信息传输至字典服务器；所述字典服务器接收并存储所述客户控制信息；

[0008] 所述客户端向所述应用服务器发送监听请求；

[0009] 所述应用服务器将所述客户端的身份信息与所述字典服务器中存储的所述客户控制信息相比对；

[0010] 若一致，则所述应用服务器根据所述监听请求监听行情数据；

[0011] 所述客户端向所述应用服务器发送具体股票的行情数据请求；

[0012] 所述应用服务器将所述具体股票的第二行情数据传输至计算服务器；

[0013] 所述计算服务器分析所述第二行情数据，生成第二分析数据，并将所述第二分析数据传输至所述应用服务器；

[0014] 所述应用服务器将所述第二分析数据传输至所述客户端

[0015] 进一步地，在所述应用服务器根据所述监听请求监听行情数据之后，还包括以下步骤：所述客户端向所述应用服务器发送具体股票的行情数据请求；所述应用服务器将所述具体股票的第一行情数据传输至所述客户端；

[0016] 进一步地，在所述应用服务器将所述具体股票的第一行情数据传输至所述客户端之后，还包括以下步骤：所述客户端分析所述第一行情数据，并生成第一分析数据；

[0017] 进一步地，在所述应用服务器根据所述监听请求监听行情数据之后，还包括以下步骤：所述客户端向所述应用服务器发送具体股票的行情数据请求；所述应用服务器将所述具体股票的订阅信息存储至所述字典服务器；所述字典服务器接收并存储所述订阅信息。

[0018] 本发明的一种行情流处理系统及方法，利用多协议行情接口，对接多种格式、各种协议的行情源数据；通过实时高速业务算法引擎，可以实时处理行情流数据，自由扩展行情算法，灵活扩展行情服务；通过高效推送引擎，将行情流处理结果推送到客户端或其他应用服务中。所述行情流处理系统，将大量计算及存储放置在服务器端，可实时处理各种行情数据，灵活扩展业务服务。能够广泛应用于各种金融机构，提供各种行情服务。

附图说明

[0019] 图1为本发明所述行情流处理系统的结构示意图；

[0020] 图2为本发明所述行情流处理方法的第一流程示意图；

[0021] 图3为本发明所述行情流处理方法的第二流程示意图；

[0022] 图4为本发明所述行情流处理方法的第三流程示意图。

具体实施方式

[0023] 下面，结合附图，对本发明的结构以及工作原理等作进一步的说明。

[0024] 如图1所示，图1为本发明所述行情流处理系统的结构示意图；包括客户端1、应用服务器2及字典服务器3；所述客户端1与所述应用服务器2相连接，所述客户端1能够将所述客户端1的客户控制信息传输至所述应用服务器2；在本发明优选的实施例中，所述客户端与所述应用服务器2的连接具体使用所述客户端1上的浏览器，采用HTML5的双向通信技术，可以建立所述客户端1上的浏览器和所述应用服务器2的长连接，可以实现所述应用服务器2主动迅速推送数据给所述客户端；同时，所述客户端1上的浏览器使用HTML5的画布技术，直接在浏览器实时生成矢量图表，无需安装任何额外的插件，只要支持HTML5的浏览器就直接可以运行；在分布式实时大数据处理框架技术基础之上能够实现实时的大数据处理引擎，客户定制的策略规则、实时关键时刻提醒等能以毫秒级的速度进行推送，及时帮助客户进行交易决策；整体技术平台去IBM小型机，甲骨文数据库，EMC存储设备化，完全采用基于最新互联网技术的开放平台。

[0025] 所述应用服务器2能够接收所述客户控制信息并将所述客户控制信息传输至所述字典服务器3；所述字典服务器3与所述应用服务器2相连接，所述字典服务器3能够存储所述客户控制信息。在本发明优选的实施例中，所述客户控制信息具体为所述客户端1的身份信息，密码，所述客户端1的会话控制信息等。

[0026] 所述客户端1还能够向所述应用服务器2发送监听请求；所述应用服务器2还能够验证所述客户端1的身份信息，并根据所述监听请求监听行情数据。在本发明优选的实施例中，所述监听请求具体为请求所述应用服务器2对股票行情的监听；所述应用服务器2还能够验证所述客户端的身份信息具体为，所述应用服务器2将所述客户端1的身份信息与存储在所述字典服务器3中的客户控制信息相比对，并判断识别两者是否相匹配，若是，则通过验证。在本发明另一种优选的实施例中，所述应用服务器2上设置有操作台系统，所述应用服务器2具体为通过所述操作台与所述客户端1建立双向通信连接；所述操作台系统负责为所述应用服务器2接收所述客户端1向所述应用服务器2发送的请求，并负责调取所述字典服务器3中的客户控制信息与所述客户端1的身份信息相比对。

[0027] 如图1所示，所述行情流处理系统还包括计算服务器4，所述计算服务器4与所述应用服务器2相连接；在本发明优选的实施例中，所述计算服务器4在网络中为客户机，诸如PC机、智能手机、ATM等终端提供计算服务。所述计算服务器4具有高速的CPU运算能力、长时间的可靠运行、强大的I/O外部数据吞吐能力以及更好的扩展性。根据所述计算服务服务器4所提供的服务，承担响应服务请求、承担服务、保障服务的能力。

[0028] 所述客户端1还能够向所述应用服务器2发送具体股票的行情数据请求；所述应用服务器2还能够将所述具体股票的第一行情数据传输至所述客户端1，将所述具体股票的第二行情数据传输至所述计算服务器4；并将所述具体股票的订阅信息存储至所述字典服务器3；在本发明优选的实施例中，所述字典服务器3能够用于存储所述订阅信息；并实施在后台更新所述客户端1的股票订阅列表和通知列表；

[0029] 所述计算服务器4能够分析所述第二行情数据，生成第二分析数据，并将所述第二分析数据传输至所述应用服务器2；所述应用服务器2还能够接收所述第二分析数据，并将所述第二分析数据传输至所述客户端1；所述客户端1还能够分析所述第一行情数据，并生成第一分析数据；在本发明优选的实施例中，所述第二行情数据具体动态的行情数据，例如当前股票的开盘价、最高价、最低价、成交总量/最新成交量、成交总金额/最新成交额、瞬时成交额、交易类型、合约持仓量(期)、累计值、股票提供买卖1‑5档等实时内容；所述第二分析数据具体为所述计算服务器4将所述第二行情数据经过计算和分析而得到的股票行情排行榜、K线图、分时图、行情图等分析数据。

[0030] 在本发明优选的实施例中，所述第一行情数据为静态的行情数据，具体为当前股票的股票名，股票代码、所对应的企业市值、企业背景资料等静态数据信息。而在本发明另一种优选的实施例中，所述第一行情数据不仅仅包括当前股票的股票名，股票代码、所对应的企业市值、企业背景资料等静态的行情数据，其中还包括行情展示信息、技术指标等诸如此类的待优化信息，在这种情况下，所述客户端1对行情展示信息、技术指标等诸如此类的待优化信息进行分析和优化，并生成优化后的行情展示信息数据及优化后的技术指标数据等。

[0031] 如图2所示，图2为本发明所述行情流处理方法的第一流程示意图；所述行情流处理方法具体包括以下步骤：

[0032] S101客户端将客户控制信息传输至应用服务器；

[0033] S102所述应用服务器接收所述客户控制信息并将所述客户控制信息传输至字典服务器；

[0034] S103所述字典服务器接收并存储所述客户控制信息；

[0035] S104所述客户端向所述应用服务器发送监听请求；

[0036] S105所述应用服务器将所述客户端的身份信息与所述字典服务器中存储的所述客户控制信息相比对；

[0037] S106若一致，则所述应用服务器根据所述监听请求监听行情数据；

[0038] S107所述客户端向所述应用服务器发送具体股票的行情数据请求；

[0039] S108所述应用服务器将所述具体股票的第一行情数据传输至所述客户端；

[0040] S109所述客户端分析所述第一行情数据，并生成第一分析数据。

[0041] 如图3所示，图3为本发明所述行情流处理方法的第二流程示意图；所述行情流处理方法具体包括以下步骤：

[0042] S101客户端将客户控制信息传输至应用服务器；

[0043] S102所述应用服务器接收所述客户控制信息并将所述客户控制信息传输至字典服务器；

[0044] S103所述字典服务器接收并存储所述客户控制信息；

[0045] S104所述客户端向所述应用服务器发送监听请求；

[0046] S105所述应用服务器将所述客户端的身份信息与所述字典服务器中存储的所述客户控制信息相比对；

[0047] S106若一致，则所述应用服务器根据所述监听请求监听行情数据；

[0048] S107所述客户端向所述应用服务器发送具体股票的行情数据请求；

[0049] S208所述应用服务器将所述具体股票的第二行情数据传输至计算服务器；

[0050] S209所述计算服务器分析所述第二行情数据，生成第二分析数据，并将所述第二分析数据传输至所述应用服务器；

[0051] S210所述应用服务器将所述第二分析数据传输至所述客户端。

[0052] 如图4所示，图4为本发明所述行情流处理方法的第三流程示意图；所述行情流处理方法具体包括以下步骤：

[0053] S101客户端将客户控制信息传输至应用服务器；

[0054] S102所述应用服务器接收所述客户控制信息并将所述客户控制信息传输至字典服务器；

[0055] S103所述字典服务器接收并存储所述客户控制信息；

[0056] S104所述客户端向所述应用服务器发送监听请求；

[0057] S105所述应用服务器将所述客户端的身份信息与所述字典服务器中存储的所述客户控制信息相比对；

[0058] S106若一致，则所述应用服务器根据所述监听请求监听行情数据；

[0059] S107所述客户端向所述应用服务器发送具体股票的行情数据请求；

[0060] S308所述应用服务器将所述具体股票的订阅信息存储至所述字典服务器；

[0061] S309所述字典服务器接收并存储所述订阅信息。

[0062] 在本发明的实施例一中，所述行情流处理系统包括客户端、应用服务器、字典服务器及计算服务器；所述客户端上设置有采用HTML5的双向通信技术的浏览器与所述应用服务器进行连接；所述应用服务器上设置有操作台系统，作为所述行情流处理系统的后台系统；

[0063] 所述行情流处理方法具体包括以下步骤：

[0064] 客户端通过所述客户端的浏览器与所述应用服务器建立连接，并将客户控制信息传输至应用服务器，所述客户控制信息具体包括所述客户端的身份信息“admin”，密码“123456”及所述客户端的会话控制信息；

[0065] 所述应用服务器接收到所述客户控制信息后，将所述客户控制信息传输至字典服务器；

[0066] 所述字典服务器接收并存储所述客户控制信息，其中存储有所述客户端的身份信息“admin”，密码“123456”及所述客户端的会话控制信息；

[0067] 所述客户端“admin”上的浏览器的画面初始化后，向所述应用服务器的操作台系统发送监听请求；与所述操作台系统建立双向通信连接；所述应用服务器的操作台系统在接收到所述监听请求后，调取存储在所述字典服务器上的客户端的身份信息及密码并验证所述客户端“admin”的信息是否与存储在所述字典服务器上的客户端的身份信息及密码相一致；经过验证，判断为一致；验证通过以后确立连接，并开始监听股票行情数据；

[0068] 所述客户端向所述应用服务器发送具体股票“股票1”、“股票2”、“股票3”及“股票4”的行情数据请求；

[0069] 所述应用服务器将监听到的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的静态的行情数据传输至所述客户端；所述静态的行情数据具体包括所述“股票1”、“股票2”、“股票3”及“股票4”的股票名，股票代码、所对应的企业市值、企业背景资料。

[0070] 所述应用服务器同时将监听到的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的动态的行情数据传输至所述计算服务器；所述动态的行情数据具体为所述“股票1”、“股票2”、“股票3”及“股票4”的开盘价、最高价、最低价、成交总量/最新成交量、成交总金额/最新成交额、瞬时成交额、交易类型、合约持仓量(期)、累计值、股票提供买卖1‑5档的实时内容；

[0071] 所述计算服务器接收到所述动态的行情数据后，利用内部算法对所述动态的行情数据进行分析和计算，得到所述“股票1”、“股票2”、“股票3”及“股票4”的行情排行榜、K线图、分时图、行情图等分析数据；并将所述分析数据传输至所述应用服务器；

[0072] 所述应用服务器再将接收到的来自于所述计算服务器的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的所述分析数据传输至所述客户端；

[0073] 此时，所述客户端的使用者可以在浏览器上浏览到所述静态的行情数据及所述动态的行情数据。

[0074] 在本发明的实施例二中，所述行情流处理系统包括客户端、应用服务器、字典服务器及计算服务器；所述客户端上设置有采用HTML5的双向通信技术的浏览器与所述应用服务器进行连接；所述应用服务器上设置有操作台系统，作为所述行情流处理系统的后台系统；

[0075] 所述行情流处理方法具体包括以下步骤：

[0076] 客户端通过所述客户端的浏览器与所述应用服务器建立连接，并将客户控制信息传输至应用服务器，所述客户控制信息具体包括所述客户端的身份信息“admin”，密码“123456”及所述客户端的会话控制信息；

[0077] 所述应用服务器接收到所述客户控制信息后，将所述客户控制信息传输至字典服务器；

[0078] 所述字典服务器接收并存储所述客户控制信息，其中存储有所述客户端的身份信息“admin”，密码“123456”及所述客户端的会话控制信息；

[0079] 所述客户端“admin”上的浏览器的画面初始化后，向所述应用服务器的操作台系统发送监听请求；与所述操作台系统建立双向通信连接；所述应用服务器的操作台系统在接收到所述监听请求后，调取存储在所述字典服务器上的客户端的身份信息及密码并验证所述客户端“admin”的信息是否与存储在所述字典服务器上的客户端的身份信息及密码相一致；经过验证，判断为一致；验证通过以后确立连接，并开始监听股票行情数据；

[0080] 所述客户端向所述应用服务器发送具体股票“股票1”、“股票2”、“股票3”及“股票4”的行情数据请求；

[0081] 所述应用服务器将监听到的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的静态的行情数据及“待优化信息”传输至所述客户端；所述静态的行情数据具体包括所述“股票1”、“股票2”、“股票3”及“股票4”的股票名，股票代码、所对应的企业市值、企业背景资料；所述“待优化信息”具体包括行情展示信息、技术指标；

[0082] 所述客户端在接收到所述“待优化信息”后，在客户端利用所述客户端的处理器对所述“待优化信息”进行分析和优化；生成优化后的行情展示信息数据及优化后的技术指标数据；

[0083] 所述应用服务器同时将监听到的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的动态的行情数据传输至所述计算服务器；所述动态的行情数据具体为所述“股票1”、“股票2”、“股票3”及“股票4”的开盘价、最高价、最低价、成交总量/最新成交量、成交总金额/最新成交额、瞬时成交额、交易类型、合约持仓量(期)、累计值、股票提供买卖1‑5档的实时内容；

[0084] 所述计算服务器接收到所述动态的行情数据后，利用内部算法对所述动态的行情数据进行分析和计算，得到所述“股票1”、“股票2”、“股票3”及“股票4”的行情排行榜、K线图、分时图、行情图等分析数据；并将所述分析数据传输至所述应用服务器；

[0085] 所述应用服务器再将接收到的来自于所述计算服务器的股票行情数据中的“股票1”、“股票2”、“股票3”及“股票4”的所述分析数据传输至所述客户端；

[0086] 此时，所述客户端的使用者可以在浏览器上浏览到所述静态的行情数据、所述动态的行情数据、所述优化后的行情展示信息数据及所述优化后的技术指标数据。

[0087] 以上，仅为本发明的示意性描述，本领域技术人员应该知道，在不偏离本发明的工作原理的基础上，可以对本发明作出多种改进，这均属于本发明的保护范围。