python3+PyQt5 创建多线程网络应用-TCP客户端和TCP服务器实例

Python3 + PyQt5 是一种强大的组合，可以用来创建多线程网络应用程序。这篇攻略将介绍如何使用 Python3 和 PyQt5 创建 TCP 客户端和 TCP 服务器实例的示例。以下是详细的步骤：

步骤一：导入必要的模块

在程序开始之前，需要导入必需的模块。这些模块包括 socket、sys、threading、PyQt5.QtCore、PyQt5.QtGui 和 PyQt5.QtWidgets。可以使用以下代码导入它们：

import socket
import sys
import threading
from PyQt5.QtCore import *
from PyQt5.QtGui import *
from PyQt5.QtWidgets import *

步骤二：创建 TCP 客户端

创建 TCP 客户端需要建立一个 socket，并使用 connect() 方法连接到服务器。在连接成功后，可以使用 send() 方法发送消息到服务器，使用 recv() 方法从服务器接收响应。

以下是一个示例代码，创建了一个简单的 TCP 客户端：

class TcpClient(QObject):
    def __init__(self):
        super().__init__()

        # 创建socket
        self.client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.address = ("localhost", 8888)

        # 连接服务器
        self.client_socket.connect(self.address)

        # 启动子线程进行消息接收
        self.thread = threading.Thread(target=self.receive_message)
        self.thread.start()

    # 消息接收方法
    def receive_message(self):
        while True:
            # 从服务器接收消息
            message = self.client_socket.recv(1024).decode('utf-8')

            # 在界面上显示消息
            self.new_message.emit(message)

    # 发送消息到服务器
    def send_message(self, message):
        self.client_socket.sendall(message.encode('utf-8'))

    # 定义消息接收信号
    new_message = pyqtSignal(str)

在上述示例代码中，TcpClient 是一个 QObject 类，被用来作为 TCP 客户端的主类。在 __init__ 方法中，首先创建了一个 socket，并使用 connect() 方法连接到服务器。然后，使用 threading 模块启动了一个子线程，用来接收从服务器响应的消息。在接收到消息后，将其发送到指定的界面上。

步骤三：创建 TCP 服务器

创建 TCP 服务器需要建立一个 socket，然后使用 bind() 方法将其绑定到一个端口上。在绑定之后，可以使用 listen() 方法开始监听客户端连接请求。一旦有客户端连接请求发送过来，就可以使用 accept() 方法接收客户端请求，并返回一个已经连接的客户端 socket。这个新的 socket 就可以用来和客户端进行通信。

以下是一个示例代码，创建了一个简单的 TCP 服务器：

class TcpServer(QObject):
    def __init__(self):
        super().__init__()

        # 创建socket
        self.server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.address = ("localhost", 8888)

        # 绑定服务器地址和端口
        self.server_socket.bind(self.address)

        # 开始监听
        self.server_socket.listen(5)

        # 启动子线程进行消息接收
        self.thread = threading.Thread(target=self.receive_message)
        self.thread.start()

    # 接收消息方法
    def receive_message(self):
        while True:
            # 接受客户端连接
            client_socket, client_address = self.server_socket.accept()

            # 启动线程进行消息发送
            t = threading.Thread(target=self.send_message, args=(client_socket,))
            t.start()

    # 发送消息方法
    def send_message(self, client_socket):
        while True:
            # 接收客户端消息
            message = client_socket.recv(1024).decode('utf-8')

            if not message:
                break

            # 在界面上显示消息
            self.new_message.emit(message)

            # 将消息发送给客户端
            client_socket.sendall(("Server:" + message).encode('utf-8'))

        client_socket.close()

    # 定义消息接收信号
    new_message = pyqtSignal(str)

在上述示例代码中，TcpServer 是一个 QObject 类，被用来作为 TCP 服务器的主类。在 __init__ 方法中，首先创建了一个 socket，并使用 bind() 方法将其绑定到一个端口上。然后，使用 listen() 方法开始监听客户端连接请求。在接收到客户端连接请求之后，使用 accept() 方法接收客户端连接，并开启一个新的线程进行消息的发送和接收。