我正在开发一种从环境中感知和收集信息（例如温度，湿度等）的设备。
该设备未连接到任何电源，但具有电池和太阳能电池板进行充电。
它大部分时间都处于深度睡眠状态，只有在需要感应和传输数据时才会唤醒。此操作大约需要1-2分钟，然后再次进入睡眠状态。
虽然我不是这个领域的专家，但如果需要让设备始终可以接收来自主题的消息，则MQTT应该是一个很好的选择。但在我的情况下，它仅读取传感器并周期性地将数据发送到服务器。
目前，我通过HTTP发送数据，但我想知道是否有必要实现MQTT？ 我是否可以从MQTT中获得优势以满足我的需求？
关于MQTT和HTTP之间的比较已经有大量的文献，您可以深入了解其细节，但以下是一些适用于您应用程序的要点。
MQTT
总之，MQTT具有许多适合您应用程序的功能。但是，您可能可以使用HTTP复制其中许多功能，但需要更多的工作。
HTTP
几乎在任何地方都受到支持，这确保了与防火墙的更容易兼容性。如果您部署在您无法控制的网络上，则这可能很重要。
它是一种更常见的协议，因此您（和您的最终用户）可能已经熟悉它。同样，您可能已经了解其安全模型，这将使其更容易获得安全性。
不同MQTT实现之间存在一些差异，可能会导致困难（例如，我使用Mosquitto，并且有时在人们谈论他们的HiveMQ设置时感到困惑）。HTTP对我来说更普遍，并且有更大的社区可用于帮助您。
因此，与MQTT相比，HTTP存在一些固有的劣势，但它可以完成工作，如果MQTT的具体功能不适合您，则可能更实用。但是，如果这是一个大规模项目，值得尝试两种方法，并在您特定的应用程序和环境中运行一些基准测试和测试。建立测试环境并获取一些指标并不难。如果这更像是一次爱好/单次项目，那么我会使用您更熟悉或更感兴趣的那个。
来源/进一步阅读：
http://stephendnicholas.com/posts/power-profiling-mqtt-vs-https https://www.ibm.com/developerworks/community/blogs/sowhatfordevs/entry/using_mqtt_protocol_advantages_over_http_in_mobile_application_development5?lang=en https://medium.com/@shubhanshusingh/http-vs-mqtt-9008d448bf88 https://www.slideshare.net/paolopat/mqtt-iot-protocols-comparison https://mobilebit.wordpress.com/2013/05/03/rest-is-for-sleeping-mqtt-is-for-mobile/ http://bec-systems.com/site/1200/iot-protocols-mqtt-vs-coap-vs-http
private static final String TAG = "PahoMqttClient";
private MqttAndroidClient mqttAndroidClient;
this.broker_userName=clientId;
this.broker_password=broker_password;
mqttAndroidClient = new MqttAndroidClient(context, brokerUrl, clientId);
try {
IMqttToken token = mqttAndroidClient.connect(getMqttConnectionOption(), null, new IMqttActionListener() {
@Override
public void onSuccess(IMqttToken iMqttToken) {
Log.d(TAG, "Success");
}
@Override
public void onFailure(IMqttToken iMqttToken, Throwable exception) {
Log.d(TAG, "Failure " + exception.toString());
}
});
} catch (MqttException e) {
e.printStackTrace();
}
return mqttAndroidClient;
}
public void disconnect(@NonNull MqttAndroidClient client) throws MqttException {
IMqttToken mqttToken = client.disconnect();
mqttToken.setActionCallback(new IMqttActionListener() {
@Override
public void onSuccess(IMqttToken iMqttToken) {
Log.d(TAG, "Successfully disconnected");
}
@Override
public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
Log.d(TAG, "Failed to disconnected " + throwable.toString());
}
});
}
@NonNull
private DisconnectedBufferOptions getDisconnectedBufferOptions() {
DisconnectedBufferOptions disconnectedBufferOptions = new DisconnectedBufferOptions();
disconnectedBufferOptions.setBufferEnabled(true);
disconnectedBufferOptions.setBufferSize(100);
disconnectedBufferOptions.setPersistBuffer(false);
disconnectedBufferOptions.setDeleteOldestMessages(false);
return disconnectedBufferOptions;
}
@NonNull
private MqttConnectOptions getMqttConnectionOption() {
MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
mqttConnectOptions.setCleanSession(false);
mqttConnectOptions.setAutomaticReconnect(true);
mqttConnectOptions.setKeepAliveInterval(120);
//mqttConnectOptions.setWill(Constants.PUBLISH_TOPIC, "I am going offline".getBytes(), 1, true);
mqttConnectOptions.setUserName(broker_userName);
mqttConnectOptions.setPassword(broker_password.toCharArray());
return mqttConnectOptions;
}
public void publishMessage(@NonNull MqttAndroidClient client, @NonNull String msg, int qos, @NonNull String topic)
throws MqttException, UnsupportedEncodingException {
byte[] encodedPayload = new byte[0];
encodedPayload = msg.getBytes("UTF-8");
MqttMessage message = new MqttMessage(encodedPayload);
message.setId(320);
message.setRetained(false);
message.setQos(qos);
try {
client.publish(topic, message);
}catch (Exception e){ Log.e("PUB", e.getMessage());}
}
public void subscribe(@NonNull MqttAndroidClient client, @NonNull final String topic, int qos) throws MqttException {
IMqttToken token = client.subscribe(topic, qos);
token.setActionCallback(new IMqttActionListener() {
@Override
public void onSuccess(IMqttToken iMqttToken) {
Log.d(TAG, "Subscribe Successfully " + topic);
}
@Override
public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
Log.e(TAG, "Subscribe Failed " + topic);
}
});
}
public void unSubscribe(@NonNull MqttAndroidClient client, @NonNull final String topic) throws MqttException {
IMqttToken token = client.unsubscribe(topic);
token.setActionCallback(new IMqttActionListener() {
@Override
public void onSuccess(IMqttToken iMqttToken) {
Log.d(TAG, "UnSubscribe Successfully " + topic);
}
@Override
public void onFailure(IMqttToken iMqttToken, Throwable throwable) {
Log.e(TAG, "UnSubscribe Failed " + topic);
}
});
}
}