crossbar

    0热度

    1回答

    据我所知(请做正确的误解,很明显),所提到的项目/技术如下: - Crossover.io - 一种WAMP路由器。跨语言。 WAMP - 异步消息传递协议,支持(除其他外)Pub/Sub和RPC。跨语言。 扭曲 - 一个异步循环,主要用于联网(低级别)。 Python的具体。据我所知,python中的当前crossover.io实现建立在扭曲之上。 klein - 建立在扭曲的仿真烧瓶顶部,但是

    1热度

    1回答

    我有一个路由器,一台服务器和多个客户端。服务器在路由器中注册方法,客户端成功调用方法并获得结果。在某些情况下,我需要服务器向特定客户端询问一些事情。我已经有sessionId使用WampInvocationContext.Current.InvocationDetails,但我不知道客户端如何注册他们的方法,也不知道如何从服务器调用它们。 我查看了文档,但没有运气。 wamp-proto实际上是否

    1热度

    2回答

    我使用crossbar.io撰写聊天。我们有几个聊天节点。 我需要写关于每个节点的统计信息,这就是为什么我需要获取运行特定节点的主机名。 是否有可能从组件实例获取主机名? 我使用crossbar/autobahn和python 3.4的最新版本。 期望得到 - 127.0.0.1如果我使用本地环境。

    1热度

    1回答

    我有一个使用高速公路的ApplicationRunner类连接到WAMP路由器(交叉开关)的高速公路客户端。在主要部分,它十分重视我ApplicationSession类“再调度”是这样的: if __name__ == '__main__': from autobahn.twisted.wamp import ApplicationRunner runner = Appli

    0热度

    1回答

    有没有一种方法可以使用crossbar.io服务器以多线程模式启动Flask应用程序?

    0热度

    1回答

    我即将设计一个基于高速公路的系统。我经常遇到以下模式: 客户端可以通过RPC题目要求全额状态 - 例如,中投例子 更新这个状态的所有选票是由服务器发布 - 例如更改了特定主题的投票 客户通过组合完整状态和更新来跟踪当前状态。 的问题如下: 有查询状态和出版变化之间的潜在的竞争,由于高速公路的异步特性。 虽然在服务器端计算状态,但更新可能已发送到客户端。 一旦客户端收到完整的状态,它不再是最新的。必

    1热度

    1回答

    我想通过使用crossbar/autobahn的RPC的websockets传输大数据。我的设置是如下: 的Python 2.7 横杆路由器(17.8.1.post1版) 后端会试图发送一个大的熊猫数据帧作为一个JSON字符串 想要接收此字符串的前端 实质上,我的前端尝试调用一个将返回大字符串的函数。 class MyComponent(ApplicationSession): @inline

    1热度

    1回答

    有什么方法可以获取有关谁(authid)发布给定消息或调用RPC的元数据?在我让用户对特定角色进行身份验证和授权后(例如,允许他们发布到mychat),我怎样才能防止客户欺骗对方的名字?订阅者/被调用者只传递发布者/调用者传递的参数;我看不到如何获取会话数据。 解决方法可能是使用dynamic authorization,其中每个客户端只被授权发布到mychat.<userid>,但看起来很糟糕。

    0热度

    1回答

    我有一个程序注册一个RPC函数,例如。 com.myapp.foo。然后我在几个独立的设备上运行这个程序,全部连接到同一个路由器。 当我启动第二个设备时,由于RPC功能已被注册(wamp.error.procedure_already_exists),所以出现错误。 这很有意义,因为路由器需要一个唯一的名称才能正确路由过程调用。但在我的情况下, 我的第一个想法是,每个设备应该生成一个独特的过程名称

    3热度

    1回答

    我目前正试图通过Crossbar/Autobahn使用Websockets实现用户通知系统。我已经做了多次试验,并经历的文档,但是,我不知道是否有具有以下工作流程的解决方案:在Web应用程序 用户的迹象 - 这是通过JWT 完成 Frontend建立与正在运行的crossbar实例的websocket连接。 前端尝试订阅特定于用户通知的URI:即com.example.notifications.