·编写TCP单进程循环服务器程序与单进程客户端程序,实现以下主体功能: 。客户端启动连接服务器之后,进入命令行交互模式。 。操作人员在命令行窗口输入一行字符并回车后,客户端进程立刻从命令行(本质即stdin)读取数据,并将该行信息发送给服务器。 。服务器收到该行信息后,会将该信息原封不动的返回给客户端,即所谓消息回声(Message Echo)。。客户端收到服务器返回的消息回声后,将其打印输出至屏幕(本质即stdout )。 。客户端在从命令行收到EXIT指令后退出。 。在启动1个客户端连接上服务器开展交互时,再启动另一个客户端连接服务器,观察体验是什么现象,并尝试分析现象背后的底层逻辑。
时间: 2024-04-09 21:28:48 浏览: 40
以下是一个简单的TCP单进程循环服务器程序和单进程客户端程序的示例代码:
TCP单进程循环服务器程序(server.py):
```python
import socket
def run_server():
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_socket.bind(('localhost', 8888))
server_socket.listen(1)
print('Server started. Listening for connections...')
while True:
client_socket, client_address = server_socket.accept()
print('Client connected:', client_address)
while True:
data = client_socket.recv(1024)
if not data:
break
print('Received from client:', data.decode())
client_socket.sendall(data)
print('Client disconnected:', client_address)
client_socket.close()
if __name__ == '__main__':
run_server()
```
单进程客户端程序(client.py):
```python
import socket
def run_client():
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client_socket.connect(('localhost', 8888))
print('Connected to server. Start typing...')
while True:
message = input()
client_socket.sendall(message.encode())
if message == 'EXIT':
break
data = client_socket.recv(1024)
print('Received from server:', data.decode())
print('Connection closed.')
client_socket.close()
if __name__ == '__main__':
run_client()
```
要运行这个示例,你需要先启动服务器程序,然后再启动一个或多个客户端程序。每个客户端将连接到服务器,并在命令行交互模式下发送和接收消息。
当你启动第二个客户端连接到服务器时,它将被接受并处理,就像第一个客户端一样。服务器使用多线程或多进程可以实现同时处理多个客户端连接的能力。在这个简单的示例中,服务器只能同时处理一个客户端连接。
这是因为服务器程序中的 `server_socket.accept()` 方法是阻塞的,它会等待新的连接,并返回一个新的套接字对象和客户端地址。只有当一个客户端连接被接受后,才会执行下一次循环迭代,因此服务器在任何给定时间只能处理一个客户端连接。
要实现服务器同时处理多个客户端连接,你可以使用多线程、多进程或异步编程技术。这样,服务器可以在接受一个客户端连接后,创建一个新的线程、进程或任务来处理该连接,而不会阻塞主循环,从而能够接受和处理更多的客户端连接。