在使用socket进行通信连接时出现java.net.SocketException: Connection reset的解决方案

以你之姓@ 2023-10-14 10:48 82阅读 0赞

## 产生原因 ##

1.  在创建客户端和服务端后，出现java.net.SocketException: Connection reset的错误。
    
     *  导致的原因
        
        1.  客户端或者服务端其中一端还在传输数据的途中，另外一端的socket被关闭（或者主动0关闭，或者运行异常退出导致的关闭），这时，客户端的第一个数据包传输过来后就会引发该异常。
        2.  一端在退出时，未断开连接，另外一端仍旧在连接中读取数据，就会抛出该异常，简单来说就是连接断开后其中一端仍旧在进行读写操作导致的。
     *  看错误代码：未及时关闭客户端连接，导致服务端仍旧在连接中读取数据。
        
        1.  客户端代码：

package com.net.TCP;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    
    //模拟客户端
    public class TcpClient {
        
        public static void main(String[] args) {
        
            OutputStream os=null;
            Socket socket =null;
            //1.获取服务端的IP地址+端口号
            try {
        
                //获取IP地址
                InetAddress getByName = InetAddress.getByName("127.0.0.1");
                //获取端口号
                int port=8080;
                //创建一个Socket连接
                socket = new Socket(getByName, port);
                System.out.println("12");
                //向连接发送数据，使用IO流
                os= socket.getOutputStream();
                os.write("你还号码".getBytes());
                Thread.sleep(3000); // 1000毫秒，即1秒钟
            } catch (Exception e) {
        
                e.printStackTrace();
            }
           //未对连接进行关闭
            }
        }
    }

2. 服务端代码：

只需要对两端的连接和数据流及时关闭就可以解决该问题

*  更改后客户端：

package com.net.TCP;
    
    import java.io.IOException;
    import java.io.OutputStream;
    import java.net.InetAddress;
    import java.net.Socket;
    
    //模拟客户端
    public class TcpClient {
        
        public static void main(String[] args) {
        
            OutputStream os=null;
            Socket socket =null;
            //1.获取服务端的IP地址+端口号
            try {
        
                //获取IP地址
                InetAddress getByName = InetAddress.getByName("127.0.0.1");
                //获取端口号
                int port=8080;
                //创建一个Socket连接
                socket = new Socket(getByName, port);
                System.out.println("12");
                //向连接发送数据，使用IO流
                os= socket.getOutputStream();
                os.write("你还号码".getBytes());
                Thread.sleep(3000); // 1000毫秒，即1秒钟
            } catch (Exception e) {
        
                e.printStackTrace();
            }
            finally {
        
                try {
        
                    os.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
                try {
        
                    socket.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
            }
        }
    }

*  更改后服务端：

package com.net.TCP;
    
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    //模拟TCP协议发送消息：三次握手
    //模拟服务端接受数据
    public class TcpService {
        
        public static void main(String[] args) {
        
            ByteArrayOutputStream bos =null;
            InputStream is =null;
            Socket accept =null;
            try {
        
                //1.客户端需要拥有一个端口号
                ServerSocket serverSocket = new ServerSocket(8080);
                //等待客户连接
                 accept = serverSocket.accept();
                //读取客户信息
                 is = accept.getInputStream();
                //使用管道流输出数据
                    //创建管道流对象
                bos = new ByteArrayOutputStream();
                //创建管道流缓冲区
                byte[] b=new  byte[1024];
                int len;
                while ((len= is.read(b))!=-1){
        
                    System.out.println("23");
                    //通过管道流输出数据
                    bos.write(b,0,len);
                }
                System.out.println(bos.toString());
            } catch (IOException e) {
        
                e.printStackTrace();
            }
            finally {
        
                try {
        
                    bos.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
                try {
        
                    is.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
                try {
        
                    accept.close();
                } catch (IOException e) {
        
                    e.printStackTrace();
                }
            }
        }
    }