SSE を使用して新しいデータをクライアントにプッシュし、Flot(javascript グラフ作成ライブラリ) を使用して「ライブ」更新を表示することを考えています。私のサーバーはpython Flaskフレームワークで実行されており、データをクライアントにプッシュする方法を理解しましたが、ページを離れるとすぐに問題が発生します:
Exception happened during processing of request from ('127.0.0.1', 38814)
Traceback (most recent call last):
File "/usr/lib/python2.7/SocketServer.py", line 582, in process_request_thread
self.finish_request(request, client_address)
File "/usr/lib/python2.7/SocketServer.py", line 323, in finish_request
self.RequestHandlerClass(request, client_address, self)
File "/usr/lib/python2.7/SocketServer.py", line 640, in __init__
self.finish()
File "/usr/lib/python2.7/SocketServer.py", line 693, in finish
self.wfile.flush()
File "/usr/lib/python2.7/socket.py", line 303, in flush
self._sock.sendall(view[write_offset:write_offset+buffer_size])
error: [Errno 32] Broken pipe
エラーが発生する理由を理解しています。「ライブ」データを提供する無限ループが原因で、ソケットが閉じられることはありません。質問は、ページの変更を検出してソケットをきれいに閉じるにはどうすればよいですか? クライアント側で接続を閉じることはできますか? ページの変更を検出するにはどうすればよいですか?
これはサーバー コードのスケルトンです。もちろん、テキスト メッセージを、表示するオブジェクトのリストを含む json に置き換えます。
def event_stream():
import time
while True:
time.sleep(1)
yield "data: This is a message number X.\n\n"
@app.route('/stream')
def stream():
return Response(event_stream(), mimetype="text/event-stream")