使用XMPPPY模块与Jabber服务器通信。

yjnet · 发表于 2005-9-15 13:39:08

转自肥肥世家论坛

Jabber服务器采用开发的XMPP协议，Google Talk也是采用XMPP协议的IM系统。在Python中有一个xmpppy模块支持该协议。也就是说，我们可以通过该模块与Jabber服务器通信，是不是很Cool。下面是一个简单的示例，可使大家对该模块有一个大概的了解。

#导入xmpppy模块
>>> import xmpp
#建立Client实例，debian是我的jabber服务器名，jabber服务器的安装可参考我的Debian学习笔记。
>>> c=xmpp.Client('debian',debug=[])
#连接
>>> c.connect()
'tcp'
#验证
>>> c.auth('yangjing','12345')
'old_auth'
#登入
>>> c.sendInitPresence()
#向ringkee@debian
>>> c.send(xmpp.protocol.Message('ringkee@debian ','test message from yangjing'))
'20'
#下面测试信息接收功能，如果没有信息，则pending_data()为空
>>>c.TCPsocket.pending_data()
[]
#如果有信息，则pending_data()不为空
>>> c.TCPsocket.pending_data()
[<socket._socketobject object at 0xb795beb4>]
#接收信息
>>> c.TCPsocket.receive()
"<message type='chat' to='yangjing@debian/xmpppy' from='ringkee@debian/Gaim'><x xmlns='jabber:x:event'><composing/></x><body>message from ringkee@debian</body><html xmlns='http://jabber.org/protocol/xhtml-im'><body xmlns='http://www.w3.org/1999/xhtml'>message from <a HREF='mailto:ringkee@debian'>ringkee@debian</a></body></html></message>"
#登出
>>> c.disconnect()

现在我正在学习XMPPPY模块和XMPP协议，看可不可以在Zope中集成IM功能。

弥敦路九号 · 发表于 2005-9-15 14:37:45

from socket import *
import sys
import os
def prompt():
print """
only users with blank password can use it,because i
have not added the password validation yet.
chinese message seems invalid.
"""
def TransferMsg(msg):
try:
if msg[0] == '[' and msg[-1] == ']':
temp_msg = msg[1:-1]
pos = temp_msg.find('*')
if pos >= 0:
stimes = temp_msg[pos + 1:]
ntimes = int(stimes)
return temp_msg[0 : pos] * ntimes
except:
return msg
def SendMsg(msg,recv_buf=2048):
s.send(msg+'\r\n')
print 'SEND:',msg
#print 'RECV:',s.recv(recv_buf)
def ShowRecvMsg():
s.setblocking(0)
try:
while(1):
recv_msg = s.recv(1024)
if recv_msg.strip() <> '':
print 'RECV:', recv_msg
except:
pass
s.setblocking(1)
def InitJabber(server,resource,user):
SendMsg('<stream:stream to="'+server+'" xmlns="jabber:client" xmlns:stream="http://etherx.jabber.org/streams">')
SendMsg('<iq type="get" id="JCOM_0"><query xmlns="jabber:iq:auth"><username>'+user+'</username></query></iq>')
SendMsg('<iq type="set" id="JCOM_1"><query xmlns="jabber:iq:auth"><username>'+user+'</username><digest/><resource>'+resource+'</resource></query></iq>')
def JbSendTo(to_user,msg):
SendMsg('<message id="JCOM_4" to="'+to_user+'" type="unsavechat"><body>'+msg+'</body></message>')
if (__name__ == '__main__'):
try:
if sys.platform == 'win32':
os.system('cls')
else:
os.system('clear')
prompt() # give some infomations.
svr_name = raw_input(r'enter server name(e.g. oraserver):')
#svr_ip = raw_input(r'enter server ip(e.g. 192.0.0.2):')
while(1):
try:
svr_ports = raw_input(r'enter server port(5222):')
if svr_ports == '':
svr_ports = '5222'
svr_porti = int(svr_ports)
break
except:
print 'please enter a valid number.'
#print svr_porti
res = raw_input(r'enter resource name(e.g. EIM_Work):')
usr_name = raw_input(r'enter user name(you logon name):')
s = socket()
s.connect((svr_name,svr_porti))
print 'connected...\r\n'
except Exception,e:
print 'connect error :' ,e
else:
try:
InitJabber(svr_name,res,usr_name)
ShowRecvMsg()
print 'init jabber finished...'
print 'ready...'
while(1):
sendto = raw_input(r'recv user(e.g. fjg@nsoa blank to exit):')
if sendto == '':
break
while(1):
sendmsg = raw_input(r'msg to send:')
sendmsg = TransferMsg(sendmsg)
if sendmsg == '':
break;
JbSendTo(sendto,sendmsg)
print 'msg: '+ sendmsg + ' sended...'
ShowRecvMsg()
except Exception,e:
print 'error :',e
s.close()

复制代码

偶直接用TCP和我们公司的服务器连接.

yjnet · 发表于 2005-9-19 09:42:45

今天测试了用XMPPPY和Google Talk的连接，连接成功。下面把过程描述一下。
1、给XMPPPY模块的client.py源码打补丁，去掉SASL验证。这个是XMPPPY的一个Bug：
- def auth(self,user,password,resource=''):
+ def auth(self,user,password,resource='',sasl=0):

- auth.SASL().PlugIn(self)
- if self.SASL.startsasl=='not-supported':
+ if sasl: auth.SASL().PlugIn(self)
+ if not sasl or self.SASL.startsasl=='not-supported':

2、连接
>>> import xmpp
>>> c=xmpp.Client('gmail.com',debug=[])
>>> c.connect(server=('talk.google.com',5223))
'tls'
>>> c.auth('ringkee','123456','xmpppy')
'old_auth'
>>> c.sendInitPresence()
#向jims.yang发出加为好友的认证请求
>>>c.Roster.Subscribe('jims.yang@gmail.com')
>>> c.send(xmpp.protocol.Message('jims.yang@gmail.com','test message from ringkee@gmail'))
'5'

		自动登录	找回密码
密码			注册