springboot连接自己的emqx

要连接自己的EMQX，可以通过以下步骤实现：

1. 在Spring Boot项目中添加EMQX的Maven依赖：

<dependency>
    <groupId>org.eclipse.paho</groupId>
    <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
    <version>1.2.5</version>
</dependency>

2. 在application.properties文件中添加EMQX的连接配置：

spring.mqtt.username=<username>
spring.mqtt.password=<password>
spring.mqtt.url=tcp://localhost:1883

其中，`<username>`和`<password>`是你在EMQX中创建的用户名和密码，`localhost`是EMQX的主机地址，`1883`是EMQX的默认MQTT端口。

3. 在代码中创建MqttClient连接EMQX：

@Autowired
private MqttProperties mqttProperties;

private MqttClient mqttClient;

@PostConstruct
public void init() throws MqttException {
    mqttClient = new MqttClient(mqttProperties.getUrl(), "spring-boot-mqtt-client");
    mqttClient.connect(createMqttConnectOptions());
}

private MqttConnectOptions createMqttConnectOptions() {
    MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
    mqttConnectOptions.setUserName(mqttProperties.getUsername());
    mqttConnectOptions.setPassword(mqttProperties.getPassword().toCharArray());
    return mqttConnectOptions;
}

其中，`MqttProperties`是读取application.properties中EMQX连接配置的类。在`init()`方法中，创建`MqttClient`实例并连接EMQX，`createMqttConnectOptions()`方法用于创建MQTT连接选项。

以上是连接自己的EMQX的基本步骤，你可以根据实际场景进行调整。