问题标签 [autobahn]

我想知道为什么 AutobahnJS 的发布方法上没有定义回调？我认为对于尝试发布某些内容的客户来说，了解他们的发布调用是否成功并做出相应的反应会很有用。我想知道其他支持 pub/sub 的框架是否有这样的发布回调。

我正在尝试为 Android 使用开发的一些 websocket 客户端库。我现在正在摆弄 AutoBahn 库，似乎无法让“示例”客户端连接到我的服务器。我正在使用以下代码：

我用wireshark嗅探，可以看到建立的tcp连接，我可以看到HTTP Get出去了。但是，我的服务器没有响应升级消息。我确实注意到 AutoBahn 连接消息（在 HTTP GET 标头中）由于某种原因不包含源字段。我尝试了一个不同的库，它确实连接了，它在 HTTP GET 中有源字段。这是一个已知问题，还是 AuotBahn 根本不支持？

我对 websockets 很陌生，并且一直在尝试将 python 与高速公路一起使用并扭曲连接到多个套接字，然后对来自每个不同套接字的数据执行不同的操作。

最后，我将拥有 3 到 4 个不同的处理功能和多达 10-15 个 websocket 连接。

我想将一个函数传递给协议以用于分析返回的数据。我遇到的问题是我能弄清楚访问 WebSocketClientProtocol 的“onMessage()”方法中的函数的唯一方法是为类而不是实际对象设置的，所以我坚持使用一个数据处理函数适用于所有 websocket。

下面的代码示例。

我目前的解决方案是为我想使用的每个数据处理函数创建一个类。所以，对于method1我有

和

以及我想使用的每种数据处理方法的类似类。

希望找到一个更优雅的解决方案，让我重用一个类。

谢谢，

使用高速公路、python 和 WAMP，WebSocket客户端是否可以注册 RPC 调用 - 基本上同时充当客户端和服务器？

例如，“聊天客户端”连接到已知 WS URI/端口上的“聊天服务器”并建立会话。客户端通过此 Web 套接字正常发送消息和接收响应。然后，服务器定期通过同一个Web 套接字向客户端发出随机 RPC 调用（通过 WAMP），请求对特定问题的回答。

客户端在伪代码中将执行以下操作：

也许我在 Twisted 的异步设计中遗漏了一些东西，但我似乎找不到“外部”调用 sendMessage() 方法的方法。我的意思是，发送消息而不仅仅是在 Twisted/AutobahnWebsockets 的回调方法中（例如在 onOpen 或在 onMessage() 从服务器接收数据时）

当然我可以启动一个线程并调用 my_protocol_instance.sendMessage("hello") 但这会破坏异步设计的所有目的，对吗？

在一个具体的例子中，我需要一个顶级包装类来打开连接并管理它，并且每当我需要时，我都会调用 my_class.send_my_toplevel_message(msg)。我该如何实施？

希望我的解释很清楚。

谢谢

在使用高速公路的发布和订阅模型中，我想限制给定订阅者的数量@exportSub(...)。你怎么知道订阅者的数量？

（来自示例）

我可能可以使用自己WampServerFactory的方法，覆盖onClientSubscribedandonClientUnsubscribed方法并使用内部数组变量来做到这一点......但我想知道是否有更清洁的方法......

代码可以在这里找到。

在高速公路 python 中，如果我的初始连接失败，似乎无法判断，或者我可以在WampClientProtocol子类中覆盖的任何回调。我尝试覆盖clientConnectionFailed，但连接失败时没有调用它。

连接失败时我得到的唯一输出是

我刚刚在我的 Windows 7 和 Ubuntu 上安装了Autobahn Testsuite 0.5.5 。每次我想运行它时，我都会遇到同样的错误。

我的设置：

• Python 2.7.5
• 安装工具 1.1.6
• 用于 Python 2.7 的 Twisted 13.1.0
• 高速公路Python 0.6.3

知道可能是什么原因吗？问候，亚当

Ubuntu 12.04

Windows 7的

我正在尝试将 json 内容从 url widh sendMessage 发送到客户端。

我得到错误

我正在尝试使用 websocket 编写客户端/服务器应用程序。我正在考虑使用 Autobahn websocket 作为我的通信媒介。客户端将向服务器发送命令以执行任务，然后等待服务器的一系列进度响应。在服务器中，我收到客户端的命令后，执行一系列任务，然后调用 self.sendMessage("percent completed") % (percent) 给客户端。我遇到的问题是 sendMessage 似乎缓冲了所有消息，然后在最后一次全部发送。关于如何解决这个问题的任何想法？这是来自 websocket/example/echo/server.py 的代码片段：

我希望客户端每 2 秒从服务器接收一条消息，而不是一次获取所有三条消息。