socketJava服务
‘壹’ java Socket中服务器断开后,客户端为什么没有抛异常
在客户端退出之后,会出现socket连接中断,此时是会抛出异常,在抛出异常时打印中断的客户端即可。
1. while(Binput.read()!= -1) 这种方法能判断出客户端输入是否为空,客户端断开能跳出死循环,但是得到的数据却从第二个开始了,所以这方法不适宜。
2. 在死循环中加入以下代码:
try {
socket.sendUrgentData(0);
} catch (IOException e) {
done= false; //如果抛出了异常,那么就是断开连接了 跳出无限循环
}
‘贰’ Java Socket常见异常处理
Java Socket编程中,常见异常处理是关键技能之一,下文将详细介绍几种主要异常及其解决方法。
首先,Java.net.SocketTimeoutException表示超时错误,分为连接超时和读取超时。连接超时多由网络不稳定造成,而读取超时原因可能更复杂,包括下游服务响应时间过长。解决方法需对网络环境进行排查。
其次,Java.net.BindException: Address already in use: JVM_Bind表示端口被占用。使用netstat –an命令可查看被占用端口,调整未被占用端口即可。
再者,Java.net.ConnectException: Connection refused: connect表示连接被拒绝。该异常可能由IP地址错误或服务端服务崩溃引起。解决策略包括验证IP地址、确认服务端服务状态。
Java.net.SocketException: Socket is closed表示连接已关闭。此异常在通信一方主动关闭Socket连接后,另一方再次进行读写操作时产生。避免该异常的策略在于确保连接操作的正确性。
Java.net.SocketException: Connection reset/Connect reset by peer: Socket write error表示连接被重置,主要由一方关闭Socket或异常退出导致。解决策略与上文类似。
Java.net.SocketException: Broken pipe表示通信管道已损坏。在接收到“Connect reset by peer: Socket write error”后,继续写数据时会抛出此异常。解决方法与解决“Connection reset”类似。
Java.net.SocketException: Too many open files表示进程打开文件句柄数超过限制。高并发环境下易出现此问题。使用lsof -p pid命令可查看进程打开的文件,排查资源泄露。如无泄露,可通过设置增加最大文件句柄数。
通过掌握上述异常及其解决策略,可有效提升Java Socket编程的稳定性与可靠性。
‘叁’ java socket输入流inputStream.read(byte[])方法一次读入多帧数据,也就是多帧数据连在一起
在使用Java Socket的inputStream.read(byte[])方法时,如果服务端发送数据的速度超过客户端读取的速度,客户端可能会一次性读取到多帧数据连在一起的情况。这种情况下,数据包的读取和处理就需要特别注意。一种处理方式是在服务端将每一帧数据作为一行写入Socket,客户端则通过BufferedReader逐行读取。这样可以确保每次读取的数据都是一个完整的数据帧。
具体实现步骤如下:
1. 在服务端使用PrintWriter将数据帧作为一行写入Socket输出流:
2. 代码示例如下:
java
PrintWriter writer = new PrintWriter(socket.getOutputStream());
writer.println(data);
2. 在客户端,通过BufferedReader逐行读取Socket输入流的数据:
2. 代码示例如下:
java
BufferedReader reader = new BufferedReader(new BufferedInputStream(socket.getInputStream()));
String s = reader.readLine();
这种方式可以确保客户端每次读取到的数据都是一个完整的数据帧,而不会出现多帧数据连在一起的情况。通过这种方式,可以更好地管理和处理Socket通信中不同帧数据的读取。
使用这种方法处理数据帧时,需要注意的是,每一帧数据必须以换行符结束,这样才能被正确地解析为一行。此外,客户端在读取每一行数据后,应该进行适当的解析和处理,以确保数据的完整性和正确性。
通过这种方式处理数据帧,可以有效地解决服务端发送数据速度过快,而客户端读取速度较慢的问题,从而提高数据通信的稳定性和可靠性。