java實現mqtt
『壹』 java/Android：關於ActiveMQ與MQTT的關系是什麼
mq是隊列
tt是推送
mqtt是
推送隊列
mq是單純的隊列
推送的話
不能一下子全部推送完
也是需要隊列一個一個來推送
『貳』 java怎麼實現mqtt的接收通配符的數據
報什麼錯？
『叄』 如何實現消息推送功能
?可以用第三方軟體極光推送來實現。對於定製化需求較強的，或者想擁有自己推送平台的開發者，極光提供全功能的私有雲方案。極光推送快速開始步驟: 1、到極光推送官方網站注冊開發者帳號；
2、登錄進入管理控制台，創建應用程序，得到 Appkey（SDK 與伺服器端通過 Appkey 互相識別）；
3、在推送設置中給 Android 設置包名、給 iOS 上傳證書、啟用 WinPhone，根據你的需求進行選擇；
4、下載 SDK 集成到 App 里。
客戶端初始化 JPush 成功後，JPush 服務端會分配一個 Registration ID，作為此設備的標識（同一個手機不同 App 的 Registration ID 是不同的）。開發者可以通過指定具體的 Registration ID 來進行對單一設備的推送。
『肆』 java 實現串口接收到數據，立馬將接收到的數據通過mqtt上傳到阿里雲。
也不是特別麻煩，你先要清楚串口和伺服器用的什麼協議，假設串口用232，伺服器採用TCP，那麼你需要做的是建立一個客戶端的發送模塊，和一個串口的操作模塊（結合必須要用到多線程，以隊列或者委託來做數據交換）;在測試之前一定要保證串口和客戶端發送接收是ok的才能做結合功能。
因為你串口已經做好了，那你需要的是將採集到的數據（字元串）保存到數組中，然後創建一個指向數組的指針p，然後在客戶端模塊里，將發送的數據寫成&p。建議先將數據轉16進制發，應該沒毛病。
『伍』 mqtt java開源框架哪個好用
MQTT（MessageQueueing Telemetry Transport Protocol）的全稱是消息隊列遙感傳輸協議的縮寫，是由IBM公司推出的一種基於輕量級代理的發布/訂閱模式的消息傳輸協議，運行在TCP協議棧之上，為其提供有序、可靠、雙向連接的網路連接保證。由於其開放、簡單和易於實現所以能夠應用在資源受限的環境中，對於M2M和物聯網應用程序來說是一個相當不錯的選擇。
『陸』 如何寫一個MQTT連接的android客戶端
MQTT是一個輕量級的消息發布/訂閱協議，它是實現基於手機客戶端的消息推送伺服器的理想解決方案。 我們可以從這里下載該項目的實例代碼，並且可以找到一個採用php書寫的伺服器端實現。 架構如下所示： wmqtt.jar 是IBM提供的MQTT協議的實現。你可以從如下站點下載它。你可以將該jar包加入你自己的Android應用程序中。 Really Small Message Broker (RSMB) ，他是一個簡單的MQTT代理，同樣由IBM提供。預設打開1883埠，應用程序當中，它負責接收來自伺服器的消息並將其轉發給指定的移動設備。 SAM是一個針對MQTT寫的PHP庫。你可以從這個下載它. send_mqtt.php是一個通過POST接收消息並且通過SAM將消息發送給RSMB的PHP腳本。 實例代碼： Ø 採用XMPP協議實現Android推送 這是我在項目中採用的方案。事實上Google官方的C2DM伺服器底層也是採用XMPP協議進行的封裝。 XMPP(可擴展通訊和表示協議)是基於可擴展標記語言（XML）的協議，它用於即時消息（IM）以及在線探測。這個協議可能最終允許網際網路用戶向網際網路上的其他任何人發送即時消息。 androidpn是一個基於XMPP協議的java開源Android push notification實現。它包含了完整的客戶端和伺服器端。經過源代碼研究我發現，該伺服器端基本是在另外一個開源工程openfire基礎上修改實現的，不過比較郁悶的是androidpn的文檔是由韓語寫的，所以整個研究過程基本都是讀源碼。它的實現示意圖如下： androidpn客戶端需要用到一個基於java的開源XMPP協議包asmack，這個包同樣也是基於openfire下的另外一個開源項目smack，不過我們不需要自己編譯，可以直接把androidpn客戶端裡面的asmack.jar拿來使用。客戶端利用asmack中提供的XMPPConnection類與伺服器建立持久連接，並通過該連接進行用戶注冊和登錄認證，同樣也是通過這條連接，接收伺服器發送的通知。 androidpn伺服器端也是java語言實現的，基於openfire開源工程，不過它的Web部分採用的是spring框架，這一點與openfire是不同的。Androidpn伺服器包含兩個部分，一個是偵聽在5222埠上的XMPP服務，負責與客戶端的XMPPConnection類進行通信，作用是用戶注冊和身份認證，並發送推送通知消息。另外一部分是Web伺服器，採用一個輕量級的HTTP伺服器，負責接收用戶的Web請求。伺服器架構如下： 最上層包含四個組成部分，分別是SessionManager，Auth Manager，PresenceManager以及Notification Manager。SessionManager負責管理客戶端與伺服器之間的會話，Auth Manager負責客戶端用戶認證管理，Presence Manager負責管理客戶端用戶的登錄狀態，NotificationManager負責實現伺服器向客戶端推送消息功能。 伺服器端界面如下，分別對應了上述的幾個功能模塊： 發送以後，我們可以在手機端看到接收的消息：
『柒』 一個能運行的，用java實現的一個MQTT協議的demo，包括服務端和客戶端
https://gitee.com/cuteTree/jmqtt/ 親測有效。加群基本上有的問題也有大神回答。
『捌』 如何對java mqtt程序測試性能
Java編程下用JMeter Java Sampler進行多介面性能測試，使用方法如下：
/**
*JMeter Java Sampler介紹
*setupTest做些初始化的工作，每個線程只執行一次
*teardownTest做些清理工作，每個線程只執行一次
*runTest具體的測試執行工作，每個並發每次循環都將執行一次
**/
//繼承AbstractJavaSamplerClient
public class hessianTest extends AbstractJavaSamplerClient{
//hessian調用地址
private static String url = "http://10.20.147.182:8080/hessian/remoting/userService";
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);
}
}
『玖』 mqtt 伺服器搭建需要用到java嗎
最近公司做的項目中有用到消息推送，經過多方面的篩選之後確定了使用MQTT協議，相對於XMPP，MQTT更加輕量級，並且佔用用戶很少的帶寬。
MQTT是IBM推出的一種針對移動終端設備的基於TCP/IP的發布/預訂協議，可以連接大量的遠程感測器和控制設備。
MQTT的官網見：http://mqtt.org/。其中http://mqtt.org/software裡面提供了官方推薦的各種伺服器和客戶端使用的各種語言版本的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 開啟伺服器，可以在瀏覽器中輸入http://127.0.0.1:61680/查看是否安裝成功，該界面展示了topic，連接數等很多信息。
經過上面的簡單步驟，伺服器基本上就已經完成，下一篇將介紹Android客戶端的編寫和注意事項。
客戶端使用的API，開始我使用的是mqtt-client，使用過後發現問題百出，不能很好的滿足要求，後來使用了官方推薦的Eclipse Paho，下面開始客戶端代碼的編寫，為了方便測試這里有android和j2se兩個工程：
1、新建android工程MQTTClient
2、MainActivity代碼如下：