| | |
| | | }
|
| | | if (MqttRecvClient.getInstance() != null) {
|
| | | MqttRecvClient.getInstance().send(requestTopic, encryBytes);
|
| | | }
|
| | | if (HDLConnectHelper.isInverterTopic(linkRequest.getCloudTopic())) {
|
| | | LogUtils.i("远程发送数据:" + linkRequest.getCloudTopic() + "\r\n" + Arrays.toString(byteArrayConvertIntArray(linkRequest.getCloudSendBytes())));
|
| | | } else {
|
| | | LogUtils.i("远程发送数据:" + linkRequest.getCloudTopic() + "\r\n" + new String(linkRequest.getCloudSendBytes()));
|
| | | }
|
| | | }
|
| | | }
|
| | | //本地TCP
|
| | | else {
|
| | | if (!linkRequest.getTopic().endsWith("heartbeat")) {//心跳主题数据过多,过滤下
|