20

Python のスレッド化モジュールを使用して、単純なマルチスレッド tcp サーバーを作成しました。このサーバーは、新しいクライアントが接続されるたびに新しいスレッドを作成します。

#!/usr/bin/env python

import socket, threading

class ClientThread(threading.Thread):

    def __init__(self,ip,port):
        threading.Thread.__init__(self)
        self.ip = ip
        self.port = port
        print "[+] New thread started for "+ip+":"+str(port)


    def run(self):    
        print "Connection from : "+ip+":"+str(port)

        clientsock.send("\nWelcome to the server\n\n")

        data = "dummydata"

        while len(data):
            data = clientsock.recv(2048)
            print "Client sent : "+data
            clientsock.send("You sent me : "+data)

        print "Client disconnected..."

host = "0.0.0.0"
port = 9999

tcpsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)

tcpsock.bind((host,port))
threads = []


while True:
    tcpsock.listen(4)
    print "\nListening for incoming connections..."
    (clientsock, (ip, port)) = tcpsock.accept()
    newthread = ClientThread(ip, port)
    newthread.start()
    threads.append(newthread)

for t in threads:
    t.join()

次に、2 つの新しいターミナルを開き、netcat を使用してサーバーに接続しました。次に、接続した最初の端末を使用して最初のデータを入力してサーバーに送信すると、サーバーからの応答が他の端末に届き、最初の接続が切断されました。理由は推測しましたが、 clientsock変数が 2 番目の接続のソケットを参照するように上書きされているためかどうかは疑問です。私は正しいですか、それを回避する方法はありますか?

限られた数のソケット変数を持つ配列を使用し、各接続に各変数を使用する以外の方法はありますか?

4

3 に答える 3

16

IP アドレスとポートの場合と同様に、クライアント sock をスレッドに渡す必要があります。

class ClientThread(threading.Thread):

    def __init__(self, ip, port, socket):
        threading.Thread.__init__(self)
        self.ip = ip
        self.port = port
        self.socket = socket
        print "[+] New thread started for "+ip+":"+str(port)

    def run(self):
        # use self.socket to send/receive

...
(clientsock, (ip, port)) = tcpsock.accept()
newthread = ClientThread(ip, port, clientsock)
...
于 2013-07-03T16:55:57.443 に答える