回顾Socket编程

刺骨的言语ヽ痛彻心扉 2024-04-18 08:01 19阅读 0赞

编写一个客户端与服务端对话的程序：

客户端：

package com.irootech.controller;
    
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.PrintStream;
    import java.net.Socket;
    public class ClientServer {
       public static void main(String arg[]){
             BufferedReader bufferedReader=null;
             BufferedReader bu=null;
           PrintStream printStream=null;
           try {
               Socket socket=new Socket("127.0.0.1",2019);
                bufferedReader=new BufferedReader(new InputStreamReader(socket.getInputStream()));
                bu=new BufferedReader(new InputStreamReader(System.in));
                printStream=new PrintStream(socket.getOutputStream());
               boolean flag=true;
               while(flag){
                   System.out.println("客户端输入消息:");
                   String str=bu.readLine();
                   if(!str.equals("no")){
                       printStream.println(str);
                   }else{
                       System.out.println("客户端终止连接");
                       flag=false;
                   }
                   System.out.println("服务端回复内容:"+bufferedReader.readLine());
               }
           } catch (IOException e) {
               e.printStackTrace();
           }finally{
               if(bufferedReader!=null){
                   try {
                       bufferedReader.close();
                   } catch (IOException e) {
                       e.printStackTrace();
                   }
               }
               if(bu!=null){
                   try {
                       bu.close();
                   } catch (IOException e) {
                       e.printStackTrace();
                   }
               }
               if(printStream!=null){
                   printStream.close();
               }
           }
       }
    }

服务端：

package com.irootech.controller;
    
    
    import java.io.*;
    import java.net.ServerSocket;
    import java.net.Socket;
    
    public class Server implements  Runnable{
        private Socket client;
        private  BufferedReader bufferedInputStream=null;
        private PrintStream printStream=null;
        private BufferedReader bufferedReader=null;
    
           public Server(Socket socket){
               this.client=socket;
           }
        boolean flag=true;
        public  void run(){
            while(flag){
                try {
                     bufferedInputStream=new BufferedReader(new InputStreamReader( client.getInputStream()));
                     printStream=new PrintStream(client.getOutputStream());
                     String str= bufferedInputStream.readLine();
                     System.out.println("客户端发送消息内容为:"+str);
                     bufferedReader=new BufferedReader(new InputStreamReader(System.in));
                   if(!str.equals("no")){
                       System.out.println("服务端输入消息:");
                       String string=bufferedReader.readLine();
                       printStream.println(string);
                   }else{
                     printStream.println("see you again");
                     flag=false;
                   }
                } catch (IOException e) {
                    e.printStackTrace();
                }finally{
                    if(bufferedInputStream!=null){
                        try {
                            bufferedInputStream.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                    if(printStream!=null){
                        printStream.close();
                    }
                    if(bufferedReader!=null){
                        try {
                            bufferedReader.close();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                }
            }
        }
    
        public static void main(String args[]){
            try {
                ServerSocket serverSocket=new ServerSocket(2019);
                System.out.println("服务启动");
                while(true){
                   Socket client=serverSocket.accept();
                   new Thread(new Server(client)).start();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }