JAVA網路程式設計（TCP篇入門）

阿新 • • 發佈：2019-01-12

此次部落格主要以程式碼為主，其中包含了豐富的註釋

簡單的tcp

簡單介紹tcp是如何傳送資料，以及接受資料

`程式碼一：客戶端`

package com.net.tcp;

import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;

/**
 * TCP協議傳送資料的步驟
 * A:建立傳送資料的socket物件。
 *  建立物件的時候要指定目標主機和埠
 * B:獲取socket物件的輸出流
 *  是位元組流還是字元流？位元組流。
 * C:寫資料
 * D:釋放資源
 * 
 * @author 
 yuliyang
 * @version $Id: ClientDemo.java, v 0.1 2016年11月23日 下午10:57:55 yuliyang Exp $
 */
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //A:建立傳送資料的socket物件
        //Socket(InetAddress address, int port) 
        //Socket(String host, int port) 
        //java.net.ConnectException: Connection refused: connect 

        //如果你先啟動了客戶端，發現如上錯誤，是因為服務端沒有開啟，TCP協議的程式，必須先開啟伺服器
        Socket s = new Socket("192.168.31.222", 10086);
        //B:獲取socket物件的輸出流
        OutputStream os = s.getOutputStream();
        //C:
        os.write("hello write".getBytes());
        //D:
        os.close();
        s.close();
    }
}

`程式碼一：服務端`

package com.net.tcp;

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

/**
 * TCP協議接收資料的步驟
 * A:建立接收資料的socket物件。
 *  建立物件的時候要指定埠
 * B:監聽客戶端連線，
 *      等待客戶端連線
 * C:讀資料，並顯示在控制檯
 * D:釋放資源
 * 注意事項;伺服器需要先開啟
 * @author yuliyang
 * @version $Id: ClientDemo.java, v 0.1 2016年11月23日 下午10:57:55 yuliyang Exp $
 */
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //A:ServerSocket(int port) 
        ServerSocket serverSocket = new ServerSocket(10086);
        //B:監聽客戶端連線
        // Socket accept()  偵聽並接受到此套接字的連線。
        Socket s = serverSocket.accept();//此處為阻塞式方法
        //C:獲取socket物件的輸入流,並讀取資料
        InputStream is = s.getInputStream();
        byte[] buf = new byte[1024];
        int len = is.read(buf);
        //此處為解析收到的資料
        String data = new String(buf, 0, len);
        System.out.println("data" + data);
        //D:釋放資源
        is.close();
        serverSocket.close();
    }
}

如果上面的程式碼你看懂了的話，那就接著繼續玩耍吧。

`程式碼二：客戶端,新增獲取了服務端返回的資訊`

package com.net.tcp2;

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

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //建立客戶端socket
        Socket socket = new Socket("192.168.31.222", 12312);
        /**
         * 使用通道輸出流寫資料
         */
        OutputStream outputStream = socket.getOutputStream();

        outputStream.write("我是傳送的".getBytes());
        /**
         * 使用通道輸入流獲取返回的訊息
         */
        InputStream inputStream = socket.getInputStream();
        byte[] b = new byte[1024];
        int len = inputStream.read(b);
        String s = new String(b, 0, len);
        System.out.println("客戶端獲取到的響應是：" + s);
        socket.close();
    }
}

程式碼二：服務端

package com.net.tcp2;

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

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12312);
        Socket s = serverSocket.accept();
        InputStream inputStream = s.getInputStream();
        byte[] buf = new byte[1024];
        int len = inputStream.read(buf);
        String data = new String(buf, 0, len);
        System.out.println("服務端獲取到的資料是:" + data);
        /**
         * 使用通道返回響應，告訴客戶端結果
         */
        OutputStream outputStream = s.getOutputStream();
        outputStream.write("我接收到了".getBytes());
        //釋放資源
        serverSocket.close();
        inputStream.close();
        outputStream.close();
    }
}

程式碼三：客戶端新增需求：看註釋、

package com.net.tcp3;

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

/**
 * 需求：把傳送的資料改進為來自鍵盤錄入，
 * 客戶端傳送資料用鍵盤錄入，服務端把資料顯示即可
 * 
 * @author yuliyang
 * @version $Id: ClientDemo.java, v 0.1 2016年11月24日 下午9:08:14 yuliyang Exp $
 */
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        Socket s = new Socket("192.168.31.222", 10010);
        //讀取鍵盤錄入的資料
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        //封裝：將通道內的輸出位元組流轉化為字元流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        s.close();
    }
}

程式碼三：服務端

package com.net.tcp3;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(10010);
        Socket s = serverSocket.accept();
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        String line = null;
        while ((line = br.readLine()) != null) {
            System.out.println("接收的資料為：" + line);
        }
        //釋放資源
        s.close();
        serverSocket.close();
    }
}

`程式碼四：客戶端`

需求：服務端需要將從客戶端獲取的資源寫入到檔案中

package com.net.tcp5;

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

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("192.168.31.222", 10086);
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String line = null;
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        socket.close();
    }
}

程式碼四：服務端

package com.net.tcp5;

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

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //建立伺服器socket物件
        ServerSocket serverSocket = new ServerSocket(10086);
        //監聽客戶端連線
        Socket socket = serverSocket.accept();//阻塞式
        //封裝通道內的輸入流
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        //將資料寫入到檔案中
        BufferedWriter bw = new BufferedWriter(new FileWriter("D:\\a.txt"));
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        bw.close();
        serverSocket.close();
    }
}

`程式碼五：客戶端`

需求：客戶端讀取本地檔案，並傳送給服務端，服務端收到檔案之後，並copy一份

package com.net.tcp6;

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

public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //建立客戶端的物件
        Socket s = new Socket("192.168.31.222", 10086);
        //讀取檔案的資料
        BufferedReader br = new BufferedReader(new FileReader("InetAddressDemo.java"));
        //把通道的輸出流包裝
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        s.close();
        br.close();
    }
}

`程式碼五：服務端`

package com.net.tcp6;

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

public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //建立伺服器物件
        ServerSocket serverSocket = new ServerSocket(10086);
        //監聽客戶端連線
        Socket s = serverSocket.accept();
        //把通道內的輸入流封裝一下
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把輸入流輸出到檔案
        BufferedWriter bw = new BufferedWriter(new FileWriter("Copy.txt"));
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        serverSocket.close();
        bw.close();

    }
}

`程式碼六：客戶端`

需求：在檔案接收完成之後，伺服器需要通知客戶端，檔案接收完成
問題：會因為阻塞式，導致接收不到反饋訊息
解決方案：A:自定義結束標籤
B:使用socket自帶的方法
此處只展現socket自帶方案

package com.net.tcp7;

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;

/**
 * 我把檔案發給你了，你沒有告訴我檔案你是否收到檔案
 * 需要服務端給我一個反饋
 * 
 * @author yuliyang
 * @version $Id: ClientDemo.java, v 0.1 2016年11月24日 下午10:21:16 yuliyang Exp $
 */
public class ClientDemo {
    public static void main(String[] args) throws IOException {
        //建立客戶端的物件
        Socket s = new Socket("192.168.31.222", 10086);
        //讀取檔案的資料
        BufferedReader br = new BufferedReader(new FileReader("InetAddressDemo.java"));
        //把通道的輸出流包裝
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line = null;
        while ((line = br.readLine()) != null) {
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        /**
         * 接收從服務端返回的資訊
         * 此處發現無法進行到這裡，由於服務端阻塞，
         * 因為伺服器無法判斷我們之前的資料是否已經傳輸完畢，
         * 此時socket提供了一個方法：
         *  shutdownOutput
         * 禁用輸出流  方法
         */
        s.shutdownOutput();
        BufferedReader infoByServer = new BufferedReader(new InputStreamReader(s.getInputStream()));

        String data = infoByServer.readLine();//阻塞式
        System.out.println("client" + data);
        s.close();
        br.close();
    }
}

`程式碼六:服務端`

package com.net.tcp7;

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

/**
 * 收到檔案之後，給客戶端一個反饋
 * 
 * @author yuliyang
 * @version $Id: ServerDemo.java, v 0.1 2016年11月24日 下午10:22:00 yuliyang Exp $
 */
public class ServerDemo {
    public static void main(String[] args) throws IOException {
        //建立伺服器物件
        ServerSocket serverSocket = new ServerSocket(10086);
        //監聽客戶端連線
        Socket s = serverSocket.accept();
        //把通道內的輸入流封裝一下
        BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
        //把輸入流輸出到檔案
        BufferedWriter bw = new BufferedWriter(new FileWriter("Copy.txt"));
        String line = null;
        while ((line = br.readLine()) != null) {//阻塞式
            bw.write(line);
            bw.newLine();
            bw.flush();
        }
        /**
         * 新增反饋
         * 從通道將反饋返回回去
         */
        BufferedWriter feadback = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        feadback.write("資料接收成功了");
        feadback.newLine();
        feadback.flush();
        serverSocket.close();
        bw.close();

    }
}

希望看到我的文章的人可以多給反饋，thanks

JAVA網路程式設計（TCP篇入門）

此次部落格主要以程式碼為主，其中包含了豐富的註釋簡單的tcp 簡單介紹tcp是如何傳送資料，以及接受資料程式碼一：客戶端 package com.net.tcp; import java.io.IOException; import java.io.Out

Java網路程式設計（輸出流 OutputStream）

網路程式所做的很大一部分工作都是簡單的輸入輸出：將資料位元組從一個系統移動到另一個系統。位元組就是位元組。在很大程度上講，讀取伺服器傳送給你的資料與讀取檔案並沒有什麼不同。向客戶端傳送文字和寫檔案也沒有什麼不同。但是，Java中輸入和輸出（I/O）的組織與其他語言都不太一

Java網路程式設計（輸入流 InputStream）

Java的基本輸入類是java.io.InputStream: public abstract class InputStream 這個類提供將資料都取為原始位元組的基本方法。這些方法包括： public abstract int read() throws

JAVA網路程式設計（UDP入門篇）

網路程式設計:通過計算機語言實現資源的共享網路程式設計模型資料一層層的封裝打包應用層:eg:應用程式，qq 表示層: 會話層: 傳輸層: 網路層:資料傳輸資料鏈路層:資料幀，使用交換機傳遞資料物理層 : 將資料轉化為1,0資料應用程式：網路程式設計+IO

java網路程式設計（3）TCP

使用TCP進行網路資料傳輸的時候，TCP會在需要傳輸資料的兩端建立兩個Socket（插座），並且在兩個Socket之間建立一條虛擬鏈路，然後這兩臺主機就可以進行通訊了。下面是一個很簡單的例子。 Server類建立一個ServerSocket物件，用於監聽客戶端Socke

Java網路程式設計（2）：TCP和UDP

1、多執行緒“服務端-客戶端” TCP客戶端使用Socket來連線伺服器和與伺服器通訊。以下為在主執行緒中將使用者輸入傳送給服務端，在建立的執行緒中將服務端發回的資料輸出來： import java.net.*; import java.io.*; class Cl

JAVA網路程式設計 ——基於TCP的Socket程式設計（1）——實現伺服器端與客戶端的實時對話

第一篇文章，我先介紹以及記錄一下我所學的知識點。（總結了一下視訊老師講的東西）一，HTTP與Socket1.HTTP：超文字傳輸協議特點：客戶端傳送的請求需要伺服器端每次來響應，在請求結束之後主動釋放連線，從建立連線到關閉連線稱為“一次連線”，所以HTTP是“短連線”。2.S

Java 網路程式設計（五）使用TCP/IP的套接字（Socket）進行通訊

使用TCP/IP的套接字（Socket）進行通訊套接字Socket的引入　　為了能夠方便地開發網路應用軟體，由美國伯克利大學在Unix上推出了一種應用程式訪問通訊協議的作業系統用呼叫socket（套接字）。　　socket的出現，使程式設計師可以很方便地訪問TCP/

Java基礎知識網路程式設計（TCP練習）

練習：複製文字練習要求：把客戶端的一個檔案內容發到服務端，在服務端把資料儲存到一個檔案當中。相當於複製檔案。 import java.io.*; import java.net.*; class TxtCopyTestClient { publi

Linux學習之網路程式設計（TCP程式設計模型總結）

言之者無罪，聞之者足以戒。 - “詩序” TCP通訊也就是伺服器和客戶端的一種通訊方式，它的整體框架為：針對TCP通訊所用到的函式，我來做一下說明：（1）插座創造一個套接字 int socket（int domain，int type，int protocol）標頭檔

Linux學習之網路程式設計（TCP相關基礎知識）

言之者無罪，聞之者足以戒。 - “詩序”、 1、網路位元組序：在TCP的編寫過程中需要從網路位元組序轉換到主機位元組序，當然也需要從主機位元組序轉換到網路位元組序 htons 把 unsigned short型別從主機序轉換到網路序htonl把unsigned long型別從

Linux學習之網路程式設計（TCP三次握手四次揮手）

言之者無罪，聞之者足以戒。 - “詩序” 1、三次握手：看一下三次握手的框圖：（1）、伺服器必須準備好接受外來連線（2）、客戶端呼叫connect來主動開啟一個連線，此時客戶端TCP將會發送一個SYN分節（3）、伺服器必須確認客戶的SYN （4）、客戶必須確認伺

Linux學習之網路程式設計（TCP程式設計）

言之者無罪，聞之者足以戒。 - “詩序” 1，TCP是什麼？ TCP傳輸控制協議向用戶程序提供可靠的全雙工位元組流（位元組流：給每一個位元組編序） 2，UDP是什麼？ UDP使用者資料報協議是一種無連線的協議 3，獲取時間服務的客戶端（1），建立一個的的I

Java語言程式設計（基礎篇）第十版程式設計練習題3.3（代數：求解2*2線性方程）

**編寫程式，提示使用者輸入a,b,c,e和f,然後顯示結果。如果ad-bc=0，則方程式無解應用Cramer規則求解線性方程組** public class linearEquation { public static void main(Stri

Java語言程式設計（基礎篇）第十版程式設計練習題3.8 （對三個整數排序）

編寫程式，提示使用者輸入三個整數。以非降序（即升序）的形式排序顯示這三個整數。由於第三章還沒有學迴圈和陣列，有迴圈和陣列即可用氣泡排序完成。所以在這用IF選擇語句方法編碼，若有更快捷的方法歡迎留言。 public class AscendingOrder

Java語言程式設計（基礎篇）第十版程式設計練習題**3.10（遊戲：加法測驗）

import java.util.Random; public class AdditionGame { public static void main(String[] args) { // TODO Auto-generated

Java語言程式設計（基礎篇）第十版程式設計練習題*3.11（給出一個月的總天數）

public class NumberOfDaysPerMonth { public static void main(String[] args) { // TODO Auto-generated method stub

java網路程式設計（2）URLDecoder和URLEncoder

一下為程式碼示例，具體的講解穿插在程式碼中 import java.net.URLDecoder; import java.net.URLEncoder; public class URLDecoderTest { public static void mai

Java語言程式設計（基礎篇）第十版程式設計練習題**3.15（遊戲：彩票）

因為第三章還沒有陣列和迴圈，所以只能用IF語句和組合數的方法來判別使用者是否匹配到數字。 import java.util.Scanner; public class Lottery { public static void main(String[

Java語言程式設計（基礎篇）第十版綜合題 **3.23（幾何：點是否在矩形內？）

public class J3_24 { public static void main(String[] args) { // TODO Auto-generated method stub java.util.Sc

JAVA網路程式設計（TCP篇入門）

此次部落格主要以程式碼為主，其中包含了豐富的註釋

程式碼一：客戶端

程式碼一：服務端

程式碼二：客戶端,新增獲取了服務端返回的資訊

程式碼四：客戶端

程式碼四：服務端

程式碼五：客戶端

程式碼五：服務端

程式碼六：客戶端

程式碼六:服務端

希望看到我的文章的人可以多給反饋，thanks

相關推薦

`程式碼一：客戶端`

`程式碼一：服務端`

`程式碼二：客戶端,新增獲取了服務端返回的資訊`

`程式碼四：客戶端`

`程式碼五：客戶端`

`程式碼五：服務端`

`程式碼六：客戶端`

`程式碼六:服務端`