[發明專利]安全生產綜合監管平臺數據傳輸方法

在審

• 申請號: 201410068999.3
• 申請日: 2014-02-27
• 公開（公告）號: CN103793749A
• 公開（公告）日: 2014-05-14
• 發明（設計）人: 王得權;劉學輝;簡祥;王海奎;王偉東
• 申請（專利權）人: 四川物聯恒安安全技術研究有限公司
• 主分類號: G06Q10/00
• 分類號: G06Q10/00;H04L29/08
• 代理公司: 北京天奇智新知識產權代理有限公司 11340
• 代理人: 楊春

技術領域

本發明涉及一種安全生產綜合監管平臺數據傳輸方法，尤其涉及一種能兼容多種傳輸協議的安全生產綜合監管平臺數據傳輸方法。

背景技術

安全生產綜合監管平臺是一種用于安全生產綜合監管過程中底層數據抽取的軟件產品，便于實現對煤礦、非煤礦山、危化企業等系統的數據抽取。

傳統的安全生產綜合監管平臺缺少數據中間件，各個廠家自行開發數據接口程序，數據格式私有，未制定標準的數據采集標準，接口協議封閉，無法實現不同廠家之間數據的通信。所以，傳統的安全生產綜合監管平臺的傳輸方式單一，具體存在以下缺點：不能提供多種可以選擇的傳輸機制，不能兼容多種傳輸協議，不支持跨平臺和分布式部署，通用型、移植性、可擴展性差，效率一般，不夠穩定；對消息的發送和接收沒有反饋機制；部分通過消息中間件的傳輸機制來實現系統之間的消息數據的交互，但是消息中間件不適宜用來實現系統之間的大數據量的傳輸。

發明內容

本發明的目的就在于為了解決上述問題而提供一種能兼容多種傳輸協議的安全生產綜合監管平臺數據傳輸方法。

本發明通過以下技術方案來實現上述目的：

一種安全生產綜合監管平臺數據傳輸方法，用于實現客戶端與中心服務器即服務端之間的數據傳輸，包括以下步驟：

（1）客戶端讀取配置文件，解析安全生產綜合數據，在獲取客戶端位置標志字段值后，將解析后的數據按設置的傳輸條件生成文本信息數據并加密，然后通過Socket通信發往服務端；所述客戶端位置標志字段值根據服務端返回的位置標志字段值進行實時更新；

（2）服務端接收到數據后，把數據內容解析為目標數據格式后判斷是否滿足寫入條件，如果不滿足，則將未寫入的位置標志字段值返回客戶端；如果滿足，則寫入數據后將處理成功的位置標志字段值返回客戶端，同時將處理成功的位置標志字段值進行保存并更新服務端位置標志字段值。

上述方法中，Socket通常也稱作“套接字”，用于描述IP地址和端口，是一個通信鏈的句柄，應用程序通常通過“套接字”向網絡發出請求或者應答網絡請求。Socket通信是網絡中計算機進行通信的一種方法，應用程序通過調用系統提供的Socket庫函數很容易實現網絡里計算機的通信。

具體地，所述步驟（1）包括以下步驟：

①客戶端讀取配置文件；

②獲取客戶端名稱目標地址；

③獲取安全生產綜合數據；

④如果該數據為文本信息數據，則轉到步驟⑤；如果該數據為數據庫數據，則轉到步驟⑦；

⑤獲取配置的標準文件名；

⑥讀取標準協議文件內容作為需要傳輸的數據，然后轉到步驟；

⑦獲取數據庫地址及表名；

⑧獲取或根據服務端返回的位置標志字段值更新客戶端位置標志字段值；

⑨獲取設置的傳輸條件；

1⑩獲取安全生產綜合數據的字段；

查詢該字段中是否有需要傳輸的數據，如果沒有，則轉到步驟⑨，如果有，則轉到步驟；

將需要傳輸的數據按設置的傳輸條件生成文本信息數據并加密，然后通過Socket通信發往服務端，結束；

所述步驟（2）包括以下步驟：

A、收到客戶端發來的加密數據，解析數據并獲取來源客戶端和表名或文件名；

B、讀取配置文件查找對應客戶端和目標數據寫入的相關配置，并獲取對應寫入表的位置標志字段值；

C、收到數據與標志字段值，比較是否滿足寫入條件，如果不滿足，則直接向客戶端返回位置標志字段值，結束；如果滿足，則轉到步驟D；

D、獲取存放的數據庫位置以及寫入的對應字段；

E、判斷是否需要更新表內容，如果需要，則轉到步驟F，如果不需要，則轉到步驟I；

F、獲取更新表的唯一字段名稱；

G、查詢數據庫表中是否存在此數據值，如果存在，則轉到步驟H，如果不存在，則轉到步驟I；

H、更新數據庫中對應的值；

I、判斷數據值中是否包含主鍵，如果包含，則轉到步驟J，如果不包含，則轉到步驟K；

J、組裝sql，將值寫入數據庫，然后轉到步驟L；

K、獲取對應寫入表的主鍵名稱和生成方式，并生成主鍵，然后轉到步驟J；

L、寫入數據并向客戶端返回處理成功的位置標志字段值，同時將處理成功的位置標志字段值進行保存并更新服務端位置標志字段值，結束。