分享

Asmack之旅(一)初识asmack源码

 WindySky 2016-06-27

重要链接网址

Asmack github地址:

https://github.com/Flowdalic/asmack

源码jar下载地址

http://asmack./

XMPP

http:///

Openfire smack地址

http://www./

smack文档

http://www./builds/smack/docs/latest/documentation/index.html

简单代码操作参考

http://www.cnblogs.com/not-code/archive/2011/07/16/2108369.html


(——以下内容为smack文档的个人部分翻译以及见解,考虑到本人英语并不是很好,写这篇文章仅仅作为记录,如果有翻译错误的请指正,共同进步,谢谢)


Getting Started

Configuration

Smack的初始化涉及到2个步骤

1 初始化系统属性——通过SmackConfiguration进行系统属性初始化。这些属性可以通过getxxx()方法获取

2 初始化启动类——初始化类意味着在启动时候实例化该类,如果继承SmackInitializer则需要调用initialize()方法。如果不继承SmackInitializer则初始化的操作必须在静态代码块中,一旦加载类时自动执行

Establishing a Connection创建连接

XmppTCPConnection类是被用来创建连接到xmpp服务器的

  1. // Create a connection to the jabber.org server._  
  2. XMPPConnection conn1 = new XMPPTCPConnection("jabber.org");  
  3. conn1.connect();  
  4.   
  5. // Create a connection to the jabber.org server on a specific port._  
  6. ConnectionConfiguration config = new ConnectionConfiguration("jabber.org", 5222);  
  7. XMPPConnection conn2 = new XMPPTCPConnection(config);  
  8. conn2.connect();  

ConectionConfiguration类提供一些控制操作,譬如是否加密。


Working with the Roster 花名册

Roster可以让你保持获取其他用户的presence状态

用户可以添加进组“Friend”或者“Co-workers”,你可以知晓用户是否在线

检索roster可以通过XMPPConnection.getRoster()方法,roster类允许你查看所有的roster enteries ,群组信息当前的登录状态


Reading and WritingPackets 读写数据包

XMPP服务器和客户端间以XML传递的信息被称为数据包。

org.jivesoftware.smack.packet包内有三种封装好的基本的packet,分别是message,

presence和IQ。

比如Chat和GroupChat类提供了更高级别的结构用以创建发送packet,当然你也可以直接用packet。

  1. // Create a new presence. Pass in false to indicate we're unavailable._  
  2. Presence presence = new Presence(Presence.Type.unavailable);  
  3. presence.setStatus("Gone fishing");  
  4. // Send the packet (assume we have a XMPPConnection instance called "con").  
  5. con.sendPacket(presence);  

Smack提供两种读取packets

PacketListener PacketCollector
这两种都通过PacketFilter进行packet加工
A packet listener is used for event style programming, while a packet collector has a result queue of packets that you can do polling and blocking operations on. 
(packet listener事件监听,而packet collector是一个packets的可以进行polling和blocking操作的结果集队列。)
So, a packet listener is useful when you want to take some action whenever a packet happens to come in, while a packet collector is useful when you want to wait for a specific packet to arrive. 
(packet listener一旦数据包传递抵达的时候你可以进行处理,packet collector则被使用在你需要等待一个指定的packet传递抵达时候。)
Packet collectors and listeners can be created using an Connection instance.
(packet listener和packet collector在connection实例中被创建。)

  1. // Create a packet filter to listen for new messages from a particular  
  2. // user. We use an AndFilter to combine two other filters._  
  3. PacketFilter filter = new AndFilter(new PacketTypeFilter(Message.class),  
  4.         new FromContainsFilter("mary@jivesoftware.com"));  
  5. // Assume we've created a XMPPConnection name "connection".  
  6.   
  7. // First, register a packet collector using the filter we created.  
  8. PacketCollector myCollector = connection.createPacketCollector(filter);  
  9. // Normally, you'd do something with the collector, like wait for new packets.  
  10.   
  11. // Next, create a packet listener. We use an anonymous inner class for brevity.  
  12. PacketListener myListener = new PacketListener() {  
  13.         public void processPacket(Packet packet) {  
  14.             // Do something with the incoming packet here._  
  15.         }  
  16.     };  
  17. // Register the listener._  
  18. connection.addPacketListener(myListener, filter);  


Managing Connection

Connect and disConnect

  1. // Create the configuration for this new connection_  
  2. ConnectionConfiguration config = new ConnectionConfiguration("jabber.org", 5222);  
  3.   
  4. AbstractXMPPConnection connection = new XMPPTCPConnection(config);  
  5. // Connect to the server_  
  6. connection.connect();  
  7. // Log into the server_  
  8. connection.login("username", "password", "SomeResource");  
  9.   
  10. ...  
  11.   
  12. // Disconnect from the server_  
  13. connection.disconnect();  


Messaging using Chat

Chat

org.jivesoftware.smack.Chat

  1. // Assume we've created a XMPPConnection name "connection"._  
  2. ChatManager chatmanager = connection.getChatManager();  
  3. Chat newChat = chatmanager.createChat("jsmith@jivesoftware.com", new MessageListener() {  
  4.     public void processMessage(Chat chat, Message message) {  
  5.         System.out.println("Received message: " + message);  
  6.     }  
  7. });  
  8.   
  9. try {  
  10.     newChat.sendMessage("Howdy!");  
  11. }  
  12. catch (XMPPException e) {  
  13.     System.out.println("Error Delivering block");  
  14. }  
  15.   
  16. Message newMessage = new Message();  
  17. newMessage.setBody("Howdy!");  
  18. message.setProperty("favoriteColor", "red");  
  19. newChat.sendMessage(newMessage);  
  20.   
  21. // Assume a MessageListener we've setup with a chat._  
  22. public void processMessage(Chat chat, Message message) {  
  23.         // Send back the same text the other user sent us._  
  24.         chat.sendMessage(message.getBody());  
  25. }<span style="color:#ff0000;">  
  26. </span>  

incoming Chat

  1. _// Assume we've created a XMPPConnection name "connection"._  
  2. ChatManager chatmanager = connection.getChatManager().addChatListener(  
  3.     new ChatManagerListener() {  
  4.         @Override  
  5.         public void chatCreated(Chat chat, boolean createdLocally)  
  6.         {  
  7.             if (!createdLocally)  
  8.                 chat.addMessageListener(new MyNewMessageListener());;  
  9.         }  
  10.     });  


Roster and Presence

roster entries

包含xmpp地址,备注名,群组(假如该用户不属于任何一组,则调用“unfiled entry”)

  1. Roster roster = connection.getRoster();  
  2. Collection<RosterEntry> entries = roster.getEntries();  
  3. for (RosterEntry entry : entries) {  
  4.     System.out.println(entry);  
  5. }  

监听roster和presence更改

  1. Roster roster = con.getRoster();  
  2. roster.addRosterListener(new RosterListener() {  
  3.     // Ignored events public void entriesAdded(Collection<String> addresses) {}  
  4.     public void entriesDeleted(Collection<String> addresses) {}  
  5.     public void entriesUpdated(Collection<String> addresses) {}  
  6.     public void presenceChanged(Presence presence) {  
  7.         System.out.println("Presence changed: " + presence.getFrom() + " " + presence);  
  8.     }  
  9. });  

Provider architecture

smack provider是用于解析packet extension 和 IQ xml流的
有两种类型的provider
IQProvider - parses IQ request into java objects
Extension Provider - parses XML sub-documents attached to packets into PacketExtension instances. By default, Smack only knows how to process a few standard packets and sub-packets that are in a few namespaces such as:
(解析packet的xml子元素到PacketExtension实例中。Smack默认仅知道处理少数的标准packets和少数的指定的namespaces下的子packets)
jabber:iq:auth
jabber:iq:roster
jabber:iq:register

(provider这块翻译目前就暂且如此,接着会写IQ扩展将会提到这个,具体看IQ扩展)




    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章