javascript - 带有 Tornado 的 Websockets-6ren

javascript - 带有 Tornado 的 Websockets

转载作者：行者123 更新时间：2023-11-30 16:13:57

24

4

我是 tornado 框架的新手，到目前为止，一切都非常困惑，尤其是在处理网络套接字时。到目前为止，我的代码如下所示:

import tornado.options
import tornado.web
import tornado.websocket
import tornado.ioloop

from tornado.options import options, define

define(name='port', default=8000, help='.', type=int)

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

    def open(self):
        WSHandler.clients.append(self)
        self.write('client connected')

    def on_close(self):
        WSHandler.clients.remove(self)
        self.write('client removed')

    def on_message(self, message):
        for client in WSHandler.clients:
            WSHandler.client.write_message(message)

    def check_origin(self, origin):
        return True

if __name__ == '__main__':
    tornado.options.parse_command_line()
    application = tornado.web.Application(
        handlers=[
            (r'/webSocket', WSHandler),
        ],
    )
    application.listen(options.port)
    tornado.ioloop.IOLoop.instance().start()

javascript 文件看起来像这样

var ws = new WebSocket("ws://localhost:8000/webSocket")
ws.onopen = function() {
  ws.setData('Hello World');
};
ws.onmessage = function(evt) {
  ws.send(evt.data);
};

我目前正在阅读“ Tornado 简介”一书，并意识到某些内容现在已被弃用。我确实下载了 git-hub 上提供的演示，并尝试理解 websocket 演示。

我尝试创建一个简单的 websocket 应用程序，但它所做的只是给我这个错误:

Can "Upgrade" only to "WebSocket"

此外，我还有一个关于 Tornado 的问题
_() 是什么意思？文档中给出的例子是

_("A person liked this", "%(num)d people liked this", len(people)) % {"num": len(people)}

如果 people 中只有一个人，这应该会返回“A person liked this”。我不太明白这是怎么回事

如果我犯了一个非常明显的错误，我深表歉意

最佳答案

我想你可以看到tornado source ，您可以找到以下内容:

# Upgrade header should be present and should be equal to WebSocket
    if self.request.headers.get("Upgrade", "").lower() != 'websocket':
        self.set_status(400)
        log_msg = "Can \"Upgrade\" only to \"WebSocket\"."
        self.finish(log_msg)
        gen_log.debug(log_msg)
        return

很明显，HTML5 WebSocket协议(protocol)是一个新的协议(protocol)。它实现了浏览器和服务器的全双工通信(full-duplex)。但是使用http只能做单机通信。所以我建议你再试试另一个demo。

服务器:

    #!/usr/bin/python
#coding:utf-8
import os.path

import tornado.httpserver
import tornado.web
import tornado.ioloop
import tornado.options
import tornado.httpclient
import tornado.websocket

import json
class IndexHandler(tornado.web.RequestHandler):
  def get(self):
    self.render("index.html")

class SocketHandler(tornado.websocket.WebSocketHandler):
  """docstring for SocketHandler"""
  clients = set()

  @staticmethod
  def send_to_all(message):
      for c in SocketHandler.clients:
          c.write_message(json.dumps(message))

  def open(self):
      self.write_message(json.dumps({
          'type': 'sys',
          'message': 'Welcome to WebSocket',
      }))
      SocketHandler.send_to_all({
          'type': 'sys',
          'message': str(id(self)) + ' has joined',
      })
      SocketHandler.clients.add(self)

  def on_close(self):
      SocketHandler.clients.remove(self)
      SocketHandler.send_to_all({
          'type': 'sys',
          'message': str(id(self)) + ' has left',
      })

  def on_message(self, message):
    SocketHandler.send_to_all({
  'type': 'user',
  'id': id(self),
  'message': message,
        })

##MAIN
if __name__ == '__main__':
  app = tornado.web.Application(
    handlers=[
      (r"/", IndexHandler),
      (r"/chat", SocketHandler)
    ],
    debug = True,
    template_path = os.path.join(os.path.dirname(__file__), "templates"),
        static_path = os.path.join(os.path.dirname(__file__), "static")
  )
  app.listen(8000)
  tornado.ioloop.IOLoop.instance().start()

客户:

    <html>
<head>
<script type="text/javascript">
var ws = new WebSocket("ws://localhost:8000/chat");
ws.onmessage = function(event) {
  console.log(event);
}
function send() {
  ws.send(document.getElementById('chat').value );
}
</script>
</head>

<body>
  <div>
    hello
    <input id="chat">
    <button  onclick="send()">send</button>
  </div>    
</body>
</html>

关于javascript - 带有 Tornado 的 Websockets，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35800629/

24

4

0

文章推荐： c# - 使用 C# 的保护级别和 Visual Studio 单元测试

文章推荐： c - 尝试在矩阵单元格中添加值时写入无效

文章推荐： c# - 创建可重用的项目和解决方案结构

文章推荐： c - 如何正确标准化 q15 定点中的 pid 系数

tornado - 优雅地处理 Tornado 应用程序中的应用程序异常
根据一些谷歌搜索，我安装了以下错误处理程序。然而，似乎返回 http 500 的 python 异常并没有被这些东西捕获，尽管 404 是这样。通过我在下面的代码中留下的打印语句，我可以看到它没有命中
tornado - Tornado write_message 并行屈服
我刚刚意识到 WebSocketHandler.write_message() 返回一个 Future。我以前没有在我的函数中产生过这个函数: @tornado.gen.coroutine
python Tornado : ImportError: No module named 'tornado'
这是我的 Tornado 文件:: from tornado.wsgi import WSGIContainer from tornado.ioloop import IOLoop from torn
python - Tornado - Tornado 中的 'Global variables'？
class MainHandler(BaseHandler): @tornado.web.authenticated def get(self): self.rende
python - Tornado 测试@tornado.web.authenticated
我正在尝试使用 AsyncHTTPTestCase 测试 Tornado .我想测试标有 @tornado.web.authenticated 注释的处理程序。因为此处理程序需要身份验证，所以我们必须
python - 如何在 Tornado 请求中执行 Tornado 请求
我正在使用 Tornado Web Server (版本 4.1)使用 Python 2.7 创建 REST Web 应用程序。我的请求处理程序之一 (web.RequestHandler) 使用多部
python - Tornado ioloop 和 Tornado 的工作流程是什么？
我想知道tornado 的内部工作流程，并且看过this article ，很好，但我就是想不通 ioloop.py里面有这样一个函数 def add_handler(self, fd, handle
python - 如何遍历从 Python/Tornado 处理程序传递到 Tornado 模板的字典？
如何遍历从 Python/Tornado 处理程序传递到 Tornado 模板的字典？我试过 {% for key, value in statistics %}
python - Tornado:来自 mysql 的更新数据未显示在由 Tornado 服务的前端中。重启服务器后才显示
我有一个 Tornado 后端，为 Angular 前端提供服务。更新数据库时，tornado api 不会获取更新的数据。它仅在我重新启动服务器后出现。有人可以帮我解决这个问题吗？我希望获取的数据能
python - 如何在 tornado.wsgi.WSGIContainer 中使用异步 tornado API？
我尝试使用自定义的 WSGIContainer 来处理异步操作: from tornado import httpserver, httpclient, ioloop, wsgi, gen @gen.
python - Tornado - 使用 render() 时找不到记录器 "tornado.application"的处理程序
from tornado.web import RequestHandler class HelloWorldHandler(RequestHandler): def get(self):
python - Pylint 和 Tornado - 在 @tornado.web.authenticated 上失败
Pylint 遇到 @tornado.web.authenticated 时崩溃 class Handler1(tornado.web.RequestHandler): def get(sel
python - tornado.gen.engine 与 tornado.gen.coroutine 的区别
经过 tornado.gen documentation有人可以帮我理解 tornado.gen.coroutine 和 tornado.gen.engine 之间的确切区别最佳答案正如 gen.
python - Tornado -redis : Why the 'listen' and the 'brpop' of tornado-redis can't work at the same time
代码如下: from tornadoredis import Client from tornado.ioloop import IOLoop from tornado.gen import coro
python - 在 Tornado 应用程序中使用 Django - 无法访问 Tornado 应用程序启动后创建的 MySQL 记录
我有一个 tornado.websocket.WebSocketHandler 的子类。在该类中，我有一个方法使用 Django ORM 从子类模型中获取用户:django.contrib.auth.
python-3.x - 无法从 Tornado Client 连接到基于 Tornado SSL 的服务器
我是 ssl 之类的新手，我已经使用 openssl 生成了自签名证书。 openssl req -newkey rsa:2048 -nodes -keyout key.pem -x509 -days
Tornado 6.0.3 从 4.2 : module 'tornado.web' has no attribute 'asynchronous'
我已经从 tornado 4.2 移动到 tornado 6.0.3，我得到了错误 AttributeError:模块“tornado.web”没有属性“异步” 根据 tornado v6 seems
python - 如何修复 Python 中的 'Install tornado itself to use zmq with the tornado IOLoop.' 警告
我一直在关注此 ( https://developer.ibm.com/tutorials/se-distributed-apps-zeromq-part2/) 教程，以设置使用 CurveZMQ 加
python - 集成 Tornado 与 celery : RuntimeError: tornado-redis must be installed to use the redis backend
我在使用tornado-celery整合tornado和celery时，出现错误:``` traceback (most recent call last): File "/usr/local/l
Tornado 认证
我正在使用 Tornado 与 twitter 等第三方进行身份验证。我的登录处理程序看起来像这样 class AuthLoginHandler(BaseHandler, tornado.auth.

首页

博学

6Ren·AI

商城

javascript - 带有 Tornado 的 Websockets