remote模块远程开关阀逻辑修改

liurunyu

2025-06-27 3878bfa207d6dd0a8a84177a437ec3b3a9a6825d

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

@@ -8,16 +8,32 @@
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());
    }
}