java網絡編程之TCP通訊

java中的網絡編程之TCP協議的詳細介紹，以及如何使用，同時我在下面舉2例說明如何搭配IO流進行操作，

/*
 *TCP
 *建立連接，形成傳輸數據的通道；
 *在連接中進行大數據量傳輸；
 *通過三次握手完成連接，是可靠協議；
 *必須建立連接，效率會稍低 
 */

/*
 * TCP傳輸
 * Socket和ServerSocket建立客戶端和服務器端建立連接后，
 * 通過Socket中的IO流進行數據的傳輸關閉socket同樣，
 * 客戶端與服務器端是兩個獨立的應用程序。
 */

//-------------------------------
//下面的是TCP協議的服務器端代碼

import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/*
 * TCP協議接收數據
 *     1.創建接收端的socket對象
 *     2.監聽客戶端，返回一個對應的socket對象
 *     3.獲取輸入流，讀取數據，顯示在控制台
 *     4.釋放資源
 */
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        // 創建接收端socket對象
        ServerSocket ss = new ServerSocket(10086);

        // 監聽客戶端，返回一個對應的socket對象
        // public Socket accept() 偵聽並接受到此套接字的連接。
        Socket s = ss.accept(); // 阻塞式方法，直到通道建立

        // 獲取輸入流，讀取數據
        InputStream is = s.getInputStream();
        byte[] bys = new byte[1024];
        int len = is.read(bys); // 阻塞式方法，直到數據發過來。
        String ip = s.getInetAddress().getHostAddress();
        
        String str = new String(bys, 0, len);
        System.out.println(str);

        // 釋放資源
        s.close();
        ss.close(); // 這個不應該關閉
    }
}

//-------------------------------
//下面是客戶端TCP協議的代碼
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

/*
 *TCP協議發送數據：
 *    1.創建發送端socket對象
 *        這一步如果成功，就說明鏈接已經成功了。
 *    2.獲取輸出流，寫數據
 *    3.釋放資源 
 *
 *TCP一些服務器必須先開啟，保證通道簡歷，否則直接報錯。
 *java.net.ConnectException: Connection refused: connect
 */
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        // 創建發送端socket對象
        // Socket(String host, int port) 創建一個流套接字並將其連接到指定主機上的指定端口號。
        Socket socket = new Socket("lpp-PC", 10086); 
//“lpp-PC”里面的字符串一般使用服務器端的IP地址代替。

        // 獲取輸出流，寫數據
        OutputStream os = socket.getOutputStream();
        os.write("TCP coming~~~".getBytes());

        // 關閉資源
        os.close();
    }
}

//==================================
//---------------------------------------------------------------
//下面給出一個案例：客戶端從指定文本文件讀取數據，發送到服務器端，
//服務器將接收到的數據，再次寫入到一個新的文本文件。數據的寫/出是字節
//流

//首先給出的是客戶端的代碼：
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;

/*
 * 客戶端從文本文件中讀取數據，服務器得到數據寫入到文本文件，
 * 為了在服務器寫完數據后，給客戶端一個反饋，但是直接在通道內額外的添加數據是不行，會導致雙方一直保持等待狀態
 *     方案  
 *       1：  在客戶端里面額外增加一條語句告訴服務器結束的標志。
 *       2: 直接使用JDK給出的方法：shutdownOutput();socket提供了一個中止功能，它會通知服務器別等了，我沒有數據過來了。
 */

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        // 客戶端socket對象
        Socket s = new Socket("lpp-PC", 12345);

        // 封裝數據源
        BufferedReader br = new BufferedReader(new FileReader("a.txt"));

        // 封裝通道內流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));

        // 寫入數據
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        // // 為了告訴服務器寫到這里就可以停止了，額外增加一個標記，自定義一個結束標記
        // bw.write("over");
        // bw.newLine();
        // bw.flush();
        
        //socket提供了一個中止功能，它會通知服務器別等了，我沒有數據過來了。
        s.shutdownOutput();
        
        // 接受服務器的反饋
        BufferedReader brClient = new BufferedReader(new InputStreamReader(
                s.getInputStream()));
        String str = brClient.readLine();
        System.out.println(str);

        // 釋放資源
        br.close();
        s.close();
    }
}


//------------------------------------------
//下面是服務器端的代碼


import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        // 服務端socke對象
        ServerSocket ss = new ServerSocket(12345);

        // 監聽客戶端，獲取socke對象
        Socket s = ss.accept();

        // 封裝目標文件
        BufferedWriter bw = new BufferedWriter(new FileWriter("b.txt"));

        // 封裝通道中的輸入流
        BufferedReader br = new BufferedReader(new InputStreamReader(
                s.getInputStream()));

        // 讀取數據,並將數據寫入文件
        String line = null;
        while ((line = br.readLine()) != null) {
            // if ("over".equals(line)) {
            // break;
            // }
            bw.write(line);
            bw.newLine();
            bw.flush();
        }

        // 在文件寫出完畢后，給客戶端一個反饋，
        BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(
                s.getOutputStream()));
        bwServer.write("數據寫入完畢");
        bwServer.newLine();
        bwServer.flush();

        // 釋放資源
        bw.close();
        s.close();

    }
}

 //======================================

//下面的這個例子是客戶端讀取的是圖片文件/視頻文件。而服務器會對象通過TCP協議讀取到的數據寫到對應格式的文中去。

//先是服務器端的class文件

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        // 服務端socke對象
        ServerSocket ss = new ServerSocket(23456);

        // 監聽客戶端，獲取socket
        Socket s = ss.accept();

        // 封裝通道內流數據
        BufferedInputStream bis = new BufferedInputStream(s.getInputStream());

        // 封裝圖標目的地
        BufferedOutputStream bos = new BufferedOutputStream(
                new FileOutputStream("lpp.jpg"));

        byte[] bys = new byte[1024];
        int len = 0;
        while ((len = bis.read(bys)) != -1) {
            bos.write(bys, 0, len);    
            bos.flush(); // 尤其是在通道內部使用時，必須使用flush否則丟包
        }

        // 給一個反饋
        OutputStream os = s.getOutputStream();
        os.write("圖片上傳成功".getBytes());

        // 釋放資源
        bos.close();
        s.close();

    }
}


//------------------------------------------------
//下面的是客戶端的class文件

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;

/*
 * 客戶端讀取一個數據，通過TCP協議發送到服務器
 */
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        // 客戶端socke對象
        Socket s = new Socket("lll-PC", 23456);

        // 封裝數據源
        BufferedInputStream bis = new BufferedInputStream(new FileInputStream(
                "a.jpg"));

        // 封裝通道數據流
        BufferedOutputStream bos = new BufferedOutputStream(s.getOutputStream());

        byte[] bys = new byte[1024];
        int len = 0;
        while ((len = bis.read(bys)) != -1) {
            bos.write(bys, 0, len);
            bos.flush();  //尤其是在通道內部使用時，必須使用flush否則丟包
        }

        // 讀取反饋，關閉寫入流，並告知服務器端，服務器端的阻塞不再等待向下執行
        s.shutdownOutput();

        InputStream is = s.getInputStream();
        byte[] buf = new byte[1024];
        int len2 = is.read(buf);
        String clientStr = new String(buf, 0, len2);
        System.out.println(clientStr);

        // 釋放資源
        bis.close();
        s.close();

    }
}