mina inputClosed()方法不断调用

Question

在学习mina框架时我重写了public void inputClosed(IoSession is) 方法

然后我在关闭客户端连接时出现了这个方法的不断调用 下面是我的代码，请问有人遇到过吗

package mina;

import org.apache.mina.core.service.IoHandler;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;

class MyHandler implements IoHandler {

    public MyHandler() {
    }

    @Override
    public void sessionCreated(IoSession is) throws Exception {
        System.out.println("create");
    }

    @Override
    public void sessionOpened(IoSession is) throws Exception {
        System.out.println("opensession");
    }

    @Override
    public void sessionClosed(IoSession is) throws Exception {
        System.out.println("session close");
    }

    @Override
    public void sessionIdle(IoSession is, IdleStatus is1) throws Exception {
        System.out.println("session idle");
    }
    
    

    @Override
    public void exceptionCaught(IoSession is, Throwable thrwbl) throws Exception {
        System.out.println("except");
    }

    @Override
    public void messageReceived(IoSession is, Object o) throws Exception {
        
        System.out.println("msg rec"+(String)o);
        is.write((String)o);
    }

    @Override
    public void messageSent(IoSession is, Object o) throws Exception {
        System.out.println("msg sent");
    }

    @Override
    public void inputClosed(IoSession is) throws Exception {
        System.out.println("close");
    }
    
}

package mina;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;

public class SocketServer {
    public static void main(String[] args) {
        try {
            NioSocketAcceptor accepter =new NioSocketAcceptor();
            accepter.setHandler(new MyHandler());
            accepter.getFilterChain().addLast("codec", new ProtocolCodecFilter( new TextLineCodecFactory()));
            accepter.bind(new InetSocketAddress(9427));
        } catch (IOException ex) {
            Logger.getLogger(SocketServer.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
}

package ps.mc.chartT;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.logging.Level;
import java.util.logging.Logger;

public class SocketClient {
    public static void main(String[] args) {
    	Socket socket=null;
    	BufferedReader inputReader=null;
        BufferedWriter outputWriter=null;
        try {
            socket =new Socket("127.0.0.1",9427);
            inputReader =new BufferedReader(new InputStreamReader(System.in));
            outputWriter =new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            String content;
            while(!(content=inputReader.readLine()).equals("bye")){
                outputWriter.write(content+"\n");
                outputWriter.flush();
            }
        } catch (IOException ex) {
            Logger.getLogger(SocketClient.class.getName()).log(Level.SEVERE, null, ex);
        }finally{
        	try {
				inputReader.close();
				outputWriter.close();
				socket.close();
			} catch (IOException e) {
				// TODO 自动生成的 catch 块
				e.printStackTrace();
			}
        	
        }
    }
}

Answer 1

@Override public void inputClosed(IoSession session) throws Exception { session.closeNow(); }将session 关闭就可以了。

Answer 2

这个问题有没有实际解决？ 看源码是因为select一直认为是需要处理状态。  尚未找到很好的解决办法。

Answer 3

更改过滤规则就好了