Python Tornado:从另一个类发送 websocket 消息

Question

有一个使用(Python 3.6(Tkinter和Tornado的应用程序。 希望它在按下按钮时发送 websocket 消息。

sendSocket 在我的类中处理接口。我可以正常打开我的套接字，并且可以将数据发送到套接字处理程序中。此外，它还从我的请求处理程序中提供我的 html 文件。

我可以看到我的代码命中了 sendSocketMessage 行。但是，我从未从SocketHandler.send_message定义中获取打印。 控制台中没有错误。

def sendSocketMessage(self, data = "whatever"):
print("sending")
#WebSocketeer.send_message(data)        
ioloop.IOLoop.current().add_callback(WebSocketeer.send_message, data)
class WebSocketeer(websocket.WebSocketHandler):    
def open(self):
print("WebSocket opened")
def on_message(self, message):
print("got message: " + message)
def on_close(self):
print("WebSocket closed")
@classmethod
def send_message(self, message):
print("sending message: " + message)
for session_id, session in self.session.server._sessions._items.iteritems():
session.conn.emit(event, message)

基于这些 SO 响应的代码

• 发送网络套接字消息： 如何在龙卷风中随意发送网络套接字消息？

• 发送给所有客户端： 是否可以向所有活动的 WebSocket 连接发送消息？使用节点.js或 python 龙卷风 websocket

Answer 1

在这里找到了一种方法：如何在python(tornado(中的websocket循环之外运行函数

但我仍然想知道为什么add_callback不起作用 - 因为从我所读到的内容来看，这是推荐的方法。

Answer 2

这是我的工作，取自：https://github.com/tornadoweb/tornado/issues/2802

clients = [];
class WSHandler(tornado.websocket.WebSocketHandler):

def open(self):
print('connection opened...')
clients.append(self);
def on_message(self, message):
self.write_message("The server says: " + message + " back at you")
print('received:', message)
def on_close(self):
clients.remove(self);
print('connection closed...')
@classmethod
def send_message(self, message):
print("sending message: " + message)
for client in clients:
client.write_message(message);
#for session_id, session in self.session.server._sessions._items.iteritems():
#    session.conn.emit(event, message);
return True;
def sendRandom():
global thread, data;
try:
print("sendRandom()");
time.sleep(0.125);
n = random.randint(0,1000);
data = str(n);
data = {"msg":"data","data":data};
if eventLoop is not None:
#If response needed
#sendData(eventLoop,WSHandler.send_message,json.dumps(data));
#else
eventLoop.add_callback(WSHandler.send_message,json.dumps(data));
except:
print("Err");
traceback.print_exc();
clients = [];
def sendData(loop,f,*a,**kw):
print("%s %s" % (type(loop),type(f)));
concurrent_future = concurrent.futures.Future();
async def wrapper():
try:
rslt = f(*a,**kw);
except Exception as e:
concurrent_future.set_exception(e);
else:
concurrent_future.set_result(rslt);
loop.add_callback(wrapper);
return concurrent_future.result();
eventLoop = None;
application = tornado.web.Application([
(r'/data', WSHandler),
])
def startServer():
global eventLoop;
try:
print("Starting server @%s:%d" %("localhost",9090));  
asyncio.set_event_loop(asyncio.new_event_loop());
eventLoop = tornado.ioloop.IOLoop();
application.listen(9090)
eventLoop.start();
except KeyboardInterrupt:
print("^C");
except:
print("ERR");
traceback.print_exc();
if __name__ == "__main__":
thread = Thread(target=startServer,);
thread.setDaemon(True);
thread.start();
time.sleep(5);
while True:
sendRandom();