pyqt5 qnetworkreply在信号处理程序中停止更新连续响应

发布于 2025-01-21 03:54:37 字数 2699 浏览 2 评论 0原文

我试图连续从该服务器获取帧:

def get_feed():
    while True:
        time.sleep(0.06)
        buffer = get_shot()
        buffer = buffer.tobytes()
        yield (b'--frame\r\n'
               b'Content-Type: image/jpeg\r\n'
               b'Content-Length: ' + str(len(buffer)).encode() + '\r\n\r\n' + 
               buffer + b'\r\n')
               
               
@app.route('/', methods=['GET'])
def index():
    return Response(get_feed(), mimetype='multipart/x-mixed-replace; boundary=frame')

为此,我使用以下代码:

class ExampleApp(QtWidgets.QMainWindow, test.Ui_MainWindow):
    def __init__(self, parent=None):
        super(ExampleApp, self).__init__(parent)
        self.setupUi(self)
        
        self._source_url = QUrl("*link_here*")
        self._image_request = QNetworkRequest(self._source_url)
        self._network_manager = QNetworkAccessManager()
        self._image_reply = self._network_manager.get(self._image_request)
        ...

        self.frameTimer = QTimer(self)
        self.timeBetweenFrames = 1
        self.timeBetweenReads = 0.06
        self.frameTimer.timeout.connect(self.updateFrame)
        self.frameTimer.start(self.timeBetweenFrames)
        ...

    def updateFrame(self):
        # Get how many bytes do I need to read for the frame
        content_length = 0
        buff = self._image_reply.readAll()
        frameSizeAddress = buff.lastIndexOf(b'Content-Length:') + len(b'Content-Length: ')
        frameSizeEndAddress = buff[frameSizeAddress:].indexOf(b'\r\n')
        
        if frameSizeAddress == -1 or frameSizeEndAddress == -1:
            self.frameTimer.start(self.timeBetweenFrames)
            return
        
        frameSize = int(str(buff[frameSizeAddress:frameSizeAddress+frameSizeEndAddress], 'utf-8'))
        frameBegin = frameSizeAddress + frameSizeEndAddress + 4
        
        imageBuffer = buff[frameBegin:frameBegin+frameSize]
        readenBytes = len(imageBuffer)
        
        # If the image came partially
        while(readenBytes < frameSize):
            time.sleep(self.timeBetweenReads)
            buff = self._image_reply.read(frameSize-readenBytes)
            imageBuffer += buff[:frameSize-readenBytes]
            readenBytes = len(imageBuffer)
            print(len(buff))

问题来了。如果图像部分出现,则永远不会被读取。最后一次打印总是给出 0。

如果在第一次读取期间使用 read(1024) 而不是 readAll()

content_length = 0
buff = self._image_reply.readAll()

那么一切正常,但如果帧速度更快,那么应用程序会读取它们:它们开始堆叠,并且馈送和显示图像之间的延迟变得越来越大。

对我来说,QNetworkReply 在信号处理程序中时似乎不会更新,因此服务器不会在其中写入新字节。

我该如何解决这个问题?

I'm trying to continuously get frames from this server:

def get_feed():
    while True:
        time.sleep(0.06)
        buffer = get_shot()
        buffer = buffer.tobytes()
        yield (b'--frame\r\n'
               b'Content-Type: image/jpeg\r\n'
               b'Content-Length: ' + str(len(buffer)).encode() + '\r\n\r\n' + 
               buffer + b'\r\n')
               
               
@app.route('/', methods=['GET'])
def index():
    return Response(get_feed(), mimetype='multipart/x-mixed-replace; boundary=frame')

For that I use this code:

class ExampleApp(QtWidgets.QMainWindow, test.Ui_MainWindow):
    def __init__(self, parent=None):
        super(ExampleApp, self).__init__(parent)
        self.setupUi(self)
        
        self._source_url = QUrl("*link_here*")
        self._image_request = QNetworkRequest(self._source_url)
        self._network_manager = QNetworkAccessManager()
        self._image_reply = self._network_manager.get(self._image_request)
        ...

        self.frameTimer = QTimer(self)
        self.timeBetweenFrames = 1
        self.timeBetweenReads = 0.06
        self.frameTimer.timeout.connect(self.updateFrame)
        self.frameTimer.start(self.timeBetweenFrames)
        ...

    def updateFrame(self):
        # Get how many bytes do I need to read for the frame
        content_length = 0
        buff = self._image_reply.readAll()
        frameSizeAddress = buff.lastIndexOf(b'Content-Length:') + len(b'Content-Length: ')
        frameSizeEndAddress = buff[frameSizeAddress:].indexOf(b'\r\n')
        
        if frameSizeAddress == -1 or frameSizeEndAddress == -1:
            self.frameTimer.start(self.timeBetweenFrames)
            return
        
        frameSize = int(str(buff[frameSizeAddress:frameSizeAddress+frameSizeEndAddress], 'utf-8'))
        frameBegin = frameSizeAddress + frameSizeEndAddress + 4
        
        imageBuffer = buff[frameBegin:frameBegin+frameSize]
        readenBytes = len(imageBuffer)
        
        # If the image came partially
        while(readenBytes < frameSize):
            time.sleep(self.timeBetweenReads)
            buff = self._image_reply.read(frameSize-readenBytes)
            imageBuffer += buff[:frameSize-readenBytes]
            readenBytes = len(imageBuffer)
            print(len(buff))

And here comes the problem. If the image came partially it will never be read. Last print always give 0.

If use read(1024) instead of readAll() during first read here

content_length = 0
buff = self._image_reply.readAll()

Then everything works but if frames come faster then the app reads them: they begin stacking and delay between feed and display-image becomes bigger and bigger.

For me it looks like QNetworkReply doesn't update when it is in signal handler, so server do not write in it new bytes.

How can I solve this?

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文