4

我需要使用 python 设置一个 jabber bot，它将根据多个联系人的在线/离线可用性发送消息。

我一直在研究 pyxmpp 和 xmpppy，但找不到任何方法（至少没有简单的方法）来检查给定联系人的状态。

关于如何实现这一目标的任何指示？

理想情况下，我想要像bot.status_of("contact1@gmail.com")返回这样的东西"online"

4

3 回答 3

2

我认为这不可能以您想要的方式进行，因为机器人会异步接收联系人的存在（其中包含有关其可用性的信息）。

您将必须编写一个存在处理函数并将其注册到连接中。每当收到来自联系人的出席信息时，都会调用此函数。通话参数会告诉你联系人是否在线。根据它，您可以将消息发送给联系人。

使用xmpppy你做这样的事情：

def connect(jid, password, res, server, proxy, use_srv):
    conn = xmpp.Client(jid.getDomain())

    if not conn.connect(server=server, proxy=proxy, use_srv=use_srv):
        log( 'unable to connect to server.')
        return None

    if not conn.auth(jid.getNode(), password, res):
        log( 'unable to authorize with server.')
        return None

    conn.RegisterHandler( 'presence', callback_presence)
    return conn

conn = connect(...)

def callback_presence(sess, pres):
    if pres.getStatus() == "online":
        msg = xmpp.Message(pres.getFrom(), "Hi!")
        conn.send(msg)

PS：我没有测试过代码，但它应该与此非常相似。

于 2010-10-08T13:15:38.180 回答
0

你想要的是通过<presence type="probe"/>. 这是代表客户端完成的，不应由他们完成（根据 XMPP IM 的 RFC）。由于这是一个机器人，您可以实现存在探测，并接收给定实体的当前存在。请记住将探测发送到裸 JID（无资源），因为服务器代表客户端响应存在探测。这意味着您的工作流程将如下所示：

<presence/> // I'm online!                                        BOT
  <presence from="juliet@capulet.org/balcony"/>                   RESPONSE
  <presence from="romeo@montague.net/hallway"/> // and so on...   RESPONSE
<presence type="probe" to="benvolio@montague.net"/>               BOT
  <presence from="benvoio@montague.net/hallway">                  RESPONSE
     <status>Huzzah!</status>
     <priority>3</priority>
  </presence>

请查看RFC的该部分，以获取有关呼叫流程应如何表现的更深入信息。

于 2010-10-09T15:42:46.407 回答
0

你需要做的是：

  1. 连接。
  2. 声明一个存在处理程序。该处理程序维护每个联系人存在的缓存（请参阅下面的详细信息）
  3. 将初始状态发送到服务器，这将引发从您的所有在线联系人接收状态状态，这将反过来触发处理程序。
  4. status_of() 方法读取缓存并立即推断联系人的存在状态。

现在，这取决于您需要哪些状态信息。为了简单起见，让我们假设您只需要一个“在线”/“离线”值。缓存将是一个字典，其键是裸（无资源）JID，值是此 JID 的一组连接资源。例如：

{'foo@bar.com': set(['work', 'notebook']), 'bob@example.net': set(['gtalk'])}

现在，当您从某个 JID/资源收到“可用”状态时：

if jid not in cache:
    cache[jid] = set()
cache[jid].add(resource)

反过来，当您收到“不可用”状态时：

if jid in cache: # bad people send "unavailable" just to make your app crash
    cache[jid].discard(resource)
    if 0 == len(cache[jid]):
        del cache[jid]

现在：

def is_online(jid):
    return jid in cache

当然，如果您想要更详细的信息，您不仅可以维护联系人的可用资源列表，还可以维护每个资源的状态、状态消息、优先级等。

于 2010-12-22T09:43:49.750 回答