使用 Python、Twisted、Redis 和 txredisapi。
建立连接后，如何获取订阅和取消订阅频道的订阅者协议？
我想我需要获取 SubscriberProtocol 的实例，然后我可以使用“订阅”和“取消订阅”方法，但不知道如何获取它。
代码示例：
import txredisapi as redis
class RedisListenerProtocol(redis.SubscriberProtocol):
def connectionMade(self):
self.subscribe("channelName")
def messageReceived(self, pattern, channel, message):
print "pattern=%s, channel=%s message=%s" %(pattern, channel, message)
def connectionLost(self, reason):
print "lost connection:", reason
class RedisListenerFactory(redis.SubscriberFactory):
maxDelay = 120
continueTrying = True
protocol = RedisListenerProtocol
然后从这些类之外：
# I need to sub/unsub from here! (not from inside de protocol)
protocolInstance = RedisListenerProtocol # Here is the problem
protocolInstance.subscribe("newChannelName")
protocolInstance.unsubscribe("channelName")
有什么建议吗？
谢谢！
下面的代码解决了这个问题：
@defer.inlineCallbacks
def subUnsub():
deferred = yield ClientCreator(reactor, RedisListenerProtocol).connectTCP(HOST, PORT)
deferred.subscribe("newChannelName")
deferred.unsubscribe("channelName")
说明： 使用“ClientCreator”在带有标志“@defer.inlineCallbacks”的函数中获取 SubscriberProtocol 的实例，不要忘记等待完成延迟数据的“yield”关键字。然后你可以使用这个 deferred 来订阅和取消订阅。
在我的情况下，我忘记了 yield 关键字，因此 deferred 不完整，并且方法 suscribe 和 unsubscribe 不起作用。