TCP通訊完成文件上傳、模擬BS
/*
文件上傳案例的客戶端:讀取本地文件,上傳到服務器,讀取服務器回寫的數據
明確:
數據源:c:\\1.jpg
目的地:服務器
實現步驟:
1.建立一個本地字節輸入流FileInputStream對象,構造方法中綁定要讀取的數據源
2.建立一個客戶端Socket對象,構造方法中綁定服務器的IP地址和端口號
3.使用Socket中的方法getOutputStream,獲取網絡字節輸出流OutputStream對象
4.使用本地字節輸入流FileInputStream對象中的方法read,讀取本地文件
5.使用網絡字節輸出流OutputStream對象中的方法write,把讀取到的文件上傳到服務器
6.使用Socket中的方法getInputStream,獲取網絡字節輸入流InputStream對象
7.使用網絡字節輸入流InputStream對象中的方法read讀取服務回寫的數據
8.釋放資源(FileInputStream,Socket)
*/
public class TCPClient {
public static void main(String[] args) throws IOException {
//1.建立一個本地字節輸入流FileInputStream對象,構造方法中綁定要讀取的數據源
FileInputStream fis = new FileInputStream("c:\\1.jpg");
//2.建立一個客戶端Socket對象,構造方法中綁定服務器的IP地址和端口號
Socket socket = new Socket("127.0.0.1",8888);
//3.使用Socket中的方法getOutputStream,獲取網絡字節輸出流OutputStream對象
OutputStream os = socket.getOutputStream();
//4.使用本地字節輸入流FileInputStream對象中的方法read,讀取本地文件
int len = 0;
byte[] bytes = new byte[1024];
while((len = fis.read(bytes))!=-1){
//5.使用網絡字節輸出流OutputStream對象中的方法write,把讀取到的文件上傳到服務器
os.write(bytes,0,len);
}
/*
解決:上傳完文件,給服務器寫一個結束標記
void shutdownOutput() 禁用此套接字的輸出流。
對於 TCP 套接字，任何之前寫入的數據都將被髮送，而且後跟 TCP 的正常鏈接終止序列。
*/
socket.shutdownOutput();
//6.使用Socket中的方法getInputStream,獲取網絡字節輸入流InputStream對象
InputStream is = socket.getInputStream();
//7.使用網絡字節輸入流InputStream對象中的方法read讀取服務回寫的數據
while((len = is.read(bytes))!=-1){
System.out.println(new String(bytes,0,len));
}
//8.釋放資源(FileInputStream,Socket)
fis.close();
socket.close();
}
}
/*
文件上傳案例服務器端:讀取客戶端上傳的文件,保存到服務器的硬盤,給客戶端回寫"上傳成功"
明確:
數據源:客戶端上傳的文件
目的地:服務器的硬盤 d:\\upload\\1.jpg
實現步驟:
1.建立一個服務器ServerSocket對象,和系統要指定的端口號
2.使用ServerSocket對象中的方法accept,獲取到請求的客戶端Socket對象
3.使用Socket對象中的方法getInputStream,獲取到網絡字節輸入流InputStream對象
4.判斷d:\\upload文件夾是否存在,不存在則建立
5.建立一個本地字節輸出流FileOutputStream對象,構造方法中綁定要輸出的目的地
6.使用網絡字節輸入流InputStream對象中的方法read,讀取客戶端上傳的文件
7.使用本地字節輸出流FileOutputStream對象中的方法write,把讀取到的文件保存到服務器的硬盤上
8.使用Socket對象中的方法getOutputStream,獲取到網絡字節輸出流OutputStream對象
9.使用網絡字節輸出流OutputStream對象中的方法write,給客戶端回寫"上傳成功"
10.釋放資源(FileOutputStream,Socket,ServerSocket)
*/
public class TCPServer {
public static void main(String[] args) throws IOException {
//1.建立一個服務器ServerSocket對象,和系統要指定的端口號
ServerSocket server = new ServerSocket(8888);
//2.使用ServerSocket對象中的方法accept,獲取到請求的客戶端Socket對象
/*
讓服務器一直處於監聽狀態(死循環accept方法)
有一個客戶端上傳文件,就保存一個文件
*/
while(true){
Socket socket = server.accept();
/*
使用多線程技術,提升程序的效率
有一個客戶端上傳文件,就開啓一個線程,完成文件的上傳
*/
new Thread(new Runnable() {
//完成文件的上傳
@Override
public void run() {
try {
//3.使用Socket對象中的方法getInputStream,獲取到網絡字節輸入流InputStream對象
InputStream is = socket.getInputStream();
//4.判斷d:\\upload文件夾是否存在,不存在則建立
File file = new File("d:\\upload");
if(!file.exists()){
file.mkdirs();
}
/*
自定義一個文件的命名規則:防止同名的文件被覆蓋
規則:域名+毫秒值+隨機數
*/
String fileName = "itcast"+System.currentTimeMillis()+new Random().nextInt(999999)+".jpg";
//5.建立一個本地字節輸出流FileOutputStream對象,構造方法中綁定要輸出的目的地
//FileOutputStream fos = new FileOutputStream(file+"\\1.jpg");
FileOutputStream fos = new FileOutputStream(file+"\\"+fileName);
//6.使用網絡字節輸入流InputStream對象中的方法read,讀取客戶端上傳的文件
int len =0;
byte[] bytes = new byte[1024];
while((len = is.read(bytes))!=-1){
//7.使用本地字節輸出流FileOutputStream對象中的方法write,把讀取到的文件保存到服務器的硬盤上
fos.write(bytes,0,len);
}
//8.使用Socket對象中的方法getOutputStream,獲取到網絡字節輸出流OutputStream對象
//9.使用網絡字節輸出流OutputStream對象中的方法write,給客戶端回寫"上傳成功"
socket.getOutputStream().write("上傳成功".getBytes());
//10.釋放資源(FileOutputStream,Socket,ServerSocket)
fos.close();
socket.close();
}catch (IOException e){
System.out.println(e);
}
}
}).start();
}
//服務器就不用關閉
//server.close();
}
}
模擬BS
/*
建立BS版本TCP服務器
*/
public class TCPServer {
public static void main(String[] args) throws IOException {
//建立一個服務器ServerSocket,和系統要指定的端口號
ServerSocket server = new ServerSocket(8080);
//使用accept方法獲取到請求的客戶端對象(瀏覽器)
Socket socket = server.accept();
//使用Socket對象中的方法getInputStream,獲取到網絡字節輸入流InputStream對象
InputStream is = socket.getInputStream();
//使用網絡字節輸入流InputStream對象中的方法read讀取客戶端的請求信息
/*byte[] bytes = new byte[1024];
int len = 0;
while((len = is.read(bytes))!=-1){
System.out.println(new String(bytes,0,len));
}*/
//把is網絡字節輸入流對象,轉換爲字符緩衝輸入流
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//把客戶端請求信息的第一行讀取出來 GET /11_Net/web/index.html HTTP/1.1
String line = br.readLine();
//把讀取的信息進行切割,只要中間部分 /11_Net/web/index.html
String[] arr = line.split(" ");
//把路徑前邊的/去掉,進行截取 11_Net/web/index.html
String htmlpath = arr[1].substring(1);
//建立一個本地字節輸入流,構造方法中綁定要讀取的html路徑
FileInputStream fis = new FileInputStream(htmlpath);
//使用Socket中的方法getOutputStream獲取網絡字節輸出流OutputStream對象
OutputStream os = socket.getOutputStream();
// 寫入HTTP協議響應頭,固定寫法
os.write("HTTP/1.1 200 OK\r\n".getBytes());
os.write("Content-Type:text/html\r\n".getBytes());
// 必需要寫入空行,不然瀏覽器不解析
os.write("\r\n".getBytes());
//一讀一寫複製文件,把服務讀取的html文件回寫到客戶端
int len = 0;
byte[] bytes = new byte[1024];
while((len = fis.read(bytes))!=-1){
os.write(bytes,0,len);
}
//釋放資源
fis.close();
socket.close();
server.close();
}
}
/*
建立BS版本TCP服務器
*/
public class TCPServerThread {
public static void main(String[] args) throws IOException {
//建立一個服務器ServerSocket,和系統要指定的端口號
ServerSocket server = new ServerSocket(8080);
/*
瀏覽器解析服務器回寫的html頁面,頁面中若是有圖片,那麼瀏覽器就會單獨的開啓一個線程,讀取服務器的圖片
咱們就的讓服務器一直處於監聽狀態,客戶端請求一次,服務器就回寫一次
*/
while(true){
//使用accept方法獲取到請求的客戶端對象(瀏覽器)
Socket socket = server.accept();
new Thread(new Runnable() {
@Override
public void run() {
try {
//使用Socket對象中的方法getInputStream,獲取到網絡字節輸入流InputStream對象
InputStream is = socket.getInputStream();
//使用網絡字節輸入流InputStream對象中的方法read讀取客戶端的請求信息
/*byte[] bytes = new byte[1024];
int len = 0;
while((len = is.read(bytes))!=-1){
System.out.println(new String(bytes,0,len));
}*/
//把is網絡字節輸入流對象,轉換爲字符緩衝輸入流
BufferedReader br = new BufferedReader(new InputStreamReader(is));
//把客戶端請求信息的第一行讀取出來 GET /11_Net/web/index.html HTTP/1.1
String line = br.readLine();
System.out.println(line);
//把讀取的信息進行切割,只要中間部分 /11_Net/web/index.html
String[] arr = line.split(" ");
//把路徑前邊的/去掉,進行截取 11_Net/web/index.html
String htmlpath = arr[1].substring(1);
//建立一個本地字節輸入流,構造方法中綁定要讀取的html路徑
FileInputStream fis = new FileInputStream(htmlpath);
//使用Socket中的方法getOutputStream獲取網絡字節輸出流OutputStream對象
OutputStream os = socket.getOutputStream();
// 寫入HTTP協議響應頭,固定寫法
os.write("HTTP/1.1 200 OK\r\n".getBytes());
os.write("Content-Type:text/html\r\n".getBytes());
// 必需要寫入空行,不然瀏覽器不解析
os.write("\r\n".getBytes());
//一讀一寫複製文件,把服務讀取的html文件回寫到客戶端
int len = 0;
byte[] bytes = new byte[1024];
while((len = fis.read(bytes))!=-1){
os.write(bytes,0,len);
}
//釋放資源
fis.close();
socket.close();
}catch (IOException e){
e.printStackTrace();
}
}
}).start();
}
//server.close();
}
}
相關文章
- 1. BS—文件上傳
- 2. jmeter完成文件上傳
- 3. Struts2完成文件上傳
- 4. golang 模擬文件上傳
- 5. TCP 上傳文件
- 6. NET使用SuperSocket完成TCP/IP通訊
- 7. [Java]TCP通信文件上傳過程
- 8. Web通訊&CS&BS
- 9. 用Apache文件完成上傳組件
- 10. tornado 文件上傳處理 和 模擬上傳文件
- 更多相關文章...
- • PHP 文件上傳 - PHP教程
- • TCP報文格式解析 - TCP/IP教程
- • 委託模式
- • Flink 數據傳輸及反壓詳解
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. Appium入門
- 2. Spring WebFlux 源碼分析(2)-Netty 服務器啓動服務流程 --TBD
- 3. wxpython入門第六步（高級組件）
- 4. CentOS7.5安裝SVN和可視化管理工具iF.SVNAdmin
- 5. jedis 3.0.1中JedisPoolConfig對象缺少setMaxIdle、setMaxWaitMillis等方法，問題記錄
- 6. 一步一圖一代碼，一定要讓你真正徹底明白紅黑樹
- 7. 2018-04-12—（重點）源碼角度分析Handler運行原理
- 8. Spring AOP源碼詳細解析
- 9. Spring Cloud（1）
- 10. python簡單爬去油價信息發送到公衆號
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. BS—文件上傳
- 2. jmeter完成文件上傳
- 3. Struts2完成文件上傳
- 4. golang 模擬文件上傳
- 5. TCP 上傳文件
- 6. NET使用SuperSocket完成TCP/IP通訊
- 7. [Java]TCP通信文件上傳過程
- 8. Web通訊&CS&BS
- 9. 用Apache文件完成上傳組件
- 10. tornado 文件上傳處理 和 模擬上傳文件