如何从协议之外发送高速公路/扭曲WAMP消息

Question

我遵循github代码中的基本wamp-pubsub示例：

此示例发布类中的消息：

class Component(ApplicationSession):
   """
An application component that publishes an event every second.
"""
   def __init__(self, realm = "realm1"):
      ApplicationSession.__init__(self)
      self._realm = realm

   def onConnect(self):
      self.join(self._realm)

   @inlineCallbacks
   def onJoin(self, details):
      counter = 0
      while True:
         self.publish('com.myapp.topic1', counter)
         counter += 1
         yield sleep(1)

我想创建一个引用，这样我就可以通过这个连接从代码中的其他地方发布消息，即myobject.myconnection.publish('com.myapp.topic1', 'My message')

从这个类似的问题来看，答案似乎是在连接时，我需要设置类似self.factory.myconnection = self的东西。我尝试了多种排列方式，但都没有成功。

工厂设置部分如下：

   ## create a WAMP application session factory
   ##
   from autobahn.twisted.wamp import ApplicationSessionFactory
   session_factory = ApplicationSessionFactory()

   ## .. and set the session class on the factory
   ##
   session_factory.session = Component

   ## create a WAMP-over-WebSocket transport client factory
   ##
   from autobahn.twisted.websocket import WampWebSocketClientFactory
   transport_factory = WampWebSocketClientFactory(session_factory, args.wsurl, debug = args.debug)
   transport_factory.setProtocolOptions(failByDrop = False)

   ## start a WebSocket client from an endpoint
   ##
   client = clientFromString(reactor, args.websocket)
   client.connect(transport_factory)

我在课堂上设置的任何参考资料都会附在哪里？到client？到transport_factory？到session_factory？

Answer 1

当你的应用程序会话加入WAMP领域时，它会在应用程序会话工厂上设置一个对自己的引用：

class MyAppComponent(ApplicationSession):
   ... snip
   def onJoin(self, details):
      if not self.factory._myAppSession:
         self.factory._myAppSession = self

然后，您可以从代码中的其他地方访问此会话，例如

   @inlineCallbacks
   def pub():
      counter = 0  
      while True:
         ## here we can access the app session that was created ..
         ##
         if session_factory._myAppSession:
            session_factory._myAppSession.publish('com.myapp.topic123', counter)
            print("published event", counter)
         else:
            print("no session")
         counter += 1
         yield sleep(1)
   pub()