Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头

简介: 如何使用OpenCV进行同步和异步操作来打开海康摄像头,并提供了相关的代码示例。

1.激活海康摄像头

通过SADP可看到下面这个信息
在这里插入图片描述
输入你想设置的密码即可

若忘记密码可看下面这篇博主的博客
https://blog.csdn.net/gao_summer_cola/article/details/72621766

2.关键信息

rtsp://[username]:[password]@[ip]:[port]/[codec]/[channel]/[subtype]/av_stream

说明:
username: 用户名。例如admin。
password: 密码。例如123456。
ip: 为设备IP。例如 192.168.0.224。
port: 端口号默认为554,若为默认可不填写。
codec:有h264、MPEG-4、mpeg4这几种。
channel: 通道号,起始为1。例如通道1,则为ch1。
subtype: 码流类型,主码流为main,子码流为sub。

用户名默认为admin 密码开始为admin,后可以设置为自己想要的,先通过使用SADP工具可以识别摄像头,然后配置IP与电脑(IPV4地址)在同一个网段。
在这里插入图片描述
然后通过IE浏览器打开对应的IP地址,输入账号和密码进入界面
,知道了用户名和密码和IP地址过后,在找到端口号(默认为554)即可
在这里插入图片描述

3.同步操作

#!/usr/bin/env python
#
# 这个代码注意点 设置好正确的用户名、密码、ip、端口,端口目前是554,
# 启动这个代码之后,会持续查看摄像头工作情况,非常好用,这个可以作为一个测试工具使用
#
import cv2
# UserName = "admin"
# PassW = "a12345678"
# IpAddr = "10.16.97.150"
# Port = "554"
url = 'rtsp://admin:a12345678@10.16.97.150:554/h264/ch1/main/av_stream'
ur2 = 'rtsp://admin:a12345678@10.16.97.149:555/h264/ch1/sub/av_stream'
# cap = cv2.VideoCapture("rtsp://" + UserName + ":" + PassW + "@" + IpAddr + ":" + Port + "/Streaming/Channels/1")
# 摄像头是否处于打开状态可以通过isOpened()方法进行判断
cap = cv2.VideoCapture(url)
cap1 = cv2.VideoCapture(ur2)
ret, frame = cap.read()
ret1, frame = cap1.read()
while ret:
    ret, frame = cap.read()
    ret, frame1 = cap1.read()
    cv2.imshow("frame",frame)
    cv2.imshow("frame1",frame1)
    if cv2.waitKey(1) & 0xFF == ord('q'):
        break
cv2.destroyAllWindows()
cap.release()
cap1.release()
print('done')

2.1效果图

在这里插入图片描述

4.异步操作

python可以使用multiprocessing多进程读取多个摄像头,但是multiprocessing自带的队列在交换数据时内存不会释放

4.1代码1

  • 数字0,代表计算机的默认摄像头(例如上面提及的笔记本前置摄像头)
  • video.avi 视频文件的路径,支持其他格式的视频文件
  • rtsp路径(不同品牌的路径一般是不同的,如下面举出的海康与大华)
user, pwd, ip, channel = "admin", "admin123456", "192.168.35.121", 1

video_stream_path = 0  # local camera (e.g. the front camera of laptop)
video_stream_path = 'video.avi'  # the path of video file
video_stream_path = "rtsp://%s:%s@%s/h265/ch%s/main/av_stream" % (user, pwd, ip, channel)  # HIKIVISION old version 2015
video_stream_path = "rtsp://%s:%s@%s//Streaming/Channels/%d" % (user, pwd, ip, channel)  # HIKIVISION new version 2017
video_stream_path = "rtsp://%s:%s@%s/cam/realmonitor?channel=%d&subtype=0" % (user, pwd, ip, channel)  # dahua

cap = cv2.VideoCapture(video_stream_path)
# 代码描述:利用多进程方法,利用两个海康威视摄像头,同时录取视频并保存本地
import cv2
import time
import numpy as np
import multiprocessing as mp

# 抓取图片,确认视频流的读入
def image_put(q, name, pwd, ip, channel):
    cap = cv2.VideoCapture("rtsp://%s:%s@%s:%s//Streaming/Channels/1" \
                           % (name, pwd, ip, channel))
    # 获取视频帧率
    fps = cap.get(cv2.CAP_PROP_FPS)
    print('fps: ', fps)
    if cap.isOpened():
        print('HIKVISION1')
        print('camera ' + ip + " connected.")

    while True:
        q.put(cap.read()[1])
        q.get() if q.qsize() > 1 else time.sleep(0.01)

# 获得视频流帧数图片,保存读入的视频
def image_get(q, window_name):
    fourcc = cv2.VideoWriter_fourcc(*'XVID')
    # 视频保存路径
    path = "F:/pycharm/practice/vedio/" + window_name + ".avi"
    out = cv2.VideoWriter(path, fourcc, 20.0, (1280, 720), True)
    while True:
        frame = q.get()
        print(frame.shape)
        out.write(frame)

def image_collect(queue_list, camera_ip_l):

    """show in single opencv-imshow window"""
    #window_name = "%s_and_so_no" % camera_ip_l[0]
    # cv2.namedWindow(window_name, flags=cv2.WINDOW_FREERATIO)
    # while True:
    #     imgs = [q.get() for q in queue_list]
    #     imgs = np.concatenate(imgs, axis=1)
    #     cv2.imshow(window_name, imgs)
    #     cv2.waitKey(1)
    """show in multiple opencv-imshow windows"""
    [cv2.namedWindow(window_name, flags=cv2.WINDOW_FREERATIO)
     for window_name in camera_ip_l]
    while True:
        for window_name, q in zip(camera_ip_l, queue_list):
            cv2.imshow(window_name, q.get())
            cv2.waitKey(1)
# 解决进程问题
def run_multi_camera():
    # user_name, user_pwd = "admin", "password"
    user_name, user_pwd = "admin", "a12345678"
    # 摄像头的账户密码改成自己摄像头注册的信息
    camera_ip_l = [
        "10.16.55.149",  # ipv4
        "10.16.55.150",
        # 把你的摄像头的地址放到这里,如果是ipv6,那么需要加一个中括号
    ]
    ports=['554','555']

    mp.set_start_method(method='spawn')  # init
    queues = [mp.Queue(maxsize=2) for _ in camera_ip_l]
    processes = [mp.Process(target=image_collect, args=(queues, camera_ip_l))]
    #processes = []
    for queue, camera_ip,port in zip(queues, camera_ip_l,ports):
        processes.append(mp.Process(target=image_put, args=(queue, user_name, user_pwd, camera_ip,port)))
        processes.append(mp.Process(target=image_get, args=(queue, camera_ip)))
    for process in processes:
        process.daemon = True  # setattr(process, 'deamon', True)
        process.start()
    for process in processes:
        process.join()

if __name__ == '__main__':
    run_multi_camera()           # 调用主函数

效果图:
在这里插入图片描述

4.2代码2

把两个摄像头收集到的实时画面传给同一个进程:

# 代码描述:利用多进程方法,利用两个海康威视摄像头,同时录取视频并保存本地
import cv2
import time
import multiprocessing as mp

# 抓取图片,确认视频流的读入
def image_put(q, name, pwd, ip, channel):
    cap = cv2.VideoCapture("rtsp://%s:%s@%s:%s//Streaming/Channels/1" \
                           % (name, pwd, ip, channel))
    # 获取视频帧率
    fps = cap.get(cv2.CAP_PROP_FPS)
    print('fps: ', fps)
    if cap.isOpened():
        print('HIKVISION1')
        print('camera ' + ip + " connected.")

    while True:
        q.put(cap.read()[1])
        q.get() if q.qsize() > 1 else time.sleep(0.01)

def image_collect(queue_list, camera_ip_l):
    import numpy as np

    """show in single opencv-imshow window"""
    window_name = "%s_and_so_no" % camera_ip_l[0]
    cv2.namedWindow(window_name, flags=cv2.WINDOW_FREERATIO)
    while True:
        imgs = [q.get() for q in queue_list]
        imgs = np.concatenate(imgs, axis=1)
        cv2.imshow(window_name, imgs)
        cv2.waitKey(1)
# 解决进程问题
def run_multi_camera():
    # user_name, user_pwd = "admin", "password"
    user_name, user_pwd = "admin", "a12345678"
    # 摄像头的账户密码改成自己摄像头注册的信息
    camera_ip_l = [
        "10.16.55.149",  # ipv4
        "10.16.55.150",
        # 把你的摄像头的地址放到这里,如果是ipv6,那么需要加一个中括号
    ]
    ports=['554','555']

    mp.set_start_method(method='spawn')  # init
    queues = [mp.Queue(maxsize=2) for _ in camera_ip_l]
    processes = [mp.Process(target=image_collect, args=(queues, camera_ip_l))]
    #processes = []
    for queue, camera_ip,port in zip(queues, camera_ip_l,ports):
        processes.append(mp.Process(target=image_put, args=(queue, user_name, user_pwd, camera_ip,port)))

    for process in processes:
        process.daemon = True  # setattr(process, 'deamon', True)
        process.start()
    for process in processes:
        process.join()

if __name__ == '__main__':
    run_multi_camera()           # 调用主函数

效果图:
在这里插入图片描述

目录
相关文章
|
2月前
|
计算机视觉
Opencv学习笔记(十二):图片腐蚀和膨胀操作
这篇文章介绍了图像腐蚀和膨胀的原理、作用以及使用OpenCV实现这些操作的代码示例,并深入解析了开运算和闭运算的概念及其在图像形态学处理中的应用。
139 1
Opencv学习笔记(十二):图片腐蚀和膨胀操作
|
2月前
|
缓存 并行计算 Ubuntu
Jetson 学习笔记(十一):jetson agx xavier 源码编译ffmpeg(3.4.1)和opencv(3.4.0)
本文是关于在Jetson AGX Xavier上编译FFmpeg(3.4.1)和OpenCV(3.4.0)的详细教程,包括编译需求、步骤、测试和可能遇到的问题及其解决方案。还提供了Jetson AGX Xavier编译CUDA版本的OpenCV 4.5.0的相关信息。
76 4
Jetson 学习笔记(十一):jetson agx xavier 源码编译ffmpeg(3.4.1)和opencv(3.4.0)
|
1月前
|
Java 调度
Java 线程同步的四种方式,最全详解,建议收藏!
本文详细解析了Java线程同步的四种方式:synchronized关键字、ReentrantLock、原子变量和ThreadLocal,通过实例代码和对比分析,帮助你深入理解线程同步机制。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 线程同步的四种方式,最全详解,建议收藏!
|
2月前
|
安全 Java 开发者
Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用
本文深入解析了Java多线程中的`wait()`、`notify()`和`notifyAll()`方法,探讨了它们在实现线程间通信和同步中的关键作用。通过示例代码展示了如何正确使用这些方法,并分享了最佳实践,帮助开发者避免常见陷阱,提高多线程程序的稳定性和效率。
40 1
|
2月前
|
缓存 监控 计算机视觉
视频监控笔记(三):opencv结合ffmpeg获取rtsp摄像头相关信息
本文介绍了如何使用OpenCV结合FFmpeg获取RTSP摄像头信息,包括网络架构、视频监控系统组成、以及如何读取和显示网络摄像头视频流。
53 1
|
2月前
|
计算机视觉 Python
python利用pyqt5和opencv打开电脑摄像头并进行拍照
本项目使用Python的PyQt5和OpenCV库实现了一个简单的摄像头应用。用户可以通过界面按钮打开或关闭摄像头,并实时预览视频流。点击“拍照”按钮可以捕捉当前画面并保存为图片文件。该应用适用于简单的图像采集和处理任务。
131 0
python利用pyqt5和opencv打开电脑摄像头并进行拍照
|
2月前
|
编解码 关系型数据库 计算机视觉
Opencv学习笔记(十一):opencv通过mp4保存为H.264视频
本文介绍了如何在OpenCV中通过使用cisco开源的openh264库来解决不支持H.264编码的问题,并提供了完整的代码示例。
121 0
Opencv学习笔记(十一):opencv通过mp4保存为H.264视频
|
2月前
|
数据可视化 计算机视觉 Python
opencv可视化学习笔记(一):绘制多图在一个画布上
这篇文章介绍了如何使用OpenCV和PIL库将多张图片绘制在同一个画布上,并提供了具体的Python代码实现。
30 0
opencv可视化学习笔记(一):绘制多图在一个画布上
|
2月前
|
安全 调度 C#
STA模型、同步上下文和多线程、异步调度
【10月更文挑战第19天】本文介绍了 STA 模型、同步上下文和多线程、异步调度的概念及其优缺点。STA 模型适用于单线程环境,确保资源访问的顺序性;同步上下文和多线程提高了程序的并发性和响应性,但增加了复杂性;异步调度提升了程序的响应性和资源利用率,但也带来了编程复杂性和错误处理的挑战。选择合适的模型需根据具体应用场景和需求进行权衡。
|
2月前
多线程通信和同步的方式有哪些?
【10月更文挑战第6天】
106 0