我正在尝试为我们的 ejabberd 集群编写一个快速负载测试脚本,该脚本只需登录到聊天室,发布几条随机消息,然后退出。
我们曾用 tsung 尝试过这个特殊的测试,但根据作者的说法,muc 功能没有进入这个版本。
pyxmpp 似乎有这个功能,但如果我能弄清楚如何让它工作,那就太糟糕了。希望有人能快速解释如何构建客户端并加入/发布到 muc。
谢谢!
我正在尝试为我们的 ejabberd 集群编写一个快速负载测试脚本,该脚本只需登录到聊天室,发布几条随机消息,然后退出。
我们曾用 tsung 尝试过这个特殊的测试,但根据作者的说法,muc 功能没有进入这个版本。
pyxmpp 似乎有这个功能,但如果我能弄清楚如何让它工作,那就太糟糕了。希望有人能快速解释如何构建客户端并加入/发布到 muc。
谢谢!
嘿,我在尝试同样的事情时偶然发现了你的问题几次。这是我的答案:
使用http://pyxmpp.jajcus.net/svn/pyxmpp/trunk/examples/echobot.py作为快速入门,您所要做的就是导入 MUC-Stuff
from pyxmpp.jabber.muc import MucRoomState, MucRoomManager
一旦您的客户端连接,您就可以连接到您的房间:
def session_started(self):
"""Handle session started event. May be overriden in derived classes.
This one requests the user's roster and sends the initial presence."""
print u'SESSION STARTED'
self.request_roster()
p=Presence()
self.stream.send(p)
print u'ConnectToParty'
self.connectToMUC()
def connectToMUC(self):
self.roomManager = MucRoomManager(self.stream);
self.roomHandler = MucRoomHandler()
self.roomState = self.roomManager.join(
room=JID('room@conference.server.domain'),
nick='PartyBot',
handler=self.roomHandler,
history_maxchars=0,
password = None)
self.roomManager.set_handlers()
要发送消息,您只需调用 self.roomState.send_message("Sending this Message")
要做的事情,从 MucRoomHandler 继承并对事件做出反应。请注意 roomManager 的“set_handlers()”,这很重要,否则不会调用回调。