【问题标题】：Cherrypy + Autobahn websockets on same port同一端口上的 Cherrypy + Autobahn websockets
【发布时间】：2023-03-23 20:41:01
【问题描述】：

是否可以运行（安装在樱桃树中）高速公路的 websocket 类以在相同的端口但不同的 URL 上运行？

例如：

http://localhost:8080/web 到服务器静态内容（html + javascript）
ws://localhost:8080/websocketA 通过类 WSA 服务一些 WS 通信
ws://localhost:8080/websocketB 通过 WSB 类服务于一些 WS 通信

这是我的高速公路配置和运行：

self.loop = asyncio.new_event_loop()
asyncio.set_event_loop(self.loop)

factory = WebSocketServerFactory("ws://0.0.0.0:8081", debug = False)
factory.protocol = WSA.SocketClient

coro = self.loop.create_server(factory, "0.0.0.0", 8081)
server = self.loop.run_until_complete(coro)

self.loop.run_forever()

这是我的cherrypy配置&运行：

cherrypy.config.update({
    'server.socket_host' : '0.0.0.0',
    'server.socket_port' : 80,
})

cherrypy.tree.mount(WebApi.Web(), '/web', {
   '/': {
        "tools.staticdir.on": True,
        "tools.staticdir.root": os.path.dirname(os.path.abspath(__file__)),
        "tools.staticdir.dir": "Web",
        "tools.staticdir.index": "index.html"
    }
})

cherrypy.engine.start()

此时，WebSocket 服务器在 8081 端口上运行，但我想在与 web (8080) 相同的端口上运行它。如果可以的话..

【问题讨论】：

我用 wss: 和 https: 做了类似的事情，我运行了 haproxy，它处理了与 Web 浏览器的连接，然后 haproxy 后端指向我的 http 服务器或我的 web 套接字路由器（高速公路）。所以，它们在后端的不同端口上，但是，它们在前端是同一个端口（haproxy 弄清楚哪个是哪个）。

标签： python websocket url-routing cherrypy autobahn

【解决方案1】：

从字面上回答你的问题，就是说你不能用 CherryPy 和 Autobahn 来做。 CherryPy 的正常请求处理是同步的，而且它是一个线程服务器。换句话说，将线程专用于 WebSocket 连接是不可行的。 CherryPy 挂载单独的 WSGI 应用程序的能力在这里没有意义，因为 WSGI 本质上是一个同步协议。 WebSocket 本质上是异步的。但这并不意味着你不能以不同的方式做到这一点。

CherryPy 和 ws4py

幸运的是，由于 CherryPy 的智能设计，它不仅限于 WSGI，还允许扩展。 CherryPy 贡献者 Sylvain Hellegouarch 在漂亮的库中采用了这一事实，ws4py。它集成了 CherryPy。

#!/usr/bin/env python3


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


class Ws:

  @cherrypy.expose
  def a(self):
    '''WebSocket upgrade method.
    Method must exist for ``WebSocketTool`` to work, 404 returned otherwise.
    '''

  @cherrypy.expose
  def b(self):
    pass


class HandlerA(WebSocket):

  def received_message(self, message):
    self.send('"A" is my reply')


class HandlerB(WebSocket):

  def received_message(self, message):
    self.send('"B" is my reply')


class App:

  @cherrypy.expose
  def index(self):
    return '''<!DOCTYPE html>
      <html>
      <body>
        <table cellspacing='10'>
          <tr>
            <td id='a'></td>
            <td id='b'></td>
          </tr>
        </table>

        <script type='application/javascript'>
          var wsA       = new WebSocket('ws://127.0.0.1:8080/websocket/a');
          wsA.onmessage = function(event)
          {
            document.getElementById('a').innerHTML += event.data + '<br/>';
          };

          var wsB       = new WebSocket('ws://127.0.0.1:8080/websocket/b');
          wsB.onmessage = function(event)
          {
            document.getElementById('b').innerHTML += event.data + '<br/>';
          };

          setInterval(function()
          {
            wsA.send('foo');
            wsB.send('bar');
          }, 1000);
          </script>
      </body>
      </html>
    '''


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(Ws(), '/websocket', {
    '/a' : {
      'tools.websocket.on'          : True,
      'tools.websocket.handler_cls' : HandlerA
    },
    '/b' : {
      'tools.websocket.on'          : True,
      'tools.websocket.handler_cls' : HandlerB
    } 
  })

  cherrypy.tree.mount(App(), '/')

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

CherryPy、nginx 和高速公路

从 1.3 开始，nginx 支持 WebSockets。因此，您可以轻松复用不同的后端。

server {
  listen  80;

  server_name localhost;

  location /web {
    proxy_pass         http://127.0.0.1:8080;
    proxy_set_header   Host             $host;
    proxy_set_header   X-Real-IP        $remote_addr;
    proxy_set_header   X-Forwarded-For  $proxy_add_x_forwarded_for;
  }

  location /websocket {
    proxy_pass         http://127.0.0.1:8081;
    proxy_set_header   Host             $host;
    proxy_set_header   X-Real-IP        $remote_addr;
    proxy_set_header   X-Forwarded-For  $proxy_add_x_forwarded_for;
  }

}

【讨论】：

非常感谢您的回答。我用 Cherrypy / ws4py 做了一些测试，我让它工作了:) 所以你的答案是 100% 正确的。

【解决方案2】：

尝试使用 cherrypy.tree.graft 将 WSA 挂载到不同的端点（在 cherrypy 文档中称为“script_name”）。

请参阅此处将 WSGI 应用程序作为静态文件安装在不同端点上的示例：http://rhodesmill.org/brandon/2011/wsgi-under-cherrypy/

【讨论】：