0

我正在制作一个 IOT 应用程序，并且我使用 mosca 作为代理（AWS EC2 上的 node.js）。我无法连接和订阅或发布，我现在不知道什么是坏的或我缺少什么。经纪人工作，当我运行 SUB 和 PUB 时什么都没有发生，不要告诉我错误，只是没什么，但是做看不到消息

// Mosca Mqtt 代理

var mosca = require('mosca')
var settings = {port: 1883} //pueto del servidor normalmente 1883
var broker = new mosca.Server(settings)

broker.on('ready', ()=>{// se le dice al servido que se prenda 
    console.log('broker is ready to use')
})
broker.on('clientConnected',()=>{

    console.log('some one is connect')    
})

broker.on('published',(packet)=>{
     console.log(packet.payload.toString())

})

// 子

var mqtt = require('mqtt');
const fs = require('fs');
var path = require('path');

var client = mqtt.connect('mqtts://ec2-44-230-22-151.us-west-2.compute.amazonaws.com',{
port: 1883,
key: fs.readFileSync(path.join(__dirname,'/servidorIOT2.pem')),
cliendID: 'ubuntu',

}
);

// ip del servidor 
var topic = 'prueba1'// topico al que me susbri

client.on('connect',()=>{
    client.subscribe(topic)
})

client.on('message', (topic,mensaje)=>{
mensaje1 = mensaje.toString()
console.log(mensaje1)

})

// mqtt PUB

var path = require('path');
var mqtt = require('mqtt')
var fs = require('fs')
var client = mqtt.connect('mqtts://ec2-44-230-22-151.us-west-2.compute.amazonaws.com',{
port: 1883,
key: fs.readFileSync(path.join(__dirname,'/servidorIOT2.pem')),
cliendID: 'ubuntu',

}
);

var topic = 'prueba1'
var mensaje = 'Hello , i am here'// mensaje que se va a mandar 

client.on('connect',()=>{
setInterval(()=>{
    client.publish(topic,mensaje)
    console.log('already send:',mensaje)
},5000)

})
console.log('llego hasta aqui')

任何想法？, 坦克 :(

4

0 回答 0