300字范文 > PYNQ 采集计划(二)Socket服务端与客户端的搭建 pynq到pc的数据流传输

PYNQ 采集计划(二)Socket服务端与客户端的搭建 pynq到pc的数据流传输

时间：2019-02-18 05:34:25

文章目录

利用Socket搭建客户端和服务端简易Socket收发服务端的搭建客户端的搭建真正的视频socket收发服务端PC端客户端进行测试源码github地址

利用Socket搭建客户端和服务端

我是真的不习惯jupyterNotebook编程，所以现在PC上写好两个端的程序再把服务器端弄过去吧。

简易Socket收发

服务端的搭建

先简单尝试一下怎么用Socket搭一个小服务器

老规矩，遇事不决看例程

其最简例程为

# Echo server programimport socketHOST = '' # Symbolic name meaning all available interfacesPORT = 50007 # Arbitrary non-privileged portwith socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:s.bind((HOST, PORT))s.listen(1)conn, addr = s.accept()with conn:print('Connected by', addr)while True:data = conn.recv(1024)if not data: breakconn.sendall(data)

所以搭建一个socket_service需要啥呢？

首先是创建一个对象

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)#############对于with那句

然后要有host和port，这个port不妨就取4000，然后host设为本机的’127.0.0.1’

s.bind(('127.0.0.1', 4000))

然后就是这个listen了参数是啥意思嘞

官方文档

给出的信息是

socket.listen([backlog])允许服务器接受连接。如果指定了backlog，它必须至少为0(如果更低，则设置为0);它指定在拒绝新连接之前系统将允许的未接受连接的数量。如果未指定，则选择一个默认的合理值。

那我们就设置个1好了，反正自己连

s.listen(1)

最后就是accept接受数据了

接受一个连接。socket必须绑定到一个地址并监听连接。返回值是一对(conn, address)，其中conn是用于在连接上发送和接收数据的新套接字对象，address是绑定到连接另一端套接字的地址。新创建的socket不可继承。

按照例程的用法，只需要一次s.accept就可以了。

conn, addr = s.accept()with conn:print('Connected by', addr)while True:data = conn.recv(1024)if not data: breakconn.sendall(data)

里面recv的参数在官方文档的描述为

socket.recv(bufsize[, flags])从socket接收数据。返回值是一个字节对象，表示接收到的数据。一次接收的最大数据量由bufsize指定。有关可选参数标志的含义，请参阅Unix手册中的recv(2)页;它默认为零。注意，为了更好地匹配硬件和网络现实，bufsize的值应该是相对较小的2的幂，例如4096。

客户端的搭建

其例程为

# Echo client programimport socketHOST = 'daring.cwi.nl' # The remote hostPORT = 50007 # The same port as used by the serverwith socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:s.connect((HOST, PORT))s.sendall(b'Hello, world')data = s.recv(1024)print('Received', repr(data))

大概意思就是我们的client端只需要进行socket对象的建立、链接、sendall命令就行了。

简单写一下，分别运行两个程序，我的host设置在了本机127.0.0.1上，可以看到成功运行了。

将其地址改为192.168.2.99并把server放到pynq上，也可以成功

真正的视频socket收发

主要参考这篇资料进行的视频客户端与服务端的修改。¹

服务端

首先进行Server的初始化，如之前的test一样。

class SocketServer:'''进行SocketServer的初始化配置'''def __init__(self,addr="",port = 8880) -> None:self.resolution = (1920,1080) # 分辨率self.img_fps = 30 # 帧率self.Set_Socket(addr,port) # 调用设置Socket的方法def Set_Socket(self,addr,port):self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)self.server.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR,1) ## 允许端口复用self.server.bind((addr,port))self.server.listen(5) # 允许连接数量print("addr:",addr,"port:",port)

接下来的重点就是将图片编码然后发出，用cv2将其编码为jpg格式然后发就行了

while(1):# 读取一帧视频server.img = hdmi_in.readframe()server.img = cv2.resize(server.img, server.resolution)# 按格式生成图片img_encode = cv2.imencode('.jpg',server.img,img_param)img_code = numpy.array(img_encode[1])server.img_data = img_code.tostring()client.send(struct.pack("lhh",len(server.img_data),server.resolution[0],server.resolution[1]) + server.img_data)

需要主要的是原文中的img_code = numpy.array(img_encode)需要修改为现在的img_code = numpy.array(img_encode[1])，看print结果可知img_encode是True和一个array合成的tuple，如果不这么写会报错。我们只需要发送array的内容就可以了。

PC端客户端

PC端前半部分配置与test类似

读取图像解码仍然需要用到cv2。这块按照大佬的程序来就可以了。

info=struct.unpack("lhh",self.client.recv(8))buf_size=info[0]#获取读的图片总长度if buf_size:try:self.buf=b""#代表bytes类型temp_buf=self.bufwhile(buf_size): #读取每一张图片的长度temp_buf=self.client.recv(buf_size)buf_size-=len(temp_buf)self.buf+=temp_buf#获取图片data = numpy.fromstring(self.buf, dtype='uint8') #按uint8转换为图像矩阵self.image = cv2.imdecode(data, 1) #图像解码cv2.imshow(self.name, self.image) #展示图片except:passfinally:if(cv2.waitKey(10)==27): #每10ms刷新一次图片，按‘ESC’（27）退出self.client.close()cv2.destroyAllWindows()break