《ServerSocket连接断开处理方式.docx》由会员分享，可在线阅读，更多相关《ServerSocket连接断开处理方式.docx（7页珍藏版）》请在金锄头文库上搜索。
1、ServerSocket连接断开处理方式ServerSocket连接断开处理方式1、概述：2、异常信息： 2.1、之前有人给出的方案：3、代码分析4、场景分析 4.1.建立Socket连接,底层就是TCP连接： 4.2.发送数据 4.3.断开连接5、总结：1、概述：WebSocket是一种在单个TCP连接上进行全双工通信的协议。在我们应用的过程仲，客户端会出现无故断开的情况。这里提供一种连接断开的异常检测机制。2、异常信息：系统中出现的异常2019-03-12 18:56:24,044 ERROR com.lenovo.SocketServer.ping(172) -2019-03-12 18
2、:56:24,045 ERROR com.lenovo.SocketServer.ping(173) - 2.1、之前有人给出的方案：总结产生原因,在服务端/客户端单方面关闭连接的情况下,另一方依然以为tcp连接仍然建立,试图读取对方的响应数据,导致出现Software caused connection abort: recv failed的异常。 通过inputstream的available()方法来判断,是否有响应结果。但是对SocketInputStream没有效果，因为SocketInputStream 在断开连接和数据正常传输状态的下 available 返回值都是0。3、代码分
3、析其中InputStream 类型为 SocketInputStream,但是SocketInputStream 在 jdk 的rt.jar 中，是JDK的核心专用类型，不是public类型，只能通过反射获取其中的参数。 有一行代码：boolean eof = (Boolean) getValueByKey(inputStream, “eof”);获取eof 字段的值就是通过Java 的反射机制做的。下面会重点说这个字段。开启WebSocket服务端： private static void generateTCPServer() throws IOException ServerSocket
4、 serverSocket = new ServerSocket(12345); while (true) Socket socket = serverSocket.accept(); Thread thread = new Thread() Override public void run() System.out.println(开启新的线程); while (true) try if (socket = null) System.out.println(socket为null); Thread.interrupted(); else boolean flag = handler(sock
5、et); if(!flag) System.out.println(Client Down); Thread.interrupted(); break; Thread.sleep(50); catch (Exception e) logger.error(System error); logger.error(e.getMessage(); e.printStackTrace(); ; thread.start(); 连接数据处理逻辑： public static boolean handler(Socket socket) try OutputStream outputStream = so
6、cket.getOutputStream(); InputStream inputStream = socket.getInputStream(); / 接受客户端的响应 byte b = new byte51200; inputStream.read(b); / 第一种方式：通过获取eof 参数获取当前连接是否断开的参数 boolean eof = (Boolean) getValueByKey(inputStream, eof); if (true = eof) / 已经断开 logger.error(); return false; / 第二种方式：获取传输的内容 String msg
7、= CommonUtil.toHexString(b); String head = msg.substring(0, 2); / client断开 if (head.equals(00) logger.error(); return false; catch (IOException e) logger.error(IOException by TCP); logger.error(e); return true; 4、场景分析4.1.建立Socket连接,底层就是TCP连接：连接过程代码走到 inputStream.read(b);就I/O中断了 并等待请求数据过来，继续执行下面的代码。n
8、ew byte51200 为下一次请求建立了一缓存区，用于接收下一次请求的数据。这里Thread的状态仍然是RUNNABLE。发起连接请求：响应 为空流程处理过程中部分核心参数： OutputStream append：false channel:null closed:false closing:false socket: bound:true created:true connected:true closed:false InputStream channel:null closed:false closing:false eof:false = 不一样的地方 socket: bound
9、:true created:true connected:true closed:false4.2.发送数据代码从连接检测的代码处继续执行，一直到返回响应结束。/ 第一种方式：通过获取eof 参数获取当前连接是否断开的参数boolean eof = (Boolean) getValueByKey(inputStream, “eof”);流程处理过程中部分核心参数：如果连接没有断开，就是上一次请求结束后的参数。 OutputStream append：false channel:null closed:false closing:false socket: bound:true created:true connected:true closed:false InputStream channel:null closed:false closing:false eof:false = 不一样的地方 socket: bound:true created:true connected:true closed:false4.3.断开连接代码从连接检
