Google Cloud IoT Core는 2023년 8월 16일에 지원 중단됩니다. 자세한 내용은 Google Cloud 계정팀에 문의하세요.

구성 메시지 리슨

구성 메시지를 리슨합니다.

코드 샘플

Node.js

자세한 내용은 Cloud IoT Core Node.js API 참조 문서를 확인하세요.

// const deviceId = `myDevice`;
// const gatewayId = `mygateway`;
// const registryId = `myRegistry`;
// const region = `us-central1`;
// const algorithm = `RS256`;
// const privateKeyFile = `./rsa_private.pem`;
// const serverCertFile = `./roots.pem`;
// const mqttBridgeHostname = `mqtt.googleapis.com`;
// const mqttBridgePort = 8883;
// const clientDuration = 60000;

const mqttClientId = `projects/${projectId}/locations/${region}/registries/${registryId}/devices/${gatewayId}`;
console.log(mqttClientId);
const connectionArgs = {
  host: mqttBridgeHostname,
  port: mqttBridgePort,
  clientId: mqttClientId,
  username: 'unused',
  password: createJwt(projectId, privateKeyFile, algorithm),
  protocol: 'mqtts',
  qos: 1,
  secureProtocol: 'TLSv1_2_method',
  ca: [readFileSync(serverCertFile)],
};

// Create a client, and connect to the Google MQTT bridge.
const client = mqtt.connect(connectionArgs);

client.on('connect', success => {
  if (!success) {
    console.log('Client not connected...');
  } else {
    console.log('Client connected: Gateway is listening, attaching device');
    attachDevice(deviceId, client);

    setTimeout(() => {
      // Subscribe to any configuration topics.
      client.subscribe(`/devices/${gatewayId}/config`, {qos: 1});
      client.subscribe(`/devices/${deviceId}/config`, {qos: 1});

      setTimeout(() => {
        detachDevice(deviceId, client);
        console.log('Closing connection to MQTT. Goodbye!');
        client.end(true);
      }, clientDuration); // Safely detach device and close connection.
    }, 5000);
  }
});

client.on('close', () => {
  console.log('Connection closed');
  shouldBackoff = true;
});

client.on('error', err => {
  console.log('error', err);
});

client.on('message', (topic, message) => {
  const decodedMessage = Buffer.from(message, 'base64').toString('ascii');

  if (topic === `/devices/${gatewayId}/errors`) {
    console.log(`message received on error topic: ${decodedMessage}`);
  } else {
    console.log(`message received on topic ${topic}: ${decodedMessage}`);
  }
});

client.on('packetsend', () => {
  // Note: logging packet send is very verbose
});

다음 단계

다른 Google Cloud 제품의 코드 샘플을 검색하고 필터링하려면 Google Cloud 샘플 브라우저를 참조하세요.