多線程方式實現Socket通信

一.首先,介紹下兩類傳輸協議：TCP；UDP

TCP是Tranfer Control Protocol的 簡稱，是一種面向連接的保證可靠傳輸的協議。通過TCP協議傳輸，得到的是一個順序的無差錯的數據流。發送方和接收方的成對的兩個socket之間必須建 立連接，以便在TCP協議的基礎上進行通信，當一個socket（通常都是server socket）等待建立連接時，另一個socket可以要求進行連接，一旦這兩個socket連接起來，它們就可以進行雙向數據傳輸，雙方都可以進行發送 或接收操作。

UDP是User Datagram Protocol的簡稱，是一種無連接的協議，每個數據報都是一個獨立的信息，包括完整的源地址或目的地址，它在網絡上以任何可能的路徑傳往目的地，因此能否到達目的地，到達目的地的時間以及內容的正確性都是不能被保證的。

比較：

UDP：1，每個數據報中都給出了完整的地址信息，因此無需要建立發送方和接收方的連接。

            2，UDP傳輸數據時是有大小限制的，每個被傳輸的數據報必須限定在64KB之內。

           3，UDP是一個不可靠的協議，發送方所發送的數據報並不一定以相同的次序到達接收方

TCP：1，面向連接的協議，在socket之間進行數據傳輸之前必然要建立連接，所以在TCP中需要連接

                時間。

            2，TCP傳輸數據大小限制，一旦連接建立起來，雙方的socket就可以按統一的格式傳輸大的  

                    數據。

             3，TCP是一個可靠的協議，它確保接收方完全正確地獲取發送方所發送的全部數據。

應用：

1，TCP在網絡通信上有極強的生命力，例如遠程連接（Telnet）和文件傳輸（FTP）都需要不定長度的數據被可靠地傳輸。但是可靠的傳輸是要付出代價的，對數據內容正確性的檢驗必然占用計算機的處理時間和網絡的帶寬，因此TCP傳輸的效率不如UDP高。

2，UDP操作簡單，而且僅需要較少的監護，因此通常用於局域網高可靠性的分散系統中client/server應用程序。例如視頻會議系統，並不要求音頻視頻數據絕對的正確，只要保證連貫性就可以了，這種情況下顯然使用UDP會更合理一些。

二.基於Socket的java網絡編程

1.什么是Socket

網絡上的兩個程序通過一個雙向的通訊連接實現數據的交換，這個雙向鏈路的一端稱為一個Socket。Socket通常用來實現客戶方和服務方的連接。Socket是TCP/IP協議的一個十分流行的編程界面，一個Socket由一個IP地址和一個端口號唯一確定。

但是，Socket所支持的協議種類也不光TCP/IP一種，因此兩者之間是沒有必然聯系的。在Java環境下，Socket編程主要是指基於TCP/IP協議的網絡編程。

2.Socket通訊的過程

Server端Listen(監聽)某個端口是否有連接請求，Client端向Server 端發出Connect(連接)請求，Server端向Client端發回Accept（接受）消息。一個連接就建立起來了。Server端和Client 端都可以通過Send，Write等方法與對方通信。

對於一個功能齊全的Socket，都要包含以下基本結構，其工作過程包含以下四個基本的步驟：

　　（1） 創建Socket；

　　（2） 打開連接到Socket的輸入/出流；

　　（3） 按照一定的協議對Socket進行讀/寫操作；

　　（4） 關閉Socket.

3.創建Socket

java在包java.net中提供了兩個類Socket和ServerSocket，分別用來表示雙向連接的客戶端和服務端。這是兩個封裝得非常好的類，使用很方便。其構造方法如下：

　　Socket(InetAddress address, int port);

　　Socket(InetAddress address, int port, boolean stream);

　　Socket(String host, int prot);

　　Socket(String host, int prot, boolean stream);

　　Socket(SocketImpl impl)

　　Socket(String host, int port, InetAddress localAddr, int localPort)

　　Socket(InetAddress address, int port, InetAddress localAddr, int localPort)

　　ServerSocket(int port);

　　ServerSocket(int port, int backlog);

　　ServerSocket(int port, int backlog, InetAddress bindAddr)

　　其中address、host和port分別是雙向連接中另一方的IP地址、主機名和端 口號，stream指明socket是流socket還是數據報socket，localPort表示本地主機的端口號，localAddr和 bindAddr是本地機器的地址（ServerSocket的主機地址），impl是socket的父類，既可以用來創建serverSocket又可 以用來創建Socket。count則表示服務端所能支持的最大連接數。

　　Socket client = new Socket("127.0.01.", 80);

　　ServerSocket server = new ServerSocket(80);

　　注意，在選擇端口時，必須小心。每一個端口提供一種特定的服務，只有給出正確的端口，才 能獲得相應的服務。0~1023的端口號為系統所保留，例如http服務的端口號為80,telnet服務的端口號為21,ftp服務的端口號為23, 所以我們在選擇端口號時，最好選擇一個大於1023的數以防止發生沖突。

　　在創建socket時如果發生錯誤，將產生IOException，在程序中必須對之作出處理。所以在創建Socket或ServerSocket是必須捕獲或拋出例外。

三.服務端與客戶端代碼

1.首先實現服務類(代碼中有詳細的注釋,不再一一贅述)

package me.socketthread;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class MultiSocketServer {
public static void main(String[] args) {
    ServerSocket s = null;  
    Socket socket  = null;  
  
        try {
            s=new ServerSocket(4567);
             System.out.println("ServerSocket Start:"+s); 
            //等待請求,此方法會一直阻塞,直到獲得請求才往下走  
            socket=s.accept();
            System.out.println("得到客戶端地址:"+socket.getInetAddress());
            //調用線程類
            new ServerSocketThread(socket).start();
        }  catch (Exception e) {  
            try {  
                socket.close();  
            } catch (IOException e1) {  
                // TODO Auto-generated catch block  
                e1.printStackTrace();  
            }  
        }finally{  
            try {  
                s.close();  
            } catch (IOException e) {  
                // TODO Auto-generated catch block  
                e.printStackTrace();  
            }  
        }  
        
    
}
}

 

2.服務端響應請求的線程類

package me.socketthread;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class ServerSocketThread extends Thread{
    private Socket socket = null;  
    private BufferedReader br = null;  
    private PrintWriter pw = null;  
    //聲明構造函數,接收客戶端請求socket
    public ServerSocketThread(Socket s)
    {   
        this.socket=s;
    
    }
    @Override
    public void run() {
       //while(true){  
            try {
                //注意此處得到的socket的輸入流為socket的輸入流即上方的(private Socket socket = null; )
                 br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                 //向客戶端返回消息的PrintWriter對象
                  pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
                 String str = br.readLine();  
              /*  if(str.equals("END")){  
                    br.close();  
                    pw.close();  
                    socket.close();  
                    break;  
                }  */
                System.out.println("Client Socket Message:"+str);  
                pw.println("Message Received");  
                pw.flush();  
            } catch (Exception e) {  
                try {  
                    br.close();  
                    pw.close();  
                    socket.close();  
                } catch (IOException e1) {  
                    // TODO Auto-generated catch block  
                    e1.printStackTrace();  
                }  
            }  
      // } 
        
    }

}

3.客戶端請求socket類

package me.socketthread;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class MultiClientSocket {
    public static void main(String[] args) {
        Socket socket = null;  
         BufferedReader br = null;  
         PrintWriter pw = null;  
      try {
            socket=new Socket("127.0.0.1",4567);
            System.out.println("Socket=" + socket); 
            //用於發送給server端的信息
               pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true); 
              //用於接收Server端發來的信息 
               br = new BufferedReader(new InputStreamReader(socket.getInputStream())); 
             // for (int i = 0; i < 10; i++) {
               //注意首先向服務端發送消息,再接收服務端返回的休息,不要寫反了
                    pw.println("howdy ");  
                    pw.flush(); //flush()一般用於處理中時需要將數據立即寫出。將緩沖區的內容輸出
                    String str = br.readLine();  
                    System.out.println("拿到server返回的消息:"+str);  
              // }  
              //  pw.println("END");  
              // pw.flush();  
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
      finally {  
          try {  
              System.out.println("close......");  
              br.close();  
              pw.close();  
              socket.close();  
          } catch (IOException e) {  
              // TODO Auto-generated catch block  
              e.printStackTrace();  
          }  
      }  
              
    }
}

四.測試

1,首先啟動服務端MultiSocketServer ,等待請求

2.啟動客戶端MultiClientSocket ,向服務端發送請求,已經拿到服務端返回的信息

3.再看看服務端的響應結果

ok,成功了

參考博文:http://blog.csdn.net/gxy3509394/article/details/7902343,感謝這位博主