Autobahn从外部应用程序发送特定用户和广播消息

Question

对于WebSockets来说是全新的。

谢谢

Answer 1

首先，Autobahn项目提供了通信协议WAMP的开源实现。WAMP提供了两种通信模式RPC（Remote-Procedure-Call）和PUBSUB（Publish-Subscribe）。因此，在您的情况下，有必要弄清楚这两种模式中哪一种适合您的需要。

RPC

根据WAMP FAQ RPC，RPC涉及三个角色。这些建议是：

null

null

------编辑-------

目前尚不清楚“外部应用程序”是什么意思，也不清楚它应该用什么语言编写。如果外部应用程序是用python、JavaScript或Cpp编写的，或者是使用Autobahn框架和(WAMP)编写的Android应用程序，则可以解决作者所解释的问题。

正如问题中提到的，Autobahn还提供了一个websocket协议实现。解决该问题的另一种方法是使用Autobahn Websockets,并为“外部应用程序”选择Websocket实现。Autobahn提供Python和Android Websocket解决方案。当然，还有更多的Websocket库或模块可用。Java Websocket库、Python Websocket客户端模块等...

{
    "type": "broadcast",
    "msg": "your_message"
}

{
    "type": "single",
    "elegible": ["IP_1", "???"],
    "msg": "your_message"
}

import sys

from twisted.internet import reactor
from twisted.python import log
from twisted.web.server import Site
from twisted.web.static import File

from autobahn.twisted.websocket import WebSocketServerFactory, \
    WebSocketServerProtocol, \
    listenWS


class BroadcastServerProtocol(WebSocketServerProtocol):

    def onOpen(self):
        self.factory.register(self)

    def onConnect(self, request):
        print("Client connecting: {}".format(request.peer))

    def onMessage(self, payload, isBinary):
        if not isBinary:
            if "send_broadcast" in payload.decode('utf8'):
                msg = "Send broadcast was ordered"
                self.factory.broadcast(msg)

    def connectionLost(self, reason):
        WebSocketServerProtocol.connectionLost(self, reason)
        self.factory.unregister(self)


class BroadcastServerFactory(WebSocketServerFactory):

    """
    Simple broadcast server broadcasting any message it receives to all
    currently connected clients.
    """

    def __init__(self, url, debug=False, debugCodePaths=False):
        WebSocketServerFactory.__init__(self, url, debug=debug, debugCodePaths=debugCodePaths)
        self.clients = []
        self.tickcount = 0
        self.tick()

    def tick(self):
        self.tickcount += 1
        self.broadcast("tick %d from server" % self.tickcount)
        reactor.callLater(1, self.tick)

    def register(self, client):
        if client not in self.clients:
            print("registered client {}".format(client.peer))
            self.clients.append(client)

    def unregister(self, client):
        if client in self.clients:
            print("unregistered client {}".format(client.peer))
            self.clients.remove(client)

    def broadcast(self, msg):
        print("broadcasting message '{}' ..".format(msg))
        for c in self.clients:
            c.sendMessage(msg.encode('utf8'))
            print("message sent to {}".format(c.peer))


class BroadcastPreparedServerFactory(BroadcastServerFactory):

    """
    Functionally same as above, but optimized broadcast using
    prepareMessage and sendPreparedMessage.
    """

    def broadcast(self, msg):
        print("broadcasting prepared message '{}' ..".format(msg))
        preparedMsg = self.prepareMessage(msg)
        for c in self.clients:
            c.sendPreparedMessage(preparedMsg)
            print("prepared message sent to {}".format(c.peer))


if __name__ == '__main__':

    if len(sys.argv) > 1 and sys.argv[1] == 'debug':
        log.startLogging(sys.stdout)
        debug = True
    else:
        debug = False

    ServerFactory = BroadcastServerFactory
    # ServerFactory = BroadcastPreparedServerFactory

    factory = ServerFactory("ws://localhost:9000",
                            debug=debug,
                            debugCodePaths=debug)

    factory.protocol = BroadcastServerProtocol
    factory.setProtocolOptions(allowHixie76=True)
    listenWS(factory)

    webdir = File(".")
    web = Site(webdir)
    reactor.listenTCP(8080, web)

    reactor.run()

客户机客户机也是使用不同的模块实现在Python中编写的，并且仍然可以工作。当然，使用Websocket协议与Websocket服务器通信是必要的。

from websocket import create_connection
ws = create_connection("ws://localhost:9000")
print "Sending 'send_broadcast'..."
ws.send("send_broadcast:PAYLOAD")
print "Sent"
print "Reeiving..."  # OPTIONAL
result = ws.recv()   # OPTIONAL
print "Received '%s'" % result    # OPTIONAL
ws.close(

）