亚马逊网络服务MQTT

Question

我正在研究基于亚马逊的网络服务，我必须向亚马逊物联网发送和接收一些信息，然后从那里接收一些消息。我在连接到物联网时遇到问题，任何人都可以帮助我使用MQTT和IOT。

Answer 1

试试这个。它可能会帮助你。

credentialsProvider = new CognitoCachingCredentialsProvider(
      getApplicationContext(), // context 
      COGNITO_POOL_ID, // Identity Pool ID 
      MY_REGION // Region); 

    Region region = Region.getRegion(MY_REGION); 

    // MQTT Client 
    mqttManager = new AWSIotMqttManager(clientId, CUSTOMER_SPECIFIC_ENDPOINT); 

    // Set keepalive to 10 seconds. Will recognize disconnects more quickly but will also send 
    // MQTT pings every 10 seconds. 
    mqttManager.setKeepAlive(10); 
    mIotAndroidClient = new AWSIotClient(credentialsProvider); 
    mIotAndroidClient.setRegion(region); 
    try { 
      mqttManager.connect(clientKeyStore, new AWSIotMqttClientStatusCallback() { 
       @Override 
       public void onStatusChanged(final AWSIotMqttClientStatus status, 
         final Throwable throwable) { 
        Log.d(LOG_TAG, "Status = " + String.valueOf(status)); 

        runOnUiThread(new Runnable() { 
         @Override 
         public void run() { 
          if (status == AWSIotMqttClientStatus.Connecting) { 
                   } else if (status == AWSIotMqttClientStatus.Connected) { 
           tvStatus.setText("Connected"); 

          } else if (status == AWSIotMqttClientStatus.Reconnecting) { 
           if (throwable != null) { 
            Log.e(LOG_TAG, "Connection error.", throwable); 
           } 
           tvStatus.setText("Reconnecting"); 
          } else if (status == AWSIotMqttClientStatus.ConnectionLost) { 
           if (throwable != null) { 
            Log.e(LOG_TAG, "Connection error.", throwable); 
           } 
                        } 
         } 
        }); 
       } 
      }); 
     } catch (final Exception e) { 
       }