| | |
| | | import com.zy.core.cache.OutputQueue; |
| | | import com.zy.core.enums.SlaveType; |
| | | import com.zy.core.thread.ShuttleThread; |
| | | import io.netty.handler.timeout.ReadTimeoutException; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | |
| | | import java.io.*; |
| | |
| | | } |
| | | |
| | | JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集 |
| | | log.info("收到Server Data: {}", JSON.toJSONString(result)); |
| | | |
| | | String msgType = result.getString("msgType"); |
| | | if ("responseMsg".equals(msgType)) { |
| | |
| | | return; |
| | | } |
| | | } |
| | | log.info("收到Server Data: {}", JSON.toJSONString(result)); |
| | | |
| | | DeviceMsgModel deviceMsgModel = new DeviceMsgModel(); |
| | | deviceMsgModel.setDeviceId(deviceConfig.getDeviceNo()); |