腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
在
'
on_message
‘
处理
过程中
收到
的
Websocket
消息
会被
跳过
吗
?
、
我使用
的
是python
websocket
-client模块。 我正在尝试做
的
是监听一个
websocket
,并
处理
输入到我
的
数据库中
的
消息
。我
的
问题是,
在
处理
最新
消息
的
过程中
传入
的
消息
是否会导致以下
消息
丢失? 如果是这样的话,我该如何着手解决这个问题呢? 谢谢。
浏览 38
提问于2021-05-11
得票数 0
1
回答
websocket
与websockets
的
区别
、
、
、
我不明白
websocket
(
websocket
客户端)和websockets之间
的
区别。我想了解其中
的
不同之处,以了解哪种方法是最优
的
。 'args': ['instrument:XBTUSD'] ws.send(json.dumps(auth_data)) def
on_message
(so
浏览 228
提问于2020-05-20
得票数 11
1
回答
如何使用ws-rs异步发送
websocket
事件?
如何使用异步发送
websocket
消息
? 每1%
的
更改服务器都会以更新响应。
在
我
的
情况下,
处理
需要很长时间,并且应该报告数据,同时,用户将在
处理
浏览 3
提问于2019-12-31
得票数 1
回答已采纳
1
回答
如何组织带有
websocket
突变
的
vuex
、
、
我使用vue+vuex+vue-本机-
websocket
。根据使用vuex
处理
websocket
消息
的
文档,我应该使用SOCKET_.突变。目前,我
处理
存储/index.js文件中
的
所有
消息
,如下所示:...case 'otherDataRsp' }我想要
的
是
处理
user.js vuex模块中
的
所有与用
浏览 0
提问于2018-04-03
得票数 5
1
回答
Python类之间
的
异步通信
、
、
、
、
我实现了一个连接到
websocket
以接收异步
消息
的
类。self.
websocket
.start() return self.
websocket
心跳函数启动
websocket
并返回它。
websocket
类本身有一个
on_message
()函数,该函数充当每次
收到
新
消息
时都会触发
的
回调函数。我不想时不时地调用某个函数来将最新<em
浏览 26
提问于2018-06-24
得票数 1
1
回答
如何将多进程委托给
websocket
(
on_message
)
的
内部函数?
、
、
、
我正在试图找到一种方法,
在
我
的
websocket
def
on_message
()函数
的
两个内部函数之间委派我
的
计算机
处理
能力。而且,我
的
代码似乎
跳过
了def
on_message
(),我不太确定是否需要在args中声明这些内部函数?import concurrent.futures as mp Stock_stream = 'wss:
浏览 7
提问于2020-07-10
得票数 0
1
回答
Python Asyncio帮助....我这样做对
吗
?
、
、
程序监听
websocket
。当
收到
某条
消息
时,我们需要等待5秒,然后向另一台服务器运行restapi调用。 它与我能够手动触发
的
单个
websocket
消息
一起工作。但是,将会有大量
的
websocket
消息
,我将每秒
处理
大约50-100条
消息
。我不确定我
的
方法是否正确。我希望asyncio也是适合这项工作
的
工具,或者如果我应该用线程做一些事情。另外,我是否需要在ws
浏览 1
提问于2020-05-14
得票数 0
1
回答
龙卷风
websocket
消息
没有接
收到
、
、
我有一个非常简单
的
设置,灵感来自于这个问题:因此,我创建了一个TestHandler实例
的
全局列表,并使用它向所有实例广播
消息
。ws_clients.append(self) self.random_number
浏览 0
提问于2018-06-22
得票数 1
回答已采纳
1
回答
python龙卷风
websocket
服务器
的
瓶颈
、
、
、
我有一个
websocket
服务器,是用python龙卷风编写
的
。服务器将从客户端接收许多连接,如您所知,我们有
on_message
函数,当
收到
websocket
消息
时会触发它。因此,我
的
问题是,如果
消息
(例如来自客户端
的
请求)需要
处理
5秒,那么当服务器
处理
某个请求时,服务器将进入阻塞模式,无法接受或接收更多
的
连接或数据。经过一些研究,我发现Asyncio可以解决我
的</em
浏览 0
提问于2018-07-03
得票数 0
回答已采纳
1
回答
如何同时
处理
多个
websocket
消息
?
、
、
、
我需要侦听
websocket
以获取
消息
,因此我设置了以下代码: import websockets my_socket = "ws://.......# .. so it does no hold process for itself 我想做
的
是: 收听留言
消息
一到达,就应用各种操作
on_message
()函数,持续几分钟 当之前
的
消息
仍在
处理
中时,继续监听
消息
o
浏览 235
提问于2021-02-27
得票数 6
回答已采纳
1
回答
从Tornado
WebSocket
服务器主动发送
消息
、
、
、
我有一台Python
WebSocket
服务器。这可以
在
收到
消息
时返回响应。self): self.write_message("You are connected") application.listen(8888) tornado.ioloop.IOLo
浏览 3
提问于2017-08-18
得票数 5
回答已采纳
2
回答
如何限制龙卷风
websocket
消息
大小
、
、
我已经用龙卷风编写了一个
websocket
服务器,并在接
收到
消息
时调用
on_message
方法。问题是,
消息
大小是无限
的
,换句话说,通过从客户端向
websocket
发送大量数据(
消息
)来打开该项目,从而使服务器端内存满。必须有一个选项来限制传入
消息
的
大小,是
吗
?如果没有,我要怎么做才能避免这样
的
错误? 这里是我
的
代码,用于获取长度小于128个字节
的</em
浏览 17
提问于2017-11-22
得票数 2
回答已采纳
2
回答
Asyncio: Fastapi和aio-pika,消费者忽略等待。
、
、
、
、
我正在尝试将我
的
websocket
端点与rabbitmq (aio-pika)连接起来。目标是
在
该端点中有侦听器,并在队列中
的
任何新
消息
上通过websockets将
消息
传递给浏览器客户端。我
在
一个具有异步循环
的
脚本中使用异步来测试使用者。我跟踪并使用了aio-pika文档。(资料来源:,worker.py)await queue.co
浏览 2
提问于2021-01-28
得票数 3
回答已采纳
1
回答
打印功能无法
在
Juypter笔记本
的
功能中工作
、
打印
在
执行中不工作,是打印接
收到
的
消息
,而不是打印
消息
本身,即打印(
消息
)没有显示出任何输出在juypter笔记本上。import
websocket
from __future__ import print_function print('opened connection') def on_
浏览 1
提问于2021-12-09
得票数 1
1
回答
在
python web爬虫中使用
websocket
-- rsv还没有实现。
、
、
、
我使用
websocket
成功地与目标wss-url建立了长时间
的
连接。但是
在
收到
一条
消息
后,代码捕获了一个名为"rsv尚未实现“
的
错误,并关闭了连接。而且
websocket
的
API文档也没有提到这个问题。我代码
的
主要部分是: print(message) print("!#
浏览 0
提问于2018-10-17
得票数 1
1
回答
使用Python
websocket
客户端访问传入
消息
、
、
我正在尝试通过
websocket
-client模块接收
消息
,并能够将接
收到
的
消息
用于其他目的(例如,根据传入
消息
执行买入/卖出订单)。这是我到目前为止所知道
的
: import
websocket
import json try:(current_price),因为它们是通过其
websocket
提要传入
的</e
浏览 16
提问于2020-05-01
得票数 0
回答已采纳
1
回答
AttributeError:模块'
websocket
‘没有属性'WebSocketApp’
、
相关代码片段:导入
websocket
def on_close(ws):blahblahblahws =
websocket
.WebSocketApp(套接字、on_open=on_open、on_close=on_close、
on_message
=
on_message
)我
浏览 11
提问于2021-05-11
得票数 0
1
回答
将附加参数传递给只需1
的
回调对象。
、
、
、
、
因此,我正在做一个小项目,我使用
websocket
客户端库,为了创建一个WebSocketApp对象来
处理
websocket
连接,您可以使用以下内容实例化这个对象 ws =
websocket
.WebSocketApp它
处理
传入
的
消息
,或者更确切地说,如何
处理
它们,并由我创建
的
ws对象调用,当一个完整
的
消息
出现时(显然)。
on_message
定义为实例化WebSocketApp对象
浏览 2
提问于2021-07-09
得票数 0
回答已采纳
2
回答
何时
在
STOMP中向队列侦听器发送ACK或NACK
、
、
说: function
on_message
(message) message.ack
浏览 2
提问于2020-02-12
得票数 1
回答已采纳
1
回答
等待变量更改
、
、
我有一个包含
websocket
客户端WebSocketApp
的
类,它是在线程中启动
的
。
websocket
连接接收
消息
并相应地设置一些类变量。一个例子是登录:发送了一个登录
消息
,过了一会儿,
on_message
函数接
收到
一个成功
的
登录
消息
。当函数捕获此
消息
时,将self.logged_in变量设置为true。目前,我
在
“等待”变量成为真使用繁忙
的
等待,这显然不是很好
浏览 8
提问于2022-05-13
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
使用Java搭建小程序WebSocket服务器
搭建websocket消息推送服务,必须要考虑的几个问题
Django Channels实时推送
基于 Swoole 的微信扫码登录
SpringBoot-系列二:使用websocket
热门
标签
更多标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM
活动推荐
运营活动
广告
关闭
领券