如何在 Python 中实现 SocketPairs？

Question

到目前为止，我一直在使用套接字。一个用于发送和接收的套接字。有人告诉我这是愚蠢的，但是我无法从头开始找到在客户端和服务器上使用套接字对的正确方法。我会给出我目前的方式，希望有人能告诉我如何用这个来做socketpairs。顺便说一下使用TCP。

#client
import socket

my_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ip =  "127.0.1.1"
port = 22222
my_socket.connect((ip, port))

#server
import socket
import multiprocessing

s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ip_address = socket.gethostbyname(hostname)
port = 22222
s.bind((ip_address, port))
s.listen(20)

connections=[]
connection_threads=[]
while True:
    clientsocket, address = s.accept()
    #does this create a new socket for every incoming connection by the way?
    new_client = client.Client(address, clientsocket)
    connections.append(new_client)
    new_process = multiprocessing.Process(target=client_butler.connect_client, args=(new_client,))
    new_process.start()
    connection_threads.append(new_process)

我的最终目标是服务器为每个客户端提供一个套接字对。我知道这可能不是一个好的实现，因为它完全忽略了错误处理等，但我会在未来考虑这一点，因为我要做的就是自学这个。所以问题是，我如何将其转化为使用套接字对？

我遇到的问题：

• 如何在我的客户端中通过my_socket.connect 连接套接字对？
• 如果我只是单独连接两个套接字，我如何在服务器中“重新组装”这对插座
• 我这样做是正确的，还是完全错误的方法？

另外：我检查了this，但即使我可以复制代码并且它会起作用，我也不知道为什么它会起作用，这不是我想要的，我不希望这个工作我也想从中学习。

谢谢！

Answer 1

引用自Computer Networking: A Top-Down Approach, 7th Edition:

client.py:

from socket import *


serverName = "127.0.0.1"
serverPort = 12000

clientSocket = socket(AF_INET, SOCK_STREAM)
clientSocket.connect((serverName, serverPort))

sentence = input('Input lowercase sentence: ')
clientSocket.send(sentence.encode())

modifiedSentence = clientSocket.recv(1024)

print('From Server: ', modifiedSentence.decode())

clientSocket.close()

server.py

from socket import *

serverPort = 12000
serverSocket = socket(AF_INET, SOCK_STREAM)

serverSocket.bind(('', serverPort))
serverSocket.listen(1)

print('The server is ready to receive')

while True:
    connectionSocket, addr = serverSocket.accept()
    sentence = connectionSocket.recv(1024).decode()
    capitalizedSentence = sentence.upper()
    connectionSocket.send(capitalizedSentence.encode())
    connectionSocket.close()