物联网通讯协议 iot-modbus V3.2.6 发布

物联网通讯协议 iot-modbus V3.2.6 发布

• 更新内容

iot-modbus本次发布的V3.2.6版本支持设备上线、掉线、处理业务异常监听处理，请看下面的源码解读。

• 设备上线监听源码解读

主要是在MiiListenerHandler重写了channelActive方法

@Overridepublic void channelActive(ChannelHandlerContext ctx) throws Exception {Channel channel = ctx.channel();if(!JudgeEmptyUtils.isEmpty(channel.remoteAddress())){String address = channel.remoteAddress().toString().substring(1,channel.remoteAddress().toString().length());ChannelConnectData connectServerData = new ChannelConnectData(this, DeviceConnectEnum.ON_LINE.getKey(), address);if(!JudgeEmptyUtils.isEmpty(connectServerData) && !JudgeEmptyUtils.isEmpty(getApplicationContext)){getApplicationContext.publishEvent(connectServerData);}}}

• 设备掉线监听源码解读

主要是在MiiListenerHandler重写了channelInactive方法。​​​​​​​

@Overridepublic void channelInactive(ChannelHandlerContext ctx) throws Exception {Channel channel = ctx.channel();if(!JudgeEmptyUtils.isEmpty(channel.remoteAddress())){String address = channel.remoteAddress().toString().substring(1,channel.remoteAddress().toString().length());ChannelConnectData connectServerData = new ChannelConnectData(this, DeviceConnectEnum.BREAK_OFF.getKey(), address);if(!JudgeEmptyUtils.isEmpty(connectServerData) && !JudgeEmptyUtils.isEmpty(getApplicationContext)){getApplicationContext.publishEvent(connectServerData);}}//连接断开后的最后处理ctx.pipeline().remove(this);ctx.deregister();ctx.close();}

• 处理业务异常监听源码解读

主要是增加了MiiExceptionHandler处理器，并在服务端MiiServer和客户端MiiClient初始化initChannel时添加进入。​​​​​​​

package com.takeoff.iot.modbus.netty.handle;
import com.takeoff.iot.modbus.common.entity.ChannelConnectData;import com.takeoff.iot.modbus.common.enums.DeviceConnectEnum;import com.takeoff.iot.modbus.common.utils.JudgeEmptyUtils;import com.takeoff.iot.modbus.common.utils.SpringContextUtil;import org.springframework.context.ApplicationContext;
import io.netty.channel.Channel;import io.netty.channel.ChannelDuplexHandler;import io.netty.channel.ChannelHandlerContext;import lombok.extern.slf4j.Slf4j;
@Slf4jpublic class MiiExceptionHandler extends ChannelDuplexHandler {private ApplicationContext getApplicationContext = SpringContextUtil.applicationContext;public MiiExceptionHandler(){}
@Overridepublic void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { Channel channel = ctx.channel();if(!JudgeEmptyUtils.isEmpty(channel.remoteAddress())){String address = channel.remoteAddress().toString().substring(1,channel.remoteAddress().toString().length());ChannelConnectData connectServerData = new ChannelConnectData(this, DeviceConnectEnum.ABNORMAL.getKey(), address);if(!JudgeEmptyUtils.isEmpty(connectServerData) && !JudgeEmptyUtils.isEmpty(getApplicationContext)){getApplicationContext.publishEvent(connectServerData);}//由Tail节点对异常进行统一处理if(cause instanceof RuntimeException){log.info("处理业务异常："+channel.remoteAddress());}super.exceptionCaught(ctx, cause);}}}

• 连接监听器源码解读

主要通过spring的发布时间监听来处理，增加连接监听器ChannelConnectListener。​​​​​​​

package com.takeoff.iot.modbus.test.listener;
import com.takeoff.iot.modbus.common.entity.ChannelConnectData;import com.takeoff.iot.modbus.common.utils.JudgeEmptyUtils;import org.springframework.context.event.EventListener;import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;
@Slf4j@Componentpublic class ChannelConnectListener {
@EventListenerpublic void handleReceiveDataEvent(ChannelConnectData data) {if(JudgeEmptyUtils.isEmpty(data.getDeviceConnect())){log.info("设备连接状态码："+data.getDeviceConnect()+" ---> "+data.getConnectMsg());}}}