node.js – 如何使用AWS IoT向/从Web浏览器发送/接收消息

// Configure Cognito identity pool
AWs.config.region = 'us-east-1';
var credentials = new AWs.CognitoIdentityCredentials({
    IdentityPoolId: 'us-east-1:your identity pool guid',});

// GetTing AWS creds from Cognito is async,so we need to drive the rest of the mqtt client initialization in a callBACk
credentials.get(function(err) {
    if(err) {
        console.log(err);
        return;
    }
    var requesturl = SigV4Utils.getSignedUrl('wss','data.iot.us-east-1.amazonaws.com','/mqtt','iotdevicegateway','us-east-1',credentials.accessKeyId,credentials.secretAccessKey,credentials.sessionToken);
    initClient(requesturl);
});

function init() {
  // do setup stuff
}

// Connect the client,subscribe to the drawing topic,and publish a "hey I connected" message
function initClient(requesturl) {
    var clientId = String(Math.random()).replace('.','');
    var client = new Paho.MQTT.Client(requesturl,clientId);
    var connectOptions = {
        onsuccess: function () {
            console.log('connected');

            // subscribe to the drawing
            client.subscribe("your/mqtt/topic");

            // publish a lifecycle event
            message = new Paho.MQTT.message('{"id":"' + credentials.identityId + '"}');
            message.desTinationName = 'your/mqtt/topic';
            console.log(messagE);
            client.send(messagE);
        },useSSL: true,timeout: 3,mqttVersion: 4,onFailure: function () {
            console.error('connect Failed');
        }
    };
    client.connect(connectOptions);

    client.onmessageArrived = function (messagE) {

        try {
            console.log("msg arrived: " +  message.payloadString);
        } catch (E) {
            console.log("error! " + E);
        }

    };
}

请记住,授权您的IAM角色也可以订阅/发布.以下是一个示例：

{
    "Version": "2012-10-17","Statement": [
        {
            "Effect": "Allow","Action": [
                "iot:Connect"
            ],"resource": "*"
        },{
            "Effect": "Allow","Action": "iot:receive","Action": "iot:Subscribe","resource": [
                "arn:aws:iot:us-east-1::your/mqtt/topic"
            ]
        },"Action": "iot:Publish","resource": [
                "arn:aws:iot:us-east-1::your/mqtt/topic"
            ]
        }
    ]
}