我已经使用
python的threding模块创建了一个简单的多线程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()
然后我打开两个新的终端,并使用netcat连接到服务器.然后,当我使用我连接的第一个终端输入并发送我的第一个数据到服务器时,服务器的回复来到另一个终端并且第一个连接断开连接.我猜到了这个原因,但是我怀疑是否发生这种情况,因为clientsock变量被覆盖,所以它引用了第二个连接的套接字.我是正确的,那么如何避免呢？
除了使用有限数量的套接字变量的数组和每个连接的每个变量之外,还有其他方法吗？