cloudiotcoremqttexample's Introduction

Cloud IoT Core MQTT Communication Example

Found it hard to understand the docs here: https://cloud.google.com/iot/docs/how-tos/mqtt-bridge and no examples online, so wrote my own.

Using MQTT to talk between an AndroidThings board and Cloud IoT Core Pub/Sub

Based on the example here:

https://github.com/GoogleCloudPlatform/java-docs-samples/blob/master/iot/api-client/mqtt_example/src/main/java/com/google/cloud/iot/examples/MqttExample.java

but written for AndroidThings instead of Java. Also tried to keep it simpler and separated.

See MainActivity.java for use.

You connect like this

communicator = new IotCoreCommunicator.Builder()
        .withContext(YourActivity.this)
        .withCloudRegion("your-region") // ex: europe-west1
        .withProjectId("your-project-id")   // ex: supercoolproject23236
        .withRegistryId("your-registry-id") // ex: my-devices
        .withDeviceId("a-device-id") // ex: my-test-raspberry-pi
        .withPrivateKeyRawFileId(R.raw.rsa_private)
        .build();
communicator.connect();

and publish a message like this:

communicator.publishMessage("subtopic", "Hello World");

finally when finished:

communicator.disconnect();

cloudiotcoremqttexample's People

Stargazers

Watchers

cloudiotcoremqttexample's Issues

How to attach root certificate?

Help me plss ! publish message on android studio

I have created a button for a publis message with a function when clicked. Send a message to the device, but when I click it, the program doesn't work, it bounced off the program as if it couldn't connect

mqtt java.lang.IllegalStateException: Timed out waiting for a response from the server (32000)

this specific error point at :
` private void clientConnect() {
try {
MqttConnectOptions connectOptions = new MqttConnectOptions();
// Note that the the Google Cloud IoT Core only supports MQTT 3.1.1, and Paho requires that we explicitly set this.
// If you don't, the server will immediately close its connection to your device.
connectOptions.setMqttVersion(MqttConnectOptions.MQTT_VERSION_3_1);

        // With Google Cloud IoT Core, the username field is ignored, however it must be set for the
        // Paho client library to send the password field. The password field is used to transmit a JWT to authorize the device.
        connectOptions.setUserName("unused-but-necessary");
        connectOptions.setPassword(passwordGenerator.createJwtRsaPassword());

        IMqttToken iMqttToken = client.connect(connectOptions);
        iMqttToken.setActionCallback(new IMqttActionListener() {
            @Override
            public void onSuccess(IMqttToken asyncActionToken) {
                Log.d("TUT", "success, connected");
            }

            @Override
            public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                Log.e("TUT", "failure, not connected", exception);
            }
        });
        iMqttToken.waitForCompletion(TimeUnit.SECONDS.toMillis(30));
        Log.d("TUT", "IoT Core connection established.");
    } catch (MqttException e) {
        throw new IllegalStateException(e);  // this exception is thrown 
    }
}`

Recommend Projects