用python编程语言实现两台腾讯云服务器之间的通信

# signal_publisher.pyimport socketimport timedef send_message(message, target_ip='10.0.22.8', target_port=5556):    """向客户端发送信息"""    try:        # 创建 TCP socket        sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)        sock.settimeout(10)        # 连接到客户端        sock.connect((target_ip, target_port))        # 发送消息        sock.sendall(message.encode('utf-8'))        print(f"消息已发送至 {target_ip}:{target_port}")        sock.close()        return True    except Exception as e:        print(f"发送失败: {e}")        return False# 示例：发送消息if __name__ == "__main__":    message = "Hello from server!"    send_message(message)

# signal_subscriber.pyimport socketimport threadingdef start_server(host='0.0.0.0', port=5556):    """启动服务端监听，接收信息"""    # 创建 TCP socket    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)    # 允许地址重用    server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)    # 绑定地址和端口    server_socket.bind((host, port))    server_socket.listen(5)    print(f"服务器已启动，监听 {host}:{port}")    while True:        # 等待连接        client_socket, client_address = server_socket.accept()        print(f"收到来自 {client_address} 的连接")        # 处理客户端请求        client_thread = threading.Thread(            target=handle_client,             args=(client_socket, client_address)        )        client_thread.start()def handle_client(client_socket, client_address):    """处理客户端连接"""    try:        # 接收数据        data = client_socket.recv(1024)        if data:            message = data.decode('utf-8')            print(f"收到来自 {client_address} 的消息: {message}")            # 发送确认回复            response = "Message received!"            client_socket.sendall(response.encode('utf-8'))    except Exception as e:        print(f"处理客户端 {client_address} 时出错: {e}")    finally:        client_socket.close()# 启动服务器if __name__ == "__main__":    start_server()