如何在Dragonbaord 410c上實(shí)現(xiàn)高性能并發(fā)處理TCP服務(wù)器
在IOT設(shè)計中,通常我們需要構(gòu)建一個或者多個監(jiān)測和控制網(wǎng)絡(luò),來實(shí)現(xiàn)對各種傳感器及設(shè)備的數(shù)據(jù)采集和控制,這樣我們就需要在網(wǎng)絡(luò)中實(shí)現(xiàn)集中管理終端,以對區(qū)域的傳感器和設(shè)備進(jìn)行集中管理,在云端和底層控制節(jié)點(diǎn)之間維護(hù)一個智能化的管理終端,dragonboard 410c憑借其強(qiáng)大的處理性能和網(wǎng)絡(luò)連接能力,可以方便的實(shí)現(xiàn)這一管理終端功能,此時我們就需要在dragonbaord 410c上設(shè)計一個多任務(wù)的接入服務(wù),讓傳感器和相關(guān)的控制設(shè)備接入,為此,本期blog將向大家介紹如何使用gevent高性能的并發(fā)處理庫在draognbaord 410c上來實(shí)現(xiàn)一個高性能的TCP服務(wù)器。
本文引用地址:http://2s4d.com/article/201710/365545.htmgevent是基于協(xié)程的Python網(wǎng)絡(luò)庫。特點(diǎn): 基于libev的快速事件循環(huán)(Linux上epoll,F(xiàn)reeBSD上kqueue)。 基于greenlet的輕量級執(zhí)行單元。 API的概念和Python標(biāo)準(zhǔn)庫一致(如事件,隊列)。 可以配合socket,ssl模塊使用。 能夠使用標(biāo)準(zhǔn)庫和第三方模塊創(chuàng)建標(biāo)準(zhǔn)的阻塞套接字(gevent.monkey)。
使用gevent來提高我們的并發(fā)處理性能,首先需要在draongboard 410c上安裝gevent模塊,具體安裝方法如下:
sudo apt-get install libevent-dev
sudo apt-get install python-all-dev
sudo apt-get install python-setuptools
sudo easy_install greenlet
sudo easy_install gevent
完成安裝后,from gevent.server import StreamServer 就可以導(dǎo)入使用gevent來實(shí)現(xiàn)高效的并發(fā)處理,這里我們以構(gòu)建一個簡答的業(yè)務(wù)邏輯處理服務(wù)為例,具體代碼如下:
from gevent.server import StreamServer
import addressbook_pb2
from testBusinessLogic import testBusinessLogic
BUFSIZE=1024
reportLenMin=10
def handle(socket,address):
while(1):
try:
report=socket.recv(BUFSIZE)
print(report)
if len(report)>reportLenMin:
testLogic=testBusinessLogic(report,“192.168.1.156”)
testLogic.startMainLogicProcess(socket)
else:
print(“recv report error”)
socket.send(“your report is error”)
except:
print(“service error”)
socket.send(“service error”)
if __name__==“__main__”:
testServer = StreamServer((‘192.168.41.156’,5000),handle)
testServer.serve_forever()
到這里我們就完成了整個測試服務(wù)器的搭建,該服務(wù)器能夠借助于gevent實(shí)現(xiàn)高并發(fā)的處理,并且支持異常處理,可以在dragonbaord 410c上穩(wěn)定運(yùn)行,這里testBusinessLogic為測試邏輯處理類,大家需要實(shí)現(xiàn)的業(yè)務(wù)邏輯可以放到里面實(shí)現(xiàn),具體不詳細(xì)介紹。
評論