《電子技術應用》
您所在的位置:首頁 > 可編程邏輯 > 設計應用 > 異步響應式集群實時監(jiān)控系統(tǒng)設計
異步響應式集群實時監(jiān)控系統(tǒng)設計
2016年電子技術應用第2期
呂海東1,陸永林2
1.大連理工大學 城市學院,遼寧 大連116600;2.大連英科時代科技發(fā)展有限公司,遼寧 大連116600
摘要: 針對傳統(tǒng)模式DCS的監(jiān)控系統(tǒng)無法滿足高并發(fā)請求的性能要求以及投資過大等問題,使用低價的樹莓派嵌入式計算機、異步非阻塞服務器平臺Node.js和集群技術設計全新的過程監(jiān)控系統(tǒng),以滿足工業(yè)監(jiān)控高性能需求。
中圖分類號: TH865
文獻標識碼: A
DOI:10.16157/j.issn.0258-7998.2016.02.020
中文引用格式: 呂海東,陸永林. 異步響應式集群實時監(jiān)控系統(tǒng)設計[J].電子技術應用,2016,42(2):74-77.
英文引用格式: Lv Haidong,Lu Yonglin. Design of asynchronous reactive cluster real-time monitoring system[J].Application of Electronic Technique,2016,42(2):74-77.
Design of asynchronous reactive cluster real-time monitoring system
Lv Haidong1,Lu Yonglin2
1.City Institute,Dalian University of Technology,Dalian 116600,China;2.Dalian Linktimes Co.Ltd,Dalian 116600,China
Abstract: To solve the problem that traditional DCS system can′t meet requirements of high concurrent requests performance and investment is too large, using new server platform Node.js with asynchronous, non-blocking,low-cost raspberryPI embedded computer and cluster technology to design a new kind of monitoring system, to meet the high performance requirements of industrial monitoring.
Key words : asynchronous;reactive;Node.js;real-time monitoring

0 引言

    大型的工業(yè)過程監(jiān)控系統(tǒng)一般都采用分布式控制系統(tǒng)(Distributed Control System,DCS[1])模式,上位控制主機和下位機都采用價格高昂的工業(yè)控制計算機。監(jiān)控系統(tǒng)的軟件通常選用專門的組態(tài)軟件,這些軟件價格不菲,導致系統(tǒng)投資過大,增加了企業(yè)的經濟負擔。當系統(tǒng)性能難以滿足實時性需求,需進行系統(tǒng)的升級改造時,原有主機基本被淘汰,造成極大的浪費。

    如何用最少的投資實現(xiàn)超高性能,以滿足工業(yè)過程控制的實時性要求,是當今所有監(jiān)控系統(tǒng)設計的終極目標。

    樹莓派[2]的出現(xiàn)以及性能的不斷提升,在硬件上為實現(xiàn)低成本監(jiān)控系統(tǒng)提供了可能。尤其是最新推出的樹莓派第2代B型,配置了ARM結構的Cortex-A7 64位4核處理器及1 GB內存,單價在200元以內,配置16 GB存儲卡,散熱器和金屬外殼也不超過300元,性能比原有B型提升6倍,其使用Debain Linux操作系統(tǒng),可運行大部分Linux應用程序。

    軟件方面,使用傳統(tǒng)的多進程和多線程軟件技術無法滿足當今應用面臨高并發(fā)請求和實時性能要求,全新的Node.js[3]服務器平臺技術應運而生。

    Node.js采用了全新的單線程、非阻塞和異步驅動模式[4],能在使用很少內存的情況下,高性能處理超大量的客戶并發(fā)請求,完美解決了傳統(tǒng)軟件技術難以逾越的C10K+問題。

    Node.js支持多種集群技術[5],可簡單地實現(xiàn)橫向和縱向伸縮技術,能適應超大規(guī)模應用的需求。

    本文將樹莓派與Node.js結合,并利用Node.js的集群技術,完美實現(xiàn)了一個超低成本、高性能的全新模式的集群式過程監(jiān)控系統(tǒng),并在大連高新園區(qū)廣源熱力有限公司供熱管網監(jiān)控中實施。

1 系統(tǒng)總體架構設計

    為減少系統(tǒng)的投資,此監(jiān)控系統(tǒng)集群中的主機沒有使用傳統(tǒng)的工業(yè)控制計算機,均采用樹莓派第2代B型,使用其Linux操作系統(tǒng),安裝Node.js,構成如圖1所示的過程監(jiān)控系統(tǒng)。為提高系統(tǒng)的可靠性和高性能,系統(tǒng)采用分層的架構。

ck5-t1.gif

    現(xiàn)場數(shù)據采集層依然使用傳統(tǒng)的PLC完成,采用西門子S7-300實現(xiàn)對供熱管網溫度、壓力和流量的監(jiān)測。

    數(shù)據采集傳輸層采用多塊樹莓派構成集群,通過TCP協(xié)議實時讀取PLC的數(shù)據,并使用socket.io模塊將數(shù)據實時推送到客戶端的Web頁面上。

    監(jiān)控數(shù)據的顯示層使用高性能的Nginx[6]發(fā)布HTML頁面和JavaScript代碼到客戶端瀏覽器上。瀏覽器的JavaScript利用socket.io客戶端直接接收數(shù)據采集層推送的監(jiān)測數(shù)據,并集成jQuery框架技術顯示在Web頁面的指定位置。由于使用了socket.io的數(shù)據推技術,克服了傳統(tǒng)Web監(jiān)控系統(tǒng)使用HTTP協(xié)議時AJAX的請求/響應模式低效率和大延遲的缺陷,極大提高了系統(tǒng)的傳輸性能,滿足了監(jiān)控系統(tǒng)對實時性的苛刻要求。

    按照此架構設計的高性能監(jiān)控系統(tǒng),主機部分采用了5塊樹莓派,按每塊300元計算(已包含核心板和輔助的配件),共計1 500元。如果采用較普及的天迪工控機,即使雙核的最低型也要4 200元,如果使用4核CPU版,則要5 600元左右,要組成本系統(tǒng)的集群,則至少3萬元,可見本系統(tǒng)的成本優(yōu)越性。

2 監(jiān)控數(shù)據采集傳輸模塊設計

    數(shù)據采集傳輸模式是系統(tǒng)設計的關鍵,其向下實時讀取PLC監(jiān)測的監(jiān)控數(shù)據,向上使用Node.js的socket.io模塊采用推技術直接將數(shù)據發(fā)送到客戶端。客戶連接成功后,不再需要客戶端發(fā)送數(shù)據請求,傳輸層定時將數(shù)據發(fā)送到客戶端進行顯示。

    為提高系統(tǒng)的性能和可靠性,系統(tǒng)采用2塊樹莓派組成集群,將來可以隨時增加更多的板子,以適應更高性能的要求,這也是此系統(tǒng)的最核心優(yōu)勢。

    樹莓派內部有一個4核64位的CPU A7,系統(tǒng)采用cluster集群模塊,單板可運行4個Node.js實例,集群模塊內置了均衡負載功能實現(xiàn)請求的均衡處理。如此2塊樹莓派可運行8個Node.js實例,使系統(tǒng)處于超高性能數(shù)據處理和傳輸狀態(tài)。

    Cluster模塊只是單主機內部集群,為解決跨主機間的Node.js的socket.io模塊的消息處理集群,系統(tǒng)采用socket.io-proxy代理模塊構成主機集群,實現(xiàn)2塊樹莓派之間的消息處理的均衡負載,未來可根據需求增加更多的Node.js主機,以滿足更高的性能需求。

2.1 現(xiàn)場監(jiān)控數(shù)據采集實現(xiàn)

    西門子S7-300支持TCP協(xié)議通信[7],可實現(xiàn)數(shù)據的直接相互傳輸。系統(tǒng)使用Node.js的TCP Client核心模塊讀取PLC的監(jiān)測數(shù)據,節(jié)省了購買昂貴的西門子數(shù)據采集組件的費用。

    西門子S7-300內置TCP FETCH WRITE通信方式,該模式下通過TCP協(xié)議,Node.js使用內置的net模塊創(chuàng)建TCP客戶端實現(xiàn)與PLC的數(shù)據交換,其示意代碼如下所示:

var net = require("net");

var  MonoteData=function(){};

MonoteData.prototype.monitor =function(){

var io = require('socket.io')(9000);

io.on('connection',function (socket){

var client=new Array();

for(var i=0;i<plcs.length;i++){

  client[i] = net.connect(plc[i].port, plc[i].ip);

  client[i].on('data', function(data) {

    var plcdate=convertToReal(data);

    iosocket.broadcast.emit("plcdata",plcdata);

  });

}  

});

}

    數(shù)據讀取程序使用JavaScript的面向對象特性封裝在對象構造函數(shù)中,以便進行集群處理。在數(shù)據采集程序之前,使用Node.js的文件模塊fs,將保存所有PLC設備IP和端口的配置文件plc.json讀入到數(shù)組plcs對象中,通過Node.js創(chuàng)建TCP客戶端,連接到所有的PLC,使用Socket對象的on事件以異步響應模式接收監(jiān)測數(shù)據。接收到PLC監(jiān)測數(shù)據后,使用專門的轉換函數(shù)轉換為JSON格式的數(shù)據,其中包含監(jiān)控點的編號、監(jiān)測的數(shù)據類型(溫度、流量或壓力)和數(shù)據值,使用socket.io模式實時推送到Web客戶端。

2.2 數(shù)據傳輸集群設計實現(xiàn)

    針對樹莓派4核64位CPU的特性,系統(tǒng)使用Node.js的cluster[8]模塊,在每塊樹莓派內部運行與CPU核數(shù)對應的Node.js實例,實現(xiàn)數(shù)據監(jiān)測和傳輸層的集群,以滿足監(jiān)控系統(tǒng)的高性能需求。其核心的示意代碼如下所示:

var cluster = require('cluster');

var numCPUs = require('os').cpus().length;

if(cluster.isMaster) {

  for(var i = 0; i < numCPUs; i++) {

    cluster.fork();

  }

}

if(cluster.isWorker){

    new MonoteData().monitor();

}

    代碼在每個樹莓派內部創(chuàng)建4個Node.js實例,并且cluster模塊自動具備動態(tài)負載均衡功能,實現(xiàn)采集任務處理的均衡分配。

    由于cluster模塊不具備跨不同樹莓派的集群功能,只能在單個主機內多CPU內核實現(xiàn)縱向的可伸縮性,為實現(xiàn)跨不同主機Node.js的橫向可伸縮性,本系統(tǒng)采用集群模塊node-http-proxy[9]

    服務器端與客戶端通過Socket.io模塊與其底層使用的WebSocket協(xié)議實時通信,此協(xié)議在連接初期依然使用HTTP協(xié)議,待握手成功后,升級為WebSocket協(xié)議,以實現(xiàn)全雙工的實時通信。因此為實現(xiàn)多主機集群,原則上可以使用任何支持HTTP協(xié)議的動態(tài)均衡負載的集群服務器產品,如著名的Nginx,同時Node.js也提供了多種模塊實現(xiàn)相同的功能。為與Node.js模塊更好地融合,系統(tǒng)選擇了node- http-proxy實現(xiàn)橫向集群,其簡化示意代碼如下所示:

var httpProxy = require('http-proxy');

var addresses = [

{ host: '172.30.39.230',port:9000},

{ host: '172.30.39.231',port:9000}

];

httpProxy.createServer(function(req, res, proxy) {

var target = addresses.shift();

proxy.proxyRequest(req, res, target);

addresses.push(target);

}).listen(9000);

    如果要增加新的Node.js主機,在addresses變量定義中增加新主機的配置項即可,極其簡便。

3 數(shù)據發(fā)布Web服務器實現(xiàn)

    本系統(tǒng)的Web客戶端全部采用純的HTML和JavaScript實現(xiàn),通過socket.io的客戶端與Node.js進行數(shù)據傳輸。雖然使用Node.js的express模塊也能實現(xiàn)靜態(tài)Web站點的發(fā)布,但Nginx是此類應用的最佳選擇,在所有靜態(tài)Web內容的請求處理上,Nginx性能是最佳的。為提高系統(tǒng)的請求處理性能,本系統(tǒng)采用1塊單獨的樹莓派運行Nginx服務器,使用其默認的配置,將監(jiān)控系統(tǒng)的Web客戶端文件保存在Nginx的html目錄下即可,該Nginx監(jiān)聽80端口上的HTTP請求。

4 數(shù)據顯示客戶端設計與實現(xiàn)

    監(jiān)控系統(tǒng)的客戶端采用Web方式,可以使用PC、手機、平板等訪問監(jiān)控頁面??蛻舳耸褂肏TML、JavaScript、jQuery和socket.io客戶端實現(xiàn)。頁面上的顯示數(shù)據使用絕對位置的div實現(xiàn),每個div通過id屬性與特定的監(jiān)控點對應。socket.io客戶端監(jiān)聽Node.js服務器廣播的數(shù)據事件,從中解析出監(jiān)控點編號和監(jiān)測數(shù)據,使用jquery顯示在指定的div中。

    頁面HTML的主div定義指定的監(jiān)控區(qū)域,將監(jiān)控設備圖作為其背景圖片,定義每個監(jiān)控數(shù)據div,并通過CSS進行絕對位置定義,并懸浮在監(jiān)控點上,其簡化示意代碼如下:

<link rel=”stylesheet” type=”text/css” href=”main,css”>

<script type="text/javascript" src="../socketio/socket. io.js"></script>

<script type="text/javascript" src="main.js"></script>

<div id="area01">

  <div id="t01"></div>

  <div id="p01"></div>

  <div id="l01"></div>

</div>

    其中area01為第1個監(jiān)控區(qū)域,每個監(jiān)控區(qū)域使用不同的頁面,用戶可以選擇查看不同監(jiān)控區(qū)域的數(shù)據。t01表示第1個溫度檢測數(shù)據,p01為壓力數(shù)據,l01為流量檢測數(shù)據。

    頁面元素的定位采用CSS進行控制,其示意代碼如下(為簡化只演示一個顯示元素,其余相似):

div#area01{

    background-image:url(../images/area01.jpg);

    width:960px;

    heighty:650px;  }

div#t01 {

  position:fixed;

  top:212px;

  left:467px;

  width:12px;

  height:11px;

}

    客戶端接收服務器發(fā)送的監(jiān)控數(shù)據和顯示,通過JavaScript結合jQuery和socket.io客戶端實現(xiàn)。通過接收異步響應式事件,取得采集服務器發(fā)送的數(shù)據,顯示在指定的div元素上,其簡化示意代碼如下:

$(document).ready(function(){

  var socket = io.connect("http://172.30.39.100:8082");

  socket.on("plcdata",function(data){

    var dataid=data.plc.id;

    var value=data.plc.data;

    $("div"+dataid).html(value);

  });

});

    這里socket.io客戶端連接的是node-http-proxy代理Node.js主機,該代理按照負載均衡算法轉發(fā)到數(shù)據采集主機,實現(xiàn)高并發(fā)請求的處理。系統(tǒng)顯示的監(jiān)控頁面截圖如圖2所示。

ck5-t2.gif

5 結論

    此系統(tǒng)的設計與實施是低成本監(jiān)控系統(tǒng)的創(chuàng)新實踐,極大減輕了企業(yè)的經濟負擔,提高了企業(yè)投入技術改造的積極性。使用全新的異步響應式編程模式和高性能的Node.js結合,極大簡化了監(jiān)控系統(tǒng)的編程和維護,加快了系統(tǒng)的建設和實施效率,通過集群技術,提供了監(jiān)控系統(tǒng)的性能,更好地滿足了監(jiān)控系統(tǒng)對處理速度和實時性的需求。

參考文獻

[1] 張士超,儀垂杰,郭健翔,等.集散控制系統(tǒng)的發(fā)展及應用現(xiàn)狀[J].微計算機信息,2007(1):94-96.

[2] Samarth Shah.Learning raspberry PI[M].Birmingham:Packt Publishing,2015.

[3] 陸凌牛.Node.js權威指南[M].北京:機械工業(yè)出版社,2014.

[4] Diogo Resende.Node.js high performance[M].Birmingham:Packt Publishing,2015.

[5] Pedro Teixeira.Professional Node.js[M].Indianapolis:John Wiley&Sons,Inc,2013.

[6] Rahul Sharma.Nginx high performance[M].Birmingham:Packt Publishing,2015.

[7] 席英杰,劉文麗.簡述西門子S7-300/400的通訊功能及工業(yè)應用[J].自動化與儀表,2007(1):37-40.

[8] TILKOV S,VINOSKI S.Node.js:using JavaScript to build high-performance network programs[J].Internet Computing,IEEE,2010,14(6):80-83.

[9] 姚立.IBM云計算平臺下NodeJS應用支持環(huán)境的設計與實現(xiàn)[D].哈爾濱:哈爾濱工業(yè)大學,2013.

此內容為AET網站原創(chuàng),未經授權禁止轉載。