分布式服务器客户端demo_示例Demo

import socket
import threading
服务器IP地址和端口
SERVER_IP = "127.0.0.1"
SERVER_PORT = 12345
接收服务器消息的函数
def receive_message(client_socket):
    while True:
        try:
            # 接收服务器发送的消息
            msg = client_socket.recv(1024).decode("utf8")
            print("收到服务器消息：", msg)
        except Exception as e:
            print("接收消息出错：", e)
            break
向服务器发送消息的函数
def send_message(client_socket):
    while True:
        msg = input("请输入要发送的消息：")
        if msg == "exit":
            client_socket.close()
            break
        try:
            # 向服务器发送消息
            client_socket.send(msg.encode("utf8"))
        except Exception as e:
            print("发送消息出错：", e)
            break
if __name__ == "__main__":
    # 创建客户端套接字
    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    # 连接服务器
    client_socket.connect((SERVER_IP, SERVER_PORT))
    print("已连接到服务器")
    # 创建接收和发送消息的线程
    receive_thread = threading.Thread(target=receive_message, args=(client_socket,))
    send_thread = threading.Thread(target=send_message, args=(client_socket,))
    # 启动线程
    receive_thread.start()
    send_thread.start()
    # 等待线程结束
    receive_thread.join()
    send_thread.join()
    print("客户端已退出")

这个示例Demo展示了一个简单的分布式服务器客户端，可以连接到指定的服务器IP地址和端口，并通过两个线程分别实现接收服务器消息和向服务器发送消息的功能，用户可以通过输入消息并发送给服务器，同时可以接收服务器发送的消息并显示在控制台，当用户输入"exit"时，客户端将关闭套接字并退出程序。