tornado websocket

2019-05-13 23:26:00

tornado websocket 轮询客户端定时去请求服务端，是客户端主动请求来促使数据更新长轮询客户端请求服务端，但是服务端并不是即时返回，而是当有内容更新的时候才返回内容给客户端，从...

tornado   websocket
轮询
客户端定时去请求服务端，  是客户端主动请求来促使数据更新





长轮询
客户端请求服务端，但是服务端并不是即时返回，而是当有内容更新的时候才返回内容给客户端，从流程上讲，可以理解为服务器向客户端推送内容；





websocket
WebSocket是通过单个TCP连接提供全双工（双向通信）通信信道的计算机通信协议。此WebSocket API可在用户的浏览器和服务器之间进行双向通信。用户可以向服务器发送消息并接收事件驱动的响应，而无需轮询服务器。 它可以让多个用户连接到同一个实时服务器，并通过API进行通信并立即获得响应。
tornado服务端websocket

 1 from tornado.web import RequestHandler, authenticated
 2 from pycket.session import SessionMixin
 3 from tornado.websocket import WebSocketHandler
 4 
 5 
 6 class BaseHandle(RequestHandler, SessionMixin):
 7     def get_current_user(self):
 8         current_user = self.session.get('login')
 9         if current_user:
10             return current_user
11 
12 
13 class BaseWebSocket(WebSocketHandler, SessionMixin):
14     def get_current_user(self):
15         current_user = self.session.get('login')
16         if current_user:
17             return current_user
18 
19 
20 class IndexHandle(BaseHandle):
21     @authenticated
22     def get(self):
23         self.render('websocket.html')
24 
25 
26 class WebSocketHandle(BaseWebSocket):
27     user = set()
28 
29     def open(self):
30         WebSocketHandle.user.add(self)
31         for i in self.user:
32             i.write_message("{}上线了！".format(self.current_user))
33 
34     def on_message(self, message):
35         for i in self.user:
36             i.write_message("{}说{}".format(self.current_user, message))
37 
38     def on_close(self):
39         WebSocketHandle.user.remove(self)
40         for i in self.user:
41             i.write_message("{}下线了！".format(self.current_user))
42 
43 
44 class LoginHandle(BaseHandle):
45     def get(self):
46         next_url = self.get_argument('next', '')
47         self.render('login.html', next_url=next_url)
48 
49     def post(self):
50         username = self.get_argument('username', '')
51         password = self.get_argument('password', '')
52         next_url = self.get_argument('next', '')
53         if username == password and next_url:
54             self.session.set('login', 'true')
55             self.redirect(next_url)
56         elif username == password:
57             self.set_secure_cookie('login', 'true')
58             self.write('登录成功!')

 

导入WebSocketHandler类
创建BaseWebSocket类，该类继承WebSocketHandler和SessionMixin
重写get_current_user方法用于验证登录
创建websocket类，继承BaseWebSocket
重写open，on_message，on_close
open: websocket客户端与服务端连接的时候使用
on_message: 服务端收到消息的时候调用
on_close：断开连接的时候调用
write_message：发送消息

创建视图类，返回含有websocket服务的页面

 1 <!DOCTYPE html>
 2 <html lang="en">
 3 <head>
 4     <meta charset="UTF-8">
 5     <title>WebSocket</title>
 6     <link rel="stylesheet" href="https://cdn.jsdelivr.net/npm/bootstrap@3.3.7/dist/css/bootstrap.min.css">
 7 </head>
 8 <body>
 9 <div>
10     <textarea name="" id="text" cols="30" rows="10" placeholder="请输入您的内容"></textarea>
11     <a href="javascript:websocket()" class="btn btn-primary">发送</a>
12     <ul id="message"></ul>
13 </div>
14 <script src="https://code.jquery.com/jquery-3.1.1.min.js"></script>
15 <script type="text/javascript">
16     var msg = document.getElementById("message");
17     msg.innerHTML = "发送成功";
18     var socket = new WebSocket("ws://39.108.125.89:1996/websocket");
19     socket.onopen = function () {
20         alert("聊天打开")
21     };
22     socket.onmessage = function (data) {
23         var receive = data.data;
24         var message = $("<li>" + receive + "</li>");
25         $(msg).append(message);
26     };
27     socket.onclose = function () {
28         msg.innerHTML = msg.innerHTML + "<br>连接关闭..."
29     };
30 
31     function websocket() {
32         socket.send($("#text").val())
33     }
34 </script>
35 </body>
36 </html>

 

效果显示
 



转载于:https://www.cnblogs.com/ivy-blogs/p/10859735.html

收起

展开全文

python tornado websocket_python tornado websocket服务器向特定客户端发送消息

2020-12-04 09:15:25

我不知道是否有可能获得客户的id，然后向该id发送消息我的客户代码是：from tornado.ioloop import IOLoop, PeriodicCallbackfrom tornado import genfrom tornado.websocket import websocket_co...

如果多个套接字客户端连接到tornado websocket服务器，是否可以向特定服务器发送消息？
我不知道是否有可能获得客户的id，然后向该id发送消息
我的客户代码是：from tornado.ioloop import IOLoop, PeriodicCallback
from tornado import gen
from tornado.websocket import websocket_connect
class Client(object):
def __init__(self, url, timeout):
self.url = url
self.timeout = timeout
self.ioloop = IOLoop.instance()
self.ws = None
self.connect()
PeriodicCallback(self.keep_alive, 20000, io_loop=self.ioloop).start()
self.ioloop.start()
@gen.coroutine
def connect(self):
print "trying to connect"
try:
self.ws = yield websocket_connect(self.url)
except Exception, e:
print "connection error"
else:
print "connected"
self.run()
@gen.coroutine
def run(self):
while True:
msg = yield self.ws.read_message()
print msg
if msg is None:
print "connection closed"
self.ws = None
break
def keep_alive(self):
if self.ws is None:
self.connect()
else:
self.ws.write_message("keep alive")
if __name__ == "__main__":
client = Client("ws://xxx", 5 )

收起

展开全文

python tornado websocket ping_关闭后，Python Tornado Websocket连接仍处于打开状态

2021-03-05 13:21:19

我有一个Tornado Websocket服务器，我想在30分钟不活动后超时。我使用self.close()在30分钟不活动后关闭连接。但似乎有些连接在关闭之后仍然保持打开状态。在打开连接：class WebSocketHandler(tornado.websocket....

我有一个Tornado Websocket服务器，我想在30分钟不活动后超时。我使用self.close()在30分钟不活动后关闭连接。但似乎有些连接在关闭之后仍然保持打开状态。在
打开连接：class WebSocketHandler(tornado.websocket.WebSocketHandler):
def open(self, *args):
self.id = self.generate_id()
self.stream.set_nodelay(True)
# ... DO STUFF ...
self.ini_time = datetime.now()
self.message_number = 0
self.last_message_time = self.ini_time
self.write_message("Connection SUCCESSFUL! Thanks for connecting! Your connection ID is: %d :)" % self.id)
self.timeout = tornado.ioloop.IOLoop.current().add_timeout(timedelta(minutes=30), self.force_close)
print datetime.now()
print "New connection. ID: %d" % self.id
print "Total number of open connections: %d" % len(clients)
收到信息时：
^{pr2}$
交割时：def on_close(self):
self.common_close()
def common_close(self):
print datetime.now()
print "Open connections are:"
print clients.keys()
print "Closing connection %d." % self.id
end = datetime.now()
timeonline = end - self.ini_time
timeconlastmsg = self.last_message_time - self.ini_time
print "Total time online:"
print timeonline
print "Time between connection start and last message received:"
print timeconlastmsg
if self.id in clients.keys():
del clients[self.id]
print "Number of open connections: %d" % len(clients)
print "Open connections are:"
print clients.keys()
超时：def force_close(self):
timout =  datetime.now()
print timout
print "Connection %d timed out, server is dropping the connection." % self.id
self.common_close()
self.close()
超时工作，并调用函数force_close。但似乎即使在被调用并从clients中删除连接之后，该连接仍然是打开和活动的。在
以下是该计划的输出示例：New connection. ID: 66919
Total number of open connections: 3
2015-07-14 21:51:48.387892
New connection. ID: 12012
Total number of open connections: 4
2015-07-14 21:51:48.641603
Open connections are:
[66919, 12012, 11281, 97458]
Closing connection 66919.
Total time online:
0:00:00.404316
Time between connection start and last message received:
0:00:00
Number of open connections: 3
Open connections are:
[12012, 11281, 97458]
... ...
Number of open connections: 4
Open connections are:
[66246, 12012, 97458, 6069]
2015-07-14 22:21:47.906129
Connection 97458 timed out, server is dropping the connection.
2015-07-14 22:21:47.906167
Open connections are:
[66246, 12012, 97458, 6069]
Closing connection 97458.
Total time online:
0:30:00.000450
Time between connection start and last message received:
0:00:00
Number of open connections: 3
Open connections are:
[66246, 12012, 6069]
2015-07-14 22:21:48.237407
Connection 66919 timed out, server is dropping the connection.
2015-07-14 22:21:48.237444
Open connections are:
[66246, 12012, 6069]
Closing connection 66919.
Total time online:
0:30:00.000143
Time between connection start and last message received:
0:00:00
Number of open connections: 3
可以看出，66919被“关闭”两次，间隔30分钟。有什么想法吗？在
另一个连接3358在假定没有更多打开的连接时关闭(再次关闭两次，间隔30分钟)：Open connections are:
[7046, 16287]
2015-07-15 11:01:13.604125
New connection. ID: 3358
Total number of open connections: 3
2015-07-15 11:01:28.429574
Open connections are:
[7046, 3358, 16287]
Closing connection 3358.
Total time online:
0:00:14.825568
Time between connection start and last message received:
0:00:00
Number of open connections: 2
Open connections are:
[7046, 16287]
--
Open connections are:
[]
2015-07-15 11:31:13.629530
Connection 3358 timed out, server is dropping the connection.
2015-07-15 11:31:13.629586
Open connections are:
[]
Closing connection 3358.
Total time online:
0:30:00.025556
Time between connection start and last message received:
0:00:00
Number of open connections: 0
Open connections are:
[]
有人指出我不应该在force_close中调用common_close，因为on_close将被{}调用，但是{}不会被{}调用。在

收起

展开全文

python tornado websocket ping_tornado WebSocket详解

2021-01-15 03:40:19

1.什么是WebSocketwebsocket和长...2.tornado的WebSocket模块tornado在websocket模块中提供了一个WebSocketHandler类，这个类提供了和已连接的客户端通信的WebSocket事件和方法的钩子。open方法，新的WebSocket连...

1.什么是WebSocket
websocket和长轮询的区别是客户端和服务器之间是持久连接的双向通信。
协议使用ws://URL格式，但它在是在标准HTTP上实现的。
2.tornado的WebSocket模块
tornado在websocket模块中提供了一个WebSocketHandler类，这个类提供了和已连接的客户端通信的WebSocket事件和方法的钩子。
open方法，新的WebSocket连接打开时被调用。
on_message方法：连接收到新消息时被调用。
on_close方法：客户端关闭时被调用。
write_message方法：向客户端发送消息时被调用。
close方法：关闭连接时调用。
3.WebSocket使用示例
1)和http长轮询中示例一样，区别在于“主页长轮询商品当前库存”的方式。
classWebSocketHandler(tornado.websocket.WebSocketHandler):defopen(self):
self.application.shoppingCart.register(self.callback)defon_close(self):
self.application.shoppingCart.unregister(self.callback)defon_message(self):pass
defcallback(self,count):
self.write_message('{"inventorycount":"%s"}'%count)
on_close方法：在客户端关闭时被调用。
on_message方法：因为服务端不需要接收客户端消息，所以这里是个空函数
2)客户端WebSocket请求如下
functionrequestInventory() {var host = 'ws://localhost:9999/websocket';var websocket = newWebSocket(host);
websocket.onopen= function(evt) { };
websocket.onmessage= function(evt) {
$('#count').html($.parseJSON(evt.data)['inventoryCount']);
};
websocket.οnerrοr= function(evt) { };
}
3)运行结果
打开多个客户端，当做添加/删除操作时，可以观察到库存数量会实时变动。
4.WebSocket和长轮询
WebSocket和长轮询的不同之处在于使用了一个持久的长连接，来代替长轮询中循环发送请求连接。

收起

展开全文

Tornado WebSocket
2019-07-24 03:10:29
WebSocket协议 WebSocket是基于HTML5规范的网络协议，它实现了浏览器与服务器之间全双工full-duplex通信，即允许服务器主动发送消息给客户端。 WebSocket通信协议于2011年被IETF定为标准RFC 6455，并被RFC 7936所...
收起
python tornado websocket_关于tornado websocket的使用
2020-12-04 09:15:26
现在的情况是这样，tornado的7999端口同时运行着两个app，一个http协议，一个websocket协议，localhost上均正常，但是在服务器上，websocket无法握手成功，直接timeout，各位有相关的经验吗？前端代码：//初始化...
收起
python tornado websocket_python tornado websocket 实时日志展示
2020-12-04 09:15:28
一、主题：实时展示服务器端动态生成的日志文件二、流程：1. 客户端浏览器与服务器... tornado 处理器接收到新内容，通过 websocket 向保存的客户端链接返回新行4. 客户端浏览器接收到新内容，修饰，展示三、代码：...
收起
初识tornado和tornado websocket
2018-05-17 20:35:00
Tornado是一个轻量级的Web框架，异步非阻塞+内置WebSocket功能。安装：pip3 install tornado tornado websocket示例 import tornado from tornado.web import Application from tornado.web import ...
收起
python tornado websocket_python tornado websocket 多聊天室（返回消息给部分连接者）
2020-12-04 09:15:25
1 #-*-coding:utf-8-*-2 __author__ = 'zhouwang'3 importjson4 importtornado.web5 importtornado.websocket6 importtornado....
收起
python tornado websocket_python在tornado下websocket客户端
2020-12-04 09:15:27
from tornado import httpclientfrom tornado import ioloopfrom tornado import websocketimport uuidimport binasciiimport structimport weakrefDEFAULT_CONNECT_TIMEOUT = 60DEFAULT_REQUEST_TIMEOUT = 60def my...
收起
python tornado websocket ping_Tornado 之 WebSocket
2021-01-28 19:14:00
WebSocket 是独立的、创建在 TCP 上的协议，和 HTTP 的唯一关联是使用 HTTP 协议的101状态码进行协议切换，使用的 TCP 端口是80，可以用于...WebSocket 使得客户端和服务器之间的数据交换变得更加简单，允许服务端直...
收起
手搓的tornado websocket
2018-11-12 17:36:39
自己手搓的tornado的 websocket实例demo，我就是为了水几个下载币，如果你没有下载币的话，就联系我814,382,690,@扣扣邮箱
收起
tornado websocket 笔记
2021-03-08 20:55:41
Tornado对异步的支持比较好，与websocket 搭配实现监控类的应用更为简便些。在tornado的github 上有关于websocket的一个聊天室应用示例。实际代码部分如下： class ChatSocketHandler(tornado.websocket....
收起
tornado websocket调用时出现403错误
千次阅读 2017-10-30 10:00:45
tornado websocket 实现的时候，调用可能出现403的错误，这个是tornado 4.0增加的特性，如果想允许所有的访问，针对websocket处理类重写同源检查的方法： class WebSocketHandler(tornado.websocket....
收起
python tornado websocket_Python中Tornado下WebSocket客户端编程的介绍
2021-03-17 02:30:27
本篇文章给大家带来的内容是关于Python中Tornado下WebSocket客户端编程的介绍，有一定的参考价值，有需要的朋友可以参考一下，希望对你有所帮助。由于WebSocket是HTML5的标准之一，所以主流浏览器的Web客户端编程...
收起
tornado websocket 学习历程
2015-09-01 21:50:13
听同事说了用websocket可以实现实时，...2.看了下tornado websocket源码、注释（google翻译），好痛苦 3.网上找了个例子，但是用不了，自己改了些东西，简单实现从web端发一个string，经过server，再回到web端显示出来
收起
python tornado websocket_基于Python Tornado框架的websocket服务
2020-12-04 09:15:27
Tornado中定义了tornado.websocket.WebSocketHandler来处理websocket请求。Tornado框架的安装以及入门这里就不说了，想入门tornado的请移步我的另一篇文章奥小飞：基于Python的Tornado框架入门zhuanlan.zhihu....
收起
一个tornado websocket 客户端例子
千次阅读 2016-04-01 14:19:31
An example of tornado websocket client to show: 1, how to use tornado client 2, auto reconnect when lost the connection github 地址 https://github.com/gjwang/towsclient# -*- coding: utf-8 -*-''' ...
收起
Python
tornado websocket编程(1) 初识websocket ——简单购物车实现
千次阅读 2016-08-24 01:37:49
tornado websocket编程：初识websocket ——简单购物车实完整代码：https://github.com/wskssau/my_notespace/tree/master/python/tornado_exercise WebSocket相关资料，第一次听过websocket的童鞋可以阅读下 ...
收起
简单tornado websocket服务器
千次阅读 2019-04-02 18:40:41
所有的实现都是通过tornado中的这个模块进行的二次开发，我们需要继承：tornado.websocket.WebsocketHandler 其中我们需要复写其中的四个方法： 1、open() 这个方法是在刚开始连接过来的时候会触发这个方法，我们...
收起
tornado websocket transport support
2020-12-09 14:11:20
<div><p>it seems there is a bug in <a href="https://github.com/miguelgrinberg/python-engineio/blob/master/engineio/async_drivers/tornado.py#L30">upgrade</a></p> <pre><code>bash super().get() </code></...
收起
python tornado websocket
2020-11-26 11:16:54
主网站启动代码 #完整打分流程V2 import os import os.path import sys # sys.path.apend() #解决yolov5的反序列化问题 start import os,sys root_path = os.getcwd() ...import tornado.ioloop import t
收起
tornado websocket模块
2020-02-09 16:29:35
websocket """ 概述 HTML5 中提出的新的客户端-服务器通信协议，本身使用新的 ws://url 创建在TCP协议之上，和HTTP的唯一关系是使用HTTP协议的101状态码使用客户端与服务端之间的数据交互更加简单，允许服务器直接...
收起
python