`
houchangxi
  • 浏览: 64632 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

Smack的api使用

阅读更多
Java代码  收藏代码
  1. ===============================================================  
  2. 主动发送信息给某个用户  
  3. ------------------------------------  
  4. XMPPConnection.DEBUG_ENABLED = true ;  
  5. //设置服务器地址   
  6. XMPPConnection conn = new  XMPPConnection( "127.0.0.1" );   
  7. conn.connect();  
  8. //输入账号和密码登陆   
  9. conn.login("test2@127.0.0.1" "123456" );   
  10. //创建一个和test1的对话,并设置信息监听   
  11. Chat mychat = conn.getManager().create("test1@127.0.0.1" ,  
  12.         new  MessageListener() {  
  13.             @Override   
  14.             public   void  processMessage(Chat chat,, Message message) {  
  15.                 String messageBody = message.getBody();  
  16.                 System.out.println("收到信息:" +messageBody);  
  17.             }  
  18. });  
  19. //发送给test1文本信息   
  20. mychat.sendMessage("hello" );  
  21. //退出登陆   
  22. conn.disconnect();  
  23. ===============================================================  
  24. 设置自己的登陆状态  
  25. ------------------------------------  
  26. XMPPConnection.DEBUG_ENABLED = true ;  
  27. //设置服务器地址   
  28. XMPPConnection conn = new  XMPPConnection( "127.0.0.1" );   
  29. conn.connect();  
  30. //输入账号和密码登陆   
  31. conn.login("test2@127.0.0.1" "123456" );   
  32.   
  33. //设置登陆后的个人状态信息   
  34. Presence p = new  Presence(Presence.Type.available);  
  35. p.setStatus("发呆中。。。" );  
  36. conn.sendPacket(p);  
  37.   
  38. //退出登陆   
  39. conn.disconnect();  
  40. ==========================================================================  
  41. 被动接收用户发来的信息  
  42. ------------------------------------  
  43. XMPPConnection.DEBUG_ENABLED = true ;  
  44. //设置服务器地址   
  45. XMPPConnection conn = new  XMPPConnection( "127.0.0.1" );   
  46. conn.connect();  
  47. //输入账号和密码登陆   
  48. conn.login("test1@127.0.0.1" "123456" );   
  49. //设置信息的监听   
  50. conn.getChatManager().addChatListener(new  ChatManagerListener() {  
  51.     @Override   
  52.     public   void  chatCreated(Chat chat,  boolean  createdLocally) {  
  53.         chat.addMessageListener(new  MessageListener() {  
  54.             @Override   
  55.             public   void  processMessage(Chat chat, Message message) {  
  56.                 String messageBody = message.getBody();   
  57.                 System.out.println("接收到信息:" +messageBody);                 
  58.             }  
  59.         });  
  60.     }  
  61. });  
  62. //退出登陆   
  63. conn.disconnect();  
  64. ==========================================================================  
  65. 获取我的好友列表  
  66. ------------------------------------  
  67. //设置服务器地址   
  68. XMPPConnection conn = new  XMPPConnection( "127.0.0.1" );   
  69. conn.connect();  
  70. //输入账号和密码登陆   
  71. conn.login("test1@127.0.0.1" "123456" );   
  72. Collection<RosterEntry> rosters = conn.getRoster().getEntries();  
  73. System.out.println("我的好友列表:=======================" );  
  74. for (RosterEntry rosterEntry : rosters){  
  75.     System.out.print("name: " +rosterEntry.getName()+ ",jid: " +rosterEntry.getUser());  
  76.     System.out.println("" );  
  77. }  
  78. System.out.println("我的好友列表:=======================" );  
  79.   
  80. conn.disconnect();  
  81. ==========================================================================  
  82. 聊天窗口输入状态,使用XEP-0085  协议  
  83. ------------------------------------  
  84. //发送给test1初始文本信息,附带输入状态   
  85. Message mess = new  Message();  
  86. mess.addExtension(new  ChatStateExtension(ChatState.active));  
  87. mychat.sendMessage(mess);  
  88. //发送给test1初始文本信息,附带正在输入的状态   
  89. Message mess = new  Message();  
  90. mess.addExtension(new  ChatStateExtension(ChatState.composing));  
  91. mychat.sendMessage(mess);  
  92.   
  93. //发送给test1初始文本信息,附带暂停输入的状态   
  94. Message mess = new  Message();  
  95. mess.addExtension(new  ChatStateExtension(ChatState.paused));  
  96. mychat.sendMessage(mess);  
  97. //其他略。。。   
  98.   
  99. //接收的时候   
  100. public   void  processMessage(Chat chat, Message message) {  
  101.     String messageBody = message.getBody();  
  102.     PacketExtension pe;  
  103.       
  104.     pe = message.getExtension("composing" , "http://jabber.org/protocol/chatstates" );  
  105.     if (pe !=  null ){  
  106.         System.out.println("对方正在输入......" );  
  107.     }  
  108.       
  109.     pe = message.getExtension("active" , "http://jabber.org/protocol/chatstates" );  
  110.     if (pe !=  null ){  
  111.         System.out.println("接收到信息:" +messageBody);  
  112.     }  
  113.   
  114.     pe = message.getExtension("paused" , "http://jabber.org/protocol/chatstates" );  
  115.     if (pe !=  null ){  
  116.         System.out.println("对方已暂停输入" );  
  117.     }  
  118.   
  119.     pe = message.getExtension("inactive" , "http://jabber.org/protocol/chatstates" );  
  120.     if (pe !=  null ){  
  121.         System.out.println("对方聊天窗口失去焦点" );  
  122.     }  
  123.   
  124.     pe = message.getExtension("gone" , "http://jabber.org/protocol/chatstates" );  
  125.     if (pe !=  null ){  
  126.         System.out.println("对方聊天窗口被关闭" );  
  127.     }  
  128. }  
  129. ==========================================================================  
  130. 接收邀请,加入多人聊天房间  
  131. ------------------------------------  
  132. MultiUserChat.addInvitationListener(conn, new  InvitationListener() {  
  133.     @Override   
  134.     public   void  invitationReceived(XMPPConnection conn, String room,  
  135.             String inviter, String reason, String password, Message message) {  
  136.         MultiUserChat multiUserChat = new  MultiUserChat(conn, room);  
  137.         System.out.println("收到来自 " +inviter+ " 的聊天室邀请。邀请附带内容:" +reason);  
  138.         try  {  
  139.             multiUserChat.join("test2" , password);  
  140.         } catch  (XMPPException e) {  
  141.             System.out.println("加入聊天室失败" );  
  142.             e.printStackTrace();  
  143.         }  
  144.         System.out.println("成功加入聊天室" );  
  145.         multiUserChat.addMessageListener(new  PacketListener() {  
  146.             @Override   
  147.             public   void  processPacket(Packet packet) {  
  148.                 Message message = (Message)packet;  
  149.                 //接收来自聊天室的聊天信息   
  150.                 System.out.println(message.getFrom()+":" +message.getBody());  
  151.             }  
  152.         });  
  153.     }  
  154.     //发送信息到聊天室   
  155.     multiUserChat.sendMessage("新手到来,大家关照!" );  
  156. });  
  157.   
  158. ==========================================================================  
  159. 登陆gtalk  
  160. ------------------------------------  
  161. XMPPConnection conn = new  XMPPConnection( new  ConnectionConfiguration( "talk.google.com" 5222 "gmail.com" ));  
  162. conn.connect();  
  163. //输入gtalk的账号密码   
  164. conn.login("88888888" "8888888888" );   
  165. Collection<RosterEntry> rosters = conn.getRoster().getEntries();  
  166. //获取gtalk上的好友列表   
  167. System.out.println("我的好友列表:=======================" );    
  168. for (RosterEntry rosterEntry : rosters){  
  169.     System.out.print("name: " +rosterEntry.getName()+ ",jid: " +rosterEntry.getUser());  
  170.     System.out.println("" );  
  171. }  
  172. System.out.println("我的好友列表:=======================" );  
  173.   
  174. conn.disconnect();  
  175. ==========================================================================  
===============================================================
主动发送信息给某个用户
------------------------------------
XMPPConnection.DEBUG_ENABLED = true;
//设置服务器地址
XMPPConnection conn = new XMPPConnection("127.0.0.1"); 
conn.connect();
//输入账号和密码登陆
conn.login("test2@127.0.0.1", "123456"); 
//创建一个和test1的对话,并设置信息监听
Chat mychat = conn.getManager().create("test1@127.0.0.1",
		new MessageListener() {
			@Override
			public void processMessage(Chat chat,, Message message) {
				String messageBody = message.getBody();
				System.out.println("收到信息:"+messageBody);
			}
});
//发送给test1文本信息
mychat.sendMessage("hello");
//退出登陆
conn.disconnect();
===============================================================
设置自己的登陆状态
------------------------------------
XMPPConnection.DEBUG_ENABLED = true;
//设置服务器地址
XMPPConnection conn = new XMPPConnection("127.0.0.1"); 
conn.connect();
//输入账号和密码登陆
conn.login("test2@127.0.0.1", "123456"); 

//设置登陆后的个人状态信息
Presence p = new Presence(Presence.Type.available);
p.setStatus("发呆中。。。");
conn.sendPacket(p);

//退出登陆
conn.disconnect();
==========================================================================
被动接收用户发来的信息
------------------------------------
XMPPConnection.DEBUG_ENABLED = true;
//设置服务器地址
XMPPConnection conn = new XMPPConnection("127.0.0.1"); 
conn.connect();
//输入账号和密码登陆
conn.login("test1@127.0.0.1", "123456"); 
//设置信息的监听
conn.getChatManager().addChatListener(new ChatManagerListener() {
	@Override
	public void chatCreated(Chat chat, boolean createdLocally) {
		chat.addMessageListener(new MessageListener() {
			@Override
			public void processMessage(Chat chat, Message message) {
				String messageBody = message.getBody();	
				System.out.println("接收到信息:"+messageBody);				
			}
		});
	}
});
//退出登陆
conn.disconnect();
==========================================================================
获取我的好友列表
------------------------------------
//设置服务器地址
XMPPConnection conn = new XMPPConnection("127.0.0.1"); 
conn.connect();
//输入账号和密码登陆
conn.login("test1@127.0.0.1", "123456"); 
Collection<RosterEntry> rosters = conn.getRoster().getEntries();
System.out.println("我的好友列表:=======================");
for(RosterEntry rosterEntry : rosters){
	System.out.print("name: "+rosterEntry.getName()+",jid: "+rosterEntry.getUser());
	System.out.println("");
}
System.out.println("我的好友列表:=======================");

conn.disconnect();
==========================================================================
聊天窗口输入状态,使用XEP-0085 协议
------------------------------------
//发送给test1初始文本信息,附带输入状态
Message mess = new Message();
mess.addExtension(new ChatStateExtension(ChatState.active));
mychat.sendMessage(mess);
//发送给test1初始文本信息,附带正在输入的状态
Message mess = new Message();
mess.addExtension(new ChatStateExtension(ChatState.composing));
mychat.sendMessage(mess);

//发送给test1初始文本信息,附带暂停输入的状态
Message mess = new Message();
mess.addExtension(new ChatStateExtension(ChatState.paused));
mychat.sendMessage(mess);
//其他略。。。

//接收的时候
public void processMessage(Chat chat, Message message) {
	String messageBody = message.getBody();
	PacketExtension pe;
	
	pe = message.getExtension("composing","http://jabber.org/protocol/chatstates");
	if(pe != null){
		System.out.println("对方正在输入......");
	}
	
	pe = message.getExtension("active","http://jabber.org/protocol/chatstates");
	if(pe != null){
		System.out.println("接收到信息:"+messageBody);
	}

	pe = message.getExtension("paused","http://jabber.org/protocol/chatstates");
	if(pe != null){
		System.out.println("对方已暂停输入");
	}

	pe = message.getExtension("inactive","http://jabber.org/protocol/chatstates");
	if(pe != null){
		System.out.println("对方聊天窗口失去焦点");
	}

	pe = message.getExtension("gone","http://jabber.org/protocol/chatstates");
	if(pe != null){
		System.out.println("对方聊天窗口被关闭");
	}
}
==========================================================================
接收邀请,加入多人聊天房间
------------------------------------
MultiUserChat.addInvitationListener(conn, new InvitationListener() {
	@Override
	public void invitationReceived(XMPPConnection conn, String room,
			String inviter, String reason, String password, Message message) {
		MultiUserChat multiUserChat = new MultiUserChat(conn, room);
		System.out.println("收到来自 "+inviter+" 的聊天室邀请。邀请附带内容:"+reason);
		try {
			multiUserChat.join("test2", password);
		} catch (XMPPException e) {
			System.out.println("加入聊天室失败");
			e.printStackTrace();
		}
		System.out.println("成功加入聊天室");
		multiUserChat.addMessageListener(new PacketListener() {
			@Override
			public void processPacket(Packet packet) {
				Message message = (Message)packet;
				//接收来自聊天室的聊天信息
				System.out.println(message.getFrom()+":"+message.getBody());
			}
		});
	}
	//发送信息到聊天室
	multiUserChat.sendMessage("新手到来,大家关照!");
});

==========================================================================
登陆gtalk
------------------------------------
XMPPConnection conn = new XMPPConnection(new ConnectionConfiguration("talk.google.com", 5222, "gmail.com"));
conn.connect();
//输入gtalk的账号密码
conn.login("88888888", "8888888888"); 
Collection<RosterEntry> rosters = conn.getRoster().getEntries();
//获取gtalk上的好友列表
System.out.println("我的好友列表:=======================");  
for(RosterEntry rosterEntry : rosters){
	System.out.print("name: "+rosterEntry.getName()+",jid: "+rosterEntry.getUser());
	System.out.println("");
}
System.out.println("我的好友列表:=======================");

conn.disconnect();
==========================================================================

 

分享到:
评论

相关推荐

    Smack API中文版

    Smack API与Openfire服务器配合使用,可以实现高效的、安全的P2P或者服务器中继的聊天功能。本文将深入探讨Smack API的基本概念、原理及其在实际应用中的使用方法。 ### 1. Smack API基本概念 Smack API是用Java...

    smack API

    Smack API 是一个开源的Java库,专门用于处理XMPP(Extensible Messaging and Presence Protocol)协议,这是一种实时通信协议,广泛应用于即时通讯、在线状态跟踪、文件传输等场景。Openfire是一款基于XMPP的服务器...

    smack api帮助文档

    在“smack api帮助文档”中,我们可以找到关于如何使用Smack API的详细指南。这份文档通常包括以下几个部分: 1. **Javadoc**:这是Java开发者非常熟悉的文档格式,它包含了Smack API中所有类、接口、方法和常量的...

    Smack API java的类库

    在实际开发中,Openfire是一款流行的开源XMPP服务器,它支持多种客户端连接,包括使用Smack API的Java应用。Openfire提供了用户管理、群组管理、权限控制等一系列服务器端功能,与Smack API相结合,可以构建出强大的...

    Smack API手册与文档

    1)smack api,基于smack官方javadoc制作而成,格式chm,语言english; 2)smack documentation,内容包括Overview,Getting Started Guide等等,格式chm,语言为中文(感谢fhqdddddd的奉献,本文档基于...

    Smack中文API文档

    Smack中文API文档

    amsmck jar包+smack API

    5. **使用Smack API开发**:开发者可以利用Smack API创建XMPP客户端,首先需要连接到XMPP服务器,然后创建用户实体,接着可以发送和接收消息,管理好友列表,加入聊天室,甚至进行服务器推送通知的设置。 6. **CHM...

    smack api文档

    xmpp协议java实现 smack3.0 api文档

    smackAPI中文版本和英文版本,非常容易懂的

    Smack API 中文版和英文版的文档都是为了帮助开发者更好地理解和使用这个库。这两个版本都提供了详细的指南、教程和API参考,确保不论母语为何的开发者都能迅速上手。中文版对于国内开发者来说尤其有帮助,因为它...

    smack api 中文

    找了好久,终于找到了smack中文版的api了

    SmackAPI_CN

    **SmackAPI_CN** 是一个专门针对 Smack 开发的中文 API 文档,它旨在帮助中文用户更好地理解和使用 Smack 库来构建即时通讯(IM)系统。Smack 是一个开源的 Java 库,用于实现 XMPP(Extensible Messaging and ...

    aSmack smack api 英文全版

    smack API文档,aSmack通用,英文版,即时通讯开发值得参考

    smack3.2的api

    开发者可以使用Smack API轻松地与Openfire服务器通信,实现各种功能,如用户注册、权限管理、群组操作等。 总的来说,Smack 3.2 API为Java开发者提供了一个强大且灵活的框架,使得构建XMPP客户端应用变得简单高效。...

    Smack_API.CHM

    Smack_API.chm Help Documents

    smack2.2中文API

    1. **连接管理**:Smack API提供了连接到XMPP服务器的类,例如`XMPPTCPConnection`,它负责建立和维护与服务器的TCP连接。开发者需要配置服务器的主机名、端口以及认证信息来创建连接。 2. **身份验证**:Smack支持...

    基于xmpp协议的开源库smack接口api详细介绍

    Smack类库的主要优势在于它的使用简便性和强大的API,使得开发者能够轻松地实现消息的发送和接收。 Smack库的主要优势可以从以下几个方面体现出来: 1. 简单易用:Smack封装了XMPP的复杂性,开发者无需深入了解...

    smackAPI

    xmpp协议的java实现库,smack3.04 chm格式

    smack4.1.4 android 测试通过

    在Android平台上,开发者常使用Smack来构建聊天应用程序,因为它提供了丰富的API和功能,可以方便地创建客户端来与XMPP服务器进行通信。在本案例中,"smack4.1.4 android 测试通过"表明这个版本的Smack库已经成功地...

    smack android

    4. 发送和接收消息:使用Smack API发送和接收文本、文件等不同类型的消息。 5. 处理事件:注册监听器以响应用户上线、离线、收到消息等事件。 6. 关闭连接:当不再需要使用时,正确关闭连接以释放资源。 总之,...

    xmpp-client:具有smack API的Java客户端

    在这个项目中,"xmpp-client"是一个使用Java语言开发的客户端,它利用了Smack API来实现与XMPP服务器的交互。Openfire是一款开源的XMPP服务器,它提供了安全、可扩展的即时通讯服务。Spark是基于Openfire的桌面...

Global site tag (gtag.js) - Google Analytics