paho相关内容

MQTT从主线程发送消息

我在MqttHelper类中实现了简单的MQTT订阅服务器,该订阅服务器可以正常工作并接收订阅.但是,当我需要从主程序向服务器发送消息时应该如何处理.我有方法publish在IMqttActionListener上工作正常,但是如何在按钮按下事件时从主程序发送文本? package com.kkk.mqtt.helpers; import android.content.Context; ..
发布时间:2020-05-12 20:18:42 Java开发

MVC应用程序中的MQTT客户端

我正在研究充当MQTT客户端的MVC应用程序.我正在使用来自paho的C#库M2Mqtt.基本上,每次有人按下我的网站上的按钮时,我都希望发布一条消息,并且它也会收到一个答案(因此它也订阅一个主题.) 我的问题是:按下按钮(调用发布消息的ActionResult)时是否必须再次连接到代理,或者是否有办法保持连接有效(例如在Global中初始化它)?那怎么办呢? 由于我对MVC/.net编程还 ..
发布时间:2020-05-12 20:17:54 C#/.NET

当多次调用onCreate时,MQTT创建多个连接

我正在使用Paho Android MQTT Client创建即时消息传递系统.它的实现按预期工作,但是我遇到了这些错误. 我在MainActivity Class的onCreate中呼叫Connection Class(这也要求创建与代理的连接). 现在的问题是,假设我在MainActivity Class上,然后按回车键从MainActivity Class转到另一活动,然后又回到 ..
发布时间:2020-05-12 20:17:51 Java开发

尝试使用Paho Client MqttCallback在messageArrived()中发布

我正在尝试在messageArrived(...)中发布对传入消息的响应.但是发布挂起和下一行:logOutgoingMessage(topic, message)从未被调用...最后,我陷入僵局,客户端断开连接. 这是我的代码: @Startup @Singleton public class AppliMqttClient implements MqttCallback { @E ..
发布时间:2020-05-12 20:17:29 Java开发

Paho MQTT Python客户端:没有引发异常,只是停止

我尝试在python3中设置一个mqtt客户端.这不是我第一次这样做,但是我遇到了一个很奇怪的行为. 尝试从其中一个回调函数(on_connect或on_message)调用包含错误的函数时,python不会引发异常(至少不打印异常),而只是在此停止.我把一个简短的例子绑在一起,重现了这种行为. 有人有主意吗? import paho.mqtt.client as mqtt impo ..
发布时间:2020-05-12 20:16:38 Python

具有HiveMQ的Paho Python客户端

我正在用python开发一个模块,这将允许我将树莓派连接到PC上托管的hivemq版本. 它正常连接,但是当我添加hivemq的文件auth插件时,它似乎不起作用 我使用username_pw_set设置我的用户名和密码 这是我的代码当前的样子: import paho.mqtt.client as mqtt client = mqtt.Client() #The cal ..
发布时间:2020-05-12 20:16:26 Python

使用Paho MqttClient在Android上尝试Mqtt连接

首次打开该应用程序时,我需要一个屏幕,您可以在其中输入经纪人信息,然后单击“尝试并保存". 单击“尝试"时,应仅显示一个Snackbar,说明信息是否构成成功的连接. 这是按下“尝试"按钮时调用的代码: private void tryConnection(View v){ if(verifyInputs()){ Snackbar.make(v, getS ..
发布时间:2020-05-12 20:16:18 移动开发

带有主机网络的Docker容器的网络性能非常慢

我在Docker容器和主机网络之间的网络性能缓慢方面遇到了问题.我在Docker论坛上问了这个问题,但到目前为止还没有收到答案. 问题 设置:同一本地网络上的两台Mac;第一个运行MQTT经纪人(mosquitto);第二个运行Docker for Mac.两个C ++程序在第二台Mac上运行,并使用Paho MQTT C库通过MQTT代理(在第一台Mac上)多次交换数据. 本机 ..
发布时间:2020-05-12 20:15:34 其他开发

Paho MQTT客户端连接可靠性(断开连接时重新连接)

使用Python Paho MQTT客户端最可靠的方法是什么?我希望能够处理由于WiFi掉线而导致的连接中断,并继续尝试重新连接,直到连接成功为止. 以下是我所拥有的,但是我不遵循任何最佳实践吗? import argparse from time import sleep import paho.mqtt.client as mqtt SUB_TOPICS = ("topic/ ..
发布时间:2020-05-12 20:15:13 Python

如何使用MqttClient的取消阻止方法

当我尝试使用下面的代码连接到mosquitto代理时,如您所知,连接到代理可能需要几秒钟/分钟,在此期间,当按下按钮进行连接时,它将一直保持按下状态直到连接成功为止建立并在建立连接时将按钮释放回其正常状态.据我所知,有两种使用paho java API连接客户端的方法,即blocking method和unblocking method.我的问题是,如何使用unblocking method? b ..
发布时间:2020-05-12 20:14:55 其他开发

Python Paho MQTT:无法立即在函数中发布

我正在实现一个程序,该程序可以侦听特定主题,并在ESP8266发布新消息时对此作出反应.从ESP8266收到新消息时,我的程序将触发回调并执行一系列任务.我在回调函数中发布了两条消息,回到了Arduino正在侦听的主题.但是,仅在函数退出后才发布消息. 提前感谢您的所有时间. 我试图在回调函数中使用loop(1),超时时间为1秒.该程序将立即发布该消息,但似乎陷入了循环.有人可以给我一 ..
发布时间:2020-05-12 20:14:41 Python

树莓派上的python mqtt脚本发送和接收消息

MQTT问题: 您好,我正在尝试在多个Raspberry Pi(以两个开头)之间建立MQTT网络. 我有一个树莓派(RPi-A),MQTT客户端和一个热敏电阻传感器,还有一个树莓派(RPi-B),MQTT代理/客户端,充当我的网络的集线器. 通过python脚本,我希望温度每30分钟从RPi-A通过MQTT发送到主题传感器/数据,并由RPi-B接收. 当RPi-B通过主题传感器/数据从RPi ..
发布时间:2020-05-12 20:14:02 Python

Spring Integration MQTT订户(paho)停止处理消息

我们在Spring集成中遇到了一个MQTT订阅者的问题(4.0.3.RELEASE在Paho MQTT Client 0.4.0上在Tomcat 7上运行). 问题出在订阅者上一个使用频繁的主题(大量消息)上.将消息发送到主题的设备是现场通过GPRS连接的设备. Spring集成和代理(Mosquitto)在同一服务器上运行. 在不重新启动服务器的情况下在Tomcat上进行了几次 ..
发布时间:2020-05-12 20:13:47 其他开发

如何在Django中使用Paho MQTT Client?

我正在编写一个Django应用程序,该应用程序应充当MQTT发布者和订阅者. 我应该在哪里启动paho客户端并运行loop_forever()函数. 应该在wsgi.py中吗? 解决方案 更新: 如果您需要在多个线程中运行Django,然后要从Django应用程序发布消息,则可以使用Paho的Publish模块中的帮助程序功能- 仅当您在单个线程中运行Django(在生 ..
发布时间:2020-05-12 20:13:36 Python