mqttjava,mqttjava案例

本文目錄一覽：

• 1、Java/Android：關於ActiveMQ與MQTT的關係是什麼？
• 2、Java項目：mqtt發送的數據如何保存到數據庫里？
• 3、mqtt java開源框架哪個好用
• 4、mqtt 服務器搭建需要用到java嗎
• 5、如何對java mqtt程序測試性能

Java/Android：關於ActiveMQ與MQTT的關係是什麼？

實在看不下去了，網上怎麼竟是些胡說八道的呢。太坑人。MQTT（Message Queuing Telemetry Transport，消息隊列遙測傳輸）是IBM開發的一個即時通訊協議，activemq只是apache下一個隊列項目，不僅僅支持MQTT協議，也支持其他比如AMQP等協議。MQTT是協議，協議只是定義好的規則，比如文檔也是協議。activemq只是實現了MQTT協議的一個程序

Java項目：mqtt發送的數據如何保存到數據庫里？

循環遍歷set的元素，通過java.sql.PreparedStatement的setObject方法將set的元素按順序放入預編譯的參數化SQL中

mqtt java開源框架哪個好用

MQTT（MessageQueueing Telemetry Transport Protocol）的全稱是消息隊列遙感傳輸協議的縮寫，是由IBM公司推出的一種基於輕量級代理的發布/訂閱模式的消息傳輸協議，運行在TCP協議棧之上，為其提供有序、可靠、雙向連接的網絡連接保證。由於其開放、簡單和易於實現所以能夠應用在資源受限的環境中，對於M2M和物聯網應用程序來說是一個相當不錯的選擇。

mqtt 服務器搭建需要用到java嗎

最近公司做的項目中有用到消息推送，經過多方面的篩選之後確定了使用MQTT協議，相對於XMPP，MQTT更加輕量級，並且佔用用戶很少的帶寬。

MQTT是IBM推出的一種針對移動終端設備的基於TCP/IP的發布/預訂協議，可以連接大量的遠程傳感器和控制設備。

MQTT的官網見：。其中裡面提供了官方推薦的各種服務器和客戶端使用的各種語言版本的API。

下面以服務器Apollo 1.6為例，之前嘗試過使用ActiveMQ，效果很不理想，只能實現服務器和客戶端一對一的通信，從官網上了解到Apollo屬於activemq的一個子工程。先不管這些了，言歸正傳，以下在windows環境下。

1、在這裡下載Apollo服務器，下載後解壓，然後運行apache-apollo-1.6\bin\apollo.cmd，輸入create mybroker（名字任意取，這裡是根據官網介紹的來取的）創建服務器實例，服務器實例包含了所有的配置，運行時數據等，並且和一個服務器進程關聯。

2、create mybroker之後會在bin目錄下生成mybroker文件夾，裡面包含有很多信息，其中etc\apollo.xml文件下是配置服務器信息的文件，etc\users.properties文件包含連接MQTT服務器時用到的用戶名和密碼，後面會介紹，可以修改原始的admin=password，可以接着換行添加新的用戶名密碼。

3、打開cmd，運行…apache-apollo-1.6\bin\mybroker\bin\apollo-broker.cmd run 開啟服務器，可以在瀏覽器中輸入查看是否安裝成功，該界面展示了topic，連接數等很多信息。

經過上面的簡單步驟，服務器基本上就已經完成，下一篇將介紹Android客戶端的編寫和注意事項。

客戶端使用的API，開始我使用的是mqtt-client，使用過後發現問題百出，不能很好的滿足要求，後來使用了官方推薦的Eclipse Paho，下面開始客戶端代碼的編寫，為了方便測試這裡有android和j2se兩個工程：

1、新建android工程MQTTClient

2、MainActivity代碼如下：

如何對java mqtt程序測試性能

Java編程下用JMeter Java Sampler進行多接口性能測試，使用方法如下：

/**

*JMeter Java Sampler介紹

*setupTest做些初始化的工作，每個線程只執行一次

*teardownTest做些清理工作，每個線程只執行一次

*runTest具體的測試執行工作，每個並發每次循環都將執行一次

**/

//繼承AbstractJavaSamplerClient

public class hessianTest extends AbstractJavaSamplerClient{

//hessian調用地址

private static String url = “”;

MyService collect = null;

HessianProxyFactory factory = new HessianProxyFactory();

public int id;

@Override

public void setupTest(JavaSamplerContext arg0) {

//獲取jmeter傳入參數

id=arg0.getIntParameter(“id”);

try {

collect = (MyService) factory.create(

MyService.class, url);

} catch (MalformedURLException e) {

e.printStackTrace();

}

}

@Override

public SampleResult runTest(JavaSamplerContext arg0) {

SampleResult sp = new SampleResult();

sp.sampleStart();

User rt = null;

try {

rt = collect.getUser(id);

} catch (Exception e) {

sp.sampleEnd();

sp.setSuccessful(false);

return sp;

}

sp.sampleEnd();

if(rt.getId()==id)

sp.setSuccessful(true);

else

sp.setSuccessful(false);

return sp;

}

@Override

public void teardownTest(JavaSamplerContext context) {

super.teardownTest(context);

}

}