From 24bed5e6b6e31090cb61600a0bdea898eac65da1 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 26 十二月 2020 17:20:23 +0800
Subject: [PATCH] cmq调整
---
utils/src/main/java/org/yeshi/utils/FileUtil.java | 207 ++++++++++++++++++++++++++++-----------------------
1 files changed, 112 insertions(+), 95 deletions(-)
diff --git a/utils/src/main/java/org/yeshi/utils/FileUtil.java b/utils/src/main/java/org/yeshi/utils/FileUtil.java
index e006f78..ee7be67 100644
--- a/utils/src/main/java/org/yeshi/utils/FileUtil.java
+++ b/utils/src/main/java/org/yeshi/utils/FileUtil.java
@@ -1,11 +1,6 @@
package org.yeshi.utils;
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.OutputStream;
+import java.io.*;
import javax.servlet.http.HttpServletRequest;
@@ -14,102 +9,124 @@
public class FileUtil {
- @SuppressWarnings("deprecation")
- public static String getRealPath(HttpServletRequest request, String folderName) {
- String f = request.getRealPath(folderName);
- if (!new File(f).exists())
- new File(f).mkdirs();
- return f;
- }
+ @SuppressWarnings("deprecation")
+ public static String getRealPath(HttpServletRequest request, String folderName) {
+ String f = request.getRealPath(folderName);
+ if (!new File(f).exists())
+ new File(f).mkdirs();
+ return f;
+ }
- public static String getFileMD5(File file) throws IOException {
- FileInputStream fis = new FileInputStream(file);
- String md5 = DigestUtils.md5Hex(IOUtils.toByteArray(fis));
- IOUtils.closeQuietly(fis);
- return md5;
- }
+ public static String getFileMD5(File file) throws IOException {
+ FileInputStream fis = new FileInputStream(file);
+ String md5 = DigestUtils.md5Hex(IOUtils.toByteArray(fis));
+ IOUtils.closeQuietly(fis);
+ return md5;
+ }
- public static void deleteFileDir(File path) {
- if (!path.exists())
- return;
- if (path.isFile()) {
- path.delete();
- return;
- }
- File[] files = path.listFiles();
- for (int i = 0; i < files.length; i++) {
- deleteFileDir(files[i]);
- }
- path.delete();
- }
+ public static void deleteFileDir(File path) {
+ if (!path.exists())
+ return;
+ if (path.isFile()) {
+ path.delete();
+ return;
+ }
+ File[] files = path.listFiles();
+ for (int i = 0; i < files.length; i++) {
+ deleteFileDir(files[i]);
+ }
+ path.delete();
+ }
- /**
- * 灏嗚緭鍏ユ祦瀛樹负鏈湴鏂囦欢
- *
- * @param inputStream
- * @param path
- * @return
- * @throws IOException
- */
- public static String saveAsFile(InputStream inputStream, String path) throws IOException {
- if (!new File(path).exists()) {
- new File(path).createNewFile();
- }
+ /**
+ * 灏嗚緭鍏ユ祦瀛樹负鏈湴鏂囦欢
+ *
+ * @param inputStream
+ * @param path
+ * @return
+ * @throws IOException
+ */
+ public static String saveAsFile(InputStream inputStream, String path) throws IOException {
+ if (!new File(path).exists()) {
+ new File(path).createNewFile();
+ }
- FileOutputStream fileOut = new FileOutputStream(new File(path));
- byte[] buf = new byte[1024 * 8];
- while (true) {
- int read = 0;
- if (inputStream != null) {
- read = inputStream.read(buf);
- }
- if (read == -1) {
- break;
- }
- fileOut.write(buf, 0, read);
- }
- fileOut.close();
- return path;
- }
+ FileOutputStream fileOut = new FileOutputStream(new File(path));
+ byte[] buf = new byte[1024 * 8];
+ while (true) {
+ int read = 0;
+ if (inputStream != null) {
+ read = inputStream.read(buf);
+ }
+ if (read == -1) {
+ break;
+ }
+ fileOut.write(buf, 0, read);
+ }
+ fileOut.close();
+ return path;
+ }
- /**
- * 鑾峰彇缂撳瓨鏂囦欢澶圭洰褰�
- *
- * @return
- */
- public static String getCacheDir() {
- String os = System.getProperty("os.name");
- if (os.toLowerCase().startsWith("win")) {
- File f = new File("D:/cache");
- if (!f.exists())
- f.mkdirs();
- return f.getPath();
- } else {
- File f = new File("/usr/local/cache");
- if (!f.exists())
- f.mkdirs();
- return f.getPath();
- }
- }
+ /**
+ * 鑾峰彇缂撳瓨鏂囦欢澶圭洰褰�
+ *
+ * @return
+ */
+ public static String getCacheDir() {
+ String os = System.getProperty("os.name");
+ if (os.toLowerCase().startsWith("win")) {
+ File f = new File("D:/cache");
+ if (!f.exists())
+ f.mkdirs();
+ return f.getPath();
+ } else {
+ File f = new File("/usr/local/cache");
+ if (!f.exists())
+ f.mkdirs();
+ return f.getPath();
+ }
+ }
-
- /**
- * 灏嗚緭鍏ユ祦瀛樹负鏈湴鏂囦欢
- *
- * @param inputStream
- * @param path
- * @return
- * @throws IOException
- */
- public static String saveAsFileByte(byte[] b, String path) throws IOException {
- if (!new File(path).exists()) {
- new File(path).createNewFile();
- }
- FileOutputStream fileOut = new FileOutputStream(path);
+ /**
+ * 灏嗚緭鍏ユ祦瀛樹负鏈湴鏂囦欢
+ *
+ * @param inputStream
+ * @param path
+ * @return
+ * @throws IOException
+ */
+ public static String saveAsFileByte(byte[] b, String path) throws IOException {
+ if (!new File(path).exists()) {
+ new File(path).createNewFile();
+ }
+
+ FileOutputStream fileOut = new FileOutputStream(path);
fileOut.write(b);
fileOut.flush();
- fileOut.close();
- return path;
- }
+ fileOut.close();
+ return path;
+ }
+
+
+ /**
+ * 澶嶅埗inputStream
+ * @param input
+ * @return
+ */
+ public static ByteArrayOutputStream cloneInputStream(InputStream input) {
+ try {
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ byte[] buffer = new byte[1024];
+ int len;
+ while ((len = input.read(buffer)) > -1) {
+ baos.write(buffer, 0, len);
+ }
+ baos.flush();
+ return baos;
+ } catch (IOException e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
}
--
Gitblit v1.8.0