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真的很陌生,在过去的日子里我已经阅读了很多关于它的文章和博客,但是我似乎并没有完全理解所需的不同部分,例如Br​​oker,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" […]