JAVA中的網路協議,UDP,TCP案例分析及筆記總結
今日內容介紹
1、網路三要素及傳輸協議
2、實現UDP協議的傳送端和接收端
3、實現TCP協議的客戶端和伺服器
4、TCP上傳檔案案例
今日內容總結
5.1知識點總結
IP地址:用來唯一表示我們自己的電腦的,是一個網路標示
埠號: 用來區別當前電腦中的應用程式的
UDP: 傳送速度快,但是容易丟資料,如視訊聊天,語音聊天
TCP: 傳送穩定,不會丟失資料,如檔案的上傳、下載
UDP程式互動的流程
傳送端
1,建立DatagramSocket物件
2,建立DatagramPacket物件,並封裝資料
3,傳送資料
4,釋放流資源
接收端
1,建立DatagramSocket物件
2,建立DatagramPacket物件
3,接收資料儲存到DatagramPacket物件中
4,獲取DatagramPacket物件的內容
5,釋放流資源
TCP程式互動的流程
客戶端
1,建立客戶端的Socket物件
2,獲取Socket的輸出流物件
3,寫資料給伺服器
4,獲取Socket的輸入流物件
5,使用輸入流,讀反饋資訊
6,關閉流資源
伺服器端
1,建立伺服器端ServerSocket物件,指定伺服器端埠號
2,開啟伺服器,等待著客戶端Socket物件的連線,如有客戶端連線,返回客戶端的Socket物件
3,通過客戶端的Socket物件,獲取客戶端的輸入流,為了實現獲取客戶端發來的資料
4,通過客戶端的輸入流,獲取流中的資料
5,通過客戶端的Socket物件,獲取客戶端的輸出流,為了實現給客戶端反饋資訊
6,通過客戶端的輸出流,寫資料到流中
7,關閉流資源
=======================第一節課開始=============================================
01網路模型
*A:網路模型
TCP/IP協議中的四層分別是應用層、傳輸層、網路層和鏈路層,每層分別負責不同的通訊功能,接下來針對這四層進行詳細地講解。
鏈路層:鏈路層是用於定義物理傳輸通道,通常是對某些網路連線裝置的驅動協議,例如針對光纖、網線提供的驅動。
網路層:網路層是整個TCP/IP協議的核心,它主要用於將傳輸的資料進行分組,將分組資料傳送到目標計算機或者網路。
傳輸層:主要使網路程式進行通訊,在進行網路通訊時,可以採用TCP協議,也可以採用UDP協議。
應用層:主要負責應用程式的協議,例如HTTP協議、FTP協議等。
02IP地址
*A:IP地址
在TCP/IP協議中,這個標識號就是IP地址,它可以唯一標識一臺計算機,
目前,IP地址廣泛使用的版本是IPv4,它是由4個位元組大小的二進位制數來表示,如:00001010000000000000000000000001。
由於二進位制形式表示的IP地址非常不便記憶和處理,因此通常會將IP地址寫成十進位制的形式,
每個位元組用一個十進位制數字(0-255)表示,數字間用符號“.”分開,如 “192.168.1.100”
127.0.0.1 為本地主機地址(本地迴環地址)
03埠號
*A:埠號
通過IP地址可以連線到指定計算機,但如果想訪問目標計算機中的某個應用程式,還需要指定埠號。
在計算機中,不同的應用程式是通過埠號區分的。
埠號是用兩個位元組(16位的二進位制數)表示的,它的取值範圍是0~65535,
其中,0~1023之間的埠號用於一些知名的網路服務和應用,使用者的普通應用程式需要使用1024以上的埠號,從而避免埠號被另外一個應用或服務所佔用
04InetAddress類
*A:InetAddress類
/*
* 表示網際網路中的IP地址
* java.net.InetAddress
* 靜態方法
* static InetAddress getLocalHost() LocalHost本地主機
* 返回本地主機,返回值InetAddress物件
*
* static InetAddress getByName(String hostName)傳遞主機名,獲取IP地址物件
*
* 非靜態方法
* String getHoustAddress()獲取主機IP地址
* String getHoustName()獲取主機名
*
*/
public class InetAddressDemo {
public static void main(String[] args)throws UnknownHostException {
function_1();
}
/*
* static InetAddress getByName(String hostName)傳遞主機名,獲取IP地址物件
*/
public static void function_1()throws UnknownHostException {
InetAddress inet = InetAddress.getByName(“www.baidu.com”);
System.out.println(inet);
}
/*
* static InetAddress getLocalHost() LocalHost本地主機
*/
public static void function() throws UnknownHostException{
InetAddress inet = InetAddress.getLocalHost();
//輸出結果就是主機名,和 IP地址
System.out.println(inet.toString());
String ip = inet.getHostAddress();
String name = inet.getHostName();
System.out.println(ip+" "+name);
/*String host = inet.toString();
String[] str = host.split("/");
for(String s : str){
System.out.println(s);
}*/
}
}
05UDP協議
A:UDP協議
a:UDP協議概述:
UDP是無連線通訊協議,即在資料傳輸時,資料的傳送端和接收端不建立邏輯連線。
簡單來說,當一臺計算機向另外一臺計算機發送資料時,傳送端不會確認接收端是否存在,就會發出資料,同樣接收端在收到資料時,也不會向傳送端反饋是否收到資料。
b:UDP協議特點:
由於使用UDP協議消耗資源小,通訊效率高,所以通常都會用於音訊、視訊和普通資料的傳輸例如視訊會議都使用UDP協議,
因為這種情況即使偶爾丟失一兩個資料包,也不會對接收結果產生太大影響。
06TCP協議
*A:TCP協議
TCP協議是面向連線的通訊協議,即在傳輸資料前先在傳送端和接收端建立邏輯連線,然後再傳輸資料,它提供了兩臺計算機之間可靠無差錯的資料傳輸。
在TCP連線中必須要明確客戶端與伺服器端,
由客戶端向服務端發出連線請求,每次連線的建立都需要經過“三次握手”。
第一次握手,客戶端向伺服器端發出連線請求,等待伺服器確認
第二次握手,伺服器端向客戶端回送一個響應,通知客戶端收到了連線請求
第三次握手,客戶端再次向伺服器端傳送確認資訊,確認連線
========================================第二節課=========================================
07資料包和傳送物件介紹
*A:資料包和傳送物件介紹:
DatagramPacket資料包的作用就如同是“集裝箱”,
可以將傳送端或者接收端的資料封裝起來。然而運輸貨物只有“集裝箱”是不夠的,還需要有碼頭。
在程式中需要實現通訊只有DatagramPacket資料包也同樣不行,為此JDK中提供的一個DatagramSocket類。
DatagramSocket類的作用就類似於碼頭,使用這個類的例項物件就可以傳送和接收DatagramPacket資料包
DatagramPacket:封裝資料
DatagramSocket:傳送DatagramPacket
08UDP傳送端
*A:UDP傳送端
/*
* 實現UDP協議的傳送端:
* 實現封裝資料的類 java.net.DatagramPacket 將你的資料包裝
* 實現資料傳輸的類 java.net.DatagramSocket 將資料包發出去
*
* 實現步驟:
* 1. 建立DatagramPacket物件,封裝資料, 接收的地址和埠
* 2. 建立DatagramSocket
* 3. 呼叫DatagramSocket類方法send,傳送資料包
* 4. 關閉資源
*
* DatagramPacket構造方法:
* DatagramPacket(byte[] buf, int length, InetAddress address, int port)
*
* DatagramSocket構造方法:
* DatagramSocket()空引數
* 方法: send(DatagramPacket d)
*
*/
public class UDPSend {
public static void main(String[] args) throws IOException{
//建立資料包物件,封裝要傳送的資料,接收端IP,埠
byte[] date = “你好UDP”.getBytes();
//建立InetAddress物件,封裝自己的IP地址
InetAddress inet = InetAddress.getByName(“127.0.0.1”);
DatagramPacket dp = new DatagramPacket(date, date.length, inet,6000);
//建立DatagramSocket物件,資料包的傳送和接收物件
DatagramSocket ds = new DatagramSocket();
//呼叫ds物件的方法send,傳送資料包
ds.send(dp);
//關閉資源
ds.close();
}
}
09UDP接收端
*A:UDP接收端
/*
* 實現UDP接收端
* 實現封裝資料包 java.net.DatagramPacket 將資料接收
* 實現輸出傳輸 java.net.DatagramSocket 接收資料包
*
* 實現步驟:
* 1. 建立DatagramSocket物件,繫結埠號
* 要和傳送端埠號一致
* 2. 建立位元組陣列,接收發來的資料
* 3. 建立資料包物件DatagramPacket
* 4. 呼叫DatagramSocket物件方法
* receive(DatagramPacket dp)接收資料,資料放在資料包中
* 5. 拆包
* 傳送的IP地址
* 資料包物件DatagramPacket方法getAddress()獲取的是傳送端的IP地址物件
* 返回值是InetAddress物件
* 接收到的位元組個數
* 資料包物件DatagramPacket方法 getLength()
* 傳送方的埠號
* 資料包物件DatagramPacket方法 getPort()傳送埠
* 6. 關閉資源
*/
public class UDPReceive {
public static void main(String[] args)throws IOException {
//建立資料包傳輸物件DatagramSocket 繫結埠號
DatagramSocket ds = new DatagramSocket(6000);
//建立位元組陣列
byte[] data = new byte[1024];
//建立資料包物件,傳遞位元組陣列
DatagramPacket dp = new DatagramPacket(data, data.length);
//呼叫ds物件的方法receive傳遞資料包
ds.receive(dp);
}
}
10UDP接收端的拆包
*A:UDP接收端的拆包
/*
* 實現UDP接收端
* 實現封裝資料包 java.net.DatagramPacket 將資料接收
* 實現輸出傳輸 java.net.DatagramSocket 接收資料包
*
* 實現步驟:
* 1. 建立DatagramSocket物件,繫結埠號
* 要和傳送端埠號一致
* 2. 建立位元組陣列,接收發來的資料
* 3. 建立資料包物件DatagramPacket
* 4. 呼叫DatagramSocket物件方法
* receive(DatagramPacket dp)接收資料,資料放在資料包中
* 5. 拆包
* 傳送的IP地址
* 資料包物件DatagramPacket方法getAddress()獲取的是傳送端的IP地址物件
* 返回值是InetAddress物件
* 接收到的位元組個數
* 資料包物件DatagramPacket方法 getLength()
* 傳送方的埠號
* 資料包物件DatagramPacket方法 getPort()傳送埠
* 6. 關閉資源
*/
public class UDPReceive {
public static void main(String[] args)throws IOException {
//建立資料包傳輸物件DatagramSocket 繫結埠號
DatagramSocket ds = new DatagramSocket(6000);
//建立位元組陣列
byte[] data = new byte[1024];
//建立資料包物件,傳遞位元組陣列
DatagramPacket dp = new DatagramPacket(data, data.length);
//呼叫ds物件的方法receive傳遞資料包
ds.receive(dp);
//獲取傳送端的IP地址物件
String ip=dp.getAddress().getHostAddress();
//獲取傳送的埠號
int port = dp.getPort();
//獲取接收到的位元組個數
int length = dp.getLength();
System.out.println(new String(data,0,length)+"..."+ip+":"+port);
ds.close();
}
}
11鍵盤輸入的聊天
*A:鍵盤輸入的聊天
*a:傳送端:
/*
* 實現UDP傳送,鍵盤輸入的形式
* 輸入完畢,傳送給接收端
*/
public class UDPSend {
public static void main(String[] args) throws IOException{
Scanner sc = new Scanner(System.in);
DatagramSocket ds = new DatagramSocket();
InetAddress inet = InetAddress.getByName(“127.0.0.1”);
while(true){
String message = sc.nextLine();
/*if(“886”.equals(message)){
break;
}*/
byte[] date = message.getBytes();
DatagramPacket dp = new DatagramPacket(date, date.length, inet,6000);
ds.send(dp);
}
// ds.close();
}
}
/*
* 實現UDP接收端
* 永不停歇的接收端
*/
public class UDPReceive {
public static void main(String[] args)throws IOException {
//建立資料包傳輸物件DatagramSocket 繫結埠號
DatagramSocket ds = new DatagramSocket(6000);
//建立位元組陣列
byte[] data = new byte[1024];
//建立資料包物件,傳遞位元組陣列
while(true){
DatagramPacket dp = new DatagramPacket(data, data.length);
//呼叫ds物件的方法receive傳遞資料包
ds.receive(dp);
//獲取傳送端的IP地址物件
String ip=dp.getAddress().getHostAddress();
//獲取傳送的埠號
int port = dp.getPort();
//獲取接收到的位元組個數
int length = dp.getLength();
System.out.println(new String(data,0,length)+"..."+ip+":"+port);
}
//ds.close();
}
}
=======================第三節課======================================
12TCP的客戶端和伺服器
*A:TCP的客戶端和伺服器
TCP通訊同UDP通訊一樣,都能實現兩臺計算機之間的通訊,通訊的兩端都需要建立socket物件。
區別在於,UDP中只有傳送端和接收端,不區分客戶端與伺服器端,計算機之間可以任意地傳送資料。
而TCP通訊是嚴格區分客戶端與伺服器端的,在通訊時,必須先由客戶端去連線伺服器端才能實現通訊,
伺服器端不可以主動連線客戶端,並且伺服器端程式需要事先啟動,等待客戶端的連線。
在JDK中提供了兩個類用於實現TCP程式,一個是ServerSocket類,用於表示伺服器端,一個是Socket類,用於表示客戶端。
通訊時,首先建立代表伺服器端的ServerSocket物件,該物件相當於開啟一個服務,並等待客戶端的連線,然後建立代表客戶端的Socket物件向伺服器端發出連線請求,伺服器端響應請求,兩者建立連線開始通訊。
13TCP的客戶端程式
*A:TCP的客戶端程式
/*
* 實現TCP客戶端,連線到伺服器
* 和伺服器實現資料交換
* 實現TCP客戶端程式的類 java.net.Socket
*
* 構造方法:
* Socket(String host, int port) 傳遞伺服器IP和埠號
* 注意:構造方法只要執行,就會和伺服器進行連線,連線失敗,丟擲異常
*
* OutputStream getOutputStream() 返回套接字的輸出流
* 作用: 將資料輸出,輸出到伺服器
*
* InputStream getInputStream() 返回套接字的輸入流
* 作用: 從伺服器端讀取資料
*
* 客戶端伺服器資料交換,必須使用套接字物件Socket中的獲取的IO流,自己new流,不行
*/
public class TCPClient {
public static void main(String[] args)throws IOException {
//建立Socket物件,連線伺服器
Socket socket = new Socket(“127.0.0.1”, 8888);
//通過客戶端的套接字物件Socket方法,獲取位元組輸出流,將資料寫向伺服器
OutputStream out = socket.getOutputStream();
out.write(“伺服器OK”.getBytes());
socket.close();
}
}
14TCP的伺服器程式accept方法
A:TCP的伺服器程式accept方法
/*
* 實現TCP伺服器程式
* 表示伺服器程式的類 java.net.ServerSocket
* 構造方法:
* ServerSocket(int port) 傳遞埠號
*
* 很重要的事情: 必須要獲得客戶端的套接字物件Socket
* Socket accept()
*/
public class TCPServer {
public static void main(String[] args) throws IOException{
ServerSocket server = new ServerSocket(8888);
//呼叫伺服器套接字物件中的方法accept() 獲取客戶端套接字物件
Socket socket = server.accept();
//通過客戶端套接字物件,socket獲取位元組輸入流,讀取的是客戶端傳送來的資料
InputStream in = socket.getInputStream();
byte[] data = new byte[1024];
int len = in.read(data);
System.out.println(new String(data,0,len));
socket.close();
server.close();
}
}
15TCP的伺服器程式讀取客戶端資料
A:TCP的伺服器程式讀取客戶端資料
/*
* 實現TCP客戶端,連線到伺服器
* 和伺服器實現資料交換
* 實現TCP客戶端程式的類 java.net.Socket
*
* 構造方法:
* Socket(String host, int port) 傳遞伺服器IP和埠號
* 注意:構造方法只要執行,就會和伺服器進行連線,連線失敗,丟擲異常
*
* OutputStream getOutputStream() 返回套接字的輸出流
* 作用: 將資料輸出,輸出到伺服器
*
* InputStream getInputStream() 返回套接字的輸入流
* 作用: 從伺服器端讀取資料
*
* 客戶端伺服器資料交換,必須使用套接字物件Socket中的獲取的IO流,自己new流,不行
*/
public class TCPClient {
public static void main(String[] args)throws IOException {
//建立Socket物件,連線伺服器
Socket socket = new Socket("127.0.0.1", 8888);
//通過客戶端的套接字物件Socket方法,獲取位元組輸出流,將資料寫向伺服器
OutputStream out = socket.getOutputStream();
out.write("伺服器OK".getBytes());
socket.close();
}
}
/*
* 實現TCP伺服器程式
* 表示伺服器程式的類 java.net.ServerSocket
* 構造方法:
* ServerSocket(int port) 傳遞埠號
*
* 很重要的事情: 必須要獲得客戶端的套接字物件Socket
* Socket accept()
*/
public class TCPServer {
public static void main(String[] args) throws IOException{
ServerSocket server = new ServerSocket(8888);
//呼叫伺服器套接字物件中的方法accept() 獲取客戶端套接字物件
Socket socket = server.accept();
//通過客戶端套接字物件,socket獲取位元組輸入流,讀取的是客戶端傳送來的資料
InputStream in = socket.getInputStream();
byte[] data = new byte[1024];
int len = in.read(data);
System.out.println(new String(data,0,len));
}
}
16TCP的伺服器和客戶端的資料交換
A:TCP的伺服器和客戶端的資料交換
/*
* 實現TCP客戶端,連線到伺服器
* 和伺服器實現資料交換
* 實現TCP客戶端程式的類 java.net.Socket
*
* 構造方法:
* Socket(String host, int port) 傳遞伺服器IP和埠號
* 注意:構造方法只要執行,就會和伺服器進行連線,連線失敗,丟擲異常
*
* OutputStream getOutputStream() 返回套接字的輸出流
* 作用: 將資料輸出,輸出到伺服器
*
* InputStream getInputStream() 返回套接字的輸入流
* 作用: 從伺服器端讀取資料
*
* 客戶端伺服器資料交換,必須使用套接字物件Socket中的獲取的IO流,自己new流,不行
*/
public class TCPClient {
public static void main(String[] args)throws IOException {
//建立Socket物件,連線伺服器
Socket socket = new Socket(“127.0.0.1”, 8888);
//通過客戶端的套接字物件Socket方法,獲取位元組輸出流,將資料寫向伺服器
OutputStream out = socket.getOutputStream();
out.write(“伺服器OK”.getBytes());
//讀取伺服器發回的資料,使用socket套接字物件中的位元組輸入流
InputStream in = socket.getInputStream();
byte[] data = new byte[1024];
int len = in.read(data);
System.out.println(new String(data,0,len));
socket.close();
}
}
/*
* 實現TCP伺服器程式
* 表示伺服器程式的類 java.net.ServerSocket
* 構造方法:
* ServerSocket(int port) 傳遞埠號
*
* 很重要的事情: 必須要獲得客戶端的套接字物件Socket
* Socket accept()
*/
public class TCPServer {
public static void main(String[] args) throws IOException{
ServerSocket server = new ServerSocket(8888);
//呼叫伺服器套接字物件中的方法accept() 獲取客戶端套接字物件
Socket socket = server.accept();
//通過客戶端套接字物件,socket獲取位元組輸入流,讀取的是客戶端傳送來的資料
InputStream in = socket.getInputStream();
byte[] data = new byte[1024];
int len = in.read(data);
System.out.println(new String(data,0,len));
//伺服器向客戶端回資料,位元組輸出流,通過客戶端套接字物件獲取位元組輸出流
OutputStream out = socket.getOutputStream();
out.write("收到,謝謝".getBytes());
socket.close();
server.close();
}
}
17TCP的中的流物件
*A:TCP的中的流物件
參見圖解TCP中的流物件.jpg
======================================第四節課=================================================
18TCP圖片上傳案例分析
*A:圖片上傳案例分析
參見圖解TCP上傳圖片案例.jpg
19TCP上傳客戶端
*A TCP上傳客戶端
/*
* 實現TCP圖片上傳客戶端
* 實現步驟:
* 1. Socket套接字連線伺服器
* 2. 通過Socket獲取位元組輸出流,寫圖片
* 3. 使用自己的流物件,讀取圖片資料來源
* FileInputStream
* 4. 讀取圖片,使用位元組輸出流,將圖片寫到伺服器
* 採用位元組陣列進行緩衝
* 5. 通過Socket套接字獲取位元組輸入流
* 讀取伺服器發回來的上傳成功
* 6. 關閉資源
*/
public class TCPClient {
public static void main(String[] args) throws IOException{
Socket socket = new Socket(“127.0.0.1”, 8000);
//獲取位元組輸出流,圖片寫到伺服器
OutputStream out = socket.getOutputStream();
//建立位元組輸入流,讀取本機上的資料來源圖片
FileInputStream fis = new FileInputStream(“c:\t.jpg”);
//開始讀寫位元組陣列
int len = 0 ;
byte[] bytes = new byte[1024];
while((len = fis.read(bytes))!=-1){
out.write(bytes, 0, len);
}
//給伺服器寫終止序列
//socket.shutdownOutput();
//獲取位元組輸入流,讀取伺服器的上傳成功
InputStream in = socket.getInputStream();
len = in.read(bytes);
System.out.println(new String(bytes,0,len));
fis.close();
socket.close();
}
}
20TCP上傳伺服器
A:TCP上傳伺服器
/*
* TCP圖片上傳伺服器
* 1. ServerSocket套接字物件,監聽埠8000
* 2. 方法accept()獲取客戶端的連線物件
* 3. 客戶端連線物件獲取位元組輸入流,讀取客戶端傳送圖片
* 4. 建立File物件,繫結上傳資料夾
* 判斷資料夾存在, 不存,在建立資料夾
* 5. 建立位元組輸出流,資料目的File物件所在資料夾
* 6. 位元組流讀取圖片,位元組流將圖片寫入到目的資料夾中
* 7. 將上傳成功會寫客戶端
* 8. 關閉資源
*
*/
public class TCPServer {
public static void main(String[] args) throws IOException{
ServerSocket server = new ServerSocket(8000);
Socket socket = server.accept();
//通過客戶端連線物件,獲取位元組輸入流,讀取客戶端圖片
InputStream in = socket.getInputStream();
//將目的資料夾封裝到File物件
File upload = new File(“d:\upload”);
if(!upload.exists())
upload.mkdirs();
//建立位元組輸出流,將圖片寫入到目的資料夾中
FileOutputStream fos = new FileOutputStream(upload+"t.jpg");
//讀寫位元組陣列
byte[] bytes = new byte[1024];
int len = 0 ;
while((len = in.read(bytes))!=-1){
fos.write(bytes, 0, len);
}
//通過客戶端連線物件獲取位元組輸出流
//上傳成功寫回客戶端
socket.getOutputStream().write("上傳成功".getBytes());
fos.close();
socket.close();
server.close();
}
}
21TCP圖片上傳問題解決
/*
* 實現TCP圖片上傳客戶端
* 實現步驟:
* 1. Socket套接字連線伺服器
* 2. 通過Socket獲取位元組輸出流,寫圖片
* 3. 使用自己的流物件,讀取圖片資料來源
* FileInputStream
* 4. 讀取圖片,使用位元組輸出流,將圖片寫到伺服器
* 採用位元組陣列進行緩衝
* 5. 通過Socket套接字獲取位元組輸入流
* 讀取伺服器發回來的上傳成功
* 6. 關閉資源
*/
public class TCPClient {
public static void main(String[] args) throws IOException{
Socket socket = new Socket(“127.0.0.1”, 8000);
//獲取位元組輸出流,圖片寫到伺服器
OutputStream out = socket.getOutputStream();
//建立位元組輸入流,讀取本機上的資料來源圖片
FileInputStream fis = new FileInputStream(“c:\t.jpg”);
//開始讀寫位元組陣列
int len = 0 ;
byte[] bytes = new byte[1024];
while((len = fis.read(bytes))!=-1){
out.write(bytes, 0, len);
}
//給伺服器寫終止序列
socket.shutdownOutput();//想服務端寫入一個結束標誌
//獲取位元組輸入流,讀取伺服器的上傳成功
InputStream in = socket.getInputStream();
len = in.read(bytes);
System.out.println(new String(bytes,0,len));
fis.close();
socket.close();
}
}
TCP上傳檔名
*A:TCP上傳檔名
/*
* TCP圖片上傳伺服器
* 1. ServerSocket套接字物件,監聽埠8000
* 2. 方法accept()獲取客戶端的連線物件
* 3. 客戶端連線物件獲取位元組輸入流,讀取客戶端傳送圖片
* 4. 建立File物件,繫結上傳資料夾
* 判斷資料夾存在, 不存,在建立資料夾
* 5. 建立位元組輸出流,資料目的File物件所在資料夾
* 6. 位元組流讀取圖片,位元組流將圖片寫入到目的資料夾中
* 7. 將上傳成功會寫客戶端
* 8. 關閉資源
*
*/
public class TCPServer {
public static void main(String[] args) throws IOException{
ServerSocket server = new ServerSocket(8000);
Socket socket = server.accept();
//通過客戶端連線物件,獲取位元組輸入流,讀取客戶端圖片
InputStream in = socket.getInputStream();
//將目的資料夾封裝到File物件
File upload = new File(“d:\upload”);
if(!upload.exists())
upload.mkdirs();
//防止檔案同名被覆蓋,從新定義檔名字
//規則: 域名+毫秒值+6位隨機數
String filename="itcast"+System.currentTimeMillis()+new Random().nextInt(999999)+".jpg";
//建立位元組輸出流,將圖片寫入到目的資料夾中
FileOutputStream fos = new FileOutputStream(upload+File.separator+filename);
//讀寫位元組陣列
byte[] bytes = new byte[1024];
int len = 0 ;
while((len = in.read(bytes))!=-1){
fos.write(bytes, 0, len);
}
//通過客戶端連線物件獲取位元組輸出流
//上傳成功寫回客戶端
socket.getOutputStream().write("上傳成功".getBytes());
fos.close();
socket.close();
server.close();
}
}
多執行緒上傳案例
*A:多執行緒上傳案例
public class TCPThreadServer {
public static void main(String[] args) throws IOException {
ServerSocket server = new ServerSocket(8000);
while (true) {
// 獲取到一個客戶端,必須開啟新執行緒,為這個客戶端服務
Socket socket = server.accept();
new Thread(new Upload(socket)).start();
}
}
}
public class Upload implements Runnable {
private Socket socket;
public Upload(Socket socket) {
this.socket = socket;
}
public void run() {
try {
// 通過客戶端連線物件,獲取位元組輸入流,讀取客戶端圖片
InputStream in = socket.getInputStream();
// 將目的資料夾封裝到File物件
File upload = new File("d:\\upload");
if (!upload.exists())
upload.mkdirs();
// 防止檔案同名被覆蓋,從新定義檔名字
// 規則: 域名+毫秒值+6位隨機數
String filename = "itcast" + System.currentTimeMillis() + new Random().nextInt(999999) + ".jpg";
// 建立位元組輸出流,將圖片寫入到目的資料夾中
FileOutputStream fos = new FileOutputStream(upload + File.separator + filename);
// 讀寫位元組陣列
byte[] bytes = new byte[1024];
int len = 0;
while ((len = in.read(bytes)) != -1) {
fos.write(bytes, 0, len);
}
// 通過客戶端連線物件獲取位元組輸出流
// 上傳成功寫回客戶端
socket.getOutputStream().write("上傳成功".getBytes());
fos.close();
socket.close();
} catch (Exception ex) {
}
}
}