Java中的TCP通訊程式

阿新 • • 發佈：2020-07-21

Java中的TCP通訊程式

TCP可以實現兩臺計算機之間的資料互動通訊的兩端，要嚴格區分客戶端與服務端
兩端通訊時的步驟：
1.服務端程式，需要事先啟動，等待客戶端連線
2.客戶端主動連線伺服器端，才能成功通訊，伺服器端不可以主動連結客戶端

在java中兩個類用於實現TCP通訊程式：

客戶端： java.net.Socket 類表示。建立 Socket 物件，向服務端發出連線請求，服務端響應請求，兩者建立連線開始通訊。
服務端： java.net.ServerSocket 類表示。建立 ServerSocket 物件，相當於開啟一個服務，並等待客戶端的連線。

Socket類

socket類

：該類實現客戶端套接字，套接字是指兩臺裝置之間的端點

構造方法：
public Socket（String host，int port）：建立套接字物件並將其連線到指定物件的主機上，如果指定的host為NULL，則相當於指定的地址為回送地址
回送地址
回送地址(127.x.x.x) 是本機回送地址（Loopback Address），主要用於網路軟體測試以及本地機程序間通訊，無論什麼程式，一旦使用回送地址傳送資料，立即返回，不進行任何網路傳輸。
構造舉例

Socket client=new Socket（“127.0.0.1”，666）

成員方法：
public InputStream getInputStream() ：返回此套接字的輸入流。如果此Scoket具有相關聯的通道，則生成的InputStream 的所有操作也關聯該通道。關閉生成的InputStream也將關閉相關的Socket。

public OutputStream getOutputStream() ：返回此套接字的輸出流。如果此Scoket具有相關聯的通道，則生成的OutputStream 的所有操作也關聯該通道。關閉生成的OutputStream也將關閉相關的Socket

public void close() ：關閉此套接字。一旦一個socket被關閉，它不可再使用。關閉此socket也將關閉相關的InputStream和OutputStream 。
public void shutdownOutput() ：禁用此套接字的輸出流。任何先前寫出的資料將被髮送，隨後終止輸出流。

ServerSocket類

public ServerSocket(int port) ：使用該構造方法在建立ServerSocket物件時，就可以將其繫結到一個指定的埠號上，引數port就是埠號
構造舉例程式碼如下：

ServerSocket server=new ServerSocket（666）

成員方法 public Socket accept() ：偵聽並接受連線，返回一個新的Socket物件，用於和客戶端實現通訊。
兩個需要明確的事情
1多個伺服器端與客戶進行互動，伺服器必須明確是和哪個客戶端進行互動，這個accept（）方法用與獲取請求的客戶端物件
2.多個客戶端同時與伺服器進行互動就需要使用多個io流物件
伺服器是沒有io流的，伺服器可以獲取到請求的客戶端物件的scoket，使用每一個客戶端Socket中提供的io流物件進行互動。
伺服器端使用客戶端的位元組輸入流讀取客戶端傳送的資料，
伺服器端使用客戶端的位元組輸出流給客戶端回寫資料
即伺服器端使用客戶端流與客戶端互動
好比生活中的我請客你買單

簡單的TCP網路程式圖解

【服務端】啟動,建立ServerSocket物件，等待連線。 Socket client = new Socket("127.0.0.1", 6666); ServerSocket server = new ServerSocket(6666);
【客戶端】啟動,建立Socket物件，請求連線。
【服務端】接收連線,呼叫accept方法，並返回一個Socket物件
【客戶端】Socket物件，獲取OutputStream，向服務端寫出資料
【服務端】Scoket物件，獲取InputStream，讀取客戶端傳送的資料。
【服務端】Socket物件，獲取OutputStream，向客戶端回寫資料。
【客戶端】Scoket物件，獲取InputStream，解析回寫資料
【客戶端】釋放資源，斷開連線。

該方法會一直阻塞直到建立連線。

下面寫一段簡單的客戶端與伺服器端互動的程式碼
伺服器端程式碼

package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
    public static void main(String[] args) throws IOException {
        System.out.println("伺服器啟動等待連線：");
        //建立伺服器端物件
        ServerSocket serverSocket = new ServerSocket(8888);
        //使用accept方法接受socket物件
        Socket accept = serverSocket.accept();
        //通過socket獲取輸入流
        InputStream inputStream = accept.getInputStream();
        //會不會阻塞
        System.out.println("XXXXXXXXXXXXXXXXX");
        byte[] bytes = new byte[1024];
        int read = inputStream.read(bytes);
        //通過位元組陣列生成字串
        String s = new String(bytes,0,read);
        //輸出
        System.out.println(s);
        //向客戶端返回資訊
        OutputStream outputStream = accept.getOutputStream();
        //返回內容
        outputStream.write("內容已經收到".getBytes());
        //關閉資源
        inputStream.close();
        serverSocket.close();
    }
}

客戶端程式碼

package Socket;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
public class Client {
    public static void main(String[] args) throws IOException {
        //建立Socket物件
        Socket socket = new Socket("127.0.0.1", 8888);
        //獲取輸出流
        OutputStream outputStream = socket.getOutputStream();
        //給服務端傳送訊息
        outputStream.write("你好".getBytes());
        //建立輸入流物件
        InputStream inputStream = socket.getInputStream();
        //建立讀取的陣列
        byte[] bytes = new byte[1024];
        //獲取位元組陣列的長度
        int read = inputStream.read(bytes);
        //輸出結果
        System.out.println(new String(bytes,0,read));
        //關閉流
        outputStream.close();
        //關閉Socket物件
        socket.close();
    }
}

結果
伺服器端

客戶端

以上就是Java中的TCP通訊程式的一些基本操作，喜歡我的可以點贊收藏一波，我會不定期跟新文章，喜歡我的可以關注呀

Java中的TCP通訊程式