如何在不同虚拟机上实现多线程socket

Question

我想实现多线程-服务器从不同虚拟机上的多个客户端接收连接。3个虚拟机位于同一子网中。我会问如何通过在vms上配置网络来使其可以相互连接，以及如何在代码中更改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()

Client1：

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')

Client2：

 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')

Answer 1

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

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

您可以将"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连接到自己的虚拟机

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

假设您的服务器地址为192.168.4.4

那么你的客户端代码应该是这样的：

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