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的接收通配符的数据

报什么错？