发送图片数据1.2

在不同进程或者不同语言间传递摄像头图片数据比如从java实现的代码中获取摄像头画面数据将其传递给python实现的算法代码中进行处理。

这里提供基于http方式和基于redis方式这两种方式进行实现并比较两者传输速度。

基于http方式传递图片数据

思路创建两个线程一个线程利用Opencv通过rtsp地址获得摄像头画面一个线程将摄像头图片数据转为字节流并通过http方式发送。

#codinggb2312

http://127.0.0.1:{}/image_post.format(port)

LifoQueue()

threading.Thread(targetself.sendFrame,

args(),

threading.Thread(targetself.readFrame,

args(),

daemonTrue)t1.start()t2.start()t1.join()t2.join()def

sendFrame(self):

self.threadFlag:time.sleep(0.01)is_get_frame

False

没有从队列中获得图片self.frameLock.acquire()if

self.frameQueue.get()is_get_frame

True

从队列中获得图片self.frameLock.release()if

is_get_frame:#

是ndarray对象,这里是把原始ndarray转成jpg的字节流转成其它格式直接替换jpg即可img_str

cv2.imencode(.jpg,

frame)[1].tobytes()#使用b64encode对bytes-like类型对象进行编码(加密)并返回bytes对象img_data

{img:

发送图片数据并获得http_receive.py的返回信息print(结果,

resp.text)def

self.cap.isOpened():time.sleep(0.01)print(成功获得句柄)while

self.threadFlag:ret,

ret:self.frameLock.acquire()while

尽量确保队列中为最新的图片帧self.frameQueue.get()self.frameQueue.put(frame)self.frameLock.release()

else:print(句柄获得失败)self.threadFlag

__name__

思路通过flask框架接收http请求并将接收到的图片数据的字节流转为np格式并进一步转为opencv格式。

另起一个线程接收opencv格式的图片数据并做显示。

#codinggb2312

threading.Thread(targetself.play,

args(),

daemonTrue)t1.start()#t1.join()def

play(self):starttime

self.threadFlag:time.sleep(0.01)print(进入展示线程)if

time.time()

None:print(展示frame)cv2.imshow(http_pic,

self.frame)if

ord(q):breakcv2.destroyAllWindows()def

setFrame(self,

np.fromstring(img_data,np.uint8)

转换np序列img

cv2.imdecode(img_array,cv2.COLOR_BGR2RGB)

转换Opencv格式mat

600))print(mat.shape)rtspPlay.setFrame(mat)time.sleep(0.01)return

receive

__main__:app.run(host127.0.0.1,

port9322)

思路创建两个线程一个线程利用Opencv通过rtsp地址获得摄像头画面一个线程将摄像头图片数据转为字节流并通过redis方式发送。

这里的redis方式具体指的是redis是一个内存数据库通过键值对存储数据通过订阅/发布机制传递消息所以将图片字节流数据存入redis中并将存入消息发布出去实现发送效果。

#codinggb2312

base64.b64encode(img_str)self.r.set(self.cameraip,

data)self.r.publish(self.topic,

self.cameraip)def

delete(self):self.r.delete(result)self.r.delete(self.cameraip)class

rtspRead:

threading.Thread(targetself.sendFrame,

args(),

threading.Thread(targetself.readFrame,

args(),

daemonTrue)t1.start()t2.start()t1.join()t2.join()def

sendFrame(self):

redisSendPic(self.cameraip)self.sendpic.r.set(result,

start)num

计算100次图片发送到接受的平均时间以及平均帧数total_time

0while

self.threadFlag:time.sleep(0.01)is_get_frame

False

没有从队列中获得图片self.frameLock.acquire()if

self.frameQueue.get()is_get_frame

True

从队列中获得图片self.frameLock.release()result

result

is_get_frame:self.sendpic.r.delete(receive_time)

删除接受时间send_time

self.sendpic.r.get(receive_time)

获得接受图片时间while

等待接受图片#print(等待接受)time.sleep(0.01)receive_time

self.sendpic.r.get(receive_time)result

result

100:print(发送收发100次平均耗时{}s平均速度为{}帧/秒.format(total_time/100,

0total_time

self.cap.isOpened():time.sleep(0.01)print(成功获得句柄)while

self.threadFlag:ret,

ret:self.frameLock.acquire()while

尽量确保队列中为最新的图片帧self.frameQueue.get()self.frameQueue.put(frame)self.frameLock.release()

else:print(句柄获得失败)self.threadFlag

__name__

思路通过redis数据库的消息监听机制当接收到数据入库消息则提取图片字节流数据并将其处理为opencv格式的图片数据从而做到显示。

#codingutf-8

redis.Redis(host127.0.0.1,port6379,db0)

r.pubsub()

np.fromstring(img_data,np.uint8)

转换np序列img

cv2.imdecode(img_array,cv2.COLOR_BGR2RGB)

str(time.time()))

600))print(mat.shape)cv2.imshow(redis_pic,

mat)if

ord(q):break#scipy.misc.imsave(D:/video.png,

img)#

redis_send.py结束进程直接在显示窗口上按下q键即可。

综合来看在可视化摄像头画面的前提下两者均可做到实时显示。

其中采用redis方式速度为14帧/秒左右采用http方式速度为10帧/秒左右。

若要提高速度可取消base64的加密过程若仅考虑传输可取消其中的可视化部分传输速度应该会进一步提高。