#

luxiaotao1123

2022-07-30 cb3cbeba7b17deb777e9866b4718bb41527c3b37

 src/main/java/com/zy/core/netty/handle/PackageServerHandler.java

@@ -2,7 +2,9 @@

import com.zy.core.netty.AbstractInboundHandler;
import com.zy.core.netty.cache.ChannelCache;
import com.zy.core.netty.constant.FireDataType;
import com.zy.core.netty.domain.ChPackage;
import com.zy.core.netty.domain.fire.Fire_3030;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
@@ -21,7 +23,16 @@

    @Override
    protected boolean channelRead0(ChannelHandlerContext ctx, ChPackage pac) {
        log.info("{}", pac.getBytes().length);
        FireDataType dataType = FireDataType.get(pac.getBytes()[1], pac.getBytes()[2]);
        switch (dataType) {
            case HEARTBEAT:
                Fire_3030 fire3030 = new Fire_3030().readFromBytes(pac.getBytes());
                break;
            case FIRE_ALARM:
                break;
            default:
                break;
        }
        return true;
    }