在一个线程中接收套接字数据，在另一个线程中写入数据-- python

在Python中，可以使用多线程来实现在一个线程中接收套接字数据，在另一个线程中写入数据的功能。

首先，我们需要导入socket和threading模块：

import socket
import threading

接下来，我们可以定义一个函数来接收套接字数据：

def receive_data(sock):
    while True:
        data = sock.recv(1024)  # 接收数据，每次最多接收1024字节
        if not data:
            break
        # 处理接收到的数据
        print("Received:", data.decode())

    sock.close()  # 关闭套接字连接

然后，我们可以定义另一个函数来写入数据：

def write_data(sock):
    while True:
        data = input("Enter data to send: ")
        if data == "exit":
            break
        sock.send(data.encode())  # 发送数据

    sock.close()  # 关闭套接字连接

接下来，我们可以创建一个套接字并连接到服务器：

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建TCP套接字
sock.connect(("服务器IP地址", 端口号))  # 连接服务器

然后，我们可以创建两个线程，一个用于接收数据，另一个用于写入数据：

receive_thread = threading.Thread(target=receive_data, args=(sock,))
write_thread = threading.Thread(target=write_data, args=(sock,))

最后，我们可以启动这两个线程：

receive_thread.start()
write_thread.start()

完整的代码如下所示：

import socket
import threading

def receive_data(sock):
    while True:
        data = sock.recv(1024)  # 接收数据，每次最多接收1024字节
        if not data:
            break
        # 处理接收到的数据
        print("Received:", data.decode())

    sock.close()  # 关闭套接字连接

def write_data(sock):
    while True:
        data = input("Enter data to send: ")
        if data == "exit":
            break
        sock.send(data.encode())  # 发送数据

    sock.close()  # 关闭套接字连接

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)  # 创建TCP套接字
sock.connect(("服务器IP地址", 端口号))  # 连接服务器

receive_thread = threading.Thread(target=receive_data, args=(sock,))
write_thread = threading.Thread(target=write_data, args=(sock,))

receive_thread.start()
write_thread.start()

这样，我们就实现了在一个线程中接收套接字数据，在另一个线程中写入数据的功能。