問題描述

我啟動(dòng)了一個(gè)簡單的tornado服務(wù)器,代碼如下

import tornado.httpserverimport tornado.ioloopimport tornado.optionsimport tornado.webimport tornado.websocketimport jsonclass IndexHandler(tornado.web.RequestHandler): def get(self):self.render('index.html')class ChatHandler(tornado.websocket.WebSocketHandler): users = set() def open(self):ChatHandler.users.add(self) def on_message(self, message):jsonObject = json.loads(message)for user in ChatHandler.users: print(user) self.write_message(jsonObject['message']) def on_close(self):ChatHandler.users.remove(self)if __name__ == ’__main__’: app = tornado.web.Application(handlers=[ (r'/', IndexHandler), (r'/ws',ChatHandler)] ) http_server = tornado.httpserver.HTTPServer(app) http_server.listen(12345) tornado.ioloop.IOLoop.instance().start()

現(xiàn)在的問題是，我分別在edge和chrome瀏覽器中通過localhost:12345訪問的時(shí)候，當(dāng)在某一個(gè)瀏覽器中發(fā)送消息的時(shí)候，想實(shí)現(xiàn)的效果是兩個(gè)頁面都能收到該消息。但實(shí)際的情況是只有發(fā)出消息的瀏覽器頁面會(huì)收到兩個(gè)MessageEvent，請(qǐng)問該如何解決這個(gè)問題？

問題解答

self.write_message(jsonObject['message'])

意思是，從誰那里收到的消息，就發(fā)給誰。有幾個(gè)人在線發(fā)幾次。

而你需要的是，不管從誰那里收到消息，都給每個(gè)在線的發(fā)一份。誰在線呢？當(dāng)然是正在被迭代的 user 了。