问题描述：

我遇到了有关制作WebSocket服务器/客户端的问题。ws4py - 发送/ received_message不工作

这是我的WebSocket柯乐：

wslist = [] 

class LoginLiveWebSocketHandler(WebSocket): # /live/ws/zones 
    loggedon = False 

    def opened(self): 
     log("Opened!") 
     wslist.append(self) 

    def received_message(self, m): 
     log("Received Message!") 
     log(m) 
     log(m.data) 
     m = str(m.data) 
     if not m.startswith("Login: ") & (not self.loggedon): 
      return 
     if m.startswith("Login: ") & self.loggedon: 
      return 
     if m.startswith("Login: ") & (not self.loggedon): 
      split = m.replace("Login: ", "").split(":") 
      try: 
       id = split[0] 
       key = split[1] 
      except KeyError: 
       self.send("Login: 0", False) 
       return 
      try: 
       usr = users.getuser(id, key) 
       nick = usr["nick"] 
       loggedin = True 
       token = usr["groupme_token"] 
       active = usr["active"] 
      except KeyError or TypeError: 
       self.send("Login: 0", False) 
       return 
      if (not loggedin) | (not active) | (not local.token) | (local.user["faction"] != "f"): 
       self.send("Login: 0", False) 
       return 
      self.send("Login: 1", False) 
      self.loggedon = True 
      return 

    def closed(self, code, reason=""): 
     log("Closed!") 
     wslist.remove(self)

而且我JavaScript页面（注意，不是全部）：

function init() { 
      showBlocking("Connecting...", "progress-bar-success"); 
      var wsprotocol = (location.protocol == "https:") ? "wss://" : "ws://"; 
      var loc = location.pathname; 
      loc = loc.replace(/live\u002flive$/i, ""); 
      var wsurl = wsprotocol + location.host + loc + "/live/ws_zones"; 
      console.log(wsurl); 
      var ws = new WebSocket(wsurl); 

      var key = getCookie("key"); 
      var id = getCookie("id"); 

      var closed = true; 

      ws.onopen = function(evt) { 
       console.log("onopen"); 
       $('#pbheader').text("Logging in..."); 
       ws.send("Login: " + id + ":" + key); 
       closed = false; 
      } 

      ws.onmessage = function(evt) { 
       console.log("OnMessage"); 
       var channel = evt.data.substring(0, 7); 
       var data = evt.data.substr(6); 
       if (channel == "Login: ") { 
        if (data == "0") { 
         ws.close(); 
         closed = true; 
         alert("Invalid Login, please re-login."); 
         $('#pbheader').text("Invalid Login!"); 
         history.back(); 
        } else if (data == "1") { 
         hideBlocking(); 
        } 
       } else if (channel == "ZoneA: ") { 
        // add new thing... 
        // %gridref% %zoneid% %zonename% %faction% %legion% %faceless% %swarm% 
        var datadict = JSON.parse(data); 
        var replitem = itemtemplate.replace("%count%", count).replace("%gridref%", datadict.gridref).replace("%zoneid%", datadict.zoneid).replace("%zonename%", datadict.zonename).replace("%faction%", datadict.faction).replace("%legion%", datadict.legion).replace("%faceless%", datadict.faceless).replace("%swarm%", datadict.swarm); 
        $('#live').prepend(replitem); 
        var curritem = $('#item' + count); 
        setTimeout(function() { fadeoutremove(curritem); }, 60*1000); 
        count = count + 1; 
       } 
      } 

      ws.onclose = function(evt) { 
       console.log("Closed"); 
       closed = true; 
      } 

      ws.onerror = function(evt) { 
       console.log("error"); 
       closed = true; 
      } 
     } 

     window.addEventListener("load", init, false);

安装服务：

log("Starting WebServer (cherrypy)") 
cherrypy.server.unsubscribe() 
if config.DO_SSL is True: 
    server1 = cherrypy._cpserver.Server() 
    server1.socket_port = config.LISTEN_PORT_SSL 
    server1._socket_host = config.LISTEN 
    server1.thread_pool = 30 
    server1.ssl_certificate = config.SSL_CERTIFICATE 
    server1.ssl_private_key = config.SSL_PRIVATE_KEY 
    server1.ssl_certificate_chain = config.SSL_CHAIN 
    server1.ssl_module = config.SSL_HANDLER 
    server1.subscribe() 
server2 = cherrypy._cpserver.Server() 
server2.socket_port = config.LISTEN_PORT 
server2._socket_host = config.LISTEN 
server2.thread_pool = 30 
server2.subscribe() 

WebSocketPlugin(cherrypy.engine).subscribe() 
cherrypy.tools.websocket = WebSocketTool() 

cherrypy.tree.mount(APIService.APIService(), "/api", config={"/": {'error_page.404': APIService.ep}}) 
cherrypy.tree.mount(JSONService.JSONService(), "/json", config={"/": {'error_page.404': JSONService.ep}}) 
cherrypy.tree.mount(USRAPIService.USRAPIService(), "/usrapi", config={"/": {'error_page.404': USRAPIService.ep}}) 
cherrypy.tree.mount(USRAPIAdminService.USRAPIAdminService(), "/usrapi/admin", config={ 
    "/": {'error_page.404': USRAPIService.ep}}) 
cherrypy.tree.mount(RootService.RootService(), "/", config={"/": {'error_page.404': RootService.ep}}) 
cherrypy.tree.mount(AdminService.AdminService(), "/admin", config={"/": {'error_page.404': AdminService.ep}}) 
cherrypy.tree.mount(HelperPanel.HelperPanel(), "/helper", config={"/": {'error_page.404': HelperPanel.ep}}) 
cherrypy.tree.mount(LiveService.LiveService(), "/live", config={"/": {'error_page.404': LiveService.ep}, 
                   "/ws_zones": {'tools.websocket.on': True, 
                       'tools.websocket.handler_cls': 
                        LiveService.LoginLiveWebSocketHandler 
                       }}) 
cherrypy.tree.mount(None, "/static", config={"/": {'error_page.404': AdminService.ep, 
                'tools.staticdir.on': True, 
                'tools.staticdir.dir': 
                 os.path.join(__current_dir, "web/static")}}) 
cherrypy.engine.start() 
log("Started WebServer (cherrypy)")

LiveService：

class LiveService(object): 

    @cherrypy.expose 
    @require(level=0) 
    def index(self, user, usrname, usrhelper, usradmin): 
     return render("index", usrname, usrhelper, usradmin) 

    @cherrypy.expose 
    @require(level=4) # Require login, Groupme, active and faceless 
    def live(self, user, usrname, usrhelper, usradmin): 
     return render("websocket/zonesdata", usrname, usrhelper, usradmin) 

    @cherrypy.expose 
    def ws_zones(self): 
     log("Handler created: %s" % repr(cherrypy.request.ws_handler)) 
     cherrypy.request.ws_handler.send(b"Login 0", False)

因此，安装和启动工作，整个生产运行数月，但带有ws的新LiveService无法正常工作。在日志中，即时获取[21/Jul/2015:16:55:28] ENGINE Starting WebSocket processing和Opened消息，但我从来没有收到或能够发送消息。当我改变LiveService.LoginLiveServiceWebSocketHandler到EchoWebSocket他得到的消息，并将它们发送，但ws_zones处理

cherrypy.request.ws_handler.send（B “登录0”，FALSE）

不工作。是否与b有关。

显示你的'LiveService.LiveService'。 – saaj

添加了LiveService。 – decontamin4t0R

答

当时有点傻......

@saaj是正确的，但真正的问题是，我试图调用函数的日志（需要STR）与男，m.data等这样做与repr（）或删除它，它的工作！

谢谢！

答

分析

首先要说的是，你应该注意的调试是在您的处置工具。例如，当您尝试应用在Firefox，萤火虫（或Web控制台）告诉你：

火狐不能建立在WS到服务器的连接：//127.0.0.1：8080 /现场/ ws_zones 。

铬控制台有更多有用的错误信息：

WebSocket连接到 'WS：//127.0.0.1：8080 /现场/ ws_zones' 失败：WebSocket的握手过程中的错误：无效的状态行

好的，我们有一个握手问题。

如果你打开Wireshark（或另一个嗅探器），你可以看到我们的Login 0出现在ws4py回复握手响应之前（或者有竞争条件）。

我可以理解你的困惑，因为在几个地方ws4py文件或暗示或直接引导你错误的方式。让我们看看：

alludes - 你不能从正常的处理程序发送。

@cherrypy.expose 
def ws(self): 
    # you can access the class instance through 
    handler = cherrypy.request.ws_handler

guides incorrectly - 你不能从opened钩发送。

def opened(self): 
    """ 
    Called by the server when the upgrade handshake 
    has succeeeded. 
    """ 
    pass

所以我认为这是一个过时的文档或错误。

解决方案

现在我建议您在客户端启动您的沟通。如果你有一些登录前的“聊天”，你可以在网络套接字上创建一个小协议（无论如何你最终都会这样做）。事情是这样的：

#!/usr/bin/env python3 


import json 

import cherrypy 
from ws4py.server.cherrypyserver import WebSocketPlugin, WebSocketTool 
from ws4py.websocket import WebSocket 


class LoginLiveWebSocketHandler(WebSocket): 

    wsset = set() 
    '''Class level attr, do not rebind''' 


    def opened(self): 
    '''You can not send yet, because handshake has not been completed. 
    Yes, a documentation is not always correct ;-) 
    ''' 

    cherrypy.log('Opened!') 
    self.wsset.add(self) 

    def closed(self, code, reason = ''): 
    cherrypy.log('Closed!') 
    self.wsset.remove(self) 

    def received_message(self, message): 
    cherrypy.log('Received Message!') 

    message = json.loads(message.data.decode()) 
    if message['cmd'] == 'init': 
     self.send('Login 0') 
    else: 
     self.send(message['payload'] + ' pong') 


class LiveService(object): 

    @cherrypy.expose 
    def index(self): 
    return '''<!DOCTYPE html> 
     <html> 
     <body> 
     <div id='log'></div> 
     <script type='application/javascript'> 
      var ws = new WebSocket('ws://127.0.0.1:8080/live/ws_zones'); 

      ws.onopen = function(event) 
      { 
      ws.send(JSON.stringify({'cmd': 'init'})); 
      }; 
      ws.onmessage = function(event) 
      { 
      document.getElementById('log').innerHTML += event.data + '<br/>'; 
      }; 

      var handle = setInterval(function() 
      { 
      if(ws.readyState == WebSocket.CLOSING || ws.readyState == WebSocket.CLOSED) 
      { 
       clearInterval(handle); 
      } 
      else 
      { 
       ws.send(JSON.stringify({'cmd': 'chat', 'payload': 'ping'})); 
      } 
      }, 1000); 
      </script> 
     </body> 
     </html> 
    ''' 

    @cherrypy.expose 
    def ws_zones(self): 
    '''You can not send yet, because handshake has not been completed''' 
    cherrypy.log('Handler created: %r' % cherrypy.request.ws_handler) 



if __name__ == '__main__': 
    cherrypy.config.update({ 
    'server.socket_host' : '127.0.0.1', 
    'server.socket_port' : 8080, 
    'server.thread_pool' : 8 
    }) 

    cherrypy.tools.websocket = WebSocketTool() 
    WebSocketPlugin(cherrypy.engine).subscribe() 

    cherrypy.tree.mount(LiveService(), '/live', { 
    '/ws_zones' : { 
     'tools.websocket.on'   : True, 
     'tools.websocket.handler_cls' : LoginLiveWebSocketHandler 
    } 
    }) 

    cherrypy.engine.signals.subscribe() 
    cherrypy.engine.start() 
    cherrypy.engine.block()

谢谢！试图现在就完成！ – decontamin4t0R

ws4py - 发送/ received_message不工作

分析

解决方案

相关推荐