2. 程式人生 > >第3章 TCP協議

第3章 TCP協議

阿新 • • 發佈：2018-04-24
Java

TCP通信同UDP通信一樣，都能實現兩臺計算機之間的通信，通信的兩端都需要創建socket對象。
區別在於，UDP中只有發送端和接收端，不區分客戶端與服務器端，計算機之間可以任意地發送數據。
而TCP通信是嚴格區分客戶端與服務器端的，在通信時，必須先由客戶端去連接服務器端才能實現通信，服務器端不可以主動連接客戶端，並且服務器端程序需要事先啟動，等待客戶端的連接。
在JDK中提供了兩個類用於實現TCP程序，一個是ServerSocket類，用於表示服務器端，一個是Socket類，用於表示客戶端。
通信時，首先創建代表服務器端的ServerSocket對象，該對象相當於開啟一個服務，並等待客戶端的連接，然後創建代表客戶端的Socket對象向服務器端發出連接請求，服務器端響應請求，兩者建立連接開始通信。
1.1 ServerSocket
通過前面的學習知道，在開發TCP程序時，首先需要創建服務器端程序。JDK的java.net包中提供了一個ServerSocket類，該類的實例對象可以實現一個服務器段的程序。通過查閱API文檔可知，ServerSocket類提供了多種構造方法，接下來就對ServerSocket的構造方法進行逐一地講解。

使用該構造方法在創建ServerSocket對象時，就可以將其綁定到一個指定的端口號上（參數port就是端口號）。
接下來學習一下ServerSocket的常用方法，如表所示。

ServerSocket對象負責監聽某臺計算機的某個端口號，在創建ServerSocket對象後，需要繼續調用該對象的accept()方法，接收來自客戶端的請求。當執行了accept()方法之後，服務器端程序會發生阻塞，直到客戶端發出連接請求，accept()方法才會返回一個Scoket對象用於和客戶端實現通信，程序才能繼續向下執行。

1.2 Socket
講解了ServerSocket對象可以實現服務端程序，但只實現服務器端程序還不能完成通信，此時還需要一個客戶端程序與之交互，為此JDK提供了一個Socket類，用於實現TCP客戶端程序。
通過查閱API文檔可知Socket類同樣提供了多種構造方法，接下來就對Socket的常用構造方法進行詳細講解。

使用該構造方法在創建Socket對象時，會根據參數去連接在指定地址和端口上運行的服務器程序，其中參數host接收的是一個字符串類型的IP地址。

該方法在使用上與第二個構造方法類似，參數address用於接收一個InetAddress類型的對象，該對象用於封裝一個IP地址。
在以上Socket的構造方法中，最常用的是第一個構造方法。

接下來學習一下Socket的常用方法，如表所示。
方法聲明
功能描述
int getPort()
該方法返回一個int類型對象，該對象是Socket對象與服務器端連接的端口號
InetAddress getLocalAddress()
該方法用於獲取Socket對象綁定的本地IP地址，並將IP地址封裝成InetAddress類型的對象返回
void close()
該方法用於關閉Socket連接，結束本次通信。在關閉socket之前，應將與socket相關的所有的輸入/輸出流全部關閉，這是因為一個良好的程序應該在執行完畢時釋放所有的資源
InputStream getInputStream()
該方法返回一個InputStream類型的輸入流對象，如果該對象是由服務器端的Socket返回，就用於讀取客戶端發送的數據，反之，用於讀取服務器端發送的數據
OutputStream getOutputStream()
該方法返回一個OutputStream類型的輸出流對象，如果該對象是由服務器端的Socket返回，就用於向客戶端發送數據，反之，用於向服務器端發送數據
在Socket類的常用方法中，getInputStream()和getOutStream()方法分別用於獲取輸入流和輸出流。當客戶端和服務端建立連接後，數據是以IO流的形式進行交互的，從而實現通信。
接下來通過一張圖來描述服務器端和客戶端的數據傳輸，如下圖所示。

1.3 TCP協議實現1.3.1 案例代碼三:

package com.itheima_04;

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

/*
 * 使用TCP協議發送數據
創建發送端Socket對象（創建連接）
獲取輸出流對象
發送數據
釋放資源
Socket(InetAddress address, int port)
Exception in thread "main" java.net.ConnectException: Connection refused: connect

 */
public class ClientDemo {
public static void main(String[] args) throws IOException {
//創建發送端Socket對象（創建連接）
Socket s = new Socket(InetAddress.getByName("itheima"),10086);
//獲取輸出流對象
OutputStream os = s.getOutputStream();
//發送數據
String str = "hello tcp,im comming!!!";
os.write(str.getBytes());
//釋放資源
//os.close();
s.close();
}
}
package com.itheima_04;

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

/*
 * 使用TCP協議接收數據
         創建接收端Socket對象
         監聽（阻塞）
         獲取輸入流對象
         獲取數據
         輸出數據
         釋放資源

         ServerSocket：接收端，服務端Socket
         ServerSocket(int port)
         Socket accept()

 */
public class ServerDemo {
public static void main(String[] args) throws IOException  {
//創建接收端Socket對象
ServerSocket ss = new ServerSocket(10086);
         //監聽（阻塞）
Socket s = ss.accept();
         //獲取輸入流對象
InputStream is = s.getInputStream();
         //獲取數據
byte[] bys = new byte[1024];
int len;//用於存儲讀到的字節個數
len = is.read(bys);
         //輸出數據
InetAddress address = s.getInetAddress();
System.out.println("client ---> " + address.getHostName());
System.out.println(new String(bys,0,len));
         //釋放資源
s.close();
//ss.close();
}
}

1.4 TCP相關案例1.4.1 案例代碼四:
使用TCP協議發送數據，服務端將接收到的數據轉換成大寫返回給客戶端

package com.itheima_05;[/font][/align] [font=微軟雅黑]
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

/*
         需求：使用TCP協議發送數據，並將接收到的數據轉換成大寫返回

         客戶端發出數據
         服務端接收數據
         服務端轉換數據
         服務端發出數據
         客戶端接收數據

 */
public class ClientDemo {
public static void main(String[] args) throws IOException {
//創建客戶端Socket對象
Socket s = new Socket(InetAddress.getByName("itheima"),10010);
//獲取輸出流對象
OutputStream os = s.getOutputStream();
//發出數據
os.write("tcp,im comming again!!!".getBytes());

//獲取輸入流對象
InputStream is = s.getInputStream();
byte[] bys = new byte[1024];
int len;//用於存儲讀取到的字節個數
//接收數據
len = is.read(bys);
//輸出數據
System.out.println(new String(bys,0,len));
//釋放資源
s.close();
}
}
package com.itheima_05;

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 {
//創建服務端Socket對象
ServerSocket ss = new ServerSocket(10010);
//監聽
Socket s = ss.accept();
//獲取輸入流對象
InputStream is = s.getInputStream();
//獲取數據
byte[] bys = new byte[1024];
int len;//用於存儲讀取到的字節個數
len = is.read(bys);
String str = new String(bys,0,len);
//輸出數據
System.out.println(str);
//轉換數據
String upperStr = str.toUpperCase();
//獲取輸出流對象
OutputStream os = s.getOutputStream();
//返回數據（發出數據）
os.write(upperStr.getBytes());
//釋放資源
s.close();
//ss.close();//服務端一般不關閉
}
}

1.4.2 案例代碼五:
客戶端:
1.提示用戶輸入用戶名和密碼,將用戶輸入的用戶名和密碼發送給服務端
2.接收服務端驗證完用戶名和密碼的結果
服務端:
1.接收客戶端發送過來的用戶名和密碼
2.如果用戶名不是itheima或者 密碼不是123456,就向客戶端寫入”登錄失敗”
否則向客戶端寫入登錄成功

package com.itheima_06;

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

/*
 * 模擬用戶登錄
 */
public class ClientTest {
public static void main(String[] args) throws  IOException  {
//創建客戶端Socket對象
//Socket s = new Socket(InetAddress.getByName("itheima"),8888);
Socket s = new Socket("itheima",8888);
//獲取用戶名和密碼
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
System.out.println("請輸入用戶名:");
String username = br.readLine();
System.out.println("請輸入密碼:");
String password = br.readLine();
//獲取輸出流對象
//BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//寫出數據
out.println(username);
out.println(password);
//獲取輸入流對象
BufferedReader serverBr = new BufferedReader(new InputStreamReader(s.getInputStream()));
//獲取服務器返回的數據
String result = serverBr.readLine();
System.out.println(result);
//釋放資源
s.close();
}
}

1.4.3 案例代碼六:
將用戶名和密碼封裝到一個User類中,提供對應的構造方法和getter/setter方法
新建一個UserDB類裏面定義一個集合,在集合中添加以下User對象
new User("zhangsan","123456");
new User("lisi","654321");
new User("itheima","itheima");
new User("admin","password");
客戶端:
1.提示用戶輸入用戶名和密碼,將用戶輸入的用戶名和密碼發送給服務端
2.接收服務端驗證完用戶名和密碼的結果

服務端:

  1. 服務端將客戶端發送過來的用戶名密碼封裝成User對象
  2. 集合中如果包括這個User對象,想客戶端寫入” 登錄成功”
    否則向客戶端寫入”登錄失敗”
package com.itheima_06;[/font][/align] [font=微軟雅黑]
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerTest {
public static void main(String[] args) throws IOException {
//創建服務器端Socket對象
ServerSocket ss = new ServerSocket(8888);
//監聽
Socket s = ss.accept();
//獲取輸入流對象
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//獲取用戶名和密碼
String username = br.readLine();
String password = br.readLine();
//判斷用戶名和密碼是否正確
boolean flag = false;
if("itheima".equals(username) && "123456".equals(password)) {
flag = true;
}
//獲取輸出流對象
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//返回判斷信息
if(flag) {
out.println("登陸成功");
}
else {
out.println("登陸失敗");
}
//釋放資源
s.close();
//ss.close();//服務器一般不關閉
}
}
package com.itheima_07;

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

/*
 * 模擬用戶登錄改寫（面向對象版本）
 */
public class ClientTest {
public static void main(String[] args) throws  IOException  {
//創建客戶端Socket對象
Socket s = new Socket("itheima",8888);
//獲取用戶名和密碼
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
System.out.println("請輸入用戶名:");
String username = br.readLine();
System.out.println("請輸入密碼:");
String password = br.readLine();
//獲取輸出流對象
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//寫出數據
out.println(username);
out.println(password);
//獲取輸入流對象
BufferedReader serverBr = new BufferedReader(new InputStreamReader(s.getInputStream()));
//獲取服務器返回的數據
String result = serverBr.readLine();
System.out.println(result);
//釋放資源
s.close();
}
}
package com.itheima_07;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;

public class ServerTest {
public static void main(String[] args) throws IOException {
//創建服務器端Socket對象
ServerSocket ss = new ServerSocket(8888);
//監聽
Socket s = ss.accept();
//獲取輸入流對象
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
//獲取用戶名和密碼
String username = br.readLine();
String password = br.readLine();
//判斷用戶名和密碼是否正確
boolean flag = false;
/*if("itheima".equals(username) && "123456".equals(password)) {
flag = true;
}*/
List<User> users = UserDB.getUsers();
User user = new User(username,password);
if(users.contains(user)) {
//匹配成功
flag = true;
}
//獲取輸出流對象
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
//返回判斷信息
if(flag) {
out.println("登陸成功");
}
else {
out.println("登陸失敗");
}
//釋放資源
s.close();
//ss.close();//服務器一般不關閉
}
}

第3章 TCP協議

相關推薦

第3章 TCP協議

JavaTCP通信同UDP通信一樣，都能實現兩臺計算機之間的通信，通信的兩端都需要創建socket對象。區別在於，UDP中只有發送端和接收端，不區分客戶端與服務器端，計算機之間可以任意地發送數據。而TCP通信是嚴格區分客戶端與服務器端的，在通信時，必須先由客戶端去連接服務器端才能實現通信，服務器端不可以主動連

第17章TCP協議

TCP協議 TCP提供一種面向連線的、可靠的位元組流服務。三個關鍵字：面向連線、可靠的（有超時重傳、流量控制、擁塞控制等機制）、位元組流（TCP對位元組流的內容不做任何解釋）。具體來講可靠性的保證由以下機制保證： 應用資料被TCP分割為最適合傳送的資料塊（

《TCP/IP網路程式設計》第3章 筆記&程式碼&註釋

IP(網路協議Internet Protocol)：為了收發網路資料而給計算機分配的值。 埠號：為了區分程式中建立的套接字而分配給套接字的序號。 網路地址 IPv4 4位元組地址族（目前主要使用） IPv6 16位元組地址族（為了應對IP地址耗盡而提出的標準，但現在仍未普及）

《圖解TCP/IP》學習——第五章 IP協議的相關技術

一、僅憑IP無法完成通訊 1）web網站的地址和電子郵件地址等都是由應用層提供的，不會使用由十進位制陣列成的某個IP地址； 2）在乙太網（資料鏈路層）的情況下，只使用MAC地址傳輸資料包 二、DNS

第3章第1講算法與流程圖

blog images 技術 bsp mage -1 ima right mar 第3章第1講算法與流程圖

裴禮文數學分析中的典型問題與方法第3章一元微分學練習

處的 試題 4.6 $$ www 鄰域 5.6 為什麽 西安電子 參考解答見: http://www.cnblogs.com/zhangzujin/p/3527416.html 3.1.1 計算下列函數的指定導數: (1) $\dps{f(x)=\sqrt{\f{(

第3章 文件的權限管理

其他屬性 文件系統 strong 問題 ble wan centos 準備 行為 本文目錄： 3.1 文件/目錄的權限 3.2 實現權限的本質 3.3 umask說明 3.4 文件的擴展ACL權限 3.5 文件隱藏屬性 3.6 suid/sgid/sbit 3.1

轉載---編寫高質量代碼:改善Java程序的151個建議(第3章:類、對象及方法___建議47~51)

閱讀 aer 集中 記事本 哈希算法 讀者 堆內存 ref 類型判斷 閱讀目錄 建議47：在equals中使用getClass進行類型判斷 建議48：覆寫equals方法必須覆寫hashCode方法 建議49：推薦覆寫toString方法 建議50：使用package

轉載---編寫高質量代碼:改善Java程序的151個建議(第3章:類、對象及方法___建議41~46)

equals 業務 父親 face 使用 訪問 his () 而是 閱讀目錄 建議41：讓多重繼承成為現實 建議42：讓工具類不可實例化 建議43：避免對象的淺拷貝 建議44：推薦使用序列化對象的拷貝 建議45：覆寫equals方法時不要識別不出自己 建議46：equ

Python作業本——第3章 函數

exc logs enter urn 沒有 != clas sof 概念 今天看完了第三章，習題都是一些概念性的問題，就不一一解答了。 實踐項目是創建一個Collatz序列，並且加上驗證輸入是不是一個整數。 1 def collatz(number): 2 i

redis實戰筆記（3）-第3章 Redis命令

chan 4.4 ges 打包 常用 重要 讀取 表操作 nio 第3章 Redis命令 本章主要內容 字符串命令、 列表命令和集合命令 散列命令和有序集合命令 發布命令與訂閱命令 其他命令 在每個不同的數據類型的章節裏， 展示的都是該數據類型所獨有的、 最具代表性

第3章·SVI和單臂路由

偶潮鋒   svi虛接口 單臂路由· 本章目的· SVI和單臂路由產生背景· 路由器與每個VLAN建立一條物理連接，浪費大量的端口· SVI和單臂路由解決什麽問題· 低成本解決終端設備跨VLAN通信· SVI虛接口和單臂路由的本質· 通過802.1Q幀來區分不同VLAN，從而進行VLAN間路由。·

Unity Shader入門精要學習筆記 - 第3章 Unity Shader 基礎

但是 detail spa net 表示 part 文件 人的 text 來源作者：candycat http://blog.csdn.net/candycat1992/article/ 概述 總體來說，在Unity中我們需要配合使用材質和Unity Shader才能達

（7）第3章的開始

lan spa 能力 std 操作 第二章 c++語言 尋找 實現 第二章介紹的內置類型是由C++語言直接定義的。這些類型，比如數字和字符，體現了大多數計算機硬件本身具備的能力，標準庫定義了另外一組更具有更高級性質的類型，它們尚未直接實現到計算機硬件中———————————

第3章 CentOS常用命令

配置 tab 內容 滾動 pac back 例如 技術分享 歷史 一、CentOS常用命令 1.1 文件和目錄 # cd /home 進入 ‘/home‘ 目錄 # cd ..

第3章線性回歸

line mil 預測 linear int str .com 判斷 pmi 簡單線性回歸 方程式： 1.1 估計參數 代表第i 個殘差第i 個觀測到的響應值和第i 個用線性模型預測出的響應值之間的差距 殘差平方和（residu

第3章 如何用DAP仿真器下載程序

cto 復位 芯片 表示 ica 魔術 大小 flash reset 第3章 如何用DAP仿真器下載程序 全套200集視頻教程和1000頁PDF教程請到秉火論壇下載：www.firebbs.cn 野火視頻教程優酷觀看網址：http://i.youku.com/fi

jQuery基礎教程(第四版)第3章練習:

top ads afa reg 1.2 weight don ems doctype 關於答案: // // (1) 在Charles Dickens被單擊時，給它應用 selected 樣式。$(document).ready(function() { $(‘#he

Java並發編程從入門到精通 - 第3章：Thread安全

調用 排序 有一個 正在 內存可見性 輪詢 線程不安全 main 而在 Java內存模型與多線程： 線程不安全與線程安全： 線程安全問題闡述： 多條語句操作多個線程共享的資源時，一個線程只執行了部分語句，還沒執行完，另一個線程又進來操作共享數據（執行語句），導致共享數據

第3章 控制循環語句

控制循環語句第3章 控制循環語句 控制跳轉語句break1.1.1 Break的使用場景和作用break的使用場景：在選擇結構switch語句中在循環語句中離開使用場景的存在是沒有意義的break的作用：跳出單層循環1.1.2 代碼案例十八 package com.itheima_07;/* break:中