close

Python を使用したリアルタイム データのブロードキャスト WebSocket

WebSocket は、双方向接続を通じてサーバーとクライアント間の効率的なリアルタイム データ送信を可能にするテクノロジーです。 WebSocket ここでは、Python でサーバーからクライアントにリアルタイム データをブロードキャストする 方法についてのガイドを示します。

WebSocket ライブラリ をインストールする

ライブラリを使用してサーバーとクライアント websockets を実装します WebSocket。 pip を使用してこのライブラリをインストールします。 

pip install websockets

WebSocket サーバー を構築する

サーバー WebSocket は、接続されているすべてのクライアントにリアルタイム データを送信します。 

import asyncio  
import websockets  
  
# Function to send real-time data from the server  
async def send_real_time_data(websocket, path):  
    while True:  
        real_time_data = get_real_time_data()  # Get real-time data from a source  
        await websocket.send(real_time_data)  
        await asyncio.sleep(1)  # Send data every second  
  
start_server = websockets.serve(send_real_time_data, "localhost", 8765)  
asyncio.get_event_loop().run_until_complete(start_server)  
asyncio.get_event_loop().run_forever()

WebSocket クライアント を構築する

クライアント WebSocket はサーバーからリアルタイム データをリッスンして受信します。 

import asyncio  
import websockets  
  
async def receive_real_time_data():  
    async with websockets.connect("ws://localhost:8765") as websocket:  
        while True:  
            real_time_data = await websocket.recv()  
            print("Received real-time data:", real_time_data)  
  
asyncio.get_event_loop().run_until_complete(receive_real_time_data())

アプリケーションを実行する

最初にサーバー コードを実行し WebSocket 、次に WebSocket クライアント コードを実行します。 リアルタイム データがサーバーからブロードキャストされ、クライアントによって継続的に受信されることがわかります。

カスタマイズと拡張

ここから、認証、データ フィルタリング、データ形式などの機能を追加して、アプリケーションをカスタマイズおよび拡張できます。

結論：

WebSocket Python でサーバーからクライアントにリアルタイム データをブロードキャストするために使用することは、リアルタイム通信アプリケーションを構築し、即座に更新されるデータを体験するための強力な方法です 。