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')
何か案が？、タンク :(
