2. 程式人生 > >Androidpn裡的Xmpp的理解(訊息推送)

Androidpn裡的Xmpp的理解(訊息推送)

阿新 • • 發佈：2019-01-23

XMPP(可擴充套件通訊和表示協議)是基於可擴充套件標記語言（XML）的協議，它用於即時訊息（IM）以及線上探測。這個協議可能最終允許因特網使用者向因特網上的其他任何人傳送即時訊息。用xmpp來實現android的push功能，感覺有點大材小用了，xmpp本身是一種即時通訊協議。

  xmpp是一種用於即時通訊的協議，使用過程有點類似於我們使用QQ的過程，其使用過程分為三步：

  1. 連線伺服器，就好像開啟QQ軟體，看程式碼：

  1. if(!mXmppManager.isConnected()) {  
  2.     ConnectionConfiguration config = new ConnectionConfiguration(mHost, mPort);  
  3.     config.setSecurityMode(SecurityMode.required);  
  4.     config.setSASLAuthenticationEnabled(false);  
  5.     config.setCompressionEnabled(false);  
  6.     XMPPConnection connection = new XMPPConnection(config);  
  7.     mXmppManager.setConnection(connection);  
  8.     try {  
  9.         connection.connect();  
  10.         Log.i(LOGTAG, "XMPP connected successfully"
    );  
  11.         /** 
  12.          * 這個就是對於通訊的xml文字進行解析的解析器，再把資訊轉換成IQ，這個相當於QQ的聊天資訊 
  13.          * 如果要用這個協議，其IQ的子類和IQProvider要進行重寫 
  14.          */
  15.         ProviderManager.getInstance().addIQProvider("notification",  
  16.                 "androidpn:iq:notification",  
  17.                 new NotificationIQProvider());  
  18.     } catch
     (XMPPException e) {  
  19.         Log.d(LOGTAG, "the connection is error ... ");  
  20.     }  
  21.     mXmppManager.runTask();  
  22. } else {  
  23.     Log.i(LOGTAG, "XMPP connected already");  
  24.     mXmppManager.runTask();  
  25. }  

這一步主要是連線伺服器，還有設定一些連線的引數，還有設定連線的解析器。

  2. 如果沒有使用者，註冊新的帳號和密碼

  1. if(!mXmppManager.isRegistered()){  
  2.     final String newUsername = newRandomUUID();  
  3.     final String newPassword = newRandomUUID();  
  4.     Registration registration = new Registration();  
  5.     PacketFilter packetFilter = new AndFilter(new PacketIDFilter(  
  6.             registration.getPacketID()), new PacketTypeFilter(  
  7.             IQ.class));  
  8.     PacketListener packetListener = new PacketListener() {  
  9.         @Override
  10.         publicvoid processPacket(Packet packet) {  
  11.             // 伺服器回覆客戶端
  12.             if(packet instanceof IQ) {  
  13.                 IQ response = (IQ) packet;  
  14.                 if(response.getType() == IQ.Type.ERROR) { // 註冊失敗
  15.                     if (!response.getError().toString().contains(  
  16.                             "409")) {  
  17.                         Log.e(LOGTAG,"Unknown error while registering XMPP account! " + response.getError().getCondition());  
  18.                     }  
  19.                 } elseif(response.getType() == IQ.Type.RESULT) { // 註冊成功
  20.                     mXmppManager.setUsername(newUsername);  
  21.                     mXmppManager.setPassword(newPassword);  
  22.                     // 把使用者名稱和密碼都儲存到磁碟
  23.                     Editor editor = mSharedPrefs.edit();  
  24.                     editor.putString(Contants.XMPP_USERNAME, newUsername);  
  25.                     editor.putString(Contants.XMPP_PASSWORD, newPassword);  
  26.                     editor.commit();  
  27.                     mXmppManager.runTask();  
  28.                 }  
  29.             }  
  30.         }  
  31.     };  
  32.     // 給註冊的Packet設定Listener，因為只有等到正真註冊成功後，我們才可以交流
  33.     mConnection.addPacketListener(packetListener, packetFilter);  
  34.     registration.setType(IQ.Type.SET);  
  35.     registration.addAttribute("username", newUsername);  
  36.     registration.addAttribute("password", newPassword);  
  37.     // 向伺服器端，傳送註冊Packet包，注意其中Registration是Packet的子類
  38.     mConnection.sendPacket(registration);  
  39. } else { // 已經註冊過了
  40.     mXmppManager.runTask();  
  41. }  

只要連線了伺服器了，客戶端就可以向伺服器端傳送訊息，傳送是以Packet（資料包）來進行傳送的，這個類有很多的子類，註冊的子類為Registration。

 還有要注意的是，上面的addPacketListener方法不是給所有傳送的資料包設定listener，而只是針對這次的註冊Packet。

  3. 用註冊的帳號和密碼進行登陸（像用QQ號帳進行登陸一樣）

  1. // 判斷是否已經登陸過了，是否是在登陸狀態
  2. if(!mXmppManager.isAuthenticated()) {  
  3.     try {  
  4.         mConnection.login(mUsername, mPassword, "AndroidpnClient");  
  5.         // 設定XmppConnection的監聽器
  6.         if(mXmppManager.getConnectionListener() != null) {  
  7.             mConnection.addConnectionListener(mXmppManager.getConnectionListener());  
  8.         }  
  9.         // 設定伺服器端推送的監聽器
  10.         PacketFilter packetFilter = new PacketTypeFilter(NotificationIQ.class);  
  11.         PacketListener packetListener = mXmppManager.getNotificationPacketListener();  
  12.         mConnection.addPacketListener(packetListener, packetFilter);  
  13.         mXmppManager.runTask();  
  14.     } catch (XMPPException e) {  
  15.         // 登陸失敗，應該重試 
  16.         String INVALID_CREDENTIALS_ERROR_CODE = "401";  
  17.         String errorMessage = e.getMessage();  
  18.         // 如果只是因為沒有註冊，則進行重新註冊
  19.         if (errorMessage != null && errorMessage.contains(INVALID_CREDENTIALS_ERROR_CODE)) {  
  20.             mXmppManager.reregisterAccount();   
  21.             return;  
  22.         }  
  23.         mXmppManager.startReconnectionThread();  
  24.     } catch (Exception e) { // 有可能mConnection都為空
  25.         Log.e(LOGTAG, "LoginTask.run()... other error");  
  26.         Log.e(LOGTAG, "Failed to login to xmpp server. Caused by: " + e.getMessage());  
  27.         mXmppManager.startReconnectionThread(); // 啟動重連執行緒
  28.     }  
  29. } else {  
  30.     mXmppManager.runTask();  
  31. }  

這裡設定了連線的監聽器mConnection.addConnectionListener()，連線過程中有可以連線突然中斷，連接出錯等等問題，要進行監聽。

  設定伺服器推送資訊的Listener，接收到資訊後，顯示給使用者。
  如果出錯的原因是401（無效的使用者名稱和密碼，則應該進行重新註冊，再連線）

對於伺服器push過來的資訊進行處理，是在PacketListener類裡面，這個接口裡，只要實現一個方法processPacket(Packet packet)，從傳過來的Packet（資料包）裡獲取自己需要的資料：

  1. publicvoid processPacket(Packet packet) {  
  2.     if(packet instanceof NotificationIQ) {  
  3.         NotificationIQ notification = (NotificationIQ) packet;  
  4.         if(notification.getChildElementXML().contains("androidpn:iq:notification")) {  
  5.             String notificationId = notification.getId();  
  6.             String notificationApiKey = notification.getApiKey();  
  7.             String notificationTitle = notification.getTitle();  
  8.             String notificationMessage = notification.getMessage();  
  9.             String notificationUri = notification.getUri();  
  10.             Intent intent = new Intent(Contants.ACTION_SHOW_NOTIFICATION);  
  11.             intent.putExtra(Contants.NOTIFICATION_ID, notificationId);  
  12.             intent.putExtra(Contants.NOTIFICATION_API_KEY,notificationApiKey);  
  13.             intent.putExtra(Contants.NOTIFICATION_TITLE,notificationTitle);  
  14.             intent.putExtra(Contants.NOTIFICATION_MESSAGE, notificationMessage);  
  15.             intent.putExtra(Contants.NOTIFICATION_URI, notificationUri);  
  16.             mXmppManager.getContext().sendBroadcast(intent);  
  17.         }  
  18.     }  
  19. }  

相關推薦

Androidpn裡的Xmpp的理解(訊息推送)

XMPP(可擴充套件通訊和表示協議)是基於可擴充套件標記語言（XML）的協議，它用於即時訊息（IM）以及線上探測。這個協議可能最終允許因特網使用者向因特網上的其他任何人傳送即時訊息。用xmpp來實現android的push功能，感覺有點大材小用了，xmpp本身是一種即時通

Android裡的Xmpp的理解(訊息推送)

 XMPP(可擴充套件通訊和表示協議)是基於可擴充套件標記語言（XML）的協議，它用於即時訊息（IM）以及線上探測。這個協議可能最終允許因特網使用者向因特網上的其他任何人傳送即時訊息。用xmpp來實現android的push功能，感覺有點大材小用了，xmpp本身是一種即時

Android開發-在Android應用裡整合友盟訊息推送SDK的實現（相容小米、華為、魅族機型離線推送）

前 言 最近由於專案的功能需求的需要，需要在Android應用整合訊息推送的功能，而目前市面上的第三方訊息推送除了友盟推送外，還有極光推送、小米推送、個推以及信鴿（騰訊）推送等。當時本人對比各大第三方的訊息推送進行了測試，覺得友盟訊息推送整合簡單，推送訊息的

Android訊息推送的Androidpn實現方式：（一）下載androidpn伺服器端與客戶端的Demo並執行

androidpn是基於XMPP協議的用於向Android客戶端推送文字資訊的一套開源的工具。它幫我們做了那些維護Socket長連線等等的事情。  在真正把它使用在我們的專案中之前，我們先領略一下推送。 第二步，啟動伺服器端與客戶端，通過Web頁面推送。詳細的步驟如下：

android訊息推送（二）之——XMPP協議

XMPP協議 XMPP協議，中文名為可擴充套件通訊和表示協議，是一種以XML為基礎的開放式實時通訊協議，它將需要實時通訊的訊息嵌入到XML結構體中，不僅具有很好的可擴充套件性，還有較強的可讀性。 XM

一種通過xmpp實現離線訊息推送的方法及系統

[0039] 此外，本發明單獨設定的功能模組-1OS訊息模組，本質上既是XMPP伺服器的客戶端，又是APNS伺服器的訊息源，當訊息處理的瓶頸位於1S訊息模組時，如當前的1S訊息模組效能待改善或者同一時間內眾多離線訊息到達1S訊息模組時，則只需增加1S訊息模組伺服器的數量即可以解決此訊息處理瓶頸，因此本發明極易

androidpn實現訊息推送

androidpn是基於XMPP協議的用於向Android客戶端推送文字資訊的一套開源的工具。它幫我們做了那些維護Socket長連線等複雜的事情。 1.下載androidpn伺服器端與客戶端的Demo

AndroidPN訊息推送原理分析

簡介 AndroidPN：基於Asmack實現和伺服器端的持久連線，以實現伺服器對客戶端的推送，全稱為android push notification。 涉及的主要內容 XMPP：可擴充套件通訊和表示協議，可用於服務類實時通訊、表示和需求響應服務中的XML資

Android 基於Netty的訊息推送方案之物件的傳遞（四）

在上一篇文章中《Android 基於Netty的訊息推送方案之字串的接收和傳送（三）》我們介紹了Netty的字串傳遞，我們知道了Netty的訊息傳遞都是基於流，通過ChannelBuffer傳遞的，那麼自然，Object也需要轉換成ChannelBuffer來傳遞。好在Netty本身已經給我們寫好了

Android 基於Netty的訊息推送方案之字串的接收和傳送（三）

在上一篇文章中《Android 基於Netty的訊息推送方案之概念和工作原理(二)》 ，我們介紹過一些關於Netty的概念和工作原理的內容，今天我們先來介紹一個叫做ChannelBuffer的東東。 ChannelBuffer  Netty中的訊息傳遞，都必須以位元

Android 基於Netty的訊息推送方案之概念和工作原理(二)

上一篇文章中我講述了關於訊息推送的方案以及一個基於Netty實現的一個簡單的Hello World，為了更好的理解Hello World中的程式碼，今天我來講解一下關於Netty中一些概念和工作原理的內容，如果你覺得本篇文章有些枯燥，請先去閱讀《Android 基於Netty的訊息推送方案之Hell

IOS APNS訊息推送框架介紹(pushy)以及詳細使用方法

最近公司需要做IOS訊息推送的功能，我負責後臺推送，IOS端資料處理以及回撥我不負責，本篇文章主要介紹基於java的apns訊息推送，使用框架為pushy。 宣告：我先前也沒有接觸過這個IOS推送，自己研究了兩天，通過百度，對比各個框架的優缺點，最後選擇了這個框架，有說的不對的地方，還

android 實現mqtt訊息推送，以及不停斷線重連的問題解決

前段時間專案用到mqtt的訊息推送，整理一下程式碼，程式碼的原型是網上找的，具體哪個地址已經忘記了。 程式碼的實現是新建了一個MyMqttService，全部功能都在裡面實現，包括連伺服器，斷線重連，訂閱訊息，處理訊息，釋出訊息等基本操作。 首先新增依賴： dependencies { &

基於Netty實現的Android 訊息推送(即時通訊)的解決方案

根據Netty框架實現訊息推送(即時聊天)功能. Netty框架，TCP長連線，心跳，阻塞訊息佇列，執行緒池處理訊息傳送, 基於Google ProtoBuf自定義的訊息協議， TCP粘包/拆包.... 客戶端通過TCP連線到伺服器，並建立TCP長連線；當伺服器端收到新訊息後通過TCP連線推送給

百度雲訊息推送

import com.baidu.yun.core.log.YunLogEvent; import com.baidu.yun.core.log.YunLogHandler; import com.baidu.yun.push.auth.PushKeyPair; import com.baidu.yun

微信公總號訊息推送

                   * 任務完成給製作者推送訊息          &nbs

Android UDP - 簡單訊息推送功能

近期接觸了幾個小的Android開發專案，根據需求要利用到網路傳輸中的UDP協議方式傳輸，遇到不少坑，在此分享一下在Android應用中UDP的一些簡單技術功能實現，希望能幫到用得到的同僚。 需(wo)求(yao)分(gan)析(ma)： 從PC上輸入一串亂七八糟，然後能在我手機（某為pow

[轉]spring boot下WebSocket訊息推送

原文連結：spring boot下WebSocket訊息推送， 修正部分錯別字 WebSocket協議 WebSocket是一種在單個TCP連線上進行全雙工通訊的協議。WebSocket通訊協議於2011年被IETF定為標準RFC 6455，並由RFC7936補充規範。WebSocket A

Django——微信訊息推送

前言 微信公眾號的分類 微信訊息推送 公眾號 已認證公眾號 服務號 已認證服務號 企業號 基於：微信認證服務號 主動推送微信訊息。 前提：關注服務號 環境：沙箱環境 沙箱環境地址： https:/

RabbitMQ訊息推送總結

藉助於 RabbitMQ 的 Web STOMP 外掛，實現瀏覽器與服務端的全雙工通訊。從本質上說，RabbitMQ 的 Web STOMP 外掛也是利用 WebSocket 對 STOMP 協議進行了一次橋接，從而實現瀏覽器與服務端的雙向通訊。 安裝 RabbitMQ 服務