基于mqtt的水肥机、气象站、墒情站协议、功能模块继续开发

liurunyu

2025-06-10 6b828ba1310db528aa8172bd14a0253ebca5a844

 pipIrr-platform/pipIrr-common/src/main/java/com/dy/common/mw/channel/tcp/DataCodecFactory.java

New file
@@ -0,0 +1,39 @@
package com.dy.common.mw.channel.tcp;

import org.apache.mina.filter.codec.ProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.core.session.IoSession;

public class DataCodecFactory implements ProtocolCodecFactory {

   private TcpUnitAdapter adapter ;
    private boolean stop = false ;//为true时，停止TCP服务，并把已经TCP连接断连接

    public DataCodecFactory(TcpUnitAdapter adapter) {
       this.adapter = adapter ;
    }

    public void stop(){
        stop = true ;
    }

    public void recover(){
        this.stop = false ;
    }


    public ProtocolEncoder getEncoder(IoSession ioSession) {
        if(stop){
            ioSession.closeNow() ;
        }
        return new DataEncoder();
    }

    public ProtocolDecoder getDecoder(IoSession ioSession) {
        if(stop){
            ioSession.closeNow() ;
        }
        return new DataDecoder(adapter.newPrefixedDataAvailableHandle());
    }
}