connectTimeout在mqtt node.js中不起作用

const mqtt = require('mqtt');

const client = mqtt.connect('mqtt://broker.example.com');

const connectTimeout = 5000; // 设置连接超时时间为5秒

const connectPromise = new Promise((resolve, reject) => {
  const timeout = setTimeout(() => {
    reject(new Error('Connection timeout'));
    client.end(); // 手动关闭连接
  }, connectTimeout);

  client.on('connect', () => {
    clearTimeout(timeout);
    resolve();
  });

  client.on('error', (error) => {
    clearTimeout(timeout);
    reject(error);
    client.end(); // 手动关闭连接
  });
});

connectPromise
  .then(() => {
    console.log('Connected successfully');
    // 在连接成功后进行其他操作
  })
  .catch((error) => {
    console.error('Failed to connect:', error.message);
  });