java编程网络编程,多线程，小型聊天系统

不念不忘少年蓝@ 2022-06-03 10:05 257阅读 0赞

package SocketTest;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.net.ServerSocket;
    import java.net.Socket;
    import java.util.Date;
    //java编程网络编程,多线程，小型聊天系统
    public class Server6 {
        public static void main(String[] args) {
                new Thread(){
                    ServerSocket serverSocket = null;//服务器套接字定义初始化
                    Socket client = null;//客服端套接字初始化
                    OutputStream os = null;//此抽象类是表示输出字节流的所有类的超类。
                    InputStream is= null;//此抽象类是表示字节输入流的所有类的超类。
                    //从字符输入流中读取文本，缓冲各个字符，从而实现字符、数组和行的高效读取。 
                    BufferedReader br = null;
                    //将文本写入字符输出流，缓冲各个字符，从而提供单个字符、数组和字符串的高效写入。 
                    BufferedWriter bw= null;
                    BufferedReader br1 = null;
    
                    @Override
                    public void run() {
                        // TODO Auto-generated method stub
                    try{
    // new Date()该对象会返回当前的时间
                        System.out.println("服务器启动："+new Date());
    // 初始化服务器
                        serverSocket = new ServerSocket(8888);
                        client =serverSocket.accept();//accept()监听客户端的连接，没有连接则处于阻塞状态
                        os =client.getOutputStream();//打开通往客户端的输出流，可以用来给客户端发数据
                        is = client.getInputStream();//打开客户端通往服务器端的输入流，用来接收来自客户端的数据
                        br1=new BufferedReader(new InputStreamReader(System.in));
                        br =new BufferedReader(new InputStreamReader(is));
                        bw = new BufferedWriter(new OutputStreamWriter(os));
    
                        while(true){
            // 1.读客户端发来的数据
                            System.out.println("客户端说："+br.readLine());
            // 2.读取服务器端通过键盘输入的内容
                            String line =br1.readLine();
            // 3.将服务器端输入的内容发送给客户端
                            bw.write(line);
                            bw.newLine();
                            bw.flush();
                            if("quit".equals(line)){
                                break;
                            }
                        }
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }finally{
                        try {
                            serverSocket.close();
                            client.close();
                            os.close();
                            is.close();
                            br.close();
                            bw.close();
                            br1.close();
                        } catch (IOException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                    }
                }.start();
            }
    }
    /* 服务器启动：Tue Dec 26 00:34:41 CST 2017 客户端说：服务器你好 你也好 客户端说：我收到了 好的 客户端说：quit quit */

package SocketTest;
    
    import java.io.BufferedReader;
    import java.io.BufferedWriter;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.InputStreamReader;
    import java.io.OutputStream;
    import java.io.OutputStreamWriter;
    import java.net.Socket;
    import java.net.UnknownHostException;
    
    public class Client6 {
        public static void main(String[] args) {
            // TODO Auto-generated method stub
            Socket client=null;
            OutputStream os = null;
            InputStream is= null;
            BufferedReader br = null;
            BufferedWriter bw= null;
            BufferedReader brServer=null;
    
            try {
    // 连接服务器，通过ip和端口号
                client = new Socket("127.0.0.1",8888);
                os =client.getOutputStream();//打开通往客户端的输出流，可以用来给客户端发数据
                is = client.getInputStream();//打开客户端通往服务器端的输入流，用来接收来自客户端的数据
    // 从键盘读取一行字符串
                br =new BufferedReader(new InputStreamReader(System.in));
    // 将字符串发送到Server1服务器端
                bw =new BufferedWriter(new OutputStreamWriter(os));
                brServer = new BufferedReader(new InputStreamReader(is));
                System.out.println("-----------开始聊天-------------");
                while(true){
    // 1.读取客户端通过键盘输入的内容
                    String line =br.readLine();
    // 2.将客户端输入的内容发送给服务器
                    bw.write(line);
                    bw.newLine();
                    bw.flush();
                    if("quit".equals(line)){
                        break;
                    }
    // 3.读server服务器发来的数据
                    System.out.println("服务器说："+brServer.readLine());
                    }   
            } catch (UnknownHostException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }finally{
                try {
                    client.close();
                    os.close();
                    is.close();
                    br.close();
                    bw.close();
                    brServer.close();
                } catch (IOException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }
    /* -----------开始聊天------------- 服务器你好 服务器说：你也好 我收到了 服务器说：好的 quit */