如何在不同的 VM 上制作多线程套接字



我想实现多线程服务器从不同虚拟机上的多个客户端接收连接。 3 个虚拟机位于同一子网中。我会问如何通过在 vm 上配置网络来使其可以相互连接,以及如何在代码中更改 ip 和端口。这是服务器上的代码:

import socket
from threading import Thread
from SocketServer import ThreadingMixIn
TCP_IP = 'localhost'
TCP_PORT = 12345
BUFFER_SIZE = 1024
class ClientThread(Thread):
def __init__(self,ip,port,sock):
Thread.__init__(self)
self.ip = ip
self.port = port
self.sock = sock
print " New thread started for "+ip+":"+str(port)
def run(self):
filename='mytext.txt'
f = open(filename,'rb')
while True:
l = f.read(BUFFER_SIZE)
while (l):
self.sock.send(l)
l = f.read(BUFFER_SIZE)
if not l:
f.close()
self.sock.close()
break
tcpsock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcpsock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
tcpsock.bind((TCP_IP, TCP_PORT))
threads = []
while True:
tcpsock.listen(5)
print "Waiting for incoming connections..."
(conn, (ip,port)) = tcpsock.accept()
print 'Got connection from ', (ip,port)
newthread = ClientThread(ip,port,conn)
newthread.start()
threads.append(newthread)
for t in threads:
t.join()

客户1:

import socket
TCP_IP = 'localhost'
TCP_PORT = 12345
BUFFER_SIZE = 1024
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((TCP_IP, TCP_PORT))
with open('received_file', 'wb') as f:
print 'file opened'
while True:
data = s.recv(BUFFER_SIZE)
print('data=%s', (data))
if not data:
f.close()
print 'file close()'
break
f.write(data)
s.close()
print('connection closed')

客户端 2:

import socket
TCP_IP = 'localhost'
TCP_PORT = 12345
BUFFER_SIZE = 1024
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((TCP_IP, TCP_PORT))
with open('received_file', 'wb') as f:
print 'file opened'
while True:
data = s.recv(BUFFER_SIZE)
print('data=%s', (data))
if not data:
f.close()
print 'file close()'
break
f.write(data)
s.close()
print('connection closed')

当您绑定到"localhost"IP 地址时,这意味着您的服务器开始侦听地址为 127.0.0.1 的"环回"内部虚拟网络接口,该接口可以从本地计算机访问,但不能从外部访问。

您的服务器不会侦听任何查看世界的物理接口,因此即使正确配置的客户端也无法从远程节点连接到您的服务器。

您可以将"localhost"替换为"0.0.0.0" - 这意味着"绑定到所有可用接口"。 这意味着您可以在不知道自己服务器的 IP 地址的情况下启动服务器。 它将等待在 VM 中配置的所有物理和虚拟接口上的传入连接。

TCP_IP = '0.0.0.0'
tcpsock.bind((TCP_IP, TCP_PORT))

但是客户端需要知道服务器的 IP 地址才能连接到它。

现在,客户端尝试使用 IP 地址 127.0.0.1 连接到自己的 VM

您需要向客户端提供服务器的真实 IP 地址,以便它们连接到它。

假设您的服务器地址为 192.168.4.4

然后,客户端代码应如下所示:

TCP_IP = '192.168.4.4'
s.connect((TCP_IP, TCP_PORT))

最新更新