static String[] meandgroup = new String[]{"timentask/c/u000000000005", "timentask/c/u0000000GRP85", "timentask/c/u000000GRP107", "timentask/c/u0000000GRP84", "timentask/c/u000000GRP100"};
public static List<MqttClient> mqttConnect(Object topicId) {
try {
mqttClient = new ArrayList<MqttClient>();
for (int i = 0; i < meandgroup.length; i++) {
//if (mqttClient.get(i) == null || !mqttClient.get(i).isConnected()){
if (!globalData.GlobalDataSetGet.MQTT_SERVER_HOST_NAME.equals("") && !globalData.GlobalDataSetGet.MQTT_SERVER_USER_NAME.equals("")) {
String topicName = meandgroup[i];
mqttClient.add(MqttMgr.subscriber(globalData.GlobalDataSetGet.MQTT_SERVER_HOST_NAME,
globalData.GlobalDataSetGet.MQTT_SERVER_PORT_NUMBER, globalData.GlobalDataSetGet.MQTT_SERVER_USER_NAME,
globalData.GlobalDataSetGet.MQTT_SERVER_USER_PASSWORD, Constants.MQTT_CONNECTION_KEEP_ALIVE_SECS, topicName, "client" + globalData.GlobalDataSetGet.getUserIdValue, new ChatPaneWrite()));
}
}
} catch (MqttException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
return mqttClient;
}
MQTT允许您通配地订阅任何主题。这意味着，您无需强制订阅所有主题。"timentask/c/u000000000005", "timentask/c/u0000000GRP85"而是订阅"timentask/c/#"
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句