22得票3回答
Python - 在单独的子进程或线程中运行Autobahn|Python asyncio websocket服务器

我有一个基于tkinter的GUI程序,运行在Python 3.4.1上。程序中有几个线程从各种URL获取JSON数据。我想添加WebSocket功能,以使程序能够作为服务器运行,并允许多个客户端通过WebSocket连接并交换其他JSON数据。 我尝试使用Autobahn|Python W...

15得票1回答
使用Python Twisted和Autobahn从Matlab发送JSON数据到WebSocket

我正在尝试从Matlab创建一个连接,以便通过WebSocket流式传输JSON帧。我已经使用以下方式测试了我的autobahn和twisted的python安装。 工作示例 Matlab代码 样本驱动程序代码,使用JSONlab工具箱将Matlab数据转换为JSON格式,然后对数据进行...

13得票1回答
Autobahn:从外部应用程序发送用户特定和广播消息

完全不了解WebSocket。 我有点难以理解如何从另一个应用程序与Python Autobahn / twisted进行交互,也似乎找不到任何有用的例子。 我有一个正在运行的Python应用程序,需要在某些事件发生时发送两种类型的消息。第一种是向所有用户发送广播消息。第二种类型是发送给单...

13得票2回答
如何使用ngrok将本地WebSocket服务器转发

我想在本地主机上运行一个WebSocket服务器,并使用ngrok将其转发到Web,但无法弄清楚如何操作。以下是来自AutobahnPython git存储库的原始代码: https://github.com/tavendo/AutobahnPython。 服务器代码:from autoba...

10得票1回答
扭曲的WebSocket聊天服务器OpenID身份验证

我有一个使用Twisted和Autobahn WebSockets进行连接的Python聊天服务器。factory = MessageServerFactory("ws://localhost:9000", debug=debug, debugCodePaths=debug) factory....

9得票1回答
Autobahn,在 onMessage 块中离开

我有一个带有典型的“onX”函数协议的Autobahn Websocket服务器。我的问题是,我找不到一种方法来退出“onX”,同时保持在特定消息到达时想要执行的各种操作。更具体地说,在我的“onMessage”函数中,有时会对非常慢的API进行HTTP请求。结果,发送Websocket消息的...

8得票1回答
什么是通过 "twisted" 方式从 RabbitMQ 消费消息并将其转发到客户端连接的方法?

我正在使用twisted写一个websocket服务器来学习这个框架。它将从rabbitmq代理接收消息,并向连接的客户端发送更新。如果我想通过许多客户端连接广播/多播许多消息,那么调用(只是作为示例)deferToThread(channel.basic_consume,queue)或cal...

8得票1回答
AutobahnJS领域的用途是什么?

我想知道AutobahnJS中神秘的realm字段是什么意思。从文档中看,创建连接的方式如下: var connection = new autobahn.Connection({ url: 'ws://127.0.0.1:9000/', realm: 'realm1' })...

8得票1回答
WebSocket 在发送 1000 条消息后关闭。

我正在编写一个应用程序,使用WebSocket从Apache Kafka向浏览器流式传输消息。当服务器一段时间内没有消费消息并且偏移量落后时,websocket会在1000或2000条消息后关闭。这个数字似乎每次测试运行都会交替出现。消息是utf8编码的,通常在8字节片段中长度为130-140...

8得票1回答
如何将PyPi依赖项添加到DEB软件包

我使用autobahn创建了一些python应用,并使用baazaar builddeb进行打包。在python的setup.py文件中,我使用requires标签添加了所有必需的依赖项。是否可以告诉debian软件包安装程序来安装这些软件包? 我将一些依赖项添加到debian/contro...