小编Hil*_*ton的帖子

我目前在我的项目中使用 MQTT eclipse/paho.mqtt.java 库。这是 eclipse/paho.mqtt.java 库的链接。

https://github.com/eclipse/paho.mqtt.java

我想用 http 协议连接 MQTT。但是原始库是为tcp协议制作的。我试图通过制作 mqtt 客户端与 mqtt 建立连接。我将在下面显示我的代码，

抱歉xxx在 IP 地址和 URL 中使用符号。

import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;


public class MQTT {
  public static void main(String[] args) {

    String topic        = "MQTT Examples";
    String content      = "Message from MqttPublishSample";
    int qos             = 2;
    //String broker       = "tcp://iot.eclipse.org:1883";
    String broker       = "http://xxx.xxx.xxx.xxx:xxxx";
    String clientId     = "JavaSample";
    MemoryPersistence persistence = new MemoryPersistence();

    try {
        MqttClient sampleClient = new MqttClient(broker, clientId, null);
        MqttConnectOptions …

我是 Spring Boot 新手，我有一个问题。我将这样介绍它。

DAO 是一种设计模式，它具有三个组成部分。那些是

1. DAO 接口 - 用于声明需要在 DTO 上执行的方法
2. DAO接口实现-用于从数据源（数据库）获取数据
3. DTO（数据传输对象） - 用于保留数据以在层之间传输。

例如，如果我们得到学生。

学生.java (DTO)

public class Student {
    private String name;
    private int rollNo;

    Student(String name, int rollNo) {
        this.name = name;
        this.rollNo = rollNo;
    }

    //getters and setters
}

StudentDao.java

import java.util.List;

public interface StudentDao {
    public List<Student> getAllStudents();
    public Student getStudent(int rollNo);
    public void updateStudent(Student student);
    public void deleteStudent(Student student);
}

StudentDaoImpl.java

import java.util.ArrayList;
import java.util.List;

public class StudentDaoImpl implements StudentDao {

    //list …