Android基於XMPP Smack Openfire開發IM【三】客戶端接收伺服器傳送的訊息

阿新 • • 發佈：2019-02-11

Demo需求：android客戶端接收伺服器傳送來的訊息。

第一，客戶端程式碼如下：
MainActivity未做改動，與之前兩篇一樣
Java程式碼

package com.example.openfiretest;
import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.packet.Message;
import android.os.Bundle;
import android.os.Handler;
import android.app.Activity;
import android.content.Intent;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.Window;
import android.widget.CheckBox;
import android.widget.EditText;
import android.widget.Toast;
publicclass MainActivity extends Activity {
private EditText accountEditText;
private EditText passwordEditText;
publicvoid onCreate(Bundle savedInstanceState) {
super

.onCreate(savedInstanceState);
requestWindowFeature(Window.FEATURE_NO_TITLE);
setContentView(R.layout.activity_main);
accountEditText = (EditText) findViewById(R.id.username);
passwordEditText = (EditText) findViewById(R.id.password);
findViewById(R.id.login).setOnClickListener(new OnClickListener() {
publicvoid onClick(View v) {
String account = accountEditText.getText().toString();
String password = passwordEditText.getText().toString();
if (account.equals("") || password.equals("")) {
Toast.makeText(MainActivity.this, "賬號或密碼不能為空！",
Toast.LENGTH_SHORT).show();
} else {
ClientConServer ccs = new ClientConServer(MainActivity.this);
boolean b = ccs.login(account, password);
// 如果登入成功
if (b) {
Toast.makeText(MainActivity.this, "登陸成功！",
Toast.LENGTH_SHORT).show();
} else {
Toast.makeText(MainActivity.this, "登陸失敗！",
Toast.LENGTH_SHORT).show();
}
}
}
});
}
}

package com.example.openfiretest;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.packet.Message;

import android.os.Bundle;
import android.os.Handler;
import android.app.Activity;
import android.content.Intent;
import android.view.Menu;
import android.view.View;
import android.view.View.OnClickListener;
import android.view.Window;
import android.widget.CheckBox;
import android.widget.EditText;
import android.widget.Toast;

public class MainActivity extends Activity {
	
	
	
	private EditText accountEditText;
	private EditText passwordEditText;

	public void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		requestWindowFeature(Window.FEATURE_NO_TITLE);
		setContentView(R.layout.activity_main);
		accountEditText = (EditText) findViewById(R.id.username);
		passwordEditText = (EditText) findViewById(R.id.password);

		findViewById(R.id.login).setOnClickListener(new OnClickListener() {
			public void onClick(View v) {
				String account = accountEditText.getText().toString();
				String password = passwordEditText.getText().toString();
				if (account.equals("") || password.equals("")) {
					Toast.makeText(MainActivity.this, "賬號或密碼不能為空！",
							Toast.LENGTH_SHORT).show();
				} else {
					ClientConServer ccs = new ClientConServer(MainActivity.this);
					boolean b = ccs.login(account, password);
					// 如果登入成功
					if (b) {
						Toast.makeText(MainActivity.this, "登陸成功！",
								Toast.LENGTH_SHORT).show();
						
						
					} else {
						Toast.makeText(MainActivity.this, "登陸失敗！",
								Toast.LENGTH_SHORT).show();
					}
				}
			}
		});
	}
	
}

下面的這個類在第二篇的基礎上，在登陸以後新增一個監聽訊息的監聽器，用來監聽收到的訊息（程式碼89、90行）：
Java程式碼

package com.example.openfiretest;
import java.util.Collection;
import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.RosterGroup;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;
import android.content.Context;
import android.content.Intent;
import android.os.Handler;
import android.util.Log;
import android.widget.Toast;
publicclass ClientConServer {
privatestaticint PORT=5222;
private Context context;
public ClientConServer(Context context){
this.context=context;
}
//這裡收到訊息後，通過廣播將訊息傳送到需要的地方.哈哈，既然收到了伺服器傳送來的資訊，如何處理自己決定。
private Handler handler = new Handler(){
publicvoid handleMessage(android.os.Message m) {
Message msg=new Message();
msg=(Message) m.obj;
//把從伺服器獲得的訊息通過廣播發送
Intent intent = new Intent("org.yhn.mes");
String[] message=new String[]{
msg.getFrom(),
msg.getBody()};
System.out.println("==========收到伺服器訊息 From==========="+message[0].toString());
System.out.println("==========收到伺服器訊息 Body==========="+message[1].toString());
intent.putExtra("message", message);
context.sendBroadcast(intent);
};
};
publicboolean login(String a,String p){
ConnectionConfiguration config = new ConnectionConfiguration("192.168.0.124", PORT);
/** 是否啟用安全驗證 */
config.setSASLAuthenticationEnabled(false);
/** 是否啟用除錯 */
//config.setDebuggerEnabled(true);
/** 建立connection連結 */
XMPPConnection connection = new XMPPConnection(config);
try {
/** 建立連線 */
connection.connect();
/** 登入*/
connection.login(a, p);
/** 開啟讀寫執行緒，並加入到管理類中*/
//ClientSendThread cst=new ClientSendThread(connection);
//cst.start();
//ManageClientThread.addClientSendThread(a, cst);
//獲取使用者組、成員資訊。
System.out.println("======開始獲取組及使用者==========");
Roster roster = connection.getRoster();
Collection<RosterGroup> entriesGroup = roster.getGroups();
System.out.println("組的個數："+entriesGroup.size());
for(RosterGroup group: entriesGroup){
Collection<RosterEntry> entries = group.getEntries();
System.out.println("=========groupName==="+group.getName());
for (RosterEntry entry : entries) {
//Presence presence = roster.getPresence(entry.getUser());
//Log.i("---", "user: "+entry.getUser());
System.out.println("組成員名字："+entry.getName());
//Log.i("---", "tyep: "+entry.getType());
//Log.i("---", "status: "+entry.getStatus());
//Log.i("---", "groups: "+entry.getGroups());
}
}
System.out.println("======結束獲取組及使用者==========");
//在登陸以後應該建立一個監聽訊息的監聽器，用來監聽收到的訊息：
ChatManager chatManager = connection.getChatManager();
chatManager.addChatListener(new MyChatManagerListener());
returntrue;
} catch (XMPPException e) {
e.printStackTrace();
}
returnfalse;
}
/** message listener*/
class MyChatManagerListener implements ChatManagerListener {
publicvoid chatCreated(Chat chat, boolean arg1) {
chat.addMessageListener(new MessageListener(){
publicvoid processMessage(Chat arg0, Message msg) {
/**通過handler轉發訊息*/
android.os.Message m=handler.obtainMessage();
m.obj=msg;
m.sendToTarget();
}
});
}
}
}

package com.example.openfiretest;

import java.util.Collection;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.Roster;
import org.jivesoftware.smack.RosterEntry;
import org.jivesoftware.smack.RosterGroup;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;


import android.content.Context;
import android.content.Intent;
import android.os.Handler;
import android.util.Log;
import android.widget.Toast;

public class ClientConServer {
	private static int PORT=5222;
	private Context context;
	public ClientConServer(Context context){
		this.context=context;

	}
	//這裡收到訊息後，通過廣播將訊息傳送到需要的地方.哈哈，既然收到了伺服器傳送來的資訊，如何處理自己決定。
	private Handler handler = new Handler(){  
        public void handleMessage(android.os.Message m) {  
            Message msg=new Message();  
            msg=(Message) m.obj; 
            //把從伺服器獲得的訊息通過廣播發送  
            Intent intent = new Intent("org.yhn.mes");  
            String[] message=new String[]{  
                    msg.getFrom(),  
                    msg.getBody()}; 
            System.out.println("==========收到伺服器訊息  From==========="+message[0].toString());
            System.out.println("==========收到伺服器訊息  Body==========="+message[1].toString());
            intent.putExtra("message", message);  
            context.sendBroadcast(intent);  
        };  
    };
	
	public boolean login(String a,String p){
		ConnectionConfiguration config = new ConnectionConfiguration("192.168.0.124", PORT);
		/** 是否啟用安全驗證 */
		config.setSASLAuthenticationEnabled(false);
		/** 是否啟用除錯 */
        //config.setDebuggerEnabled(true);
        /** 建立connection連結 */
		XMPPConnection connection = new XMPPConnection(config);
		try {
			/** 建立連線 */
			connection.connect();
			
			
			/** 登入*/
			connection.login(a, p);
			/** 開啟讀寫執行緒，並加入到管理類中*/
			//ClientSendThread cst=new ClientSendThread(connection);
			//cst.start();
			//ManageClientThread.addClientSendThread(a, cst);
			
			//獲取使用者組、成員資訊。
			System.out.println("======開始獲取組及使用者==========");
			Roster roster = connection.getRoster();
			Collection<RosterGroup> entriesGroup = roster.getGroups();
			System.out.println("組的個數："+entriesGroup.size());
			for(RosterGroup group: entriesGroup){
				Collection<RosterEntry> entries = group.getEntries();
				System.out.println("=========groupName==="+group.getName());
				for (RosterEntry entry : entries) {
					//Presence presence = roster.getPresence(entry.getUser());
					//Log.i("---", "user: "+entry.getUser());
					System.out.println("組成員名字："+entry.getName());
					//Log.i("---", "tyep: "+entry.getType());
					//Log.i("---", "status: "+entry.getStatus());
					//Log.i("---", "groups: "+entry.getGroups());
				}
			}
			System.out.println("======結束獲取組及使用者==========");
			
			
			//在登陸以後應該建立一個監聽訊息的監聽器，用來監聽收到的訊息：
			ChatManager chatManager = connection.getChatManager();
			chatManager.addChatListener(new MyChatManagerListener());
			
			
			return true;
		} catch (XMPPException e) {
			e.printStackTrace();
		}
		return false;
	 }
	/** message listener*/  
    class MyChatManagerListener implements ChatManagerListener {  
    	
    	
        public void chatCreated(Chat chat, boolean arg1) {  
            chat.addMessageListener(new MessageListener(){  
                public void processMessage(Chat arg0, Message msg) {  
                    /**通過handler轉發訊息*/  
                    android.os.Message m=handler.obtainMessage();  
                    m.obj=msg;  
                    m.sendToTarget(); 
                	
                	
                }  
            });  
        } 
    }
}

第二，啟動android客戶端，進行登入。
[img]

[/img]

第三、在openfire的管理控制檯，會話-工具中傳送訊息給所有線上使用者，如下圖
[img]

[/img]

第四、列印資訊如下：
[img]

[/img]

Android基於XMPP Smack Openfire開發IM【三】客戶端接收伺服器傳送的訊息

Demo需求：android客戶端接收伺服器傳送來的訊息。第一，客戶端程式碼如下： MainActivity未做改動，與之前兩篇一樣 Java程式碼 package com.example.openfiretest; import org.jivesoftware.smack.Chat;

Android基於XMPP Smack Openfire開發IM【四】初步實現兩個客戶端通訊

本部落格要介紹的內容： Openfire做伺服器端，兩個客戶端：Spark、android模擬器。實現兩個客戶端之間的通訊。第一步：啟動openfire伺服器。（這裡需要用到兩個使用者登入，前面的部落格中已經說明如何新增使用者了。） [img] [/img] 第

Android基於XMPP Smack Openfire下學習開發IM(五)連接斷開重連

pen ide get ref ces 最好 string smack led 學習過程中大家都碰到過連接被斷開的問題給困擾吧，下面教大家如何做到連接斷開後，重新連接首先要創建連接監聽器，用來監聽連接狀態，這裏我寫了一個類繼承了ConnectionListener，重寫了裏

Android基於XMPP Smack Openfire下學習開發IM(一)實現使用者註冊、登入、修改密碼和登出等

以前學習過用Scoket 建立聊天，簡單的建立聊天是沒問題的，但如果要實現多人複雜的聊天，後臺伺服器程式碼就比較複雜，對於我這新手來講就比較難了。後來在網上看到用openfire做伺服器，利用強大的Smack API庫來實現IM聊天就簡單多了。網上也有很多關於這方面的資

Android基於XMPP Smack Openfire下學習開發IM(五)連線斷開重連

學習過程中大家都碰到過連線被斷開的問題給困擾吧，下面教大家如何做到連線斷開後，重新連線首先要建立連線監聽器，用來監聽連線狀態，這裡我寫了一個類繼承了ConnectionListener，重寫了裡面5個方法，最重要的兩個方法connectionClosed()和conn

Android基於環信SDK開發IM即時聊天（一）

目前市面上我瞭解的做第三方即時聊天SDK的有兩家：環信、融雲，這裡我使用環信SDK來完成即時聊天的初步開發工作。下面先奉上1張效果圖： 1、開發準備首先要到環信官網註冊開發者賬號，目前只有企業賬號註冊，不過反正也不會去稽核企業資訊的正確與否，所

android 使用xmpp smack openfire實現即時通訊（一）

介紹： XMPP ：XMPP（可擴充套件訊息處理現場協議）是基於可擴充套件標記語言（XML）的協議，它用於即時訊息（IM）以及線上現場探測。 smack:是一個開源包，易於使用的XMPP（jabber）客戶端類庫 openfire :作為伺服器提供服務。 ope

STemWin移植到MiCO物聯網作業系統筆記-基於秉火STM32F429開發板【2】

把 MiCO 移植到了 STM32F429上，並移植了 emWin到 MiCO 上原始碼Git地址https://github.com/zhaojuntao/MiCO-STM32F429-emWin 本DEMO所在目錄為：demos\application\LTDC_LCD em

STemWin移植到MiCO物聯網作業系統筆記-基於秉火STM32F429開發板【1】

這段時間，因為客戶要用WiFi模組來更新LCD螢幕圖片內容，但是傳統的WiFi模組都是基於串列埠透傳的，於是乎就看到秉火挑戰者開發板上有EMW1062 WiFi模組，SDIO通訊介面，於是就索性用秉火現成的STemWin DEMO來做了。之前也沒有移植過STemwin，網上簡單查了下，簡單

【iOS】客戶端安全性問題分析及處理方式

目前，大部分的移動應用都是需要聯網，與伺服器進行通訊，獲取最新的資料。一提到網路，肯定就有大量和安全性相關的問題出來。所以，對於我們開發者而言，如何打造一個安全的App，是必須面對的問題。前段時間我專門對iOS移動應用安全性方面進行了研究，下面我們分析iOS應用中可能會存在的安全風險以及相對應的處理

Go語言（伺服器開發）：客戶端向伺服器傳送資料並接收返回資料

客戶端向伺服器傳送資料並接收返回資料。示例程式碼： package mysocket import ( "fmt" "io" "net" ) func MySocketBase() { var ( host = "www.apache.org" p

【memcache】客戶端 cmd操作常用指令

1，啟動memcache 在開始-執行（也即cmd命令介面）下輸入以下命令安裝windows服務: D:\WampServer\bin\memcached>memcached.exe -d start 2，連線到memcahe telnet 127.0

【Zookeeper】——客戶端簡介

本篇部落格介紹客戶端，客戶端是開發人員使用Zookeeper最主要的途徑，包括Zookeeper的客戶端和第三方提供的客戶端。 Zookeeper的客戶端對Zookeeper的客戶端

Wb開發基礎-Http1.0協議-客戶端與伺服器端的互動

Web開發的學習已經有一段時間了，但是對於Web開發來講，最基礎的來講還要屬Http協議，因為它是Web瀏覽器和伺服器之間進行一問一答互動過程必須遵守的規則。當然，基本步驟大家都瞭解

【Unet】客戶端同步GameObject 列表

Unity 內建同步變數支援同步一些資料型別同步變數可以是基礎型別，如整數，字串和浮點數。也可以是Unity內建資料型別，如Vector3和使用者自定義的結構體，但是對結構體型別的同步變數，如

android開發學習 ------- 【轉】 android中的單例模式（詳解）

lan post tail -- and 使用 href details android開發 https://blog.csdn.net/u011418943/article/details/60139644 這篇文章前因後果都說出來了，值得學習。 htt

Android TV開發總結【RecycleView】

在TV開發中RecycleView的使用是最讓人頭疼的經常會出現焦點丟失。因為當item未顯示時不能獲取焦點。所以當我們按上下鍵時經常丟失焦點或者焦點亂跳。要解決這個問題我們必須要手動控制RecyclerView 的按鍵和焦點移動。所以我們這裡需要需要自定義

（iOS）基於XMPP協議的簡單IM實現

【 ********************************************************************************** 有網友在資源那留言，但是自己無法評論自己的資源，故在此說明：1、當初只是簡單的學習XMPP，通過自己做了個小Demo來了解其原理，進攻各

基於.net開發chrome核心瀏覽器【三】

本篇我們講解怎麼用CefGlue開發一個最簡單的瀏覽器一： CefGlue是建立在Cef專案之上的， Cef專案是C/C++的專案； CefGlue只不過是通過PInvoke來訪問Cef專案生成的一些dll 下面我們來看看Cef專案生成的一些dll和資源都

Vite ❤ Electron——基於Vite搭建Electron+Vue3的開發環境【一】

背景目前社群兩大Vue+Electron的腳手架：electron-vue和vue-cli-plugin-electron-builder，都有這樣那樣的問題，且都還不支援Vue3，然而Vue3已是大勢所趨， Vite勢必也將成為官方Vue腳手架，下圖是尤雨溪在開發好Vite之後與webpack之父的對

Android基於XMPP Smack Openfire開發IM【三】客戶端接收伺服器傳送的訊息

相關推薦