溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
通過在Java項目中使用tcp協議實現一個文件上傳功能？相信很多沒有經驗的人對此束手無策，為此本文總結了問題出現的原因和解決方法，通過這篇文章希望你能解決這個問題。
服務端
package lesson02;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務端接收文件
*/
public class TcpServerDemo2 {
public static void main(String[] args) throws IOException {
//1、創建服務
ServerSocket serverSocket = new ServerSocket(9000);
//2、監聽客戶端的連接
Socket socket = serverSocket.accept();//阻塞式監聽，會一直等待客戶端連接
//3、獲取輸入流
InputStream is = socket.getInputStream();
//4、文件輸出
FileOutputStream fos = new FileOutputStream(new File("receive.jpg"));
byte[] buffer = new byte[1024];
int len;
while ((len = is.read(buffer)) != -1){
fos.write(buffer, 0, len);
}
//通知客戶端我接收完畢了
OutputStream os = socket.getOutputStream();
os.write("我接收完畢了，你可以斷開了".getBytes());
//5、關閉資源
fos.close();
is.close();
socket.close();
serverSocket.close();
}
}客戶端
package lesson02;
import java.io.*;
import java.net.InetAddress;
import java.net.Socket;
/**
* 客戶端上傳文件
*/
public class TcpClientDemo2 {
public static void main(String[] args) throws Exception {
//1、創建一個Socket連接
Socket socket = new Socket(InetAddress.getByName("127.0.0.1"), 90000);
//2、創建一個輸出流
OutputStream os = socket.getOutputStream();
//3、讀取文件
FileInputStream fis = new FileInputStream(new File("toux.jpg"));
//4、寫出文件
byte[] buffer = new byte[1024];
int len;
while ((len = fis.read(buffer)) != -1){
os.write(buffer, 0, len);
}
//通知服務器，我已經結束了
socket.shutdownOutput(); //我已經傳輸完了
//確定服務器接收完畢，才能夠斷開連接
InputStream inputStream = socket.getInputStream();
//Sting byte[]
ByteArrayOutputStream baos = new ByteArrayOutputStream();
byte[] buffer2 = new byte[1024];
int len2;
while ((len2 = inputStream.read(buffer2)) != -1){
baos.write(buffer2, 0, len2);
}
System.out.println(baos.toString());
//5、關閉資源
fis.close();
os.close();
socket.close();
}
}看完上述內容，你們掌握通過在Java項目中使用tcp協議實現一個文件上傳功能的方法了嗎？如果還想學到更多技能或想了解更多相關內容，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
