您的位置 首页 ADAS

如安在Dragonbaord 410c上完成高性能并发处理TCP服务器

如何在Dragonbaord 410c上实现高性能并发处理TCP服务器-在IOT设计中,通常我们需要构建一个或者多个监测和控制网络,来实现对各种传感器及设备的数据采集和控制,这样我们就需要在网络中实现

在IOT规划中,一般咱们需求构建一个或许多个监测和操控网络,来完结对各种传感器及设备的数据收集和操控,这样咱们就需求在网络中完结会集办理终端,以对区域的传感器和设备进行会集办理,在云端和底层操控节点之间保护一个智能化的办理终端,dragonboard 410c凭仗其强壮的处理功用和网络连接才能,能够便利的完结这一办理终端功用,此刻咱们就需求在dragonbaord 410c上规划一个多任务的接入服务,让传感器和相关的操控设备接入,为此,本期blog将向咱们介绍怎么运用gevent高功用的并发处理库在draognbaord 410c上来完结一个高功用的TCP服务器。

gevent是根据协程的Python网络库。特色: 根据libev的快速事情循环(Linux上epoll,FreeBSD上kqueue)。 根据greenlet的轻量级履行单元。 API的概念和Python规范库共同(如事情,行列)。 能够合作socket,ssl模块运用。 能够运用规范库和第三方模块创立规范的堵塞套接字(gevent.monkey)。

运用gevent来进步咱们的并发处理功用,首要需求在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 就能够导入运用gevent来完结高效的并发处理,这儿咱们以构建一个简答的事务逻辑处理服务为例,具体代码如下:

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()

到这儿咱们就完结了整个测验服务器的建立,该服务器能够借助于gevent完结高并发的处理,而且支撑反常处理,能够在dragonbaord 410c上安稳运转,这儿testBusinessLogic为测验逻辑处理类,咱们需求完结的事务逻辑能够放到里边完结,具体不具体介绍。

声明:本文内容来自网络转载或用户投稿,文章版权归原作者和原出处所有。文中观点,不代表本站立场。若有侵权请联系本站删除(kf@86ic.com)https://www.86ic.net/qiche/adas/183527.html

为您推荐

联系我们

联系我们

在线咨询: QQ交谈

邮箱: kf@86ic.com

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

返回顶部