2

我刚开始使用 Crossbar.io 来实现实时统计页面。我查看了很多代码示例，但我无法弄清楚如何做到这一点：

我有一个 Django 服务（为了避免混淆，你可以假设我在谈论 views.py 中的一个函数），我希望它在特定主题中发布消息，只要它被调用。我见过这些方法：（1）扩展 ApplicationSession和（2）使用“运行”的 Application 实例。

它们都不适合我，因为 Django 服务不存在于类中，也不作为独立的 python 文件执行，所以我找不到调用“发布”方法的方法（即我唯一想在服务器端做的事情）。

我试图获取“StatsBackend”的一个实例，它扩展了ApplicationSession，并发布了一些东西......但是StatsBackend._instance总是无（即使我执行'crossbar start'并且调用了StatsBackend.init （））。

统计后端.py：

from twisted.internet.defer import inlineCallbacks
from autobahn import wamp
from autobahn.twisted.wamp import ApplicationSession

class StatsBackend(ApplicationSession):

    _instance = None

    def __init__(self, config):
        ApplicationSession.__init__(self, config)
        StatsBackend._instance = self

    @classmethod
    def update_stats(cls, amount):
        if cls._instance:
            cls._instance.publish('com.xxx.statsupdate', {'amount': amount})

    @inlineCallbacks
    def onJoin(self, details):
        res = yield self.register(self)
        print("CampaignStatsBackend: {} procedures registered!".format(len(res)))

测试.py：

import StatsBackend

StatsBackend.update_stats(100) #Doesn't do anything, StatsBackend._instance is None
4

2 回答 2

6

Django 是一个阻塞的 WSGI 应用程序，它不能很好地与非阻塞（在 Twisted 或 asyncio 之上运行）的 AutobahnPython 融合。

但是，Crossbar.io 有一个内置的 REST 桥，其中包括一个HTTP 推送器，您可以通过任何支持 HTTP/POST 的客户端向其提交事件。Crossbar.io 会将这些事件转发给常规的 WAMP 订阅者（例如通过实时 WebSocket）。

Crossbar.io 还附带了一个完整的应用程序模板来演示上述功能。尝试：

cd ~/test1
crossbar init --template pusher
crossbar start

http://localhost:8080在（打开 JS 控制台）和第二个终端中打开浏览器

curl -H "Content-Type: application/json" \
   -d '{"topic": "com.myapp.topic1", "args": ["Hello, world"]}' \
   http://127.0.0.1:8080/push

然后，您可以在 Django 等阻塞应用程序中进行发布。

于 2014-10-08T19:14:46.827 回答
0

我找到了我需要的东西：可以通过 HTTP POST 请求发布主题。

您可以阅读文档以获取更多信息：https ://github.com/crossbario/crossbar/wiki/Using-the-REST-to-WebSocket-Pusher

于 2014-10-07T19:17:37.060 回答