一种分布式数据处理系统

摘要

本发明涉及一种数据处理系统，其包括多个服务器以及通过网络连接到服务器的客户端，服务器包括数据库服务器和应用服务器，数据库服务器用于存储列车席位库和基础信息库，其中列车席位库用于存储车票的详细信息；基础信息库用于存储与列车、车站相关信息；数据库服务器在伺服器的监督和控制下，压缩席位提取器每隔15分钟以窗口滑动策略统计列车席位库的席位概要信息以完成数据预处理过程；应用服务器用于数据处理与展示生成数据表；通过人机交互界面对视图构造器发起请求，由视图构造器从数据表中获取信息进行各种密度表的展现格式。本发明的分布式数据处理系统，可提供实时、高速、可靠的数据通信服务以及旅客列车密度表的灵活展现方式。

主权项

一种数据处理系统，其包括多个服务器，以及通过网络连接到服务器的客户端，其特征在于：服务器包括数据库服务器和应用服务器，数据库服务器用于存储列车席位库和基础信息库，其包含列车席位库镜像、基础信息库镜像、伺服器、算法库、压缩席位提取器、售出概貌转换器、定员数据提取器、数据发送器、列车位置信息表、数据接收器、数据合成器部件：其中列车席位库用于存储与车票对应的关系型二维表，以记录车票的详细信息；基础信息库用于存储与列车、车站相关的二维表集合，以记录车站的名称、代码以及列车的停靠站和开车时间信息；数据库服务器进行数据预处理：在伺服器的监督和控制下，压缩席位提取器以一定时间的间隔提取席位概要信息，进行数据预处理过程：首先数据库服务器每隔15分钟以窗口滑动策略统计一次列车席位库的席位概要信息，窗口滑动策略具体为：以列车开车日期为基准，统计各次列车开车日期前2天和后2天的数据，此时窗口宽度的数值为4，且该数值可以定制并保存，并且每经过一天以步长1向下一天进行窗口滑动；售出概貌转换器和定员数据提取器分别以席位概要信息为基础，计算出列车的售出情况和动态的列车定员情况，数据在伺服器的引导下送入数据发送队列；数据发送器根据列车位置信息表检索的结果，将数据发送给与该列车相关的异地服务器；数据接收器不断接受异地服务器传过来的本地相关的列车售出情况和列车定员情况，本地和异地的数据在数据合成器进行合成、完整性校验和入库，形成数据表供应用服务器访问；应用服务器用于数据处理与展示：通过人机交互界面对视图构造器发起请求，从数据表中获取完整的列车信息进行各种密度表的展现格式；视图构造器完成基于售出人数和列车定员数据计算列车在不同停靠站的上车人数和下车人数，按照车内人数=上车‑下车+上一站车内人数，得到当前车站的车内人数，按照列 车在不同停靠站的上车和下车人数，所述车内人数，上座率进行显示，上座率＝车内人数／列车定员。