java里tcp中socket的io流到底要不要关闭，请说下原因。

Posted 2023-04-02

我原来都是不关闭的（我的理解是这io流是通过socket获取到的，关闭socket那么io流就自然没了）但是有人告诉我还是要关闭。

最好关闭。
虽然java会在你关闭socket时关的。
不要等到垃圾回收，因为回收时机不确定。
这样玩玩可以，但是不能做工作也这样。 参考技术A 如果你要保持tcp一直连接的话就不要关，不然数据直接就接收不到了。如果你每次请求都建立tcp的连接的话，就可以关。 参考技术B 最好还是使用完了就手动关闭它，虽然有垃圾回收机制，但可能会有内存泄漏来自：求助得到的回答 参考技术B 最好关闭，以防内存泄漏。 参考技术C 最好使用完，自己关闭。 socket 未必能正确关闭的

Java Socket编程之TCP

基于TCP的Socket通信：

服务器端：

1. 创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
2. 调用accept()方法开始监听，等待客户端的连接
3. 连接建立后，通过输入流读取客户发送的请求信息
4. 通过输出流向客户端发送响应信息
5. 关闭相关资源

客户端：

1. 创建客户端Socket，指定服务器地址和端口
2. 连接建立后，通过输出流，向服务器端发送信息
3. 获取输入流，并读取服务器端的响应信息
4. 关闭资源

例：服务器端：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
    public static void main(String[] args) {
        try {
            //1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
            ServerSocket serverSocket=new ServerSocket(8888);
            Socket socket=null;
            //记录客户端的数量
            int count=0;
            System.out.println("***服务器即将启动，等待客户端的连接***");
            //循环监听等待客户端的连接
            while(true){
                //调用accept()方法开始监听，等待客户端的连接
                socket=serverSocket.accept();
                //创建一个新的线程
                ServerThread serverThread=new ServerThread(socket);
                //启动线程
                serverThread.start();
                count++;//统计客户端的数量
                System.out.println("客户端的数量："+count);
                InetAddress address=socket.getInetAddress();
                System.out.println("当前客户端的IP："+address.getHostAddress());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

   客户端：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class Client {
    public static void main(String[] args) {
        try {
            //1.创建客户端Socket，指定服务器地址和端口
            Socket socket=new Socket("localhost", 8888);
            //2.获取输出流，向服务器端发送信息
            OutputStream os=socket.getOutputStream();//字节输出流
            PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
            pw.write("用户名：alice;密码：789");
            pw.flush();
            socket.shutdownOutput();//关闭输出流
            //3.获取输入流，并读取服务器端的响应信息
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            String info=null;
            while((info=br.readLine())!=null){
                System.out.println("我是客户端，服务器说："+info);
            }
            //4.关闭资源
            br.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服务器线程处理类：

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerThread extends Thread {
    // 和本线程相关的Socket
    Socket socket = null;
        public ServerThread(Socket socket) {
        this.socket = socket;
    }
    //线程执行的操作，响应客户端的请求
    public void run(){
        InputStream is=null;
        InputStreamReader isr=null;
        BufferedReader br=null;
        OutputStream os=null;
        PrintWriter pw=null;
        try {
            //获取输入流，并读取客户端信息
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);
            String info=null;
            while((info=br.readLine())!=null){//循环读取客户端的信息
                System.out.println("我是服务器，客户端说："+info);
            }
            socket.shutdownInput();//关闭输入流
            //获取输出流，响应客户端的请求
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("欢迎您！");
            pw.flush();//调用flush()方法将缓冲输出
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            //关闭资源
            try {
                if(pw!=null)
                    pw.close();
                if(os!=null)
                    os.close();
                if(br!=null)
                    br.close();
                if(isr!=null)
                    isr.close();
                if(is!=null)
                    is.close();
                if(socket!=null)
                    socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

使用TCP通信传输对象:

       ObjectOutputStream oos=new ObjectOutputStream（os）；

       User user=new User(“admin”,”123”);//封装为对象

       oos.writeObject(user);//序列化

Tips:

 　　优先级问题：serverthread.setPriority();//降低优先级，以防运行速度较慢

        输入输出流问题：同一个Socket，关闭输出流则会关闭与之关联的Socket，所以不用关闭输出流，最后关闭Socket即可。