“开关阀卡”修改成“巡检卡”

liurunyu

2024-10-25 f16c96a3bbd126dca21b254ceb018a0558f5ea1d

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
package com.dy.common.mw.channel.tcp;
 
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;
 
public class TcpIoHandler extends IoHandlerAdapter {
 
    private TcpUnitAdapter adapter ;
 
    private boolean stop = false ;//为true时，停止TCP服务，并把已经TCP连接断连接
 
    public TcpIoHandler(TcpUnitAdapter adapter){
        this.adapter = adapter ;
    }
 
    public void stop(){
        stop = true ;
    }
 
    public void recover(){
        this.stop = false ;
    }
 
    /**
     * 创建了会话
     */
    @Override
    public void sessionCreated(IoSession session) throws Exception {
        if(stop){
            session.closeNow() ;
        }else{
            super.sessionCreated(session);
        }
    }
   
    /**
     * 会话open时回调的方法 
     */
    public void sessionOpened(IoSession session) throws Exception {
        if(stop){
            session.closeNow() ;
        }else{
            this.adapter.newSessionEventCallback().sessionOpened(session);
        }
    }
    
    /**
     * 会话空闲
     */
    @Override
    public void sessionIdle(IoSession session, IdleStatus status)
            throws Exception {
        super.sessionIdle(session, status);
    }
    
    /**
     * 输入关闭
     */
    @Override
    public void inputClosed(IoSession session) throws Exception {
        super.inputClosed(session);
    }
    
    /**
    * 网络关闭
    */
   @Override
    public void sessionClosed(IoSession session) throws Exception {
          this.adapter.newSessionEventCallback().sessionClosed(session);
        super.sessionClosed(session);
    }
 
   /**
     * 发生异常
     */
   @Override
   public void exceptionCaught(IoSession session, Throwable cause) throws Exception {
        this.adapter.newSessionEventCallback().exceptionCaught(session, cause);
    }
    
    /**
     * 消息发送了
     */
    @Override
    public void messageSent(IoSession session, Object message) throws Exception {
        super.messageSent(session, message);
        this.adapter.newSessionEventCallback().messageSended(session, message);
    }
 
    /**
     * 接收到数据后，回调的方法，进行数据处理
     */
    @Override
    public void messageReceived(IoSession session, Object message) throws Exception {
        if(stop){
            session.closeNow() ;
        }else{
            this.adapter.newSessionEventCallback().messageReceived(session, message);
        }
    }
 
}