如何从AutobahnPython中的ApplicationRunner获取反应堆
我有一个Autobahn客户端，它使用Autobahn中的ApplicationRunner类连接到WAMP路由器(Crosbar)。在主要部分中，它按如下方式附加了我的ApplicationSession类“Rescheduler”： if __name__ == '__main__': from autobahn.twisted.wamp import ApplicationRu
..
autobahn相关内容
Autobahn.twisted.wamp.应用程序是否可以发布/订阅？
我想使用一些发布/订阅功能以及来自aubahn.twisted.wamp.Application的RPC 如果我可以不创建ApplicationSession类，我宁愿不这样做。 注册的RPC方法是否可以引起客户端订阅和发布？ 如果他们可以，请告诉我怎么做。 推荐答案 是，当然： def onEvent(msg): print("got event: {}".f
..
从自定义Autobahn WampClientProtocol外部调用发布
如何从协议类外部调用Autobahn/WAMP/TWISTED协议发布方法？ 我有一个基于https://github.com/tavendo/AutobahnPython/blob/master/examples/wamp/pubsub/custom/client.py的定制Python Autobahn客户端。我正在尝试从自定义WampClientProtocol类的外部发布事件，但遇到
..
使用tac文件运行twistd时出现Autobahn WebSocket问题
我有一个使用autobahnWebSocket框架实现的WebSocket服务器。WebSocket服务器在运行该程序时运行良好。但是，如果我使用twistd服务器运行器通过创建TAC文件作为扭曲服务来运行此程序，当任何客户端尝试建立连接并且握手失败时，我在服务器中得到以下错误。 2015-12-08 07:17:56,022 - CRITICAL - twisted.publishToNe
..
如何解决WebSocket ping超时？
运行以下代码时(理论上它应该每分钟发送一个值) from __future__ import print_function from twisted.internet.ssl import CertificateOptions options = CertificateOptions() from os import environ from twisted.internet.defer i
..
使用autbahn.asyncio.wamp无阻塞地运行多个ApplicationSession
我正在尝试同时运行两个autobahn.asyncio.wamp.ApplicationSession中的。以前，我使用this post's answer中建议的Autobahn库修改来完成此操作。我现在 需要更专业的解决方案。 搜索了一段时间后，this post appeared quite promising，但使用twisted库，而不是asyncio。我无法为autobahn库的
..
如何通过推送 api(WAMP 协议)更新 poloniex 订单簿
我在 poloniex.com 上制作剥头皮软件为此，我需要有关订单簿的最新信息.API DOCUMENTATION 谈到了推送 api.据我所知，它是这样工作的: 使用 returnOrderBook(公共方法 API)获取快照 从响应中获取序列号(seq key) 订阅使用快照序列号推送 api 接收新数据并对快照数据进行更正. log = new Logger('Polon
..
如何通过推送 api(WAMP 协议)更新 poloniex 订单簿
我在 poloniex.com 上制作剥头皮软件为此，我需要有关订单簿的最新信息.API DOCUMENTATION 谈到了推送 api.据我所知，它是这样工作的: 使用 returnOrderBook(公共方法 API)获取快照 从响应中获取序列号(seq key) 订阅使用快照序列号推送 api 接收新数据并对快照数据进行更正. log = new Logger('Polon
..
连接到 Poloniex Push-API
我想连接到 Poloniex 的 Push API.他们在他们的页面上写了以下内容: 为了使用推送 API，请连接到 wss://api.poloniex.com 并订阅所需的提要. wss = WebSocket Secure -> SSL 保护 他们还给出了 Node.js 和 Autobahn|JS 的示例: var autobahn = require('autobah
..
使用 autobahn.js 的浏览器客户端无法连接到 Ratchet Websocket 服务器
我遇到了一个问题:我使用 PHP Ratchet 开发了一个 Ratchet Web Socket Serversocketo.me 我的服务器已启动并正在侦听端口 8082 : require 'vendor/autoload.php';$loop = React\EventLoop\Factory::create();$pusher = new MyApp\Pusher;//监听 we
..
带有使用线程和扭曲的 sendMessage 的高速公路
从这个线程(sendMessage from external in autobahn running in单独的线程)我试图让下面的代码工作. 但我收到以下错误: 文件“/usr/local/lib/python2.7/dist-packages/autobahn/websocket/protocol.py"，第 2421 行，在 sendMessage 中断言(类型(有效载荷)==字
..
覆盖 Autobahn/Twisted WebsocketClientProtocol 类
我想覆盖我的 WebSocketClientFactory 类以允许传入数据填充作业队列.这是我正在尝试的连接代码 factory = WebSocketClientFactory("ws://localhost:7096")job_queue = Queue.Queue()factory.protocol = BridgeSocket(job_queue)连接WS(工厂) 这是我的套接字类
..
如何通过 modbus/TCP 异步读取数据并将它们发送到网络
我需要从通过以太网 (modbus/TCP) 连接的设备接收数据并将其发送到网页(可能使用网络套接字). 我找不到好的例子.现在我可以使用 ModbusClientProtocol.read_input_registers() 连接驱动程序并打印值，但我必须创建自己的工厂和协议类.我正在使用高速公路、扭曲、pymodbus. 解决方案 我对 modbus 或 pymodbus 不熟悉
..
高速公路从外部应用程序发送特定于用户的消息和广播消息
对 websockets 完全陌生. 我在理解如何与 python Autobahn/twisted from another application 交互时遇到了一些麻烦，似乎找不到任何有用的示例. 我有一个 Python 应用程序正在运行，它需要在某些事件上发送两种类型的消息之一.第一个是对所有用户的广播消息.第二种是针对单个特定用户. 使用以下两个示例，我可以接收消息并发送
..
如何创建一个带有两个线程的 python 应用程序，每个线程都有一个高速公路应用程序
我还没有找到任何解决我的问题的方法.我需要创建一个带有两个线程的 python 应用程序，每个线程都使用高速公路库连接到 WAMP 路由器. 按照我写的实验代码: wampAddress = 'ws://172.17.3.139:8181/ws'wampRealm = 's4t'从线程导入线程从 autobahn.twisted.wamp 导入 ApplicationRunner从 aut
..
如何从协议之外发送高速公路/扭曲 WAMP 消息?
我正在关注 github 代码: 这个例子从类中发布消息: 类组件(ApplicationSession):"""每秒发布一个事件的应用程序组件."""def __init__(self, realm = "realm1"):ApplicationSession.__init__(self)self._realm = 领域def onConnect(self):self.join(self
..
Python - 在单独的子进程或线程中运行高速公路|Python asyncio websocket 服务器
我有一个在 Python 3.4.1 中运行的基于 tkinter 的 GUI 程序.我在程序中运行了几个线程来从各种 url 获取 JSON 数据.我想添加一些 WebSocket 功能，以便允许程序充当服务器并允许多个客户端通过 WebSocket 连接到它并交换其他 JSON 数据. 我正在尝试将 Autobahn|Python WebSocket 服务器用于 asyncio.
..
使用 Autobahn Testsuite 进行 Websocket 压力测试
我尝试对我的 websocket 服务器进行一些压力测试.在客户端，我运行以下脚本 从此站点 : 导入时间，sys从twisted.internet 导入延迟，反应器fromtwisted.internet.defer import Deferred, returnValue, inlineCallbacks从 autobahn.twisted.websocket 导入 connectWS，\
..
PHP 实时聊天 +Redis +Pub/Sub +WebSockets (+NodeJS)
我想开发与频道的实时聊天，这是我的需求: 用于管理站点的 PHP 后端 Redis 作为会话和数据的主存储 Pub/Sub 仅向频道感兴趣的用户发送消息 一个用于发送和接收消息的 WebSocket 连接. (可选)NodeJS 使用很棒的 npm 包，例如 timesync 或 socket.io 我看到了两种不同的架构来实现这一点: 使用 Socket.io 使
..
在高速公路的pubsub中获取初始值的设计模式
通常，发布-订阅模式与获取内容更新有关.但是，订阅者如何获得订阅更新之前的初始内容? 我在我的应用程序的高速公路框架内使用发布-订阅示例.当关节移动时，发布者后端发布机器人关节的位置.客户端前端有时稍后会订阅该主题.由于数据的性质，客户端上“主题"的初始值与发布者随后进行的更新一样重要.因此，在建立成功的连接之后，我想获取该主题的“当前"值. 框架内是否可以使用某种类型的设计模式来获取
..