Je ne parle pas de tout réécrire… Mais plutôt d'en recréer une version simple
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | var mosca = require('mosca') var ascoltatore = { //using ascoltatore type: 'mongo', url: 'mongodb://localhost:27017/mqtt', pubsubCollection: 'ascoltatori', mongo: {} }; var settings = { port: 1883, backend: ascoltatore }; server.on('clientConnected', function(client) { console.log('client connected', client.id); }); // fired when a message is received server.on('published', function(packet, client) { console.log('Published', packet.payload); if ((packet.topic.indexOf('tables/') > -1)) { //Traitement de toutes les publications des tables (tables/*) } }); var server = new mosca.Server(settings); server.on('ready', setup); // fired when the mqtt server is ready function setup() { console.log('Mosca server is up and running') } |
Et oui c'est un discourt un peu marketing, mais tu avoueras que tu ne peux pas implémenter un broker avec si peu de ligne en PHP ?
+0
-0