2つ以上のクライアントに同時にデータを返すことができるPyQtを使用してQTcpServerを作成しようとしています。これにはスレッド化が必要になると思います。
threadedfortuneserver.pyの例をテストケースとして使用して（PyQt4に含まれていますが、私のシステムでは/ usr / share / doc / python-qt4-doc / examples / networkにあります）、複数のクライアントを接続したいと思います。クライアントのうちの1つが幸運を要求すると、他のクライアントも「クライアントXが幸運を受け取ったばかりです」のようなメッセージで更新されます。
fortuneserver / clientプログラムがどのように機能するかは理解していますが、幸運がクライアントに返送された後、クライアント接続はすぐに終了するようです。私の具体的な質問は次のとおりです。
すべての接続を開いたままにして、クライアントの1つが財産を要求するたびに、他のクライアントを更新できるようにすることは可能ですか？
もしそうなら、接続されたクライアントを追跡してループするための最良の方法は何ですか？
複数のクライアントが対話でき、各クライアントが他のクライアントのアクションについて更新できるアプリを開発したいので、これは私にとって深刻な障害です。
よろしくお願いします。他にご不明な点がございましたら、お気軽にお問い合わせください。
このスレッドを見つけましたが、利用するのに十分な特定の情報がありませんでした。他の議論はPythonソケットパッケージに関するものでしたが、PyQtを使用する場合、すべてがうまく機能するようにサーバーはQTcpServerである必要があることを理解しています。
*** 編集 ***
これが私のソリューションの最初の段階です。基本的なサーバーとクライアントを作成しました。サーバーは、クライアントが行編集ボックスに入力した内容を送り返すだけです。
これは、PythonとQtを使用したRapidGUIプログラミングの第18章の「buildingservices」の例に基づいています。
私が行った主な変更は、スレッドが無期限に実行され続け、ソケットが開いたままになり、クライアントから送信されるデータをリッスンすることです。
複数のクライアントを正常に処理します。確かに醜いですが、良い出発点だと思います。
私が望んでいるのは、1人のクライアントがテキストを入力するたびに各クライアントに通知できるようにすることです（たとえば、通常のチャットプログラムのように）。
また、あなたが誰と取引しているのかを知るために、私はプロのプログラマーではありません。私は物理学者であり、何年にもわたって規律のないスクリプトを書き、自分のベルトの下をいじっています。しかし、私はデータを渡すことができる基本的なサーバー/クライアントプログラムを開発しようと思います。
ヘルプや提案をありがとう！
サーバ：
import sys
from PyQt4.QtCore import *
from PyQt4.QtGui import *
from PyQt4.QtNetwork import *
PORT = 9999
SIZEOF_UINT16 = 2
class Thread(QThread):
#lock = QReadWriteLock()
def __init__(self, socketId, parent):
super(Thread, self).__init__(parent)
self.socketId = socketId
def run(self):
self.socket = QTcpSocket()
if not self.socket.setSocketDescriptor(self.socketId):
self.emit(SIGNAL("error(int)"), socket.error())
return
while self.socket.state() == QAbstractSocket.ConnectedState:
nextBlockSize = 0
stream = QDataStream(self.socket)
stream.setVersion(QDataStream.Qt_4_2)
if (self.socket.waitForReadyRead(-1) and
self.socket.bytesAvailable() >= SIZEOF_UINT16):
nextBlockSize = stream.readUInt16()
else:
self.sendError("Cannot read client request")
return
if self.socket.bytesAvailable() < nextBlockSize:
if (not self.socket.waitForReadyRead(-1) or
self.socket.bytesAvailable() < nextBlockSize):
self.sendError("Cannot read client data")
return
textFromClient = stream.readQString()
textToClient = "You wrote: \"{}\"".format(textFromClient)
self.sendReply(textToClient)
def sendError(self, msg):
reply = QByteArray()
stream = QDataStream(reply, QIODevice.WriteOnly)
stream.setVersion(QDataStream.Qt_4_2)
stream.writeUInt16(0)
stream.writeQString("ERROR")
stream.writeQString(msg)
stream.device().seek(0)
stream.writeUInt16(reply.size() - SIZEOF_UINT16)
self.socket.write(reply)
def sendReply(self, text):
reply = QByteArray()
stream = QDataStream(reply, QIODevice.WriteOnly)
stream.setVersion(QDataStream.Qt_4_2)
stream.writeUInt16(0)
stream.writeQString(text)
stream.device().seek(0)
stream.writeUInt16(reply.size() - SIZEOF_UINT16)
self.socket.write(reply)
class TcpServer(QTcpServer):
def __init__(self, parent=None):
super(TcpServer, self).__init__(parent)
def incomingConnection(self, socketId):
self.thread = Thread(socketId, self)
self.thread.start()
class ServerDlg(QPushButton):
def __init__(self, parent=None):
super(ServerDlg, self).__init__(
"&Close Server", parent)
self.setWindowFlags(Qt.WindowStaysOnTopHint)
self.tcpServer = TcpServer(self)
if not self.tcpServer.listen(QHostAddress("0.0.0.0"), PORT):
QMessageBox.critical(self, "Threaded Server",
"Failed to start server: {}".format(
self.tcpServer.errorString()))
self.close()
return
self.connect(self, SIGNAL("clicked()"), self.close)
font = self.font()
font.setPointSize(24)
self.setFont(font)
self.setWindowTitle("Threaded Server")
app = QApplication(sys.argv)
form = ServerDlg()
form.show()
form.move(0, 0)
app.exec_()
クライアント：
import sys
from PyQt4.QtCore import *
from PyQt4.QtGui import *
from PyQt4.QtNetwork import *
PORT = 9999
SIZEOF_UINT16 = 2
class Form(QDialog):
def __init__(self, parent=None):
super(Form, self).__init__(parent)
# Ititialize socket
self.socket = QTcpSocket()
# Initialize data IO variables
self.nextBlockSize = 0
self.request = None
# Create widgets/layout
self.browser = QTextBrowser()
self.lineedit = QLineEdit("Texty bits")
self.lineedit.selectAll()
self.connectButton = QPushButton("Connect")
self.connectButton.setDefault(False)
self.connectButton.setEnabled(True)
layout = QVBoxLayout()
layout.addWidget(self.browser)
layout.addWidget(self.lineedit)
layout.addWidget(self.connectButton)
self.setLayout(layout)
self.lineedit.setFocus()
# Signals and slots for line edit and connect button
self.lineedit.returnPressed.connect(self.sendToServer)
self.connectButton.released.connect(self.connectToServer)
self.setWindowTitle("Client")
# Signals and slots for networking
self.socket.readyRead.connect(self.readFromServer)
self.socket.disconnected.connect(self.serverHasStopped)
self.connect(self.socket,
SIGNAL("error(QAbstractSocket::SocketError)"),
self.serverHasError)
# Update GUI
def updateUi(self, text):
self.browser.append(text)
# Create connection to server
def connectToServer(self):
self.connectButton.setEnabled(False)
print("Connecting to server")
self.socket.connectToHost("localhost", PORT)
# Send data to server
def sendToServer(self):
self.request = QByteArray()
stream = QDataStream(self.request, QIODevice.WriteOnly)
stream.setVersion(QDataStream.Qt_4_2)
stream.writeUInt16(0)
stream.writeQString(self.lineedit.text())
stream.device().seek(0)
stream.writeUInt16(self.request.size() - SIZEOF_UINT16)
self.socket.write(self.request)
self.nextBlockSize = 0
self.request = None
self.lineedit.setText("")
# Read data from server and update Text Browser
def readFromServer(self):
stream = QDataStream(self.socket)
stream.setVersion(QDataStream.Qt_4_2)
while True:
if self.nextBlockSize == 0:
if self.socket.bytesAvailable() < SIZEOF_UINT16:
break
self.nextBlockSize = stream.readUInt16()
if self.socket.bytesAvailable() < self.nextBlockSize:
break
textFromServer = stream.readQString()
self.updateUi(textFromServer)
self.nextBlockSize = 0
def serverHasStopped(self):
self.socket.close()
def serverHasError(self):
self.updateUi("Error: {}".format(
self.socket.errorString()))
self.socket.close()
app = QApplication(sys.argv)
form = Form()
form.show()
app.exec_()