Java的SocketChannel中写入和读取String有几个需要注意的坑

如果直接使用write()和read()的话,有可能会出现发送或者接受到空消息的情,所以要加一个while()来循环检测是否把数据都写入/读取了

例子中使用UTF-8来传输字符串避免乱码

write()

非阻塞模式下，write()方法在尚未写出任何内容时可能就返回了。所以需要在循环中调用write()。

read()

非阻塞模式下,read()方法在尚未读取到任何数据时可能就返回了。所以需要关注它的int返回值，它会告诉你读取了多少字节。

 // Send Method
public static void SCSend(SocketChannel sc, String s) throws IOException {
Charset charset = Charset.forName("UTF-8");
ByteBuffer buf = ByteBuffer.allocate(1024);
buf.clear();
buf = ByteBuffer.wrap(s.getBytes(charset));
while(buf.hasRemaining()){
sc.write(buf);
}
}

 // Receive Method
public static void SCReceive(SocketChannel sc) throws IOException {
Charset charset =Charset.forName("UTf-8");
ByteBuffer buf = ByteBuffer.allocate(1024);
buf.clear();
int bytesRead = sc.read(buf);
while(bytesRead==0){
bytesRead = sc.read(buf);
}
buf.flip();
String s = charset.decode(buf).toString();
System.out.println(s); //可选输出内容
}