该 s 在这个方法是主题: public void messageArrived(String s, MqttMessage mqttMessage)
s
public void messageArrived(String s, MqttMessage mqttMessage)
正如有很好的记录 这里 :
的 messageArrived 强> void messageArrived(java.lang.String topic,MqttMessage message)抛出java.lang.Exception 当消息从服务器到达时,将调用此方法。 MQTT客户端同步调用此方法。在此方法之前,不会将确认发送回服务器 干净利落地回来。 如果此方法的实现抛出异常,则客户端将被关闭。当客户端下次重新连接时,任何 QoS 1或2消息将由服务器重新传送。 在此方法的实现运行时到达的任何其他消息将在内存中建立,然后将备份 在网络上。 如果应用程序需要持久保存数据,则应确保在从此方法返回之前保留数据,如下所示 从此方法返回,该消息被认为是 交付,不会再现。 可以在此回调的实现中发送新消息(例如,对此消息的响应),但是 实现不得像现在这样断开客户端 无法发送正在处理的消息的确认, 并且会发生僵局。 参数: 话题 - 已发布消息主题的名称 信息 - 实际的消息。 抛出: java.lang.Exception的 - 如果发生终端错误,应关闭客户端。
的 messageArrived 强>
void messageArrived(java.lang.String topic,MqttMessage message)抛出java.lang.Exception
当消息从服务器到达时,将调用此方法。
MQTT客户端同步调用此方法。在此方法之前,不会将确认发送回服务器 干净利落地回来。
如果此方法的实现抛出异常,则客户端将被关闭。当客户端下次重新连接时,任何 QoS 1或2消息将由服务器重新传送。
在此方法的实现运行时到达的任何其他消息将在内存中建立,然后将备份 在网络上。
如果应用程序需要持久保存数据,则应确保在从此方法返回之前保留数据,如下所示 从此方法返回,该消息被认为是 交付,不会再现。
可以在此回调的实现中发送新消息(例如,对此消息的响应),但是 实现不得像现在这样断开客户端 无法发送正在处理的消息的确认, 并且会发生僵局。
参数:
话题 - 已发布消息主题的名称
信息 - 实际的消息。
抛出:
java.lang.Exception的 - 如果发生终端错误,应关闭客户端。