使用 Jersey 服務器實現上傳，使用 HTTP 請求實現下載

引入依賴

在 pom.xml 中添加 Jersey 相關依賴

com.sun.jersey

jersey-client

1.18.1

創建工具類

import com.sun.jersey.api.client.Client;

import com.sun.jersey.api.client.ClientHandlerException;

import com.sun.jersey.api.client.UniformInterfaceException;

import com.sun.jersey.api.client.WebResource;

import org.springframework.web.context.request.RequestContextHolder;

import org.springframework.web.context.request.ServletRequestAttributes;

import org.springframework.web.multipart.MultipartFile;

import javax.servlet.http.HttpServletRequest;

import java.io.*;

import java.net.HttpURLConnection;

import java.net.URL;

import java.util.UUID;

public class FileUtils {

// 加密/解密文件的密鑰

public static final int CRYPTO_SECRET_KEY = 0x99;

public static int FILE_DATA = 0;

/**

* 加密/解密 文件

* @param srcFile 原文件

* @param encFile 加密/解密后的文件

* @throws Exception

*/

public static void cryptoFile(File srcFile, File encFile) throws Exception {

InputStream inputStream = new FileInputStream(srcFile);

OutputStream outputStream = new FileOutputStream(encFile);

while ((FILE_DATA = inputStream.read()) > -1) {

outputStream.write(FILE_DATA ^ CRYPTO_SECRET_KEY);

}

inputStream.close();

outputStream.flush();

outputStream.close();

}

/**

* MultipartFile 生成臨時文件

* @param multipartFile

* @param tempFilePath 臨時文件路徑

* @return File 臨時文件

*/

public static File multipartFileToFile(MultipartFile multipartFile, String tempFilePath) {

File file = new File(tempFilePath);

// 獲取文件原名

String originalFilename = multipartFile.getOriginalFilename();

// 獲取文件后綴

String suffix = originalFilename.substring(originalFilename.lastIndexOf("."));

if (!file.exists()) {

file.mkdirs();

}

// 創建臨時文件

File tempFile = new File(tempFilePath + "\\" + UUID.randomUUID().toString().replaceAll("-", "") + suffix);

try {

if (!tempFile.exists()) {

// 寫入臨時文件

multipartFile.transferTo(tempFile);

}

} catch (IOException e) {

e.printStackTrace();

}

return tempFile;

}

/**

* 上傳文件

* @param fileServerPath文件服務器地址

* @param folderPath 存放的文件夾路徑(比如存放在文件服務器的 upload 文件夾下，即 ”/upload“)

* @param uploadFile需要上傳的文件

* @param isCrypto是否加密

* @return String文件上傳后的全路徑

*/

public static String uploadByJersey(String fileServerPath, String folderPath, File uploadFile, boolean isCrypto) {

String suffix = uploadFile.getName().substring(uploadFile.getName().lastIndexOf("."));

String randomFileName = UUID.randomUUID().toString().replaceAll("-", "") + suffix;

String fullPath = fileServerPath + folderPath + "/" + randomFileName;

try {

if (isCrypto) {

// 創建加密文件

File cryptoFile = new File(uploadFile.getPath().substring(0, uploadFile.getPath().lastIndexOf(".")) + "crypto" + uploadFile.getPath().substring(uploadFile.getPath().lastIndexOf(".")));

// 執行加密

cryptoFile(uploadFile, cryptoFile);

// 保存加密后的文件

uploadFile = cryptoFile;

}

// 創建 Jersey 服務器

Client client = Client.create();

WebResource wr = client.resource(fullPath);

// 上傳文件

wr.put(String.class, fileToByte(uploadFile));

} catch (Exception e) {

e.printStackTrace();

}

return fullPath;

}

/**

* 下載文件

* @param url 文件路徑

* @param filePath 文件保存路徑

* @param fileName文件名稱(包含文件后綴)

* @param isCrypto 是否解密

* @return File

*/

public static File downloadByURL(String url, String filePath, String fileName, boolean isCrypto) {

File file = new File(filePath);

if (!file.exists()) {

file.mkdirs();

}

FileOutputStream fileOut;

HttpURLConnection httpURLConnection;

InputStream inputStream;

try {

URL httpUrl = new URL(url);

httpURLConnection = (HttpURLConnection) httpUrl.openConnection();

httpURLConnection.setDoInput(true);

httpURLConnection.setDoOutput(true);

httpURLConnection.setUseCaches(false);

httpURLConnection.connect();

inputStream = httpURLConnection.getInputStream();

BufferedInputStream bufferedInputStream = new BufferedInputStream(inputStream);

if (!filePath.endsWith("\\")) {

filePath += "\\";

}

file = new File(filePath + fileName);

fileOut = new FileOutputStream(file);

BufferedOutputStream bufferedOutputStream = new BufferedOutputStream(fileOut);

byte[] bytes = new byte[4096];

int length = bufferedInputStream.read(bytes);

//保存文件

while (length != -1) {

bufferedOutputStream.write(bytes, 0, length);

length = bufferedInputStream.read(bytes);

}

bufferedOutputStream.close();

bufferedInputStream.close();

httpURLConnection.disconnect();

} catch (Exception e) {

e.printStackTrace();

}

if (isCrypto) {

try {

// 創建解密文件

File cryptoFile = new File(((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest().getServletContext().getRealPath("/") + "\\temp\\" + UUID.randomUUID().toString().replaceAll("-", "") + file.getName().substring(file.getName().lastIndexOf(".")));

// 執行解密

cryptoFile(file, cryptoFile);

// 刪除下載的原文件

file.delete();

// 保存解密后的文件

file = cryptoFile;

} catch (Exception e) {

e.printStackTrace();

}

}

return file;

}

/**

* 刪除文件服務器上的文件

* @param url 文件路徑

* @return boolean

*/

public static boolean deleteByJersey(String url) {

try {

Client client = new Client();

WebResource webResource = client.resource(url);

webResource.delete();

return true;

} catch (UniformInterfaceException e) {

e.printStackTrace();

} catch (ClientHandlerException e) {

e.printStackTrace();

}

return false;

}

/**

* File轉Bytes

* @param file

* @return byte[]

*/

public static byte[] fileToByte(File file) {

byte[] buffer = null;

try {

FileInputStream fileInputStream = new FileInputStream(file);

ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();

byte[] bytes = new byte[1024];

int n;

while ((n = fileInputStream.read(bytes)) != -1) {

byteArrayOutputStream.write(bytes, 0, n);

}

fileInputStream.close();

byteArrayOutputStream.close();

buffer = byteArrayOutputStream.toByteArray();

} catch (FileNotFoundException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

return buffer;

}

}

測試上傳

/**

* @param multipartFile 上傳文件

* @param isCrypto 是否加密文件

* @return

*/

@Test

public String upload(MultipartFile multipartFile, boolean isCrypto) {

HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();

// 生成臨時文件

File tempFile = FileUtil.multipartFileToFile(multipartFile, request.getServletContext().getRealPath("/") + "\\static\\temp");

// 上傳文件并返回文件路徑

String uploadFilePath = FileUtil.uploadByJersey("http://localhost:8080", "/upload", tempFile, isCrypto);

if (uploadFilePath != null) {

return "上傳成功";

}

else {

return "上傳失敗";

}

}

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

總結

以上是生活随笔為你收集整理的java上传加密_Java上传下载文件并实现加密解密的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。