class ChatServerProtocol(asyncio.DatagramProtocol):

class ChatServerProtocol(asyncio.DatagramProtocol):  # UDP用の非同期プロトコルクラス
    def __init__(self):
        self.transport = None  # UDPソケットの送受信用オブジェクト

    def connection_made(self, transport):
        self.transport = transport  # サーバーソケットが作成されたときに呼ばれる

    def datagram_received(self, data, addr):
        if not data:
            return  # データが空なら何もしない
        usernamelen = data[0]  # 最初の1バイトはユーザー名の長さ
        username = data[1:1+usernamelen].decode('utf-8')  # ユーザー名部分をデコード
        message = data[1+usernamelen:].decode('utf-8')    # 残りがメッセージ本文
        print(f"Received from {username}@{addr}: {message}")  # 受信内容を表示
        clients[addr] = time.time()  # クライアントの最終通信時刻を更新
        # 他の全クライアントにメッセージをリレー
        for client in clients.keys():
            if client != addr:  # 送信元以外に送信
                try:
                    self.transport.sendto(data, client)  # UDPでデータを送信
                except Exception as e:
                    print(f"Failed to send message to {client}: {e}")  # 送信失敗時のエラー表示