2021年7月27日星期二

Java 中使用 Jersey 实现上传文件（附加密和解密）

Jersey 简介

Jersey 是开源的 RESTful 框架，实现了 JAX-RS 规范，提供了更多的特性和工具， 可以进一步地简化 RESTful service 和 client 开发，与 Struts 类似，它同样可以和 Hibernate、Spring 框架整合。此处使用它实现文件上传功能。

引入依赖

在 pom. 中添加 Jersey 相关依赖

<dependency> <groupId>com.sun.jersey</groupId> <artifactId>jersey-client</artifactId> <version>1.18.1</version></dependency>

然后创建一个名为 FileUtils 的文件工具类。

生成临时文件方法

/** * 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;}

加密/解密文件方法

// 加密/解密文件的密钥public static final int CRYPTO_SECRET_KEY = 0x99;/** * 加密/解密文件 * @param srcFile 原文件 * @param encFile 加密/解密后的文件 * @return 加密/解密后的文件 * @throws Exception*/public static File 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(); return encFile;}

上传文件方法

/** * 上传文件 * @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(".")));   // 执行加密并覆盖原文件   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;}

完整工具类

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.get......
原文转载：http://www.shaoqun.com/a/898546.html
跨境电商：https://www.ikjzd.com/
Zozo：https://www.ikjzd.com/w/2180
 
雨果：https://www.ikjzd.com/w/1307
 
www.made-in-china.com：https://www.ikjzd.com/w/2777
 
Jersey简介Jersey是开源的RESTful框架，实现了JAX-RS规范，提供了更多的特性和工具，可以进一步地简化RESTfulservice和client开发，与Struts类似，它同样可以和Hibernate、Spring框架整合。此处使用它实现文件上传功能。引入依赖在pom.中添加Jersey相关依赖<dependency><groupId>com.sun.je
c79：https://www.ikjzd.com/w/1016
三维度科技：https://www.ikjzd.com/w/1312
兴宁熙和湾水上乐园必须穿泳衣吗？熙和湾水上乐园泳衣有卖的吗？：http://www.30bags.com/a/431697.html
兴宁熙和湾音乐节有什么好玩的？2021熙和湾音乐节活动安排？：http://www.30bags.com/a/431731.html
兴善门下，"品物咸亨"话长城，斑驳陆离鉴古墙_江南：http://www.30bags.com/a/219993.html
星湖湿地公园好玩吗？肇庆星湖湿地公园怎么样？：http://www.30bags.com/a/424443.html
七十女人喜欢被㖭 进去后女人就不反抗了：http://lady.shaoqun.com/a/248366.html
岳下面好紧我受不 岳的好深好浪啊：http://lady.shaoqun.com/a/248121.html
冲出亚马逊！鸿星尔克登上新品榜第一名：https://www.ikjzd.com/articles/146952
上半年国内出口排名出炉，看看你省排第几！：https://www.ikjzd.com/articles/146954
亚马逊B2B业务是如何运作的？：https://www.ikjzd.com/articles/146953
亚马逊否认将在年内接受比特币支付，未来趋势将更加重视品牌：https://www.ikjzd.com/articles/146958
发帖者 时间：

没有评论:

发表评论

订阅： 博文评论 (Atom)