如何用Python UDP Socket编程向新客户端发送完整聊天日志？

我已经实现了基于UDP的Python聊天服务器与客户端，基础功能正常运行，现在希望实现新客户端加入时能接收所有历史聊天记录。目前的代码如下，纠结应该选择文本文件存储消息、内存字符串列表存储还是数据库存储？

服务器代码 #

import socket
import threading
import queue
import pickle

messages = queue.Queue()
clients = []

# AF_INET used for IPv4
# SOCK_DGRAM used for UDP protocol

ip = "localhost"
port = 5555
chatlog = []
UDPServerSocket = socket.socket(family=socket.AF_INET, type=socket.SOCK_DGRAM)

# binding IP and port
UDPServerSocket.bind((ip, port))


def receive():
    while True:
        try:
            message, addr = UDPServerSocket.recvfrom(1024)
            messages.put((message, addr))
            chatlog.append((message, addr))
        except:
            pass


def broadcast():
    while True:
        while not messages.empty():
            message, addr = messages.get()
            print(message.decode())
            if addr not in clients:
                clients.append(addr)
            for client in clients:
                try:
                    if message.decode().startswith("SIGNUP_TAG:"):
                        name = message.decode()[message.decode().index(":") + 1:]
                        UDPServerSocket.sendto(f"{name} joined!".encode(), client)
                        if len(chatlog) > 0:
                            sending = pickle.dumps(chatlog)
                            UDPServerSocket.sendto(sending, client)
                        else:
                            pass
                    else:
                        UDPServerSocket.sendto(message, client)
                except:
                    clients.remove(client)


t1 = threading.Thread(target=receive)
t2 = threading.Thread(target=broadcast)

t1.start()
t2.start()

客户端代码 #

import socket
import threading
import random

client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
client.bind(("localhost", random.randint(7000, 8000)))  # random port for every client

name = "Henk"  # test name

def receive():
    while True:
        try:
            message, _ = client.recvfrom(1024)
            # 注意：当前代码无法处理服务器发送的pickle历史记录，需要修改这里
            print(message.decode())
        except:
            pass

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

# this gives the server the name of the people who have entered the server
client.sendto(f"SIGNUP_TAG: {name}".encode(), ("localhost", 5555))

while True:
    message = input("")
    if message == "!q":
        exit()
    else:
        client.sendto(f'[{name}]: {message}'.encode(), ("localhost", 5555))

三种存储方案的对比与选择 #

1. 内存字符串列表（当前使用的chatlog） #

• 适用场景：本地测试、临时运行的聊天服务，不需要持久化记录
• 优点：实现零成本，读写速度极快，无需额外IO操作
• 缺点：服务器重启后所有历史记录丢失，仅能保存当前运行周期内的消息

2. 文本文件存储 #

• 适用场景：小体量、低并发的长期运行服务，需要简单持久化
• 优点：实现简单，无需依赖第三方库，记录可永久保存
• 缺点：并发写入需加锁防止数据混乱，记录量大时读写效率低，查询历史消息只能全文件读取

3. 数据库存储（如SQLite、MySQL） #

• 适用场景：用户量较多、记录量大的正式服务，需要高效查询与可靠持久化
• 优点：支持高效查询、分页，并发处理更稳定，数据持久化可靠
• 缺点：需要编写更多代码，SQLite为Python自带无需额外安装，其他数据库需配置环境

具体建议 #

• 若只是做本地测试或临时使用，继续用内存列表即可，或添加简单的文本文件持久化（服务器启动时加载文件，收到消息时追加写入）
• 若要搭建长期运行的小体量服务，优先选SQLite，Python自带无需额外安装，代码改动小，能满足持久化与基本查询需求
• 若面向大规模用户或需要复杂数据操作，再考虑MySQL等数据库

另外，当前客户端代码无法处理服务器发送的pickle格式历史记录，需修改客户端receive函数，判断消息类型（比如在服务器发送历史记录前加特定标识，或先尝试反序列化pickle，失败则按普通文本处理）。

内容的提问来源于stack exchange，提问作者fil_prog