當(dāng)前位置：首頁 > 编程语言 > java >内容正文

java

java xmpp_Java XMPP负载测试工具

發(fā)布時間：2023/12/3 java 33 豆豆

生活随笔收集整理的這篇文章主要介紹了 java xmpp_Java XMPP负载测试工具小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

java xmpp

在本文中，我們將開發(fā)用Java編寫的XMPP負載測試工具。

1.簡介

可擴展消息傳遞和狀態(tài)協(xié)議 （ XMPP ）是基于XML（可擴展標記語言）的面向消息的中間件的通信協(xié)議。它是由Internet工程任務(wù)組（IETF）標準化并由XMPP標準基金會（XSF）支持和擴展的開放協(xié)議。 XMPP是在開放標準中定義的，并使用開放系統(tǒng)的開發(fā)和應(yīng)用方法。因此，許多服務(wù)器，客戶端和庫的實現(xiàn)都以自由和開源軟件的形式分發(fā)。 XMPP擴展協(xié)議（XEP）中還定義了許多擴展。

IgniteRealtime發(fā)行的一種免費的開源發(fā)行版提供了以下實現(xiàn)：

Openfire聊天服務(wù)器
Spark聊天客戶端
XMPP協(xié)議的Smack Java庫

Spark是類似于Messenger，What's app，Viber或Google Talk（實際上后者使用XMPP協(xié)議）的聊天客戶端應(yīng)用程序。一個人可以發(fā)送聊天消息，文件作為附件等。這些消息被發(fā)送到Openfire服務(wù)器，然后由其負責(zé)將它們傳遞到目的地，該服務(wù)器可以是直接與其連接的另一個Spark（或其他）聊天客戶端，也可以是另一個Openfire。實例（聯(lián)盟），直到他們到達最終目的地。

但是，服務(wù)器和客戶端在負載下的性能如何，即當(dāng)它們必須處理許多聊天消息或許多文件傳輸時？

2. XMPP負載測試工具

存在許多解決方案來對XMPP服務(wù)器（例如Openfire）進行負載/壓力測試（列表并不詳盡）：

帶有XMPP協(xié)議支持插件的Apache JMeter（請參閱[1,2]）
iksemel XMPP C庫
Tsung ，一種開源的多協(xié)議分布式負載測試工具

在本文中，我們將使用Smack XMPP庫編寫Java XMPP負載測試工具。

3.先決條件

您需要在系統(tǒng)上下載并安裝Openfire 。要嘗試我們的負載測試工具，使用嵌入式數(shù)據(jù)庫就足夠了，即使您需要記住嵌入式數(shù)據(jù)庫（HSQLDB）將在一段時間后填滿。當(dāng)然，推薦使用真實的RDBMS。

您必須創(chuàng)建許多用戶，這些用戶將模擬用戶消息交換負載。在我們的示例中，我們將創(chuàng)建50個用戶名，用戶名分別為user001到user050并具有相同的密碼a 。如果您不知道該怎么做，請登錄管理控制臺（例如http：// localhost：9090或https：// localhost：9091 ），然后單擊“ 用戶/組”選項卡；然后單擊“確定”。在那里，您可以單擊創(chuàng)建新用戶來創(chuàng)建用戶。

由于創(chuàng)建大量用戶非常繁瑣，因此有幾個插件可以節(jié)省您的時間。單擊Openfire管理控制臺的“ 插件”標簽，然后單擊“ 可用插件”并安裝“ 用戶創(chuàng)建”和/或“ 用戶導(dǎo)入/導(dǎo)出”插件。如果現(xiàn)在單擊返回到“ 用戶/組”選項卡，您將看到已創(chuàng)建新鏈接； 用戶創(chuàng)建 （由于用戶創(chuàng)建插件）和導(dǎo)入和導(dǎo)出 （由于用戶導(dǎo)入/導(dǎo)出插件）。剩下的練習(xí)是找出它們?nèi)绾喂ぷ鳌?

但是，這些并不是唯一需要做的更改。在最新版本的Openfire中，安全機制已更改，因此要使我們的程序正常運行，我們需要定義兩個屬性。單擊服務(wù)器選項卡， 服務(wù)器管理器->系統(tǒng)屬性，然后在頁面底部輸入以下屬性名稱/值對：

sasl.mechs.00001	PLAIN
sasl.mechs.00002	DIGEST-MD5

4. LoadXmppTest Java程序

我們將創(chuàng)建的工具是一個使用smack庫的Java程序。它提供了命令行界面（CLI），但是如果發(fā)現(xiàn)有用，則可以為其編寫圖形用戶界面（GUI）。

$ java -Djava.util.logging.config.file=logging.properties -jar loadxmpptest.jar Required options: s, d, p, n usage: java -Djava.util.logging.config.file=logging.properties –jar loadxmpptest.jar -a,--attachment Test attachments -b,--big Test big attachments or messages -d,--domain Domain -n,--number Number of users -o,--observer Observer -p,--password Password -s,--server Server Usage : java -Djava.util.logging.config.file=logging.properties -jar loadxmpptest.jar -s -d -p -n [-o ] [-a] [-b]jabber id : userXXX@chatroom : roomXXX@conference.observer : userXXX@/Spark (just to test)10 users per chatroom5 chatrooms Use:-a to test small attachments (file transfers) or-a -b to test big attachments (file transfers) or:-b to test long messages

此外， loadxmpptest.properties允許進一步配置測試應(yīng)用程序：

SHORT_MESSAGES_DELAY_SECONDS = 100 LONG_MESSAGES_DELAY_SECONDS = 60 SMALL_ATTACHMENTS_DELAY_MINUTES = 1 BIG_ATTACHMENTS_DELAY_MINUTES = 5 DELAY_TO_SEND_MESSAGES_MILLISECONDS = 1000 BIG_FILE_NAME_PATH=blob.txt SMALL_FILE_NAME_PATH=test.txt

日志存儲在log/loadxmpptest.log ，可以通過編輯logging.properties進行配置。

這是一個執(zhí)行示例，其中服務(wù)器為localhost ，域為localhost （可以是其他名稱），使用相同的密碼a模擬了50個用戶：

java -Djava.util.logging.config.file=logging.properties -jar loadxmpptest.jar -s localhost -d localhost -p a -n 50

另一個例子，這次發(fā)送大型附件：

java -Djava.util.logging.config.file=logging.properties -jar loadxmpptest.jar -s localhost -d localhost -p a -n 50 -ba

如上所述，要在loadxmpptest.properties中配置要發(fā)送的文件。

4.1創(chuàng)建一個新的Maven項目

跳到您最喜歡的IDE并創(chuàng)建一個新的Maven項目。將以下依賴項添加到pom.xml ：

<dependencies><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-core</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-tcp</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-im</artifactId><version>4.3.4</version></dependency> <dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-extensions</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-java7</artifactId><version>4.3.4</version></dependency><dependency><groupId>org.igniterealtime.smack</groupId><artifactId>smack-debug</artifactId><version>4.3.4</version></dependency><dependency><groupId>commons-cli</groupId><artifactId>commons-cli</artifactId><version>1.4</version></dependency> </dependencies>

這些是撰寫本文時的最新版本，但是您可以使用在Maven Central中可能找到的最新版本。

4.2創(chuàng)建主類

該程序由基于[10]的兩個類組成。 XmppLoadTest包含main()方法，并委托XmppManager來完成工作（與現(xiàn)實相反，因為規(guī)范是經(jīng)理委托而不是實際進行工作:)）。

public static void main(String[] args) throws Exception {parseCLIArguments(args);final XmppLoadTest loadXmppTest = new XmppLoadTest();loadProperties(PROPERTIES_FILE);init(loadXmppTest);performLoad(loadXmppTest); }

我將跳過parseCLIArguments()方法的描述。它使用Apache Commons CLI庫來解析命令行參數(shù)（請參見[4]）。您可以根據(jù)需要選擇其他任何CLI庫或創(chuàng)建GUI。

我們的測試模擬了50個用戶和5個聊天室（您可以模擬自己的方案來滿足您的需求）。這些存儲在：

private static final List<User> users = new ArrayList< >(numberOfUsers); private static final List<ChatRoom> chatRooms = new ArrayList< >(numberOfRooms);

類User和ChatRoom的定義如下：

/*** User (e.g. {@code user001}). Functionality delegated to @{see* XmppManager}.*/ final class User {private final String username;private final String password;private final String domain;private final XmppManager xmppManager; // delegate to itprivate MultiUserChat joinedChatRoom;public User(String username, String password, String domain, XmppManager xmppManager) {this.username = username;this.password = password;this.domain = domain;this.xmppManager = xmppManager;}public String getUsername() { return username; }public String getPassword() { return password; }public String getJabberID() { return username + "@" + domain; }public void connect() {xmppManager.connect();}public void disconnect() {xmppManager.destroy();LOG.info("User " + username + " disconnected.");}public void login() {xmppManager.login(username, password);}public void setStatus(boolean available, String status) {xmppManager.setStatus(available, status);}public void sendMessage(String toJID, String message) {xmppManager.sendMessage(toJID, message);}public void receiveMessage() {xmppManager.receiveMessage();}public void sendAttachment(String toJID, String path) {xmppManager.sendAttachment(toJID, "Smack", path);}public void receiveAttachment() {xmppManager.receiveAttachment(username);}public void joinChatRoom(String roomName, String nickname) {joinedChatRoom = xmppManager.joinChatRoom(roomName, nickname);}public void leaveChatRoom() {try {joinedChatRoom.leave();} catch (SmackException.NotConnectedException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());}}public void sendMessageToChatRoom(String message) {xmppManager.sendMessageToChatRoom(joinedChatRoom, message);}public String getJoinedChatRoom() {return joinedChatRoom.getRoom().toString();}public void addRosterListener() {xmppManager.rosterChanged();}}/*** Chat room, e.g. {@code room001}*/final class ChatRoom {private final String name;private final String domain;public ChatRoom(String name, String domain) {this.name = name;this.domain = domain;}public String getName() {return name + "@conference." + domain;}}

ChatRoom類很簡單。聊天室被標識為例如room001@conference.localhost ，其中conference是您在單擊Group Chat- > Group Chat Settings時在Openfire管理員控制臺中定義的子域，而localhost是我們通過命令行參數(shù)-d傳遞的域。 getName()返回的String是房間的裸JID ，我們將在后面看到。

User類更為復(fù)雜。它需要一個username ，一個password和一個domain并委托給XmppManager ，我們將很快看到。

XMPP客戶端的地址格式為user@server.com ，其中user是用戶名， server.com是域。 XMPP中的節(jié)點地址稱為Jabber ID，縮寫為JID 。 JID也可以具有資源（ user@server.com/resource ），這意味著用戶可以從多個設(shè)備連接。格式為user@server.com JID稱為裸JID ，而格式為user@server.com/resource的JID稱為完整JID 。

用戶可以setStatus() connect()到Openfire服務(wù)器，然后再login() ，然后用戶可以setStatus() ， sendMessage()/receiveMesage(), sendAttachment()/receiveAttachment(), joinChatRoom()/leaveChatRoom()和sendMessageToChatRoom() 。

init()方法初始化XmppManager()并創(chuàng)建50個用戶，每個用戶連接，登錄并將其狀態(tài)設(shè)置為available 。如果要測試文件傳輸，則每個用戶都開始收聽文件傳輸。也創(chuàng)建了五個聊天室。 50個用戶中的每個用戶都分配到一個聊天室，因此最后，每個聊天室都包含10個用戶。

private static void init(XmppLoadTest loadXmppTest) {XmppManager xmppManager = new XmppManager(server, domain, port);for (int i = 1; i <= numberOfUsers; i++) {User user = loadXmppTest.new User("user" + String.format("%03d", i), password, domain, xmppManager);user.connect();user.login();user.setStatus(true, "Hello from " + user.getUsername());users.add(user);if (testAttachments || testBigAttachments) {user.receiveAttachment();}}for (int i = 0; i < numberOfRooms; i++) {chatRooms.add(loadXmppTest.new ChatRoom("room" + String.format("%03d", i + 1), domain));}if (!testAttachments && !testBigAttachments) {// join chatroomsfor (int i = 1; i <= numberOfUsers; i++) {ChatRoom chatRoom = chatRooms.get((i - 1) % numberOfRooms);User user = users.get(i - 1);user.joinChatRoom(chatRoom.getName(), user.getJabberID());}} }

一種方案是讓每個user連接到五個聊天室之一并發(fā)送消息。任務(wù)被創(chuàng)建（ chatRoomMessageTask ）在performLoad()和每執(zhí)行every取決于消息的類型秒（長或短）作為配置loadxmpptest.properties 。

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1); ....} else { // send messages to chat roomsfinal Runnable task = () -> {while (true) {if (Thread.currentThread().isInterrupted()) {return;}loadXmppTest.chatRoomMessageTask();}};int every = testLongMessages ? longMessagesDelayInSeconds : shortMessagesDelayInSeconds;scheduler.scheduleWithFixedDelay(task, 0, every, SECONDS); // every x seconds }

另一種情況是將附件發(fā)送給另一個用戶，而不是將消息發(fā)送到聊天室：

if (testAttachments || testBigAttachments) { // send attachmentsString filePath = testBigAttachments ? bigFileNamePath : smallFileNamePath;int delay = testBigAttachments ? bigAttachmentsDelayInMinutes : smallAttachmentsDelayInMinutes;final Runnable task = () -> {while (true) {if (Thread.currentThread().isInterrupted()) {return;}loadXmppTest.fileTransferTask(filePath);}};scheduler.scheduleWithFixedDelay(task, 0, delay, MINUTES);

當(dāng)然，您可以將兩種情況結(jié)合起來，但是您需要確保不會溢出Openfire的緩存。

/** Each user sends a message to a chat room. */ private synchronized void chatRoomMessageTask() {for (int i = 1; i <= numberOfUsers; i++) {String message = testLongMessages ? LONG_MESSAGE : MESSAGE;User user = users.get(i - 1);try {Thread.currentThread().sleep(delayToSendMessagesInMillis); // sleep 1"user.sendMessageToChatRoom(message);LOG.info(user.getJabberID() + " sent " + (testLongMessages ? "long" : "short") + " message to " + user.getJoinedChatRoom());} catch (InterruptedException ie) {Thread.currentThread().interrupt(); // reset the flag}} }

在上述方法（稱為第一種情況）中，每個用戶向該用戶加入的聊天室發(fā)送一條消息（短消息或長消息）。

在fileTransferTask() ，每個用戶將附件發(fā)送給另一個用戶（避免將附件發(fā)送給自己）。請注意此方法和先前方法中的synchronized關(guān)鍵字，以避免代碼中出現(xiàn)死鎖。

/*** Exchange file attachments between users.** @param path path of the file to send* @see #transferFile(int, java.lang.String)*/ private void fileTransferTask(String path) {for (int i = 1; i <= numberOfUsers; i++) {transferFile(i, path);} } /*** Transfer the file to all other users.** @param i i-th user* @param path path of the file to be sent*/ private synchronized void transferFile(int i, String path) {int j;for (j = 1; j <= numberOfUsers; j++) {if (i != j) {try {int delay = testBigAttachments ? bigAttachmentsDelayInMinutes : smallAttachmentsDelayInMinutes;Thread.currentThread().sleep(delay); if (users.get(i - 1).sendAttachment(users.get(j - 1).getJabberID(), path)) {LOG.info("Attachment " + path + " sent from " + users.get(i - 1).getJabberID() + " to " + users.get(j - 1).getJabberID());} else {LOG.severe("Attachment " + path + " from " + users.get(i - 1).getJabberID() + " to " + users.get(j - 1).getJabberID() + " was not sent!");}} catch (InterruptedException ie) {Thread.currentThread().interrupt(); // reset the flag}}} }

這樣就完成了XmppLoadTest類的描述。

4.3 XmppManager類

XmppManager類使用smack庫[6，7]與Openfire服務(wù)器進行通信。 Smack是用于與XMPP服務(wù)器通信以執(zhí)行實時通信（包括即時消息傳遞和群聊）的庫。

XmppManager與[10]中的類似，但是直到那時事情已經(jīng)發(fā)生了發(fā)展，API也發(fā)生了變化。如前所述， User委托給XmppManager 。

4.3.1連接到Openfire

要連接到Openfire服務(wù)器，您需要托管Openfire 的服務(wù)器名稱，域和端口（已固定： 5222 ）。 XMPPTCPConnection類用于創(chuàng)建與XMPP服務(wù)器的連接。可以使用XMPPTCPConnectionConfiguration.Builder配置其他連接參數(shù)：

private String resource = "Smack"; ... XMPPTCPConnectionConfiguration.Builder builder = XMPPTCPConnectionConfiguration.builder(); try {builder.setXmppDomain(JidCreate.domainBareFrom(domain)).setHost(server).setPort(port).setResource(resource).setSecurityMode(SecurityMode.disabled).setHostnameVerifier((String hostname, SSLSession session) -> true); } catch (XmppStringprepException ex) {LOG.severe(ex.getLocalizedMessage()); } try {builder = TLSUtils.acceptAllCertificates(builder); } catch (KeyManagementException | NoSuchAlgorithmException ex) {LOG.log(Level.SEVERE, null, ex); } XMPPTCPConnection.setUseStreamManagementDefault(true); XMPPTCPConnectionConfiguration config = builder.build();

resource String對于文件傳輸很重要。如果您使用的是smack，則可以是"Smack"或"Resource" 。如果使用其他客戶端，例如Spark，則可以將其設(shè)置為"Spark ”。它可以確定將文件發(fā)送到的資源。

//SASLMechanism mechanism = new SASLDigestMD5Mechanism(); SASLMechanism mechanism = new SASLPlainMechanism(); SASLAuthentication.registerSASLMechanism(mechanism); SASLAuthentication.unBlacklistSASLMechanism("PLAIN"); SASLAuthentication.blacklistSASLMechanism("SCRAM-SHA-1"); SASLAuthentication.unBlacklistSASLMechanism("DIGEST-MD5"); try {builder = TLSUtils.acceptAllCertificates(builder); } catch (KeyManagementException | NoSuchAlgorithmException ex) {LOG.severe(ex.getLocalizedMessage()); } XMPPTCPConnection.setUseStreamManagementDefault(true); XMPPTCPConnectionConfiguration config = builder.build();

TLSUtils.acceptAllCertificates(builder); 這一點很重要，因為最新版本的Openfire中的安全模型已更改。因此，我們在Openfire的管理控制臺中添加了sasl.mechs.00001和sasl.mechs.00002 。如果他仍然遇到連接/身份驗證問題，則此鏈接可能有幫助。

4.3.2登錄

配置與Openfire的連接后，就可以連接到它了：

private AbstractXMPPConnection connection; ... connection = new XMPPTCPConnection(config); connection.setReplyTimeout(1000L); try {connection.connect(); } catch (SmackException | IOException | XMPPException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage()); }

默認情況下，如果突然斷開連接，Smack將嘗試重新連接。重新連接管理器將嘗試立即重新連接到服務(wù)器，并增加嘗試之間的延遲，因為連續(xù)的重新連接始終會失敗。創(chuàng)建連接后，用戶應(yīng)使用其憑據(jù)使用XMPPConnection.login()方法登錄：

public void login(String username, String password) {if (connection != null && connection.isConnected()) {try {connection.login(username, password);} catch (XMPPException | SmackException | IOException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());}}LOG.info(username + " authenticated? " + connection.isAuthenticated()); }

4.3.3在場和名冊

用戶登錄后，可以通過創(chuàng)建新的Chat或MultiUserChat對象開始與其他用戶Chat 。用戶還可以將其狀態(tài)設(shè)置為可用：

public void setStatus(boolean available, String status) {Presence.Type type = available ? Type.available : Type.unavailable;Presence presence = new Presence(type);presence.setStatus(status);try {connection.sendStanza(presence);} catch (SmackException.NotConnectedException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());} }

從客戶端到XMPP服務(wù)器的每條消息稱為數(shù)據(jù)包或節(jié)，并以XML的形式發(fā)送。節(jié)是客戶端可以在一個程序包中發(fā)送給服務(wù)器的最小XML數(shù)據(jù)段，反之亦然。 org.jivesoftware.smack.packet Java軟件包包含一些類，這些類封裝了XMPP允許的三種不同的基本數(shù)據(jù)包類型（ message ，狀態(tài)和IQ ）。這些節(jié)中的每個節(jié)由XMPP服務(wù)器和客戶端以不同的方式處理。節(jié)具有類型屬性，這些可用于進一步區(qū)分節(jié)[3]。

消息節(jié)旨在用于在XMPP實體之間發(fā)送數(shù)據(jù)。實在是忘了，也就是說，接收方不承認節(jié)。通常，當(dāng)您從客戶端發(fā)送消息節(jié)并且未生成任何類型的錯誤時，可以假定消息已成功發(fā)送。消息節(jié)的類型可以為“聊天”，“ groupchar”，“錯誤”等。

狀態(tài)節(jié)會通告其他實體的在線狀態(tài)（網(wǎng)絡(luò)可用性）。在線狀態(tài)類似于XMPP中的訂閱。當(dāng)您對某些JID的存在感興趣時，您就訂閱它們的存在，即，您告訴XMPP服務(wù)器“每次該JID向您發(fā)送狀態(tài)更新時，我都希望收到通知”。當(dāng)然，服務(wù)器會詢問JID持有者是否接受向您透露其在線信息。當(dāng)他們接受后，服務(wù)器會記住他們的決定，并在更改在線狀態(tài)時更新訂閱該狀態(tài)的任何人。術(shù)語“ 存在”還表示用戶是否在線。

最后， IQ （信息/查詢）節(jié)用于從服務(wù)器獲取一些信息（例如，有關(guān)服務(wù)器或其注冊客戶端的信息）或?qū)⒛承┰O(shè)置應(yīng)用于服務(wù)器。

在XMPP中，術(shù)語名冊用于指聯(lián)系人列表。用戶的聯(lián)系人列表通常存儲在服務(wù)器上。該名冊使您可以跟蹤其他用戶的可用性（狀態(tài)）。可以將用戶分為“朋友”和“同事”之類的組，然后您會發(fā)現(xiàn)每個用戶是聯(lián)機還是脫機。 Roster類允許您查找所有名單條目，它們所屬的組以及每個條目的當(dāng)前狀態(tài)。

名冊中的每個用戶都由RosterEntry表示，該成員包括：

XMPP地址（例如john@example.com ）。
您分配給用戶的名稱（例如"John" ）。
條目所屬的名冊中的組的列表。如果名冊條目不屬于任何組，則稱為“未歸檔條目”。

在名單中的每個條目都有一個與之關(guān)聯(lián)的存在。 Roster.getPresence(String user)方法將返回一個具有用戶狀態(tài)的Presence對象；如果用戶不在線或您尚未訂閱該用戶的狀態(tài)，則返回null 。用戶要么在線要么離線。當(dāng)用戶在線時，他們的存在可能包含擴展信息，例如他們當(dāng)前正在做什么，是否希望受到打擾等。

public Roster createRosterFor(String user, String name) throws Exception {LOG.info(String.format("Creating roster for buddy '%1$s' with name %2$s", user, name));Roster roster = Roster.getInstanceFor(connection);roster.createEntry(JidCreate.bareFrom(user), name, null);return roster; } public void printRosters() throws Exception {Roster roster = Roster.getInstanceFor(connection);Collection entries = roster.getEntries();for (RosterEntry entry : entries) {LOG.info(String.format("Buddy: %s", entry.getName()));} } public void rosterChanged() {Roster roster = Roster.getInstanceFor(connection);roster.addRosterListener(new RosterListener() {@Overridepublic void presenceChanged(Presence presence) {LOG.info("Presence changed: " + presence.getFrom() + " " + presence);resource = presence.getFrom().getResourceOrEmpty().toString();}@Overridepublic void entriesAdded(Collection clctn) { }@Overridepublic void entriesUpdated(Collection clctn) { }@Overridepublic void entriesDeleted(Collection clctn) { }}); }

狀態(tài)信息可能會經(jīng)常更改，并且名冊條目也可能會更改或刪除。要偵聽更改的花名冊和狀態(tài)數(shù)據(jù)，請使用RosterListener 。為了通知有關(guān)名冊的所有更改，應(yīng)在登錄XMPP服務(wù)器之前注冊RosterListener 。文件傳輸知道，如果收件人的資源發(fā)生了變化，所描述的是很重要的位置。

4.3.4聊天和多聊

您可以在ChatManager的幫助下發(fā)送和接收聊天消息。盡管可以將單個消息作為數(shù)據(jù)包發(fā)送和接收，但是使用org.jivesoftware.smack.chat2.Chat類將消息字符串視為聊天通常會更容易。聊天會在兩個用戶之間創(chuàng)建新的消息線程。 Chat.send(String)方法是一種便捷方法，它創(chuàng)建一個Message對象，使用String參數(shù)設(shè)置正文，然后發(fā)送消息。

/*** Send message to another user.** @param buddyJID recipient* @param message to send*/ public void sendMessage(String buddyJID, String message) {LOG.info(String.format("Sending message '%1$s' to user %2$s", message, buddyJID));try {Chat chat = ChatManager.getInstanceFor(connection).chatWith(JidCreate.entityBareFrom(buddyJID));chat.send(message);} catch (XmppStringprepException | SmackException.NotConnectedException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());} } public void receiveMessage() {ChatManager.getInstanceFor(connection).addIncomingListener((EntityBareJid from, Message message, Chat chat) -> {LOG.info("New message from " + from + ": " + message.getBody());}); }

要加入聊天室（ MultiUserChat ）并向其中發(fā)送消息：

public MultiUserChat joinChatRoom(String roomName, String nick) {try {MultiUserChatManager manager = MultiUserChatManager.getInstanceFor(connection);MultiUserChat muc = manager.getMultiUserChat(JidCreate.entityBareFrom(roomName));Resourcepart nickname = Resourcepart.from(nick);muc.join(nickname);LOG.info(muc.getNickname() + "joined chat room " + muc.getRoom());return muc;} catch (XmppStringprepException | SmackException.NotConnectedException | InterruptedException | SmackException.NoResponseException | XMPPException.XMPPErrorException | MultiUserChatException.NotAMucServiceException ex) {LOG.severe(ex.getLocalizedMessage());}return null; }public void sendMessageToChatRoom(MultiUserChat muc, String message) {try {muc.sendMessage(message);LOG.fine("Message '" + message + "' was sent to room '" + muc.getRoom() + "' by '" + muc.getNickname() + "'");} catch (InterruptedException | SmackException.NotConnectedException ex) {LOG.severe(ex.getLocalizedMessage());} }

您可以在加入聊天室時定義昵稱。

4.3.5文件傳輸

要發(fā)送/接收附件，它比較復(fù)雜（請參見此處）：

/*** File transfer.** @param buddyJID recipient* @param res e.g. "Spark-2.8.3", default "Smack" (cannot be empty or null)* @param path path of the file attachment to send* @return {@code true} if file transfer was successful*/ public boolean sendAttachment(String buddyJID, String res, String path) {LOG.info(String.format("Sending attachment '%1$s' to user %2$s", path, buddyJID));FileTransferManager fileTransferManager = FileTransferManager.getInstanceFor(connection);FileTransferNegotiator.IBB_ONLY = true;OutgoingFileTransfer fileTransfer = null;try {fileTransfer = fileTransferManager.createOutgoingFileTransfer(JidCreate.entityFullFrom(buddyJID + "/Spark-2.8.3"));} catch (XmppStringprepException ex) {LOG.log(Level.SEVERE, null, ex);return false;}if (fileTransfer != null) {OutgoingFileTransfer.setResponseTimeout(15 * 60 * 1000);LOG.info("status is:" + fileTransfer.getStatus());File file = Paths.get(path).toFile();if (file.exists()) {try {fileTransfer.sendFile(file, "sending attachment...");} catch (SmackException ex) {LOG.severe(ex.getLocalizedMessage());return false;}LOG.info("status is:" + fileTransfer.getStatus());if (hasError(fileTransfer)) {LOG.severe(getErrorMessage(fileTransfer));return false;} else {return monitorFileTransfer(fileTransfer, buddyJID);}} else try {throw new FileNotFoundException("File " + path + " not found!");} catch (FileNotFoundException ex) {LOG.severe(ex.getLocalizedMessage());return false;}}}return true; }/*** Monitor file transfer.** @param fileTransfer* @param buddyJID* @return {@code false} if file transfer failed.*/ private boolean monitorFileTransfer(FileTransfer fileTransfer, String buddyJID) {while (!fileTransfer.isDone()) {if (isRejected(fileTransfer) || isCancelled(fileTransfer)|| negotiationFailed(fileTransfer) || hasError(fileTransfer)) {LOG.severe("Could not send/receive the file to/from " + buddyJID + "." + fileTransfer.getError());LOG.severe(getErrorMessage(fileTransfer));return false;} else if (inProgress(fileTransfer)) {LOG.info("File transfer status: " + fileTransfer.getStatus() + ", progress: " + fileTransfer.getProgress());}try {Thread.sleep(1000);} catch (InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());}}if (isComplete(fileTransfer)) {LOG.info(fileTransfer.getFileName() + " has been successfully transferred.");LOG.info("The file transfer is " + (fileTransfer.isDone() ? "done." : "not done."));return true;}return true; }public void receiveAttachment(String username) {final FileTransferManager manager = FileTransferManager.getInstanceFor(connection);manager.addFileTransferListener((FileTransferRequest request) -> {// Check to see if the request should be acceptedif (request.getFileName() != null) {StringBuilder sb = new StringBuilder(BUFFER_SIZE);try {// Accept itIncomingFileTransfer transfer = request.accept();String filename = transfer.getFileName() + "_" + username;transfer.receiveFile(new File(filename));while (!transfer.isDone()) {try {Thread.sleep(1000);LOG.info("STATUS: " + transfer.getStatus()+ " SIZE: " + sb.toString().length()+ " Stream ID : " + transfer.getStreamID());} catch (Exception e) {LOG.severe(e.getMessage());}if (transfer.getStatus().equals(FileTransfer.Status.error)) {LOG.severe(transfer.getStatus().name());}if (transfer.getException() != null) {LOG.severe(transfer.getException().getLocalizedMessage());}}LOG.info("File received " + request.getFileName());} catch (SmackException | IOException ex) {LOG.severe(ex.getLocalizedMessage());}} else {try {// Reject itrequest.reject();LOG.warning("File rejected " + request.getFileName());} catch (SmackException.NotConnectedException | InterruptedException ex) {LOG.severe(ex.getLocalizedMessage());}}}); }

Openfire中定義了3種類型的文件傳輸：

帶內(nèi) （ FileTransferNegotiator.IBB_ONLY ），其中消息被分解為多個塊并作為編碼消息發(fā)送。它速度較慢，但??始終有效。此外，由于交換的消息存儲在Openfire數(shù)據(jù)庫中，因此備份起來更容易。
當(dāng)兩個用戶都在同一網(wǎng)絡(luò)上時，對等（p2p）效果很好，但是當(dāng)一個用戶在防火墻后面或使用NAT時，對等（p2p）失敗。它速度更快，除了上述問題之外，您還無法控制要交換的內(nèi)容。
代理服務(wù)器 （SOCKS5，請參閱XEP-0096或更新的XEP-0234 ）使用文件傳輸代理，但需要打開端口7777。它比p2p慢，但比帶內(nèi)快。

在我們的測試工具中，正在使用帶內(nèi)文件傳輸。

一旦成功發(fā)送文件，就需要監(jiān)視其狀態(tài)（ monitorFileTransfer() ）。可能存在網(wǎng)絡(luò)錯誤，或者收件人可能只是拒絕文件傳輸。實際上，其他用戶可以選擇接受，拒絕或忽略文件傳輸請求。

發(fā)送附件是OutgoingFileTransfer ，而接收是IncomingFileTransfer 。這是通過將偵聽器添加到FileTransferManager來實現(xiàn)的。如前所述，接收者需要在發(fā)送者發(fā)送文件之前開始偵聽。此外，在我們的負載測試中，正在發(fā)送和接收相同的文件。為了避免覆蓋同一文件，源文件以不同的名稱存儲，在文件名中添加"_"和收件人的名稱。當(dāng)然，這些文件名在負載測試工具運行時會一次又一次地寫入。

建立

為了能夠執(zhí)行負載測試工具，您需要創(chuàng)建一個可執(zhí)行文件XmppLoadTest-1.0.jar 。一種方法是將以下內(nèi)容添加到pom.xml中：

<build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-jar-plugin</artifactId><version>3.2.0</version><configuration><archive><manifest><addClasspath>true</addClasspath><mainClass>test.xmpp.xmpploadtest.XmppLoadTest</mainClass></manifest></archive></configuration></plugin></plugins> </build>

并且還需要將依賴項包括到classpath中。或者，您可以使用依賴項插件來創(chuàng)建一個單個jar ，該jar可以創(chuàng)建此處所述的所有內(nèi)容。

<plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-assembly-plugin</artifactId><version>3.2.0</version><configuration><archive><manifest><mainClass>test.xmpp.xmpploadtest.XmppLoadTest</mainClass></manifest></archive><descriptorRefs><descriptorRef>jar-with-dependencies</descriptorRef></descriptorRefs></configuration><executions><execution><id>make-assembly</id> <phase>package</phase> <goals><goal>single</goal></goals></execution></executions> </plugin>

您也可以使用maven命令代替執(zhí)行它：

mvn exec:java -Dexec.mainClass=test.xmpp.xmpploadtest.XmppLoadTest "-Dexec.args=-s localhost -d localhost -p a -n 50"

4.5負載測試

一旦執(zhí)行了負載測試工具，您將看到許多發(fā)送到Openfire服務(wù)器的消息。根據(jù)您選擇的方案（群聊或文件傳輸），如果您使用第50個用戶（例如Spark）之類的聊天客戶端進行連接并加入聊天室，您將看到他們被重復(fù)發(fā)送的相同消息所填充其他49個模擬用戶。

Apr 25, 2020 11:55:16 PM test.xmpp.xmpploadtest.XmppManager connect INFO: Initializing connection to server localhost port 5222 Apr 25, 2020 11:55:18 PM test.xmpp.xmpploadtest.XmppManager connect INFO: Connected: true Apr 25, 2020 11:55:18 PM test.xmpp.xmpploadtest.XmppManager login INFO: user001 authenticated? True ... Apr 25, 2020 11:55:21 PM test.xmpp.xmpploadtest.XmppManager joinChatRoom INFO: user001@localhost joined chat room room001@conference.localhost Apr 25, 2020 11:55:21 PM test.xmpp.xmpploadtest.XmppManager joinChatRoom INFO: user002@localhost joined chat room room002@conference.localhost ... Apr 25, 2020 11:55:24 PM test.xmpp.xmpploadtest.XmppLoadTest chatRoomMessageTask INFO: user001@localhost sent short message to room001@conference.localhost Apr 25, 2020 11:55:25 PM test.xmpp.xmpploadtest.XmppLoadTest chatRoomMessageTask INFO: user002@localhost sent short message to room002@conference.localhost ...

在user050情況下運行該工具時，您不會在Spark或以user050連接到的聊天客戶端中看到任何附件。

INFO: Sending attachment 'test.txt' to user user003@localhost [Sun May 10 17:55:15 CEST 2020] INFO: status is:Initial [Sun May 10 17:55:15 CEST 2020] INFO: status is:Initial [Sun May 10 17:55:15 CEST 2020] INFO: STATUS: Complete SIZE: 0 Stream ID : jsi_2604404248040129956 [Sun May 10 17:55:15 CEST 2020] INFO: File received test.txt [Sun May 10 17:55:15 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_4005559316676416776 [Sun May 10 17:55:16 CEST 2020] WARNING: Closing input stream [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_6098909703710301467 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_2348439600749627884 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_8708250841661514027 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_2119745768373873364 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_6583436044582265363 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_3738252107587424431 [Sun May 10 17:55:16 CEST 2020] INFO: STATUS: In Progress SIZE: 0 Stream ID : jsi_4941117510857455094 [Sun May 10 17:55:16 CEST 2020] INFO: test.txt has been successfully transferred. [Sun May 10 17:55:16 CEST 2020] INFO: The file transfer is done. [Sun May 10 17:55:16 CEST 2020]

一旦運行了加載/壓力工具，就可以搜索XMPP服務(wù)器或客戶端的內(nèi)存泄漏或CPU使用率過高。您可以使用VisualVM之類的工具來監(jiān)視內(nèi)存和CPU，或者甚至可以根據(jù)需要使用YourKit或Java Flight Recorder之類的工具進行概要分析。

5.總結(jié)

在本教程中，我們學(xué)習(xí)了如何編寫自己的負載測試工具來對XMPP服務(wù)器（如Openfire）進行負載/壓力測試。負載/壓力工具還可以用于測試XMPP客戶端（例如Spark）。如果您編寫了自己的XMPP客戶端或服務(wù)器，那么它也可以用于測試它們。該工具使用Smack XMPP庫以Java編寫。它可以在兩種模式或場景下運行，既可以將消息發(fā)送到聊天室，也可以在用戶之間發(fā)送文件傳輸。 XMPP服務(wù)器需要使用模擬用戶和聊天室進行預(yù)配置。

您可以根據(jù)需要進行自定義，進一步擴展源代碼，例如用戶數(shù)量，消息或文件附件的大小，消息之間的延遲，發(fā)送消息和文件傳輸?shù)慕M合或測試XMPP的其他方面協(xié)議。

6.參考

Aladev R.（2017a），“ XMPP負載測試–最終指南 ”。

Aladev R.（2017b），“ XMPP負載測試–高級方案 ”。

Gakwaya D.（2016），“ XMPP的友好介紹 ”。

Marx D.（2017），“ Java命令行界面（第1部分）：Apache Commons CLI ”，JavaCodeGeeks。

Saint-Andre P.，Smith K.，Troncon R.（2009年）， XMPP：權(quán)威指南，O'Reilly。

Smack API

打擊文件

Tsagklis I.（2010a），“ Openfire服務(wù)器安裝-即時消息基礎(chǔ)結(jié)構(gòu) ”，JavaCodeGeeks。

Tsagklis I.（2010b），“ Openfire服務(wù)器配置-即時消息基礎(chǔ)結(jié)構(gòu) ”，JavaCodeGeeks。

Tsagklis I.（2010c），“ 帶有適用于Java應(yīng)用程序的Smack的XMPP IM –即時消息基礎(chǔ)結(jié)構(gòu) ”，JavaCodeGeeks。

7.下載Maven項目

那是一篇有關(guān)Java XMPP負載測試工具的文章。

下載
您可以在此處下載完整的源代碼： Java XMPP負載測試工具

翻譯自: https://www.javacodegeeks.com/java-xmpp-load-test-tool.html