简易聊天程序怎么做控制台多线程通信实现-C++-PHP中文网

简易聊天程序怎么做控制台多线程通信实现

P粉602998670

发布： 2025-08-22 10:10:02

原创

168人浏览过

先运行服务器再启动多个客户端，客户端通过多线程实现收发消息互不阻塞，服务器广播消息给所有客户端并管理连接列表，使用utf-8编码确保中文正常传输。

简易聊天程序怎么做控制台多线程通信实现

做一个简易的控制台多线程聊天程序，核心是让发送和接收消息互不阻塞。可以用 Python 的 socket 模块实现通信，用 threading 模块实现多线程。下面是一个简单的客户端-服务器模型示例，适合学习和理解基本原理。

1. 服务器端：同时处理多个客户端

服务器监听端口，为每个连接的客户端创建一个新线程来接收消息，同时能广播消息给所有客户端。

import socket
import threading
<p>clients = []
clients_lock = threading.Lock()</p><p>def broadcast(message, sender_conn):
with clients_lock:
for client in clients:
if client != sender_conn:
try:
client.send(message)
except:
client.close()
clients.remove(client)</p><p>def handle_client(conn, addr):
print(f"[新连接] {addr} 已连接")
with clients_lock:
clients.append(conn)</p><pre class='brush:php;toolbar:false;'>while True:
    try:
        msg = conn.recv(1024)
        if msg:
            print(f"[来自 {addr}] {msg.decode('utf-8')}")
            broadcast(msg, conn)
        else:
            break
    except:
        break

with clients_lock:
    if conn in clients:
        clients.remove(conn)
conn.close()
print(f"[断开] {addr} 已离开")

登录后复制

def start_server(): server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server.bind(('127.0.0.1', 5000)) server.listen(5) print("服务器启动，等待连接...")

while True:
    conn, addr = server.accept()
    thread = threading.Thread(target=handle_client, args=(conn, addr))
    thread.start()

登录后复制

if name == "main": start_server()

2. 客户端：同时收发消息

客户端连接服务器后，开启两个线程：一个负责接收消息，一个负责发送输入内容。

豆包AI编程

豆包推出的AI编程助手

483

查看详情

import socket
import threading
<p>def receive_messages(sock):
while True:
try:
msg = sock.recv(1024).decode('utf-8')
if msg:
print(f"\n[收到] {msg}")
print(">", end="", flush=True)  # 重新打印输入提示
else:
break
except:
print("\n连接已断开")
break</p><p>def send_messages(sock):
while True:
msg = input("> ")
if msg.lower() in ['exit', 'quit']:
sock.close()
break
sock.send(msg.encode('utf-8'))</p><p>def start_client():
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
client.connect(('127.0.0.1', 5000))
print("已连接到服务器")</p><pre class='brush:php;toolbar:false;'># 启动接收线程
thread_recv = threading.Thread(target=receive_messages, args=(client,))
thread_recv.daemon = True
thread_recv.start()

# 主线程负责发送
send_messages(client)

登录后复制

if name == "main": start_client()