WebSocket广播消息的实现思路

# 1. WebSocket简介

WebSocket作为一种在客户端与服务器之间进行双向实时通信的协议，为Web开发带来了全新的可能性。本章将介绍WebSocket的基本概念、作用以及在实时通信中的应用场景。

## 1.1 WebSocket的概念和作用
WebSocket是一种在单个TCP连接上进行全双工通信的协议，相较于传统的HTTP通信更加高效。通过WebSocket，客户端与服务器可以建立持久性的连接，实现实时的数据传输。这种实时通信的特点，使得WebSocket在在线聊天、实时游戏、股票行情等领域有着广泛的应用。

## 1.2 WebSocket与传统HTTP通信的区别
传统的HTTP协议是无状态的，每次请求都需要建立新的连接，而且是单向请求-响应模式，无法支持服务器主动向客户端推送数据。WebSocket则是建立在TCP协议之上，实现了客户端与服务器之间的双向通信，可以实时传输数据。

## 1.3 WebSocket在实时通信中的应用
WebSocket在实时通信中有着广泛的应用，比如在线聊天室、实时协作编辑、多人在线游戏等。通过WebSocket，客户端可以实时接收来自服务器的消息，也可以向服务器发送实时数据，实现了更加即时和高效的通信方式。

下一步，我们将介绍WebSocket的基本实现，包括建立与断开连接、客户端与服务器端通讯以及数据传输格式。

# 2. WebSocket的基本实现

WebSocket是一种在单个TCP连接上进行全双工通信的协议，通过WebSocket可以实现客户端与服务器端的实时通讯。本章将介绍WebSocket的基本实现方式。

### 2.1 WebSocket的建立与断开

WebSocket的建立是基于HTTP协议的，客户端与服务器端需要首先建立一个HTTP连接，然后发起WebSocket握手请求，握手成功后升级为WebSocket连接。断开WebSocket连接则需要发送特定的关闭帧来通知对方断开连接。

import asyncio
import websockets

async def connect_to_server():
    uri = "ws://localhost:8765"
    async with websockets.connect(uri) as websocket:
        # 连接建立成功
        await websocket.send("Hello, WebSocket!")
        response = await websocket.recv()
        print(response)

asyncio.get_event_loop().run_until_complete(connect_to_server())

### 2.2 WebSocket客户端与服务器端的通讯

WebSocket客户端与服务器端可以通过send和recv方法进行数据的发送和接收，实现双向通讯。客户端发送的消息会被服务器端接收并处理，服务器端发送的消息也会被客户端接收。

// Java WebSocket服务器端示例
@ServerEndpoint("/websocket")
public class MyWebSocketServer {

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("WebSocket opened: " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Message received: " + message);
        session.getBasicRemote().sendText("Server received: " + message);
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("WebSocket closed: