\u9996\u5148\u5f00\u901a\u4e24\u4e2agtalk\u5e10\u53f7\uff0c\u76f8\u4e92\u52a0\u4e3a\u597d\u53cb\u3002\u5982xxxxx@gmail.com\u548cyyyyy@gmail.com\u3002
\n\u7136\u540e\u5b89\u88c5xmpppy-0.5.0rc1\u4ee5\u4e0a\u7248\u672c\u7684xmpp\u5e93\u3002<\/p>\n
\u7528xxxxx@gmail.com\u767b\u5f55gtalk\uff0c\u7136\u540e\u8ddfyyyyy@gmail.com\u5bf9\u8bdd\u3002
\n\u4ee3\u7801\u5982\u4e0b\uff1a<\/b>
\n#!\/usr\/bin\/env python
\n# -*- coding: utf-8 -*-<\/p>\n
import\u00a0 os, sys, string<\/p>\n
import time
\nimport codecs
\nimport threading<\/p>\n
import getpass
\nimport xmpp<\/p>\n
programName=”<\/p>\n
class Xmpp_Msg_Class(threading.Thread):
\ndef __init__(self, threadName, loginUser, loginPasswd, xmppServer, xmppDomain, xmppPort):
\nthreading.Thread.__init__(self)
\nself.name = threadName<\/p>\n
self.loginUser = loginUser
\nself.loginPasswd = loginPasswd
\nself.xmppServer = xmppServer
\nself.xmppDomain = xmppDomain
\nself.xmppPort = xmppPort<\/p>\n
self.isQuit = False<\/p>\n
self.xmppTo = ”
\nself.client = None
\nself.conn = None
\nself.connOK = False<\/p>\n
def __del__(self):
\ntime.sleep(1)\u00a0\u00a0 # some older servers will not send the message if you disconnect immediately after sending
\nif not self.client == None:
\nself.client.disconnect()<\/p>\n
def quit(self):
\nself.isQuit = True<\/p>\n
def run(self):
\nwhile True:
\nif self.isQuit:
\nbreak
\nif self.client == None:
\nif not self.ConnectToXmppServer():
\nprint ‘ERROR: can not connect to XMPP server.’
\nself.client = None
\ntime.sleep(5)
\ncontinue
\nif not self.client.isConnected():
\nif not self.client.reconnectAndReauth():
\nprint ‘ERROR: can not connect to XMPP server.’
\ntime.sleep(5)
\ncontinue
\nif self.client.Process(1) == None:
\nprint ‘ERROR: lost connection!’
\ntime.sleep(5)
\ntime.sleep(0.1)<\/p>\n
def ConnectToXmppServer(self):
\nprint ‘Create Client: DOMAIN:%s, port:%u’ % (self.xmppDomain, 5222)
\n#self.client = xmpp.Client(self.xmppDomain, port=5222, debug=[‘always’])
\nself.client = xmpp.Client(self.xmppDomain, port=5222, debug=[])
\nprint ‘Create Connect: SERVER:%s, port:%u’ % (self.xmppServer, self.xmppPort)
\nself.conn = self.client.connect((self.xmppServer, self.xmppPort), proxy=None, secure=None, use_srv=True)
\nif not self.conn:
\nprint ‘ERROR: Could not connect to %s !’ % (self.xmppServer)
\nreturn False
\nprint ‘INFO: Connected with ‘,self.conn
\nprint ‘Create Auth: USER:%s, PASSWORD:%s’ % (self.loginUser.split(‘@’)[0], ‘******’)#self.loginPasswd)
\nauth=self.client.auth(self.loginUser.split(‘@’)[0], self.loginPasswd, resource=”, sasl=1)
\nif not auth:
\nprint ‘ERROR: Could not authenticate with %s !’ % (self.xmppServer)
\nreturn False
\nprint ‘INFO: Aauthenticated using ‘,auth
\n# …register some handlers (if you will register them before auth they will be thrown away)
\nprint ‘Register Handle: presence\/iq\/message\/disconnect’
\nself.client.RegisterHandler(‘presence’,self.presenceHandler)
\nself.client.RegisterHandler(‘iq’,self.iqHandler)
\nself.client.RegisterHandler(‘message’,self.messageHandler)
\nself.client.RegisterDisconnectHandler(self.disconnectHandler)
\n# …become available
\nprint ‘INFO: Online’
\nself.client.sendInitPresence(requestRoster=0)\u00a0\u00a0 # you may need to uncomment this for old server
\nprint “============> I’m online <=============”
\nself.connOK = True
\nreturn True<\/p>\n
def presenceHandler(self, conn,presence_node):
\n“”” Handler for playing a sound when particular contact became online “””
\nfor targetJID in self.xmppTo:
\nif presence_node.getFrom().bareMatch(targetJID):
\nprint ‘USER: %s has login!’ % (targetJID)<\/p>\n
def iqHandler(self, conn,iq_node):
\n“”” Handler for processing some “get” query from custom namespace”””
\nreply=iq_node.buildReply(‘result’)
\n# … put some content into reply node
\nself.conn.send(reply)
\nraise NodeProcessed\u00a0 # This stanza is fully processed<\/p>\n
def messageHandler(self, conn,mess_node):
\nprint ‘Send message to <%s>, MSG: “%s”‘ % (str(mess_node.getFrom()), mess_node.getBody().encode(‘utf-8’))
\nid = self.client.send(xmpp.protocol.Message(str(mess_node.getFrom()), mess_node.getBody().encode(‘utf-8’)))
\nprint ‘INFO: Sent message with id ‘,id<\/p>\n
def disconnectHandler(self, conn,disconn_node):
\nprint ‘INFO: Disconnect!’<\/p>\n
def SendMsg(self, xmppTo, xmppMsg):
\nself.xmppTo = xmppTo<\/p>\n
if not self.connOK:
\nprint ‘ERROR: not connected to XMPP server.’
\nreturn<\/p>\n
for tojid in self.xmppTo:
\nprint ‘Send message to <%s>, MSG: “%s”‘ % (tojid, xmppMsg)
\nid = self.client.send(xmpp.protocol.Message(tojid, xmppMsg))
\nprint ‘INFO: Sent message with id ‘,id
\nif self.client.Process(1) == None:
\nprint ‘ERROR: lost connection!’<\/p>\n
def OutputHelp():
\nprint ‘Use XMPP to send messages to gtalk: ‘
\nprint ‘Usage: ‘ + programName + ‘ ‘
\nprint ‘Example: ‘ + programName + ‘ ‘
\nprint ‘ ‘<\/p>\n
if __name__ == ‘__main__’ :
\nprogramName = sys.argv[0]
\nif len(sys.argv) > 1:
\nOutputHelp()
\nsys.exit(0)<\/p>\n
password = getpass.getpass(prompt=’Please input the password for “xxxxx@gmail.com”: ‘).strip()
\nif password == “”:
\nsys.exit(0)
\nxmpp_msg = Xmpp_Msg_Class(‘CHART’, ‘xxxxx@gmail.com’, password, ‘talk.google.com’, ‘gmail.com’, 443)
\nxmpp_msg.start()
\ntime.sleep(5)
\nxmpp_msg.SendMsg([‘yyyyy@gmail.com’], ‘test\u6d4b\u8bd51’)
\nwhile True:
\ninput = raw_input(‘======>>>msg(“q” is quit)>>>: ‘).strip()
\nif input == ‘q’:
\nxmpp_msg.quit()
\nbreak
\nif input == ”:
\ncontinue
\nxmpp_msg.SendMsg([‘yyyyy@gmail.com’], input)
\nxmpp_msg.join()<\/p>\n
sys.exit()<\/p>\n","protected":false},"excerpt":{"rendered":"
\u9996\u5148\u5f00\u901a\u4e24\u4e2agtalk\u5e10\u53f7\uff0c\u76f8\u4e92\u52a0\u4e3a\u597d\u53cb\u3002\u5982xxxxx@gmail.com\u548cyyyyy@gmail.com\u3002 …<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[14],"tags":[116,115,119,118,117],"class_list":["post-151","post","type-post","status-publish","format-standard","hentry","category-14","tag-gtalk","tag-xmpp","tag-119","tag-118","tag-117"],"views":1553,"_links":{"self":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/151","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=151"}],"version-history":[{"count":2,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/151\/revisions"}],"predecessor-version":[{"id":153,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=\/wp\/v2\/posts\/151\/revisions\/153"}],"wp:attachment":[{"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=151"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=151"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.max-shu.com\/blog\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=151"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}