使用javascript应用程序在MQTT服务器上只发送一次

// 引入MQTT.js库
const mqtt = require('mqtt');

// 设置连接参数
const options = {
  host: 'mqtt.example.com', // MQTT服务器地址
  port: 1883, // MQTT服务器端口号
  clientId: 'client1', // 客户端ID
};

// 创建MQTT客户端实例
const client = mqtt.connect(options);

// 连接到MQTT服务器
client.on('connect', () => {
  console.log('Connected to MQTT server');

  // 创建消息对象
  const message = 'Hello, MQTT!';

  // 发布消息到指定主题
  client.publish('topic1', message, (err) => {
    if (err) {
      console.error('Failed to publish message:', err);
    } else {
      console.log('Message published successfully');
    }

    // 断开与MQTT服务器的连接
    client.end();
  });
});

// 处理连接错误
client.on('error', (err) => {
  console.error('Failed to connect to MQTT server:', err);
});