pyqt5 qnetworkreply在信号处理程序中停止更新连续响应
我试图连续从该服务器获取帧:
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 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论