JAVA如何取出mqtt伺服器數據

1. 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代碼如下：

2. Java項目：mqtt發送的數據如何保存到資料庫里

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

3. 設備將數據發送到MQTT伺服器，那伺服器怎麼數據轉發到後台系統

伺服器發給中間kafka kafka轉存到資料庫，可以應對高並發。
也可以直接轉存，比如emq。但是emq的直接連接資料庫是收費的大約5000一年。

4. java中怎樣取出文件中的數據

分為讀位元組，讀字元兩種讀法
◎◎◎FileInputStream 位元組輸入流讀文件◎◎◎
public class Maintest {

public static void main(String[] args) throws IOException {

File f=new File("G:\just for fun\xiangwei.txt");

FileInputStream fin=new FileInputStream(f);

byte[] bs=new byte[1024];

int count=0;
while((count=fin.read(bs))>0)
{

String str=new String(bs,0,count); //反復定義新變數：每一次都 重新定義新變數，接收新讀取的數據

System.out.println(str); //反復輸出新變數：每一次都 輸出重新定義的新變數
}
fin.close();
}
}

◎◎◎FileReader 字元輸入流讀文件◎◎◎
public class Maintest {
public static void main(String[] args) throws IOException {

File f=new File("H:\just for fun\xiangwei.txt");

FileReader fre=new FileReader(f);

BufferedReader bre=new BufferedReader(fre);

String str="";
while((str=bre.readLine())!=null) //●判斷最後一行不存在，為空
{
System.out.println(str);
}
bre.close();
fre.close();

}

}

5. 在java中怎麼取出數組中的數據

1.方法：
public final synchronized void setsize(int newsize);
此方法用來定義向量的大小，若向量對象現有成員個數已經超過了newsize的值，則超過部分的多餘元素會丟失。
2.程序中定義Enumeration類的一個對象Enumeration是java.util中的一個介面類，
在Enumeration中封裝了有關枚舉數據集合的方法。
在Enumeration提供了方法hasMoreElement()來判斷集合中是否還有其他元素和方法nextElement()來判斷集合中是否還有其他元素和方法nextElement()來獲取下一個元素。利用這兩個方法，可以依次獲得集合中的元素。
3.Vector中提供方法：
public final synchronized Enumeration elements();
此方法將向量對象對應到一個枚舉類型。java.util包中的其他類中也都有這類方法，以便於用戶獲取對應的枚舉類型。

6. java 從資料庫取出數據並保存到本地文本中

先看資料庫表， 我裡面有46條記錄，其中有三條重復，我就拿其中一條emp_id 為"

DWR65030M" 做例子

裡面有兩條記錄 ，實現了

7. java 實現串口接收到數據，立馬將接收到的數據通過mqtt上傳到阿里雲。

也不是特別麻煩，你先要清楚串口和伺服器用的什麼協議，假設串口用232，伺服器採用TCP，那麼你需要做的是建立一個客戶端的發送模塊，和一個串口的操作模塊（結合必須要用到多線程，以隊列或者委託來做數據交換）;在測試之前一定要保證串口和客戶端發送接收是ok的才能做結合功能。
因為你串口已經做好了，那你需要的是將採集到的數據（字元串）保存到數組中，然後創建一個指向數組的指針p，然後在客戶端模塊里，將發送的數據寫成&p。建議先將數據轉16進制發，應該沒毛病。

8. Java中如何通過txt文件存儲和取出數據

Java中讀取txt文件可以使用file類先創建一個對象，然後使用I/O操作，進行讀取或者寫入操作，示例如下：
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;

public class demo2 {
private static String path = "f:/demo1.txt";
private static File file;
static{
file = new File(path);
if(!file.exists()){
try {
file.createNewFile();
} catch (IOException e) {
e.printStackTrace();
}
}
}

public static void main(String[] args) throws IOException {
Student stu = new Student(1,"張三",90);
writeDataToFile(file,stu);
readDataFromFile(file);
}

private static void readDataFromFile(File file) throws IOException {
BufferedReader reader = new BufferedReader(new InputStreamReader(new FileInputStream(file)));
String str = "";
while((str = reader.readLine())!=null){
String[] stuInfo = str.split(",");
System.out.println("學號："+stuInfo[0]+" 姓名："+stuInfo[1]+" score："+stuInfo[2]);
}
}

private static void writeDataToFile(File file,Student stu) throws FileNotFoundException {
PrintWriter out = new PrintWriter(new FileOutputStream(file, true));
out.println(stu.toString());
out.close();
}
}

9. Java中通過txt文件存儲和取出數據

如果是這樣的話，你就先用string的split方法以,為分隔符號分開，再replace「」，這兩個東東就可以得到你要的中間的數據了。有個缺點比較佔用內存，或許你也可以去讀文件讀到,的時候就將之前的存起來，然後再讀下面的東西。思路而已試試看吧～

10. java怎麼實現mqtt的接收通配符的數據

報什麼錯？