mqttx向mqtt发送消息

以下是使用MQTTX向MQTT发送消息的步骤：

1. 打开MQTTX，并在服务器地址中输入mqtt协议的地址，例如：mqtt://实例id.mqtt.aliyuncs.com。端口默认为1883。
2. 在MQTTX中创建一个新的连接，输入用户名和密码。根据引用中的用户名生成规则，使用用户名+AK+SK生成对应的用户名和密码。
3. 连接到MQTT服务器。
4. 在MQTTX中选择要发送消息的主题（Topic）。
5. 在消息内容中输入要发送的消息。
6. 点击发送按钮，即可向MQTT服务器发送消息。

以下是Java实现MQTT发送消息的示例代码：

服务端代码：

import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MqttServer {
    public static void main(String[] args) {
        String broker = "tcp://实例id.mqtt.aliyuncs.com:1883";
        String clientId = "GID_test@@@xxxx";
        String topic = "test/topic";
        String content = "Hello, MQTT!";

        try {
            MqttClient client = new MqttClient(broker, clientId);
            client.connect();

            MqttMessage message = new MqttMessage(content.getBytes());
            client.publish(topic, message);

            client.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}

客户端代码：

import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

public class MqttClientDemo {
    public static void main(String[] args) {
        String broker = "tcp://实例id.mqtt.aliyuncs.com:1883";
        String clientId = "GID_test@@@xxxx";
        String topic = "test/topic";

        try {
            MqttClient client = new MqttClient(broker, clientId, new MemoryPersistence());

            MqttConnectOptions options = new MqttConnectOptions();
            options.setCleanSession(true);

            client.connect(options);

            client.subscribe(topic);

            client.setCallback(new MqttCallback() {
                @Override
                public void connectionLost(Throwable cause) {
                    // 处理连接丢失的情况
                }

                @Override
                public void messageArrived(String topic, MqttMessage message) throws Exception {
                    // 处理接收到的消息
                    System.out.println("Received message: " + new String(message.getPayload()));
                }

                @Override
                public void deliveryComplete(IMqttDeliveryToken token) {
                    // 处理消息发送完成的情况
                }
            });

            client.disconnect();
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }
}