如何正确初始化twisted reactor?

Question

我有一个叫 MyJabber 的类，它用来初始化一个基本的 Jabber 账号，能够把收到的消息打印到标准输出（也就是屏幕上），并把这些消息放进一个队列里。

把客户端添加到反应器（reactor）的代码如下：

def addReactor(self):
    print 'inside  AddReactor'
    factory = client.basicClientFactory(self.jid, self.option['jabber']['password'])
    print "factory initialized"
    factory.addBootstrap(xmlstream.STREAM_AUTHD_EVENT, self.authd)
    print 'factory bootsraped'
    reactor.connectTCP(self.option['jabber']['server'], 5222, factory)

这个代码是这样调用的：

jabber = MyJabber(options, to_irc)
jabber.addReactor()
reactor.run()

当我启动这个应用时，我能看到 addReactor 的打印信息，但之后就没有任何反应了。我通过 'tcpdump' 看到有东西在尝试连接 'jabber.org'，但是没有看到和认证相关的定义：

def authd(self, xmlstream):
    global thexmlstream
    thexmlstream = xmlstream
    # need to send presence so clients know we're
    # actually online.
    print 'Initializing...'
    presence = domish.Element(('jabber:client', 'presence'))
    presence.addElement('status').addContent('Online')

    xmlstream.send(presence)
    # add a callback for the messages
    print 'Add gotMessaged callback'
    xmlstream.addObserver('/message', gotMessage)
    print 'Add * callback'
    xmlstream.addObserver('/*', gotSomething)

Answer 1

解决了，发现了两个错误。

1) 我不小心忘记了JID的格式是名字@域名.后缀/额外信息。

2) 忘记在gotMessage/gotSomething前面加上self.。

我还让addReactor返回工厂，并在main()里写了：

jabber = MyJabber(options, to_irc)
factory = jabber.addReactor()
reactor.connectTCP(options['jabber']['server'], 5222, factory)
reactor.run()

Answer 2

这看起来并不是一个关于如何“初始化 Twisted reactor”的问题。实际上，这更像是关于如何使用 Twisted Words 的 XMPP 支持来发送和回复 XMPP 消息。

你可以在 Twisted Words 的示例目录中找到几个相关的例子：

http://twistedmatrix.com/documents/current/words/examples/

可以试试 xmpp_client.py 和 jabber_client.py 这两个文件。