基于P2P的局域网即时通信系统python

要实现基于P2P的局域网即时通信系统，你可以使用Python的socket模块和线程模块。以下是一个简单的示例程序：

import socket
import threading

# 服务器IP和端口号
SERVER_IP = '127.0.0.1'
SERVER_PORT = 8080

# 创建socket对象
server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 绑定IP和端口号
server_socket.bind((SERVER_IP, SERVER_PORT))

# 监听连接
server_socket.listen(5)

# 客户端列表
clients = []

# 处理客户端连接
def handle_client_connection(client_socket):
    while True:
        # 接收客户端消息
        message = client_socket.recv(1024).decode()

        # 广播消息给所有客户端
        for c in clients:
            c.send(message.encode())

        # 如果客户端退出，移除客户端
        if not message:
            clients.remove(client_socket)
            client_socket.close()
            break

while True:
    # 等待客户端连接
    client_socket, address = server_socket.accept()

    # 添加客户端到列表
    clients.append(client_socket)

    # 启动新线程处理客户端连接
    client_thread = threading.Thread(target=handle_client_connection, args=(client_socket,))
    client_thread.start()

此程序创建一个基于TCP协议的服务器，监听指定的IP和端口号。当客户端连接到服务器时，服务器将该客户端添加到客户端列表中，并启动一个新线程处理该客户端连接。每个客户端连接将接收到所有其他客户端发送的消息。当客户端退出时，服务器将该客户端从客户端列表中移除。

要使用此程序，你需要在每个客户端上运行一个客户端程序，该程序将连接到服务器，并发送和接收消息。你可以使用Python的socket模块创建客户端程序。以下是一个简单的示例程序：

import socket
import threading

# 服务器IP和端口号
SERVER_IP = '127.0.0.1'
SERVER_PORT = 8080

# 创建socket对象
client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

# 连接到服务器
client_socket.connect((SERVER_IP, SERVER_PORT))

# 处理服务器消息
def handle_server_message():
    while True:
        # 接收服务器消息
        message = client_socket.recv(1024).decode()

        # 输出消息
        print(message)

# 启动新线程处理服务器消息
server_thread = threading.Thread(target=handle_server_message)
server_thread.start()

while True:
    # 发送消息给服务器
    message = input()
    client_socket.send(message.encode())

此程序创建一个基于TCP协议的客户端，连接到指定的IP和端口号的服务器。当客户端连接到服务器时，客户端将启动一个新线程处理服务器发送的消息。主线程将等待用户输入消息并将其发送到服务器。

此示例程序只是一个简单的局域网即时通信系统，你可以根据需要修改和扩展它。例如，你可以添加身份验证、加密、文件传输等功能。