Netty学习4—NIO服务端报错:远程主机强迫关闭了一个现有的连接

1 发现问题

NIO编程中服务端会出现报错

Exception in thread "main" java.io.IOException: 远程主机强迫关闭了一个现有的连接。
at sun.nio.ch.SocketDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:)
at sun.nio.ch.IOUtil.read(IOUtil.java:)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:)
at com.rb.socket.nio.server.n.NIOServer.handleKey(NIOServer.java:)
at com.rb.socket.nio.server.n.NIOServer.listen(NIOServer.java:)
at com.rb.socket.nio.server.n.NIOServer.main(NIOServer.java:)

主要原因是客户端强制关闭了连接(没有调用SocketChannel的close方法),服务端还在read事件中,此时读取客户端的信息时会报错

2 解决问题

服务器读取事件增强健壮性:

public void handelerRead(SelectionKey key) throws IOException {
// 服务器可读取消息:得到事件发生的Socket通道
SocketChannel channel = (SocketChannel) key.channel();
// 创建读取的缓冲区
ByteBuffer buffer = ByteBuffer.allocate();
int read = channel.read(buffer);
if (read > ) {
byte[] data = buffer.array();
String msg = new String(data).trim();
System.out.println("服务端收到信息:" + msg); // 回写数据, 将消息回送给客户端
ByteBuffer outBuffer = ByteBuffer.wrap("好的".getBytes());
channel.write(outBuffer);
} else {
System.out.println("客户端关闭");
key.cancel();
}
}

待验证

原贴地址:http://www.myexception.cn/program/1059786.html

上一篇:poj3694 network(边双联通分量+lca+并查集)


下一篇:Java堆内存溢出模拟