我有一个客户端(C++(到服务器(Python(项目。
客户端向服务器发送了一条消息,每条消息包含三个属性。
GUI 应在屏幕上显示所有属性。当客户端发送第一条消息时,一切正常。但是当他发送下一条消息时,我需要关闭窗口,当我这样做时,它会打开一个新窗口并显示以下消息,如果我不这样做,他不会显示收到的新消息。
我怀疑app.exec_()
阻止程序像在这种情况下一样接收新消息,但我不确定。我的问题是:
-
真的是这样吗?如果是这样,我应该把线程放在哪里?
-
我以前从未使用过
QThread
,我看到我们正在为Run()
在Run()
方法中,我们输入了所有的逻辑,我应该在我的特定问题中加入什么逻辑。您可以在此处找到完整的项目
相关代码:
def recive(self):
global income
global table2
msg = Payload(0, 0, 0)
while (True):
print('waiting for a connection..')
conn, addr = self.My_socket.accept()
print("connection has been established | " + repr(addr))
logger.info("connection has been established | " + repr(addr))
while conn:
myThread = MyThread()
buff = conn.recv(sizeof(msg))
print("recv %d bytes" % sizeof(msg))
payload_in = Payload.from_buffer_copy(buff)
print(f"Received id={payload_in.id}, counter={payload_in.counter}, opcode={payload_in.opcode}")
payload_out = payload_in
self.opcode = payload_in.opcode
if self.opcode == 1:
self.export()
elif self.opcode == 2:
payload_out.counter += 1
else:
logger.info("Unexpected opcode %d" % self.opcode)
nsent = conn.send(payload_out)
print("send %d bytes" % nsent)
print("send id=%d, counter=%d, opcode=%d" % (payload_out.id,
payload_out.counter,
payload_out.opcode))
self.setNewTable(payload_in, payload_out)
print("Closing connection to client")
print("----------------------------")
sys.exit()
def setNewTable(self,payload_in, payload_out):
self.insertValues(table1, payload_in)
self.insertValues(table2, payload_out)
ex.show()
app.exec_()
def insertValues(self,table, payload):
table.setItem(0, 1, QTableWidgetItem(str(payload.id)))
table.setItem(1, 1, QTableWidgetItem(str(payload.counter)))
table.setItem(2, 1, QTableWidgetItem(str(payload.opcode)))
一些关于QThread UI的事情,认为你需要使用python信号和插槽来更新UI。 参考以下代码
from PyQt4 import QtCore, QtGui
from PyQt4.QtGui import *
from PyQt4.QtCore import *
import datetime
import sys
import struct
import threading
import os
import datetime
import time
try:
_fromUtf8 = QtCore.QString.fromUtf8
except AttributeError:
def _fromUtf8(s):
return s
try:
_encoding = QtGui.QApplication.UnicodeUTF8
def _translate(context, text, disambig):
return QtGui.QApplication.translate(context, text, disambig, _encoding)
except AttributeError:
def _translate(context, text, disambig):
return QtGui.QApplication.translate(context, text, disambig)
class MySignal(QObject):
signelforWritemsg=Signal(str)
class EchoThread(QThread):
#def __init__(self,Inf_found1,inf_cleaned1,Auto_clean,timer,movie,Scan_btn,cancel_btn,status_text):
def __init__(self,parent = None):
QThread.__init__(self,parent)
self.exiting = False
self.signal = MySignal()
def run(self):
while True:
scantimenow= datetime.datetime.now()
scantime=scantimenow.strftime('%Y-%m-%d %H:%M:%S')
print(scantime)
self.signal.signelforWritemsg.emit(scantime)
time.sleep(5)
class Ui_Clientserver(object):
def setupUi(self, Clientserver):
Clientserver.setObjectName(_fromUtf8("Clientserver"))
Clientserver.resize(400, 300)
self.label = QtGui.QLabel(Clientserver)
self.label.setGeometry(QtCore.QRect(150, 70, 200, 200))
self.label.setObjectName(_fromUtf8("label"))
self.retranslateUi(Clientserver)
self.thread = EchoThread()
self.thread.start()
self.thread.signal.signelforWritemsg.connect(self.signelforWritemsg)
def signelforWritemsg(self,data):
self.label.setText(_translate("Clientserver",str(data), None))
def retranslateUi(self, Clientserver):
Clientserver.setWindowTitle(_translate("Clientserver", "Clientserver", None))
self.label.setText(_translate("Clientserver", "inProgess", None))
if __name__ == "__main__":
import sys
QtCore.QCoreApplication.setAttribute(QtCore.Qt.AA_X11InitThreads)
app = QtGui.QApplication(sys.argv)
Clientserver = QtGui.QWidget()
ui = Ui_Clientserver()
ui.setupUi(Clientserver)
Clientserver.show()
sys.exit(app.exec_())