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