java代碼實現socket接口通訊（堵塞I/O）

   傳統的java實現socket通訊比較簡單實現，不過它屬於堵塞式的I/O流存取，只能由一個線程完成當前任務才能起下個一個線程，無法解決高並發；

  1、簡單的socketservice

對每一個Socket連接建立一個Handler處理線程，處理線程對inputstream流中的數據進行相應的處理后，將處理結果通過PrintWriter發送給客戶端，在最后需要關閉輸入流、輸出流和socket套接字句柄資源。

public class TimeServer {

    public static void main(String[] args) throws IOException {

       int port = 8080;//server 端口采用8080
       ServerSocket server = null;
       Socket socket = null;
       try {
           server = new ServerSocket(port);
           while(true){
               socket = server.accept();
               new Thread(new TimeHandler(socket)).start();
           }
       } catch (Exception e) {
          e.printStackTrace();
       }finally{
           if(server!=null){
               server.close();
               server =null;
               System.out.println("the time server close...");
           }
       }
    }

}

class TimeHandler implements Runnable{

    private Socket socket;

    public TimeHandler(){

    }
    public TimeHandler(Socket socket){
        this();
        this.socket = socket;
    }

    public void run() {
        System.out.println(Thread.currentThread().getName()+" start success...");
        BufferedReader in = null;
        PrintWriter out = null;
        try {
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(),true);
            while(true){
                String str = in.readLine();
                if("end".equals(str)){
                    break;
                }
                String time = str+":"+System.currentTimeMillis();
                out.println(time);
            }
        } catch (Exception e) {
             e.printStackTrace();
        }finally{
            if(in!=null){
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                in = null;
            }
            if(out!=null){
                out.close();
                out= null;
            }
            if(socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                socket =null;
            }
        }

    }
}

2、socketclient

public class TimeClient {

    public static void main(String[] args) {
        int port = 8080;
        Socket socket = null;
        BufferedReader in =null;
        PrintWriter out =null;

        try {
            socket = new Socket("127.0.0.1", port);
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(),true);
            out.println("hello");
            out.println("world");
            out.println("end");

            System.out.println("send message success...");
            while(true){
                String res = in.readLine();
                if("".equals(res)||res==null){
                    break;
                }
                System.out.println("the res is:"+res);
            }


        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            if(in!=null){
                try {
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                in = null;
            }
            if(out!=null){
                out.close();
                out= null;
            }
            if(socket!=null){
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                socket =null;
            }
        }

    }

}