paho相关内容
我在MqttHelper类中实现了简单的MQTT订阅服务器,该订阅服务器可以正常工作并接收订阅.但是,当我需要从主程序向服务器发送消息时应该如何处理.我有方法publish在IMqttActionListener上工作正常,但是如何在按钮按下事件时从主程序发送文本? package com.kkk.mqtt.helpers; import android.content.Context;
..
我正在研究充当MQTT客户端的MVC应用程序.我正在使用来自paho的C#库M2Mqtt.基本上,每次有人按下我的网站上的按钮时,我都希望发布一条消息,并且它也会收到一个答案(因此它也订阅一个主题.) 我的问题是:按下按钮(调用发布消息的ActionResult)时是否必须再次连接到代理,或者是否有办法保持连接有效(例如在Global中初始化它)?那怎么办呢? 由于我对MVC/.net编程还
..
我正在使用Paho Android MQTT Client创建即时消息传递系统.它的实现按预期工作,但是我遇到了这些错误. 我在MainActivity Class的onCreate中呼叫Connection Class(这也要求创建与代理的连接). 现在的问题是,假设我在MainActivity Class上,然后按回车键从MainActivity Class转到另一活动,然后又回到
..
我正在尝试在messageArrived(...)中发布对传入消息的响应.但是发布挂起和下一行:logOutgoingMessage(topic, message)从未被调用...最后,我陷入僵局,客户端断开连接. 这是我的代码: @Startup @Singleton public class AppliMqttClient implements MqttCallback { @E
..
我尝试在python3中设置一个mqtt客户端.这不是我第一次这样做,但是我遇到了一个很奇怪的行为. 尝试从其中一个回调函数(on_connect或on_message)调用包含错误的函数时,python不会引发异常(至少不打印异常),而只是在此停止.我把一个简短的例子绑在一起,重现了这种行为. 有人有主意吗? import paho.mqtt.client as mqtt impo
..
我正在用python开发一个模块,这将允许我将树莓派连接到PC上托管的hivemq版本. 它正常连接,但是当我添加hivemq的文件auth插件时,它似乎不起作用 我使用username_pw_set设置我的用户名和密码 这是我的代码当前的样子: import paho.mqtt.client as mqtt client = mqtt.Client() #The cal
..
首次打开该应用程序时,我需要一个屏幕,您可以在其中输入经纪人信息,然后单击“尝试并保存". 单击“尝试"时,应仅显示一个Snackbar,说明信息是否构成成功的连接. 这是按下“尝试"按钮时调用的代码: private void tryConnection(View v){ if(verifyInputs()){ Snackbar.make(v, getS
..
我在Docker容器和主机网络之间的网络性能缓慢方面遇到了问题.我在Docker论坛上问了这个问题,但到目前为止还没有收到答案. 问题 设置:同一本地网络上的两台Mac;第一个运行MQTT经纪人(mosquitto);第二个运行Docker for Mac.两个C ++程序在第二台Mac上运行,并使用Paho MQTT C库通过MQTT代理(在第一台Mac上)多次交换数据. 本机
..
python中是否有任何支持以8080端口订阅mqtt代理 import sys import paho.mqtt.client as mqtt def on_connect(mqttc, obj, flags, rc): print("rc: "+str(rc)) def on_message(mqttc, obj, msg): print(msg.topi
..
使用Python Paho MQTT客户端最可靠的方法是什么?我希望能够处理由于WiFi掉线而导致的连接中断,并继续尝试重新连接,直到连接成功为止. 以下是我所拥有的,但是我不遵循任何最佳实践吗? import argparse from time import sleep import paho.mqtt.client as mqtt SUB_TOPICS = ("topic/
..
我想将消息从android service发布到本地服务器.这是基于此处中的代码段的最简单形式的部分代码. MemoryPersistence memPer; MqttAndroidClient client; @Override public IBinder onBind(Intent intent) { memPer = new MemoryPersistence();
..
当我尝试使用下面的代码连接到mosquitto代理时,如您所知,连接到代理可能需要几秒钟/分钟,在此期间,当按下按钮进行连接时,它将一直保持按下状态直到连接成功为止建立并在建立连接时将按钮释放回其正常状态.据我所知,有两种使用paho java API连接客户端的方法,即blocking method和unblocking method.我的问题是,如何使用unblocking method? b
..
我正在实现一个程序,该程序可以侦听特定主题,并在ESP8266发布新消息时对此作出反应.从ESP8266收到新消息时,我的程序将触发回调并执行一系列任务.我在回调函数中发布了两条消息,回到了Arduino正在侦听的主题.但是,仅在函数退出后才发布消息. 提前感谢您的所有时间. 我试图在回调函数中使用loop(1),超时时间为1秒.该程序将立即发布该消息,但似乎陷入了循环.有人可以给我一
..
这是paho异步客户端: client = new MqttAsyncClient(appProps.getProperty("mqtt.broker"), appProps.getProperty("mqtt.clientId"), new MemoryPersistence()); client.setCallback(this); cli
..
嗨,我正在物联网上工作,我正在使用paho MQTT,我需要使用SSL,我使用python编写了发布代码,但出现了“证书验证失败"错误. 请帮助我预先感谢 我的出版代码 import time import paho.mqtt.client as paho import ssl import certifi #define callback def on_message(clie
..
import paho.mqtt.client as mqtt def on_connect(client, userdata, flags, rc): print("Connected with result code "+str(rc)) client.subscribe("/leds/pi") def on_message(client, userdata, msg):
..
MQTT问题: 您好,我正在尝试在多个Raspberry Pi(以两个开头)之间建立MQTT网络. 我有一个树莓派(RPi-A),MQTT客户端和一个热敏电阻传感器,还有一个树莓派(RPi-B),MQTT代理/客户端,充当我的网络的集线器. 通过python脚本,我希望温度每30分钟从RPi-A通过MQTT发送到主题传感器/数据,并由RPi-B接收. 当RPi-B通过主题传感器/数据从RPi
..
我们在Spring集成中遇到了一个MQTT订阅者的问题(4.0.3.RELEASE在Paho MQTT Client 0.4.0上在Tomcat 7上运行). 问题出在订阅者上一个使用频繁的主题(大量消息)上.将消息发送到主题的设备是现场通过GPRS连接的设备. Spring集成和代理(Mosquitto)在同一服务器上运行. 在不重新启动服务器的情况下在Tomcat上进行了几次
..
我正在编写一个Django应用程序,该应用程序应充当MQTT发布者和订阅者. 我应该在哪里启动paho客户端并运行loop_forever()函数. 应该在wsgi.py中吗? 解决方案 更新: 如果您需要在多个线程中运行Django,然后要从Django应用程序发布消息,则可以使用Paho的Publish模块中的帮助程序功能- 仅当您在单个线程中运行Django(在生
..
我正在尝试通过SSL/TLS使用m2mqtt c#客户端版本4.3.0库与mosquitto代理连接.下面是我尝试过的代码 static void Main(string[] args) { // create client instance MqttClient client = new MqttClient(IPAddress.Parse("12
..