4

我正在设计一个 gui 应用程序作为我有 3 个类的服务器的客户端

一个用于扭曲协议的类，另一个用于工厂，第三个用于自身的 pyqt 线程。我如何从 pyqt 线程发送数据，例如，如果单击按钮，我如何使用当前的扭曲连接发送命令，这是我的代码的副本

from OpenSSL import SSL;import sys
from twisted.internet.protocol import ClientFactory
from twisted.internet import ssl, protocol
from PyQt4 import QtCore, QtGui
from gui import Ui_clientgui

class clientgui(QtGui.QMainWindow):
    def __init__(self, parent=None):
        QtGui.QWidget.__init__(self, parent)
        self.ui = Ui_clientgui()
        self.ui.setupUi(self)

    def closeEvent(self, e):
        try:reactor.callFromThread(reactor.stop)
        except:pass

class Client(protocol.Protocol):
    def connectionMade(self):
        global server_options
        server_options['connection'] = True

    def send(self,data):
        self.transport.write(data)

    def connectionLost(self, reason):
        server_options['connection'] = False

    def dataReceived(self, line):
        print "receive:", line

class ClientFactory(ClientFactory):
    protocol = Client
    def clientConnectionFailed(self, connector, reason):
        print 'connection failed'
        try:reactor.stop()
        except:pass

if __name__ == '__main__':
    app = QtGui.QApplication([])
    import qt4reactor
    qt4reactor.install()
    from twisted.internet import reactor
    factory = ClientFactory()
    reactor.connectSSL('localhost', 8080, factory, ssl.ClientContextFactory())
    application = clientgui(reactor)
    application.show()
    reactor.runReturn()
    sys.exit(app.exec_())
4

1 回答 1

1

如果您使用qt4reactor，则根本不需要处理多个线程；Twisted 将运行在 QT 线程中，它们可以自由地接触彼此的数据结构。

但是，如果您想使用线程执行此操作，则您的示例已经包含解决方案：reactor.callFromThread. （我建议这样做callFromThread(client.send)而不是callFromThread(transport.write)因为它Client是 a Protocol，因此更多地存在于 Twisted 的宇宙中而不是 Qt 的宇宙中。

于 2012-05-23T16:45:42.377 回答