在Bokeh中使用回調和WebSockets實現服務器和客戶端之間的實時通信可以通過以下步驟完成：
創建一個Bokeh服務器應用程序，并在應用程序中添加一個具有回調功能的圖表或小部件。
在Bokeh服務器應用程序中使用WebSockets創建一個連接到客戶端的通道。
在客戶端的JavaScript代碼中創建一個WebSocket對象，連接到Bokeh服務器應用程序中創建的WebSocket連接。
在客戶端的JavaScript代碼中監聽WebSocket連接，以接收從服務器發送的數據并更新圖表或小部件。
下面是一個示例代碼，演示了如何在Bokeh中使用回調和WebSockets實現服務器和客戶端之間的實時通信：
# 服務器端代碼
from bokeh.server.server import Server
from bokeh.application import Application
from bokeh.application.handlers.function import FunctionHandler
from bokeh.plotting import figure
from bokeh.models import ColumnDataSource
from bokeh.layouts import column
from tornado.ioloop import IOLoop
from tornado.websocket import WebSocketHandler
import asyncio
import random
# 創建一個圖表和數據源
source = ColumnDataSource(data=dict(x=[0], y=[0]))
plot = figure(plot_width=400, plot_height=400)
plot.line(x='x', y='y', source=source)
# 回調函數，每秒更新一次數據源
async def update_data():
while True:
new_data = dict(x=[source.data['x'][-1]+1], y=[random.random()])
source.stream(new_data)
await asyncio.sleep(1)
# 創建Bokeh應用程序
async def app(doc):
doc.add_root(column(plot))
doc.title = "Real-time Data Streaming"
loop = asyncio.get_event_loop()
task = loop.create_task(update_data())
# 創建Bokeh服務器
apps = {'/': Application(FunctionHandler(app))}
server = Server(apps, port=5006)
server.start()
# 定義WebSocket處理程序
class WebSocketHandler(WebSocketHandler):
async def on_message(self, message):
pass
# 運行Bokeh服務器
server.io_loop.add_handler(server._tornado._sockets[0].fileno(), WebSocketHandler)
server.io_loop.start()
<!-- 客戶端代碼 -->
<!DOCTYPE html>
<html>
<head>
<title>Real-time Data Streaming</title>
<script src="https://cdn.bokeh.org/bokeh/release/bokeh-2.4.2.min.js"></script>
</head>
<body>
<div id="plot"></div>
<script>
var ws = new WebSocket("ws://localhost:5006");
ws.onmessage = function(event) {
var data = JSON.parse(event.data);
// 更新圖表
// 示例代碼省略
};
</script>
</body>
</html>
在這個示例中，我們創建了一個Bokeh服務器應用程序，其中包含一個圖表和一個數據源，通過回調函數每秒更新一次數據源。然后我們使用Tornado的WebSocketHandler創建了一個WebSocket連接，并在客戶端的JavaScript代碼中連接到Bokeh服務器應用程序中創建的WebSocket連接，并監聽WebSocket連接以接收從服務器發送的數據并更新圖表。
