python - 如何使用 django 纠正 zmq 地址使用错误-6ren

python - 如何使用 django 纠正 zmq 地址使用错误

转载作者：行者123 更新时间：2023-12-01 08:38:15

28

4

我正在尝试使用 Django 创建一个简单的视频流网站。我使用 cv2 启动网络摄像头，使用 ZMQ 将数据从客户端传输到服务器。我发现了这个link 我用它编写了代码的网络部分。

代码本身工作正常，但是当我创建一个简单的 HTML 文件以通过浏览器启动实时流时，代码失败并显示此错误消息

zmq.error.ZMQError: Address in use

我猜这个错误的出现是因为Django使用的IP和ZMQ尝试使用的IP是相同的。但我不知道如何纠正这个错误。

这是我到目前为止的代码

服务器.py

def start_server():
    context = zmq.Context()
    footage_socket = context.socket(zmq.SUB)
    print('socket created')

    footage_socket.setsockopt_string(zmq.SUBSCRIBE, np.unicode(''))
    footage_socket.bind('tcp://192.168.1.18:5020')

    print('binding complete')
    print('server ready')

    return footage_socket

def recv_content(socket, face_cascade_path):

    cascade = cv2.CascadeClassifier(face_cascade_path)

    while True:
        try:
            data = socket.recv_string()
            img = base64.b64decode(data)
            npimg = np.fromstring(img, dtype=np.uint8)
            frame = cv2.imdecode(npimg, 1)
            print(frame)

            face = cascade.detectMultiScale(frame, scaleFactor=1.3, minNeighbors=3)

            for (x, y, w, h) in face:
                cv2.rectangle(frame, (x, y), (x+w, y+h), (0, 0, 255), 2)

            if cv2.waitKey(1) & 0xFF == ord('q'):
                break

            cv2.imshow("Stream", frame)

        except KeyboardInterrupt:
            cv2.destroyAllWindows()
            break

views.py

from server import *

def index(request):

    face_cascade_path = '../../../TRAINED MODELS/FACE/haarcascade_frontalface_default.xml'
    footage_socket = start_server()
    recv_content(footage_socket, face_cascade_path)

    return render(request, 'index.html')

def start_client(request):
    context = zmq.Context()
    footage_socket = context.socket(zmq.PUB)
    footage_socket.connect('tcp://192.168.1.18:5020')

    print('connected to server')
    print('starting video on client machine')

    camera = cv2.VideoCapture(0)  # init the camera

    while True:
        try:
            grabbed, frame = camera.read()  # grab the current frame
            frame = cv2.resize(frame, (640, 480))  # resize the frame
            frame = cv2.flip(frame, 1)
            encoded, buffer = cv2.imencode('.jpg', frame)
            jpg_as_text = base64.b64encode(buffer)
            footage_socket.send(jpg_as_text)

        except KeyboardInterrupt:
            camera.release()
            cv2.destroyAllWindows()
            break

index.html

<html>
<head>

</head>
<body>
  <div class='container'>
    <h2>CAMERA SERVER CLIENT TEST</h2>

    <p>
    Click the start_client button to start camera. Each frame of the stream is sent to the server.
    </p>
    <p>
      The camera code is running on the client side.
    </p>

    <a href ='start_client/'><button>start client</button></a>

  </div>
</body>
</html>

请帮助我。

提前谢谢

编辑1 - 我已编辑以添加代码的客户端部分和index.html。 start_client函数位于views.py下。当单击index.html中的start_client按钮时运行该函数

编辑 2 - 我已编辑问题以添加问题的屏幕截图。虽然在添加 try- except block 后刷新页面时我没有遇到“地址正在使用”错误，但网页仍然无法加载。

最佳答案

您应该采用其他端口，而不是通常使用的常见 8000 端口。

另一个想法是，任何套接字选项都必须放在 ZMQ 中的 bind 或 connect 方法之前。

所以你的代码看起来像这样:

def start_server():
    context = zmq.Context()
    footage_socket = context.socket(zmq.SUB)
    footage_socket.setsockopt_string(zmq.SUBSCRIBE, np.unicode(''))

    try:
        footage_socket.bind('tcp://192.168.1.18:5020')  # Another port used.
    except:
        pass

    return footage_socket

<小时/>

[注意]:

不要忘记将客户端的端口 (.connect()) 更改为 5020。

<小时/>

[更新]:

我用一个简单的 try- except 更新了答案，以解决令人耳目一新的问题。或者，您可以使用 footage_socket.close() 方法清除先前的套接字，或者您可以设置一个条件来检查先前的套接字。
How to take a snapshot with client-side camera in my Django web application

关于python - 如何使用 django 纠正 zmq 地址使用错误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/53606151/

28

4

0

文章推荐： clojure，使用函数列表

文章推荐： jquery - 使用 Filter 方法未获取所需元素

linux - 找不到包 zmq， "package require zmq"
当我尝试运行文件时收到此错误？ can't find package zmq while executing "package require zmq" 如何在 Ubuntu 中安装 zmq？谢谢
linux - 执行 require ('zmq' 时 zmq 失败)
我已经使用 Installation on Linux / bsd without root access 中提到的步骤安装了 zmq已成功安装，但在启动应用程序时出现错误。我在没有根访问权限的环境中
python - ZMQ : "Resource temporarily unavailable" when connecting zmq socket
我正在尝试通过 czmqz (4.0.2) 使用 libzmq (4.2.2) 在 Python 程序和我的 C++ 应用程序之间建立 IPC 通信 channel 。我正在使用 ZMQ 发布者/订
python - 如何将数据序列化为 C++ zmq 客户端和 Python zmq 服务器之间的通信
更新我的问题如何在我的 python zmq 服务器中表示到达的消息以显示其内容？根据这种行为，我是否可以假设 btnState 数据无论如何都会发送到 python 服务器？上下文: 我正在发
python - 在 zmq.PAIR 套接字上从 zmq.error.Again 中恢复
我有一个客户端使用一对套接字与单个服务器通信: context = zmq.Context() socket = context.socket(zmq.PAIR) socket.setsockopt(
c++ - ZMQ : Sending custom CPP object over the ZMQ queue
我有一个名为 GenericMessage 的类，显示在下面的第一个代码片段中(在 GenericMessage.hxx 中定义)。我有一个名为 TestFE.cpp 的 .cpp 文件(参见下面的
Golang zmq 绑定(bind)，ZMQ4，返回包错误找不到文件 zmq.h
我试图在 Go 应用程序中包含 ZMQ 套接字，但 zmq4 和 gozmq(Go 的引用 ZMQ 绑定(bind)库)都给我带来了问题。我想了解为什么 zmq4 特别不能在我的系统上导入。我运行的
c++ - ZeroMQ 如何管理 zmq::proxy 和 zmq::poll 中的套接字？
我遇到了一个关于 ZeroMQ 的问题，因为我在 ZMQ 套接字上为 zmq::proxy 和 zmq::poll 使用了指针。这样做会发生错误 88 的异常(非套接字上的套接字操作)。实际上 Ze
python - Python zmq SUB 套接字未接收到 MQL5 Zmq PUB 套接字
我正在尝试在 MQL5 中设置一个 PUB 套接字，在 Python 中设置一个 SUB 套接字来接收消息。我在 MQL5 中有这个: #include Context context("hell
php - React ZMQ，路由器到经销商，不工作。 ZMQ 4.0.5
我想用 React 做一个异步路由器到经销商消息传递，但它不工作。 http://zguide.zeromq.org/php:rtdealer中的代码正在工作，但我无法确定我在做什么不同。我正在使用
Python ZMQ 和多处理导致 zmq.error.ZMQError : Interrupted system call
我有一个 Python 脚本，我在其中绑定(bind)了多个(例如 5 个)ZMQ 接收器套接字，如下所示: receiver_1 = context.socket(zmq.PULL) receive
c++ - libzmq 和 cppzmq 之间以及 zmq.h 和 zmq.hpp 之间的区别？
在Linux-Ubuntu上安装ZeroMQ，一个网站 https://tuananh.org/2015/06/16/how-to-install-zeromq-on-ubuntu/ 说要运行以下命令
zeromq - ZMQ/0MQ如何实现多个发布者和订阅者？
如何创建允许多个发布者和这些发布者的多个订阅者的网络？还是绝对有必要使用消息代理？ import time import zmq from multiprocessing import Proces
zeromq - zmq 中的端口分配是如何在幕后完成的？
我研究 zmq 有一段时间了，并实现了一个简化的 poc - 模仿我的基础架构设计 - 使用它(特别是使用 NetMQ 包装器)，取得了很好的效果。我的情况是这样的: 将来我计划在一台机器上运行多个
zeromq - ZMQ 中的乒乓心跳
我一直在阅读 ZMQ documentation在心跳上并阅读应该使用乒乓方法而不是用于偏执海盗模式的方法 For Paranoid Pirate, we chose the second appro
sockets - ZMQ Socket解决方案用于一对一双向通信并重新建立连接？
我正在寻找一种支持 ZMQ 的解决方案，用于连接到 0 或 1 个对等点的绑定(bind)端点之间的通信，仅此而已。通信是双向的，连接可以随时结束或切断；并且可以与新的对等点或同一对等点重新建立连接。
callback - ZMQ 通知订阅
我正在使用 ZMQ PUB 套接字来发布不同主题的新闻。但是其中一些消息的计算成本很高。有没有办法有一个 on_subscribe 回调，这样我就可以只计算实际需要的东西？最佳答案只是为了记录我找
java - ZMQ 是否压缩消息？
我有兴趣了解 ZMQ 在发送消息之前是否已经压缩了消息，这样我自己就不会这样做，因为压缩消息两次是多余的。如果确实这样做，它是自动的，还是有一个选项参数可以指定？我正在使用java，但这确实不重要
java - ZMQ 中的流量不均匀
我在我的 Java 应用程序中使用 ZMQ。我发现它的行为不均匀，即如果我发送大约 100 条消息，其中一个消费者说需要 1 秒，那么如果我们继续增加消费者，所花费的时间将变为 2,1.5,3，这样。
c - zmq - 当进程终止时拉队列会发生什么？
所以我有 8 个工作线程(PULL 套接字)，它们从单个绑定(bind)的 PUSH 套接字提供数据。它们每秒处理大量数据，有时会随机崩溃。显然，我应该尝试处理这些崩溃，但我很好奇这个系统目前的弹性如

首页

博学

6Ren·AI

商城