强制清洁MINA鼻腔接受器
|
我开始使用Mina对套接字进行异步写入，但是现在我似乎无法关闭会话。有没有办法强迫Mina关闭所有托管会话或清理？我现在有清洁的地方：
if(this.acceptor.isActive()) {
for(IoSession session : this.acceptor.getManagedSessions().values()) {
session.close(true);
}
this.acceptor.unbind();
this.acceptor.dispose();
}
没有找到相关结果
已邀请:
1 个回复
距相镭
import java.net.InetSocketAddress; import java.nio.charset.Charset; import org.apache.mina.core.service.IoAcceptor; import org.apache.mina.core.session.IoSession; import org.apache.mina.filter.codec.ProtocolCodecFilter; import org.apache.mina.filter.codec.textline.TextLineCodecFactory; import org.apache.mina.filter.logging.LoggingFilter; import org.apache.mina.transport.socket.nio.NioSocketAcceptor; public class MinaServer { public static void main(String[] args) throws Exception { IoAcceptor acceptor = new NioSocketAcceptor(); acceptor.getFilterChain().addLast(\"logger\", new LoggingFilter()); acceptor.getFilterChain().addLast( \"codec\", new ProtocolCodecFilter(new TextLineCodecFactory(Charset .forName(\"UTF-8\")))); acceptor.setHandler(new ServerHandler()); acceptor.bind(new InetSocketAddress(1071)); Thread.sleep(10000); if (acceptor.isActive()) { for (IoSession ss : acceptor.getManagedSessions().values()) { ss.close(true); } } } }