JAVA實現(xiàn)TCP通信

sxw6wduc8b7bn5 2019-12-10

展開全文

TCP的Java支持
協(xié)議相當于相互通信的程序間達成的一種約定，它規(guī)定了分組報文的結構、交換方式、包含的意義以及怎樣對報文所包含的信息進行解析，TCP/IP協(xié)議族有IP協(xié)議、TCP協(xié)議和UDP協(xié)議?，F(xiàn)在TCP/IP協(xié)議族中的主要socket類型為流套接字（使用TCP協(xié)議）和數(shù)據(jù)報套接字（使用UDP協(xié)議）。
TCP協(xié)議提供面向連接的服務，通過它建立的是可靠地連接。Java為TCP協(xié)議提供了兩個類：Socket類和ServerSocket類。一個Socket實例代表了TCP連接的一個客戶端，而一個ServerSocket實例代表了TCP連接的一個服務器端，一般在TCP Socket編程中，客戶端有多個，而服務器端只有一個，客戶端TCP向服務器端TCP發(fā)送連接請求，服務器端的ServerSocket實例則監(jiān)聽來自客戶端的TCP連接請求，并為每個請求創(chuàng)建新的Socket實例，由于服務端在調用accept（）等待客戶端的連接請求時會阻塞，直到收到客戶端發(fā)送的連接請求才會繼續(xù)往下執(zhí)行代碼，因此要為每個Socket連接開啟一個線程。服務器端要同時處理ServerSocket實例和Socket實例，而客戶端只需要使用Socket實例。另外，每個Socket實例會關聯(lián)一個InputStream和OutputStream對象，我們通過將字節(jié)寫入套接字的OutputStream來發(fā)送數(shù)據(jù)，并通過從InputStream來接收數(shù)據(jù)。
TCP連接的建立步驟：
客戶端向服務器端發(fā)送連接請求后，就被動地等待服務器的響應。典型的TCP客戶端要經過下面三步操作：
1. 創(chuàng)建一個Socket實例：構造函數(shù)向指定的遠程主機和端口建立一個TCP連接；
2. 通過套接字的I/O流與服務端通信；
3. 使用Socket類的close方法關閉連接。
服務端的工作是建立一個通信終端，并被動地等待客戶端的連接。典型的TCP服務端執(zhí)行如下操作：
1. 創(chuàng)建ServerSocket對象，綁定并監(jiān)聽端口
2. 通過accept監(jiān)聽客戶端的請求
3. 建立連接后，通過輸出輸入流進行讀寫操作
4. 關閉相關資源

一個程序為服務端，建立TCP服務端套接字。
java源程序如下：

import java.io.DataInputStream;//導入DataInputStream類import java.io.DataOutputStream;//導入DataOutputStreamimport java.io.IOException;//導入IOException類import java.net.Socket;//導入Socket類import java.util.Scanner;//導入Scanner類/** * 注意用到的輸入輸出流DataInputStream和DataOutputStream，成對出現(xiàn)，最好用字節(jié)流 */// 客戶端類public class ChatClient {//創(chuàng)建公共類    private String host = 'localhost';// 默認連接到本機    private int port = 8189;// 默認連接到端口8189    public ChatClient() {    }    // 連接到指定的主機和端口    public ChatClient(String host, int port) {//構造方法        this.host = host;//將構造方法的參數(shù)host傳遞給類變量host        this.port = port;//將構造方法的參數(shù)port傳遞給類變量port    }    public void chat() {//chat方法        try {            // 連接到服務器            Socket socket = new Socket(host, port);//創(chuàng)建Socket類對象            try {                DataInputStream in = new DataInputStream(socket                        .getInputStream());// 讀取服務器端傳過來信息的DataInputStream                DataOutputStream out = new DataOutputStream(socket                        .getOutputStream());// 向服務器端發(fā)送信息的DataOutputStream                Scanner scanner = new Scanner(System.in);// 裝飾標準輸入流，用于從控制臺輸入                while (true) {                    String send = scanner.nextLine();//讀取控制臺輸入的內容                    System.out.println('客戶端：' + send);//輸出鍵盤輸出內容提示 ，也就是客戶端向服務器端發(fā)送的消息                    // 把從控制臺得到的信息傳送給服務器                    out.writeUTF('客戶端：' + send);//將客戶端的信息傳遞給服務器                                 String accpet = in.readUTF();// 讀取來自服務器的信息                    System.out.println(accpet);//輸出來自服務器的信息                }            } finally {                socket.close();//關閉Socket監(jiān)聽            }        } catch (IOException e) {//捕獲異常            e.printStackTrace();        }    }    public static void main(String[] args) {//主程序方法        new ChatClient().chat();//調用chat方法    }}

另外一個程序為客戶端，建立TCP客戶端套接字。
java源程序如下：

import java.io.DataInputStream; //導入 DataInputStream類import java.io.DataOutputStream;//導入DataOutputStream類 import java.io.IOException;//導入IOException類import java.net.ServerSocket;//導入ServerSocket類   import java.net.Socket; //導入Socket 類 import java.util.Scanner; //導入Scanner類/**  * 模擬qq聊天功能： 實現(xiàn)客戶端與服務器（一對一）的聊天功能，客戶端首先發(fā)起聊天，輸入的內容在服務器端和客戶端顯示，  * 然后服務器端也可以輸入信息，同樣信息也在客戶端和服務器端顯示  */  // 服務器類  public class ChatServer {//ChatServer類      private int port = 8189;// 默認服務器端口      public ChatServer() {    }      // 創(chuàng)建指定端口的服務器      public ChatServer(int port) {//構造方法          this.port = port;//將方法參數(shù)賦值給類參數(shù)      }      // 提供服務      public void service() {//創(chuàng)建service方法          try {// 建立服務器連接              ServerSocket server = new ServerSocket(port);//創(chuàng)建  ServerSocket類                         Socket socket = server.accept();// 等待客戶連接              try {                                  DataInputStream in = new DataInputStream(socket                          .getInputStream());// 讀取客戶端傳過來信息的DataInputStream                                   DataOutputStream out = new DataOutputStream(socket                          .getOutputStream());// 向客戶端發(fā)送信息的DataOutputStream                                     Scanner scanner = new Scanner(System.in);//從鍵盤接受數(shù)據(jù)                  while (true) {                                           String accpet = in.readUTF();// 讀取來自客戶端的信息                       System.out.println(accpet);//輸出來自客戶端的信息                      String send = scanner.nextLine();//nextLine方式接受字符串                      System.out.println('服務器：' + send);//輸出提示信息                                            out.writeUTF('服務器：' + send);//把服務器端的輸入發(fā)給客戶端                   }              } finally {// 建立連接失敗的話不會執(zhí)行socket.close();                socket.close();//關閉連接                 server.close();//關閉                            }          } catch (IOException e) {//捕獲異常            e.printStackTrace();          }      }      public static void main(String[] args) {//主程序方法          new ChatServer().service();//調用 service方法     }  }