Paho-不同类android java中的mqtt回调
Paho是一个开源的MQTT（Message Queuing Telemetry Transport）客户端库，用于在不同类的Android Java应用程序中实现MQTT协议的通信。MQTT是一种轻量级的发布/订阅消息传输协议，适用于物联网设备之间的通信。
Paho库提供了一组API，使开发人员能够在Android应用程序中轻松地实现MQTT通信。它支持与MQTT代理服务器的连接、发布消息、订阅主题以及处理接收到的消息。
Paho库的主要优势包括：
- 轻量级：Paho库是基于MQTT协议的轻量级实现，具有较小的内存占用和网络带宽消耗，适用于资源受限的设备和网络环境。
- 灵活性：Paho库提供了丰富的API，使开发人员能够根据应用程序的需求进行定制和扩展。它支持多种连接选项、消息发布和订阅的灵活配置，以及消息质量控制。
- 可靠性：Paho库具有可靠的消息传递机制，确保消息的可靠传输和交付。它支持持久化会话、消息确认和重连机制，以应对网络中断和不稳定性。
- 跨平台：Paho库不仅支持Android平台，还可以在其他Java应用程序中使用。这使得开发人员能够在不同的设备和平台上实现统一的MQTT通信解决方案。
Paho库适用于许多应用场景，包括但不限于：
- 物联网设备通信：Paho库可以用于连接和管理物联网设备之间的通信，实现设备之间的数据交换和控制。
- 实时数据传输：Paho库可以用于实时数据传输和监控，例如传感器数据的采集和监测系统。
- 消息推送和订阅：Paho库可以用于实现消息推送和订阅功能，例如新闻、天气、股票等实时信息的订阅和推送。
腾讯云提供了一系列与MQTT相关的产品和服务，可以与Paho库配合使用，例如：
- 云物联网平台（IoT Hub）：腾讯云的物联网平台提供了完整的物联网解决方案，包括设备管理、数据采集、消息传输等功能。您可以使用Paho库与腾讯云的物联网平台进行集成，实现设备与云端的通信。
- 消息队列服务（CMQ）：腾讯云的消息队列服务提供了高可靠、高可扩展的消息队列，用于实现分布式系统之间的异步通信。您可以使用Paho库与腾讯云的消息队列服务进行集成，实现消息的发布和订阅。
更多关于腾讯云的MQTT相关产品和服务信息，您可以访问以下链接：
相关·内容
我一直在尝试将MQTT整合到我的一个Android应用程序中。我最初让它在一个活动中工作，后来尝试将它移到一个服务中在后台运行。我可以连接并发送来自该服务的消息，但无法接收消息。我的服务实现了MqttCallback并覆盖了messageReceived()函数，但它似乎从未被调用过。有人能帮我解释一下为什么回调没有触发吗？
package com.example.test;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import org.eclipse.paho.client.mqttv3.IMqttDel
浏览 7提问于2017-08-13得票数 1
当客户机订阅多个主题时，是否可以使用类似的概念(在javascript中)和paho python中使用的message_callback_add来使用多个回调？我已经看到了if条件在onMessageArrived()中的使用，但我想知道是否存在一种更高效、更干净的方法？
var mqtt; // MQTT variable/object
var reconnectTimeout = 5000; // 5 seconds for the reconnectTimeout
var host="localhost"
浏览 9提问于2021-06-07得票数 1
回答已采纳
我正试图向我的MQTT代理(这是我的Raspberry Pi)发布一条关于rpi/gpio主题的消息。发送该信息的目的是打开/关闭连接到我的Raspberry的LED (就像教程中的那样，但该教程是针对Swift而不是安卓的)。因此，当我在我的Android应用程序上打开开关小部件时，消息" on“将被发布到Raspberry Pi代理以打开它(通过一个python脚本也连接到Raspberry Pi上的MQTT )。如果没有所有的MQTT代码，下面的片段可以通过显示开关很好地工作。但是，使用以下代码，它会崩溃。
public class ControlsFragment extend
浏览 1提问于2018-03-06得票数 4
回答已采纳
1回答
我想实现paho-mqtt，在其中它应该异步处理传入的消息。 我已经用asyncio实现了gmqtt，它运行得非常好，但据我所知，使用paho-mqtt要比使用gmqtt (链接：https://www.emqx.io/blog/comparision-of-python-mqtt-client)更好。 带异步的gmqtt： def assign_callbacks_to_client(self, client):
""" Helper function which sets up client's callbacks. """
浏览 53提问于2021-01-11得票数 0
这是我在MQTT类中编写的on_message回调，我试图在其中返回收到的发布消息：
def message(self):
def on_message(client, userdata, msg):
Message = str(msg.payload)
print("[Receiving msg] Topic:" +msg.topic+" / Message: "+Message)
return Message
return on_message
但是，一旦调用了message：print(occ
浏览 7提问于2020-05-13得票数 1
回答已采纳
我对ESP8266上的以下Lua代码有问题.
function sendData(humidity,temperature)
-- Setup MQTT client and events
print("sendData() entered")
print("Setting up mqtt.Client...")
m = mqtt.Client(mqtt_client_id, 120, username, password)
print("Attempting client connect...")
浏览 5提问于2016-04-16得票数 1
关于持久会话和队列消息，我有一个问题/问题。下面是一个场景:我有一个发布者(java服务器)，它是发布消息，我有一个接收器(android客户端)。当android客户端在线时，它会收到令人惊奇的信息，效果非常好。然而，当我杀死android应用程序并继续从服务器发送消息时，当我打开android应用程序时，android就不会收到以前的消息了。
服务器端：
final Mqtt5BlockingClient client = MqttClient.builder()
.useMqttVersion5()
.serverHost(host
浏览 9提问于2022-11-17得票数 1
回答已采纳
2回答
MQTT从主线程发送消息
、、、、
我在MqttHelper类中实现了简单的MQTT订阅服务器，它工作正常并接收订阅。但是当我需要从主程序发送消息到服务器时，我应该如何处理。我有publish方法，它可以很好地从IMqttActionListener中运行，但是如何在按下按钮的事件上从主程序发送文本呢？
package com.kkk.mqtt.helpers;
import android.content.Context;
import android.util.Log;
import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclips
浏览 4提问于2019-11-20得票数 0
我试图围绕Paho MQTT JavaScript客户端编写一个简单的包装类。(其想法是对MQTT消息进行一些额外的验证，以确保按正确的顺序处理消息。)
我对JavaScript课程不太满意，我想弄清楚这是怎么回事.
class Hermes {
constructor(uri, topic, callback) {
var clientId = "clientID_" + parseInt(Math.random() * 1000);
this.client = new Paho.MQTT.Client(uri, clientId);
this.t
浏览 9提问于2020-09-11得票数 0
回答已采纳
1回答
我可以发布和订阅一个主题，但是当取消订阅功能不起作用时呢？
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://localhost:1883');
var topic = 'home/machine1/lightSensor';
client .on('connect', ()=>{
client.unsubscribe(topic,console.log);
});
它返回null
浏览 10提问于2021-11-10得票数 0
我实现了一个使用MQTT客户端的服务，该客户端运行在与main不同的线程中。我的MQTT客户端是一个继承自pahoo的mqtt客户端的类。
def run(self):
logging.info("Starting MQTT Client")
self.loop_start()
self.connect(self._host, self._port, keepalive=self._timeout)
然后，我向一些topi添加了一些特定的回调，如下所示：
self.message_callback_add(topic, callback)
问题是，当回调
浏览 0提问于2021-04-04得票数 0
我尝试过使用导入，但是我得到了一个错误：
未定义的ReferenceError: mqtt未定义
我试图运行的代码位于HTML文件中：
<script>
require(["https://unpkg.com/mqtt@3.0.0/dist/mqtt.min.js"], function (mqtt) {
console.log("Libraries loaded");
})
</script>
<script src="../text-to-speech/sub_mqtt.
浏览 4提问于2020-04-24得票数 0
回答已采纳
一周前，我在android上工作，我必须在我的android中使用MQTT的服务器(就像蚊子一样)；因为我们要使用Delphy服务器。安卓的手机是Galaxy在2.3.6 .API :9
为了学习如何使用它，我测试了戴尔莱恩的摩斯基托为android，但一天后，我已经找到了我可以做的论坛.戴尔巷的链接：
我的LogCat：
10-01 10:34:50.203 17844-17879/org.mosquitto.android.mqttdemo
W/Settings: Setting android_id has moved from
android.provider.Settings.Sy
浏览 6提问于2013-10-01得票数 0
回答已采纳
2回答
我正在试图隐藏图标时，我的抽屉拿铁显示。这只是隐藏设置，而不是我想要的图标。
在我的MainActivity上，我已经看到如果我添加这段代码，图标就会隐藏，但是如果我按下其他片段来显示它会崩溃。
@Override
public boolean onPrepareOptionsMenu(Menu menu) {
// if nav drawer is opened, hide the action items
boolean drawerOpen = mDrawerLayout.isDrawerOpen(mDrawerList);
menu.findItem(R
浏览 3提问于2015-01-09得票数 0
回答已采纳
我有一个Mqtt客户端订阅了一个主题。当订阅者收到消息时，on_message回调开始工作。我有一个基于on_message回调中的消息的猫鼬查询。这个查询执行起来太长了。
但是，将查询保持在on_message回调之外将立即执行。但我想把它放回电话里。
这是我的代码样本-
var mqtt = require('mqtt');
mqttClient = mqtt.connect("mqtt://broker.emqx.io:1883",{clientId:"mqttClient", keepalive: 1000});
let optio
浏览 5提问于2022-06-14得票数 0
回答已采纳
如何在mqtt消息中获取报头代理或设备/浏览器的详细信息。我的mqtt代码示例：
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://127.0.0.1:1883',{
username: 'xxxx',
password: 'xxxx'
});
client.on('connect', function (err,done) {
if(err){
console.log(err)
}else{
浏览 0提问于2018-04-13得票数 0
回答已采纳
首先，我们在Hyperledger Fabric和MQTT领域是相当新的。我们正在构建一个原型，其中包含一个用nodeJS编写的区块链平台(Hyperledger Fabric)和一个用于传输IoT数据的树莓派(与mqtt一起工作)。在我们的nodeJS文件中，我们创建了一个MQTT客户端，该客户端订阅一个主题并以消息的形式获取一个JSON对象。该对象的参数必须传递给智能合约(submitContract)。我们意识到Hyperledger Fabric的网关在运行MQTT event functions (client.on)之前就断开了连接，因此我们认为应该让网关在提交契约的情况下断开连接
浏览 9提问于2020-03-07得票数 1
我使用MQTT和paho一起在android上接收和发布消息。
我有下面的MQTT初始化代码。
private void initializeMQTT(){
try{
mqttClient = new MqttClient(
"tcp://broker.hivemq.com:1883",
MqttClient.generateClientId(),
new MemoryPersistence()
);
mqttClient.c
浏览 2提问于2017-01-30得票数 2
回答已采纳
2回答
我尝试用paho库实现一个异步MQTT客户机，它接收关于主题“请求”的消息，制定一个字符串，并将响应放到主题" response“上。我使用回调来处理传入的消息。
#include "mqtt/async_client.h"
#include "mqtt/topic.h"
const std::string SERVER_ADDRESS {"tcp://localhost:2883"};
const std::string CLIENT_ID {"test_client"};
class TestCallback
浏览 30提问于2022-03-31得票数 0
回答已采纳
我正在尝试按照提供者架构模型来实现一系列传输提供商。因此，我创建了一个抽象的传输提供者，然后由特定的提供者进行扩展，比如mqtt、nats等等。然而，我在初始化mqtt客户机时遇到了问题。初始化、连接和与客户端交互的代码(当放在处理程序之外时)将正确运行。但是，提供程序方法connect()中的相同代码不起作用(它似乎在使用调试器监视时初始化客户机，然后跳过所有client.on函数)。
这是抽象提供程序，它简单地概述了需要使用的方法：
class abTransProvider {
constructor() {
this.client;
this
浏览 6提问于2022-09-16得票数 0
回答已采纳
1回答
我刚刚开始Java Android编程，甚至是一般的Java编程，我希望使用某个MqttHandler类实现Paho MQTT Android Service，并希望将回调设置为MqttHandler类的参数。其他关于回调的答案通常建议使用接口类，但我不知道它是如何工作的。这是我尝试过的：
public interface InterfaceMqttCallback extends MqttCallbackExtended{
@Override
public void connectComplete(boolean b, String s);
@Override
浏览 12提问于2016-08-06得票数 4
我写了这段MQTT发布代码： import paho.mqtt.client as mqtt
import time
HOST = "localhost"
PORT = 1883
KEEP_ALIVE_INT = 100
TOPIC = "noti"
def sendMsg():
MSG = ["1111", "2222", "3333", "4444", "5555"]
i = 0
try:
while i<5:
浏览 33提问于2021-08-31得票数 0
回答已采纳
1回答
我正在开发一个mqtt订阅服务器，它将消息转发到豆茎管或api端点。我想出了以下代码：
#!/usr/bin/python
import pymysql.cursors
import sys
import time
import paho.mqtt.client as mqtt
from threading import Thread
class Process(Thread):
def __init__(self, sid=None, host=None, username=None, password=None, topic=None, topic_qos=None, dest
浏览 3提问于2016-05-18得票数 2
回答已采纳
假设我订阅了某个主题，而蚊子服务器将继续发布有关该主题的消息。
当一条来自蚊虫经纪人的新消息到达时，如何调用on_message方法？它是在主线程上运行，从而阻塞它，并且只在当前消息被处理时处理下一条消息，还是每次新消息到达时它都会使用on_message方法生成一个新线程？
import paho.mqtt.client as mqtt
def on_message(client, userdata, message):
print message.payload
return True
topics = ["topic1",]
client = mqtt
浏览 0提问于2019-09-13得票数 3
回答已采纳
我从一个python脚本同时从多个客户端发送多个消息，并尝试在另一个脚本上接收这些消息。我得到的问题是，消息被接收，但只从第一个连接的客户端收到，并且它一直在它上面循环。我需要的是以发布消息的方式从每个客户端获取消息。 import paho.mqtt.client as mqtt
import time
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to broker")
global Connected
浏览 114提问于2019-08-27得票数 0
回答已采纳
1回答
我们创建了一个android原生应用程序，它在某些情况下会崩溃。这肯定与相机有关，但不太确定可能是什么。
我想强调的是，我不是一个android开发人员(我主要是用python开发的)，但我想知道android专家是否能提供一些关于这个错误的背景信息。
以下是来自google play控制台的堆栈跟踪：
java.lang.RuntimeException:
at android.hardware.Camera.native_setParameters (Native Method)
at android.hardware.Camera.setParameters (Camera.j
浏览 0提问于2017-12-10得票数 0
我已经成功地在后台线程中实现了HiveMQ，但是在激活飞行模式之后有一个小问题。日志显示了原因，但我认为缺少了一些东西，我看不到缺少的错误处理程序在哪里。 日志： com.hivemq.client.mqtt.exceptions.MqttSessionExpiredException: Session expired as connection was closed.
System.err W io.reactivex.exceptions.OnErrorNotImplementedException: The exception was not handled due to miss
浏览 27提问于2019-09-19得票数 0
回答已采纳
我正在从事自定义ROM项目，并且需要创建服务，它可以继续通过Websocket或套接字或MQTT与我们的云服务器连接，就像Google服务正在做的那样。为此，我创建了AOSP系统服务。
我已经成功地在自定义ROM中创建了系统服务，它运行良好，但是在这个类上，我无法访问websocket或HTTPAPI。每当我要访问这些API时，aosp构建都会失败，并引发异常，如下所示。
error: package java.net.http does not exist
import java.net.http.HttpClient;
error: package java.net.http does
浏览 3提问于2022-06-06得票数 0
我使用的是ruby中的paho-mqtt gem。
我想知道，如果客户端由于某种原因没有收到PUBACK，gem是否会自动将消息重新发送(重新发布)到MQTT代理，还是必须手动执行？QOS=1
例如(这是我使用QOS=1发布内容，不做其他任何事情)：
client = PahoMqtt::Client.new
client.on_puback do
puts "PUBACK received"
end
client.connect(@mqtt_server_ip, @mqtt_server_port)
client.publish(topic, message_payl
浏览 5提问于2018-05-31得票数 0
启动flask、mqtt和socketio应用程序时，如何在应用程序启动时但在浏览器首次连接之前订阅主题？
我假设我可以使用before_first_request，但只在第一次请求时调用，还假设我可以使用mqtt.on_connect，但在使用socket io时从不调用，如果我在__main__中启动应用程序之前订阅，那么我将获得两个线程订阅，而不是一个。
#!/usr/bin/env python3
import json
from flask import Flask, render_template
from flask_mqtt import Mqtt
from flask_soc
浏览 7提问于2021-09-22得票数 0
我正在学习MQTT和Android Studio。我想用Android Studio做一个简单的应用程序，但我从4天开始就一直在挣扎，我无法应付。
应用说明:1Button-> Push -> Send to mqtt topic / message ( "mqtt“/ "test”)
Mqtt Broker = rpi (IP: namerpibrok.ddns.net )
Broker工作正常，不需要密码或用户名
问题出在应用上--这是我第一次使用Android Studio。
我按照页面上的描述执行了所有操作：
现在，当我按下按钮..。什么都没发生。
浏览 2提问于2017-11-16得票数 1
1回答
你好，这是我收到的关于“状态”的消息，我有一些客户端要发送关于“状态”的消息。
问题是‘如何打印客户端的名称以发送消息；“在下面的代码行中。
print("received message: " ,str(message.payload.decode("utf-8"))," from: ",str())
import paho.mqtt.client as mqtt
import time
def on_message(client, userdata, message):
print("received message: &#
浏览 3提问于2022-06-16得票数 -1
1回答
我使用的是mqtt，我想用不同的主题显示一些数据
这是我的剧本，有一个这样的主题，它很有用：
<!DOCTYPE html>
<html lang="fr">
<script src="https://unpkg.com/mqtt/dist/mqtt.min.js"></script>
<script src="https://cdnjs.cloudflare.com/ajax/libs/paho-mqtt/1.0.1/mqttws31.js" type="text/javascri
浏览 2提问于2021-07-22得票数 0
回答已采纳
1回答
在下面的脚本中，我可以订阅一个主题，但是它不会发布我的数据字符串，也不会收到错误消息。有些功能不正常吗？
import paho.mqtt.client as mqtt
broker = "broker" #Broker address
port = 1883 #Broker port
user = "user" #Connection username
psw = "psw"
浏览 7提问于2022-09-29得票数 0
2回答
在等待消息时发送消息
、、、
我使用mqtt协议向蚊虫中介.What发送传感器数据消息，我想做的是每t秒发送一次传感器数据，但是如果我接收到一条消息并行处理，我正在使用time.sleep()，但我认为这将延迟使用paho-mqtt和python2.7的"on_message“函数.Im。对我怎么能完成这件事有什么想法吗？
客户端No1。(发送传感器数据)
from mysignals import mysignals
import paho.mqtt.client as mqtt
import time
def on_connect(client, userdata, rc):
mqttc.subs
浏览 1提问于2017-03-29得票数 0
回答已采纳
1回答
Python异常处理
、、、
目前，我正在努力确保我的Python脚本仍然活着，不管它是在什么情况下，因此，我试图捕获所有的异常，并找到一个apropiate脚本响应。
在我的脚本中，我试图捕捉在连接到MQTT代理时可能发生的错误，即：(1)通过没有插入的eth0连接，或者(2)路由器无法访问internet。
1的错误消息是：
socket.gaierror: [Errno -5] No address associated with hostname
2的错误消息是：
socket.gaierror: [Errno -2] Name or service not known
遗憾的是，我还没有捕捉到这些例外。这些是我试
浏览 4提问于2016-04-10得票数 0
回答已采纳
在我的一个活动中，我以片段的形式展示了google地图。它在3g或高速互联网连接上工作得很好。但在2g或非常慢的互联网连接中，我的手机挂起了，一段时间后，我收到了“没有响应”的信息。有什么办法可以处理这种情况吗？下面是代码
@Override
protected void onCreate(Bundle savedInstanceState) {
try {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_maps);
浏览 2提问于2017-06-29得票数 0
1回答
我使用的是ESP8266芯片和SMING软件框架MqttClient_Hello的例子。
我希望MQTT连接始终存在。如果由于任何原因，连接被打破，我希望重新连接发生。这是如何做到的呢？
MqttClient_Hello中的相关代码；
void startMqttClient();
void onMessageReceived(String topic, String message);
MqttClient mqtt("192.168.1.8", 1883, onMessageReceived);
// Run MQTT client
void startMqttClien
浏览 0提问于2016-01-06得票数 0
回答已采纳
我试图在一个有一个AsyncTask的片段中运行ProgressDialog，我已经在其他活动中做了很多次了，但是当我尝试在一个片段中运行时，它会因为内存泄漏而崩溃。我知道造成这种情况的原因与ProgressDialog有关，但我似乎不知道如何正确地做到这一点。
AsynTask：
private void startNewAsyncTask() {
NetCheck asyncTask = new NetCheck();
asyncTask.execute();
}
private class NetCheck extends AsyncTask<String
浏览 0提问于2014-03-25得票数 3
回答已采纳
预期行为
我希望有一个回呼，以倾听每个主题，我订阅的只是一次每一条消息。我的意思是，我想订阅一个主题1000次，但当收到一条消息，我想听它只一次。
如果有什么事情我做错了(我猜)。
实际行为
我正在开发一个家庭安全摄像头应用程序。我有一个我拥有的相机列表。对于列表中的每一个相机，我都订阅了一个主题。每隔30岁就更新一次屏幕，然后再为每个相机订阅一个主题。这意味着一个主题可以被多次订阅。每次我收到主题上的消息时，都会触发消息，说明相同的topi订阅了多少次。
再生产
步骤
主题camera/123subscribe主题N次，下面的方法称为subscribeWithSend，camera/123Y
浏览 8提问于2020-12-18得票数 0
回答已采纳
这是我的代码：
public void connect(Context application) throws MqttException {
Log.d(MainActivity.TAG, "Connecting to MQTT");
String mqttServerUri = "tcp://18.219.333.193:1883";
String userName = "xxxxxxx";
String password = "xxxxxxx";
MqttAndroidClient
浏览 0提问于2019-07-17得票数 1
我已经写了一段代码，可以在同一个python文件中进行发布和订阅。我的目标是能够无休止地向灯发送色温，并接收回其状态(开/关或在线/离线)。
但是，当我运行代码时，我可以向lamp发送消息，但我没有收到任何消息(请注意，发布者和订阅者分别工作得很好)
import paho.mqtt.client as mqtt
import sys
import time
topic = "testtopic/3"
topic_casa = "testtopic/1"
def on_connect(client, userdata, flags, rc):
pr
浏览 42提问于2020-05-07得票数 0
回答已采纳
我已经安装了蚊子，并在终端使用没有问题，也安装了c++的paho，蚊子和paho都很好用。然后通过pip为python安装了paho。现在我尝试用这段代码来测试它，但是on_message和on_connect函数从未被调用过。我正在做
mosquitto_pub -h localhost -t "test" -m "This is a message"
虽然python脚本运行，但它不工作。它永远不会到达打印"on_message!“的代码行。
import paho.mqtt.client as mqtt
def on_connect(self,
浏览 5提问于2016-06-21得票数 3
1回答
我有一个关于paho mqtt库的小问题。我注册了一个回调函数MQTTClient_messageArrived和MQTTClient_connectionLost。
我在这个回调函数中调用了MQTTClient_subscribe()或MQTTClient_unsubscribe()。在运行此回调函数之后。我从MQTTClient_connectionLost得到一个错误代码(-3)。此外，我打印的原因是空。
我的问题可能有什么问题吗？谢谢
下面是我的初始化函数和回调函数：
void mqtt_initialize(void){
int rc;
MQTTClient_con
浏览 0提问于2018-07-09得票数 0
这可能是我问得最多的问题，但我仍然无法解决我的问题。我已经检查了、和其他许多东西，但问题仍然存在。
如果twitter应用程序安装在用户的设备上，一切正常，但如果它不在那里，我会收到以下错误消息。
无效的json:未批准此客户端应用程序的回调URL。已批准的回调URL可以在应用程序设置com.google.gson.JsonSyntaxException: java.lang.IllegalStateException:预期的BEGIN_OBJECT中进行调整，但在第1列第1列路径$处为BEGIN_OBJECT字符串。
由: java.lang.IllegalStateException:预
浏览 2提问于2018-07-15得票数 9
2回答
在我的应用程序中，我一直在为我的webservice调用使用改装。它运行良好，但是当应用程序进入后台时，它崩溃并获得错误日志，
java.lang.NullPointerException: Attempt to invoke interface method 'void retrofit.Callback.failure(retrofit.RetrofitError)' on a null object reference
at retrofit.CallbackRunnable$2.run(CallbackRunnable.java:53)
a
浏览 4提问于2015-10-16得票数 5
回答已采纳
我正在为我的android项目实现Paho MQTT Java客户端。它基本上是一个即时消息系统。发布和订阅实现对我来说工作得很好，但我留下了一个问题。订阅的客户端能够在消息发布时接收消息，但是系统检查客户端(订阅者)是否接收/传递消息的能力有点难以实现，我认为这是因为MQTT不支持这一点。
有没有人知道如何以不同的方式实现这个逻辑？
浏览 4提问于2017-01-24得票数 2
我有一个mqtt类 class MQTT():
def __init__(self):
# Observer.__init__(self) # DON'T FORGET THIS
self.mqttClient = paho.Client(client_id=constants.MQTT_CLIENT_ID)
self.mqttClient.username_pw_set(username=constants.MQTT_BROKER_USERNAME, password=constants.MQTT_BROKER_PASSWO
浏览 24提问于2021-01-06得票数 1
回答已采纳
请帮我弄一下这个。我已经在这上面花了两天的时间，但没有成功。
我使用的是Paho-Mqtt python客户端示例。我的digitalocean debian服务器上也有HiveMq mqtt服务器。如果我在我的笔记本电脑或linux Debian机器上运行，用python编写的客户端示例代码可以连接并订阅digitalocean服务器。但。这就是但是。当我在digitalocean服务器( hivemq mqtt服务器)上运行客户端时，它只能连接而不能订阅！我同时使用了本地主机和服务器IP，但仍然没有成功。
但是，在digitalocean服务器(以及hivemq mqtt服务器)上运行的相
浏览 5提问于2015-07-27得票数 0
1回答
我想要创建一个简单的程序，使用MQTT协议，特别是Android中的HiveMQ库发送一个简单的消息。
package com.example.mqtt;
import static java.nio.charset.StandardCharsets.UTF_8;
import android.os.Bundle;
import android.widget.Button;
import android.widget.TextView;
import androidx.appcompat.app.AppCompatActivity;
import com.hivemq.client.m
浏览 36提问于2022-06-01得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
