Tag: mqtt

基于本地经纪人（MQTT）的发布/订阅使用Android应用程序: 在我目前的项目中，我正在使用这个链接使用基于MQTT本地代理的实现和设置。本地基于经纪人的MQTT实施工作正常。最初，我使用Node.js发布者和订阅者与这个本地代理来启用消息交换，并且它也可以在没有互联网连接的情况下工作（因为这些设备连接到同一个networking，本地基于代理的实现的mqtt API就像http://192.168.0.105 ）。现在，我想用Android应用程序replaceNode.js订阅者。我的android应用程序使用mqtt paho库进行通信和使用mqtt API mqtt://test.mosquitto.org:1883 。如果我正在使用mqtt开放代理，即比Node.js发布者和Android应用程序用户都是蚊子都工作正常（这种情况下讨论使用API mqtt://test.mosquitto.org:1883基于蚊子的mqtt实现）。现在，我想在Android应用程序中使用基于本地代理的实现。所以我必须用http://192.168.0.105replacemqtt://test.mosquitto.org:1883 API，因为我想使用基于本地代理的mqtt实现。当我在android代码中使用http://192.168.0.105 API并将其部署到移动设备时，它显示错误，不幸的是，Android应用程序已停止在andoid应用程序中。如何在android应用程序中使用基于本地代理的实现？另外分享Node.js发布者和订阅者的代码。 Node.js发布者（基于本地代理的实现） var mqtt = require('mqtt'); var client = mqtt.connect('http://192.168.0.105'); setInterval(function() { var data = { "tempValue" : Math.random(), "unitOfMeasurement" : 'C' }; client.publish('tempMeasurement', JSON.stringify(data)); }, 5000); Node.js订阅者（基于本地代理的实现） var mqtt = require('mqtt'); var client = […]

如何使用node.js创buildMQTT客户端？: 我是MQTT的新成员，希望使用node.js来创buildMQTT客户端，它接受authentication头以连接到MQTT。连接的URL是tcp：// ip_address：61616，需要用户名和sessionId。 [服务器使用activeMQ]。请帮我解决一下这个。

Nodejs MQTT：设置收到消息后超时: 在MQTT第一次接收消息之后，我想要设置超时约1分钟。如果1分钟内没有更多消息，我想通知一些事情。有什么办法可以做到吗？ client.on('message', function (topic, message) { // if in one minute timeout, there is no more message // console.log("warning") }

用于node.js的MQTT客户端负载大于128字节: 我尝试了解并实现node.js的MQTT-Client，可以在http://jahbromo.blogspot.de/2011/12/client-mqttt-javascript.htmlfind它。当我发布less于128字节的playload时，没有任何问题，并且消息的定向正确，但是当负载较大时，node.js在发布后立即打印出“由代理closures的连接”。因为我对websockets和node.js比较陌生，所以我不明白为什么上面提到的node.js-server-implemenatation不能处理大于128字节的playload。因为我需要发送更大的有效载荷，如果有人能够帮助我增加限制，那将是非常好的。谢谢。

调度mqtt后: 我将有一个文件（文本，excel … doesen没关系）。在这个文件的每一行上都有date，时间和一个函数的代码。我需要的是在指定的时间和date在服务器上的node.js中执行写在我的文件中的函数。由于该函数实际上是一个mqtt经纪人的职位，我真的在寻找任何可以做的方法。任何人都可以指出我正确的方向吗？谢谢

mosca MQTT代理的安全密钥和证书: 我试图build立基于node.js的Mosca MQTT代理从下面的文档中， https://github.com/mcollina/mosca/wiki/TLS-SSL-Configuration var mosca = require('mosca') var SECURE_KEY = __dirname + '/../../test/secure/tls-key.pem'; var SECURE_CERT = __dirname + '/../../test/secure/tls-cert.pem'; 我在哪里得到tls-key.pem和tls-cert.pem ？

通过节点应用程序之间的MQTT进行简单通信: 您好，我对MQTT真的很陌生，在过去的日子里我已经阅读了很多关于它的文章和博客，但是我似乎并没有完全理解所需的不同部分，例如Broker，Clients。我想要两个节点应用程序通过本地mqtt服务相互通信。据我所知，这个mqtt服务叫做broker。我pipe理它让2个节点的应用程序通过这样的公共经纪人进行沟通： app1（发件人） const mqtt = require('mqtt'); // to be changed to own local server/service const client = mqtt.connect('http://broker.hivemq.com'); client.on('connect', () => { let id = 0; setInterval(() => { client.publish('myTopic', 'my message – ' + ++id); }, 3000); }); app2（接收器） const mqtt = require('mqtt'); // to be changed to own local server/service […]

在浏览器中轮询并从AJAX获取MQTT消息: 初学者在这里。好的，我试图完成一个简单的数据stream： MQTT-Data-source —> MQTT Broker —> NodeJS-MQTT-Client —>浏览器上的AJAX（每3秒轮询一次）我希望能够获得MQTT消息，并在浏览器端的AJAX组件中显示它。其次，在console.log(mqttMessage); ，我如何清除以前的消息？因为在控制台上，我可以看到所有以前的数据以及新增的数据。我在Express上使用mqtt.js作为我的nodejs mqtt支持。 //Server.js var mqtt = require('mqtt'); … … var getData = function() { mqttClient.subscribe(mqttTopic); mqttClient.on('message', function(topic, message) { mqttMessage = message.toString(); console.log(mqttMessage); }) return mqttMessage; } app.get('/pollData', function(req, res) { res.send(getData()); }); 而在一个简单的HTML页面上，我有： <script type="text/javascript" src="http://code.jquery.com/jquery-1.10.1.min.js"></script> <script> $(document).ready( function() { setInterval(function() […]

节点mqtt为什么我得到发布的消息三次: 只是玩弄mqtt和mosca节点模块 server.js var mosca = require('mosca') var settings = { port: 1884 }; //here we start mosca 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') } // fired whena client is connected server.on('clientConnected', function(client) { console.log('client connected', client.id); }); […]

控制angularjs ui从外部事件切换: 我有一个angularjs材料ui开关。当外部事件发生时，我想改变它的状态。这个外部事件是在已发布的主题之一上收到的mqtt消息。我正在使用在浏览器上运行的node.js mqtt客户端。 <div ng-controller="SWCtrl"> <md-switch ng-model="switch_status.sw1" aria-label="Switch" ng-change="onChange(switch_status.sw1)"> Switch: {{ switch_status.sw1 }} </md-switch> </div> 相应的控制器代码; angular.module('myApp.controllers', []) .controller('SWCtrl', ['$scope', function ($scope, ) { $scope.switch_status = { sw1: true, }; var mqtt_client = mqtt.connect('ws://127.0.0.1:3000'); mqtt_client.subscribe('hello/world'); mqtt_client.on('connect', function () { console.log("MQTT connected"); }); mqtt_client.on("message", function(topic, payload) { console.log([topic, payload].join(": ")); if (topic === "hello/world" […]