Python实现实时聊天系统

在这个信息爆炸的时代，实时聊天系统已经成为我们日常生活中不可或缺的一部分。无论是工作沟通还是社交娱乐，实时聊天系统都扮演着重要角色。今天，我们将用Python语言来构建一个简单的实时聊天系统，带你领略编程的魅力。

Python实现实时聊天系统

项目准备

首先，我们需要明确项目的需求和技术栈。我们的目标是实现一个基本的实时聊天系统，用户可以互相发送消息并实时接收。技术栈方面，我们将使用Python的socket库来处理网络通信，以及tkinter库来构建图形用户界面。

安装依赖

pip install tkinter

项目结构

chat_system/
│
├── server.py
├── client.py
└── utils.py

服务器端实现

服务器端负责监听客户端的连接请求，接收和转发消息。

server.py

import socket
import threading
from utils import receive_message, send_message

def handle_client(client_socket, client_address):
    while True:
        try:
            message = receive_message(client_socket)
            if message:
                print(f"Received message: {message}")
                send_message(client_socket, f"Server received: {message}")
        except:
            print(f"Connection closed with {client_address}")
            client_socket.close()
            break

def main():
    server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    server_socket.bind(('0.0.0.0', 12345))
    server_socket.listen(5)
    print("Server is listening...")

    while True:
        client_socket, client_address = server_socket.accept()
        print(f"Connected with {client_address}")
        client_thread = threading.Thread(target=handle_client, args=(client_socket, client_address))
        client_thread.start()

if __name__ == "__main__":
    main()

客户端实现

客户端负责与服务器建立连接，发送和接收消息。

client.py

import socket
from tkinter import *
from utils import receive_message, send_message

def send():
    message = message_entry.get()
    send_message(client_socket, message)
    message_entry.delete(0, END)

def receive():
    while True:
        try:
            message = receive_message(client_socket)
            message_list.insert(END, message)
        except:
            break

def main():
    global client_socket, message_list, message_entry

    root = Tk()
    root.title("Chat Client")

    message_list = Listbox(root, height=15, width=50)
    message_list.pack()

    message_entry = Entry(root, width=40)
    message_entry.pack()

    send_button = Button(root, text="Send", command=send)
    send_button.pack()

    client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    client_socket.connect(('localhost', 12345))

    receive_thread = threading.Thread(target=receive)
    receive_thread.start()

    root.mainloop()
    client_socket.close()

if __name__ == "__main__":
    main()

工具函数

为了简化代码，我们将一些常用的功能封装成工具函数。

utils.py

def receive_message(sock):
    message = sock.recv(1024).decode('utf-8')
    return message

def send_message(sock, message):
    sock.sendall(message.encode('utf-8'))