// 指令发送
ByteBuf buffer = Unpooled.buffer();
log.info("开始发送报文:{}",Arrays.toString(msgBytes));
buffer.writeBytes(msgBytes);
channel.writeAndFlush(buffer).addListener((ChannelFutureListener) future -> {
System.out.println(future);
if (future.isSuccess()) {
// 修改为合闸状态
if (msgBytes.equals(msgBytes1)){
log.info("客户端:{},查询结果为合闸:{}",imei,Arrays.toString(msgBytes));
WlEquipmentConfig wlEquipmentConfig = new WlEquipmentConfig();
wlEquipmentConfig.setWlPumpState(0);
wlEquipmentConfig.setWlEquipmentImei(imei);
wlEquipmentConfigMapper.updateWlEquipmentConfigByIMEI(wlEquipmentConfig);
}else if (msgBytes.equals(msgBytes2)){
log.info("客户端:{},查询结果为分闸:{}",imei,Arrays.toString(msgBytes));
WlEquipmentConfig wlEquipmentConfig = new WlEquipmentConfig();
wlEquipmentConfig.setWlPumpState(1);
wlEquipmentConfig.setWlEquipmentImei(imei);
wlEquipmentConfigMapper.updateWlEquipmentConfigByIMEI(wlEquipmentConfig);
}
log.info("客户端:{},查询结果为:{}",imei,Arrays.toString(msgBytes));
我现在好像就是发送的啥回写打印就是啥,netty如何监听到真正的设备响应报文呢?想请教一下
这个应该不是说通过 writeAndFlush() 方法后如何用监听器去监听服务端给你返回的数据,应该是说接收出站的数据,那么 netty 是由相应的出站接口 XxxOutBoundChannel 可以监听给你会写的数据(报文)