3

我有一个应用程序可以发送 xmpp 消息。这些场合很少见（有时几天都没有），但又可能成群结队地出现。我什么都没用，我只想发送。直截了当的方法会遇到未检测到的超时。最后一个send()没有发生（接收者没有得到任何东西）但没有报告问题就返回（返回一个简单的 id，好像一切正​​常）。只有下一次调用send()then 会引发 IOError('Disconnected from server.')。

我可以为每条消息持续断开/重新连接，但我不喜欢这样，因为有时这会经常断开和重新连接（我不知道服务器是否在一秒钟内多次欣赏这一点）。

我可以尝试在此问题中作为答案给出的方法，但我真的不需要接收 XMPP 回复。

问题：有没有一种简单的方法可以在发送之前或之后检测连接超时而不尝试发送第二条消息（如果一切正常，这会向接收者发送垃圾邮件）？

我的直接方法：

import xmpp

def connectXmppClient(fromJidName, password):
  fromJid = xmpp.protocol.JID(fromJidName)
  xmppClient = xmpp.Client(fromJid.getDomain(), debug=[])
  connection = xmppClient.connect()
  if not connection:
    raise Exception("could not setup connection", fromJid)
  authentication = xmppClient.auth(
    fromJid.getNode(), password, resource=fromJid.getResource())
  if not authentication:
    raise Exception("could not authenticate")
  return xmppClient

def sendXmppMessage(xmppClient, toJidName, text):
  return xmppClient.send(xmpp.protocol.Message(toJidName, text))

if __name__ == '__main__':
  import sys, os, time, getpass
  if len(sys.argv) < 2:
    print "Syntax: xsend fromJID toJID"
    sys.exit(0)
  fromJidName = sys.argv[1]
  toJidName = sys.argv[2]
  password = getpass.getpass()
  xmppClient = connectXmppClient(fromJidName, password)
  while True:
    line = sys.stdin.readline()
    if not line:
      break
    print xmppClient.isConnected()
    id = sendXmppMessage(xmppClient, toJidName, line)
    print id
4

1 回答 1

1

您需要使用xmppClient.RegisterDisconnectHandler()注册断开连接处理程序。这使您可以指定将在断开连接时调用的函数。

于 2012-04-25T18:40:07.057 回答