在Bokeh中使用回调和WebSockets实现服务器和客户端之间的实时通信可以通过以下步骤完成：
创建一个Bokeh服务器应用程序，并在应用程序中添加一个具有回调功能的图表或小部件。
在Bokeh服务器应用程序中使用WebSockets创建一个连接到客户端的通道。
在客户端的JavaScript代码中创建一个WebSocket对象，连接到Bokeh服务器应用程序中创建的WebSocket连接。
在客户端的JavaScript代码中监听WebSocket连接，以接收从服务器发送的数据并更新图表或小部件。
下面是一个示例代码，演示了如何在Bokeh中使用回调和WebSockets实现服务器和客户端之间的实时通信：
# 服务器端代码from bokeh.server.server import Serverfrom bokeh.application import Applicationfrom bokeh.application.handlers.function import FunctionHandlerfrom bokeh.plotting import figurefrom bokeh.models import ColumnDataSourcefrom bokeh.layouts import columnfrom tornado.ioloop import IOLoopfrom tornado.websocket import WebSocketHandlerimport asyncioimport 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连接以接收从服务器发送的数据并更新图表。
