Java基于Tcp的基础聊天功能实例

import java.io.*;
import java.net.*;
public class ChatServer {
    public static void main(String[] args) {
        ServerSocket server = null;
        try {
            server = new ServerSocket(12138);
        } catch (IOException e) {
            System.out.println("error" + e);
        }
//        server = null;
        try {
            Socket ac = null;
//            ac = new Socket();
//            ac = null;
            ac = server.accept();
            BufferedReader is = null;
            is = new BufferedReader(new InputStreamReader(ac.getInputStream()));
            BufferedReader dis = new BufferedReader(new InputStreamReader(System.in));
            PrintWriter os = new PrintWriter(ac.getOutputStream());
            String line = null;
            System.out.println("clinent " + is.readLine());
            line = dis.readLine();
            while(!line.equals("bey")) {
                os.println(line);
                os.flush();
                System.out.println("server " + line);
                System.out.println("client " + is.readLine());
                line = dis.readLine();
            }
            os.close();
            dis.close();
            is.close();
            ac.close();
        } catch (Exception e) {
            System.out.println("error" + e);
        }
    }
}

public class ChatClient {
    public static void main(String[] args) {
        Socket client = null;
        try {
            client = new Socket("127.0.0.1",12138);
            BufferedReader dis = new BufferedReader(new InputStreamReader(System.in));
            BufferedReader is = new BufferedReader(new InputStreamReader(client.getInputStream()));
            PrintWriter os = new PrintWriter(client.getOutputStream());
            String line = dis.readLine();
            while(!line.equals("bey")) {
                os.println(line);
                os.flush();
                System.out.println("client " + line);
                System.out.println("server " + is.readLine());
                line = is.readLine();
            }
            os.close();
            dis.close();
            is.close();
            client.close();
        } catch (Exception e) {
            System.out.println("error" + e);
        }
    }
}