[發(fā)明專利]一種用電信息采集前置數(shù)據(jù)處理的方法及系統(tǒng)

有效

• 申請?zhí)枺?/td>: 201410494447.9
• 申請日: 2014-09-24
• 公開（公告）號: CN104243481B
• 公開（公告）日: 2019-02-05
• 發(fā)明（設(shè)計）人: 欒文鵬;周逢權(quán);徐大青;張展國
• 申請（專利權(quán)）人: 國家電網(wǎng)公司;中國電力科學研究院;許繼集團有限公司;國網(wǎng)浙江省電力公司
• 主分類號: H04L29/06
• 分類號: H04L29/06;H04L29/08
• 代理公司: 北京安博達知識產(chǎn)權(quán)代理有限公司 11271
• 代理人: 徐國文

1.一種用電信息采集前置數(shù)據(jù)處理的方法，其特征在于，所述方法包括

(1)用epoll_create()函數(shù)創(chuàng)建文件描述，并設(shè)定管理的socket描述符數(shù)目；

(2)創(chuàng)建與epoll關(guān)聯(lián)的接收線程；

(3)創(chuàng)建偵聽socket描述符ListenSock，并設(shè)定為非阻塞模式，調(diào)用Listen()函數(shù)在套接字上偵聽有無新的連接請求；

(4)如有新的連接請求，調(diào)用accept()函數(shù)，將客戶端socket描述符添加到epoll_data聯(lián)合體，并設(shè)定該描述符為非阻塞，在epoll_event結(jié)構(gòu)中設(shè)置要處理的事件類型為讀和寫；

(5)如socket描述符上有數(shù)據(jù)可讀，則將該socket描述符加入可讀隊列，并通知接收線程讀入數(shù)據(jù)，將接收到的數(shù)據(jù)放入到接收數(shù)據(jù)的鏈表中，將反饋的數(shù)據(jù)包放入到發(fā)送數(shù)據(jù)鏈表中，等待發(fā)送線程發(fā)送；

適用于用電信息采集前置數(shù)據(jù)處理方法的系統(tǒng)包括依次連接的應用服務模塊、前置機路由模塊、前置機集群、網(wǎng)絡負載均衡器和用電終端；

所述前置機路由模塊分別與應用服務器模塊和前置機集群連接，以將前置機解析數(shù)據(jù)發(fā)送相應的應用服務模塊中；保存終端網(wǎng)絡信息和前置機服務器網(wǎng)絡信息的關(guān)聯(lián)結(jié)構(gòu)圖，響應前置機的關(guān)聯(lián)修改請求；

所述前置機集群：包括多臺相互獨立、通過高速網(wǎng)絡互聯(lián)的計算機，并以單一系統(tǒng)模式進行管理；

所述網(wǎng)絡負載均衡器設(shè)定前置服務器上可連接的客戶端個數(shù)，將連接請求依次循環(huán)地連接于每個允許連接的服務器上；

連接數(shù)達到設(shè)定的閾值時，根據(jù)各個前置服務器的實時負載情況進行適當?shù)姆峙洌挥晌挥谇爸梅掌鞯男阅鼙O(jiān)測軟件經(jīng)過集群間的“心跳”專用線傳輸前置服務器的實時負載；

所述前置機路由模塊保存前置機攜帶終端IP信息的和本機IP地址的注冊關(guān)聯(lián)表，在下行數(shù)據(jù)傳輸時，前置路由模塊根據(jù)終端信息，在注冊關(guān)聯(lián)表中找到對應的前置服務器，將下行數(shù)據(jù)傳輸?shù)皆撉爸梅掌魃线M行報文組裝和下發(fā)；發(fā)生socket遷移時，前置路由接受上行的更改命令對注冊關(guān)聯(lián)表進行修改；

所述步驟(2)包括創(chuàng)建與epoll關(guān)聯(lián)的接收線程，應用程序可以創(chuàng)建接收線程處理epoll上的讀通知事件，線程的數(shù)量依賴于程序的具體需要和設(shè)備環(huán)境；

所述步驟(3)包括創(chuàng)建偵聽socket描述符ListenSock；將該描述符設(shè)定為非阻塞模式，調(diào)用Listen()函數(shù)在套接字上偵聽有無新的連接請求，在epoll_event結(jié)構(gòu)中將要處理的事件類型設(shè)置為EPOLLIN，工作方式為epoll_ET，使用epoll_ctl()注冊事件，啟動網(wǎng)絡監(jiān)視線程；

所述步驟(4)包括epoll事件表明有新的連接請求，則調(diào)用accept()函數(shù)，將客戶端socket描述符添加到epoll_data聯(lián)合體，設(shè)定該描述符為非阻塞，在epoll_event結(jié)構(gòu)中設(shè)置要處理的事件類型為讀和寫，工作方式為epoll_ET；

所述步驟(5)包括如epoll事件表明socket描述符上有數(shù)據(jù)可讀，則將該socket描述符加入可讀隊列，并通知接收線程讀入數(shù)據(jù)，將接收到的數(shù)據(jù)放入到接收數(shù)據(jù)的鏈表中，經(jīng)邏輯處理，將反饋的數(shù)據(jù)包放入到發(fā)送數(shù)據(jù)鏈表中，等待由發(fā)送線程發(fā)送。

2.如權(quán)利要求1所述的一種用電信息采集前置數(shù)據(jù)處理的方法，其特征在于，如接收數(shù)據(jù)的鏈表長度到達一定閥值，則創(chuàng)建本地文件，對數(shù)據(jù)接收鏈表溢出數(shù)據(jù)進行本地緩存。

3.如權(quán)利要求1所述的一種用電信息采集前置數(shù)據(jù)處理的方法，其特征在于，所述網(wǎng)絡監(jiān)視線程啟動循環(huán)中，epoll_wait()等待epoll事件發(fā)生。