- * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - *
- * http://www.apache.org/licenses/LICENSE-2.0 - *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package io.jboot.codegen.service;
-
-import com.jfinal.kit.Kv;
-import com.jfinal.kit.PathKit;
-import com.jfinal.kit.StrKit;
-import com.jfinal.plugin.activerecord.generator.BaseModelGenerator;
-import com.jfinal.plugin.activerecord.generator.TableMeta;
-import com.jfinal.template.Engine;
-import com.jfinal.template.source.ClassPathSourceFactory;
-
-import java.io.File;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.util.List;
-
-public class JbootServiceImplGenerator extends BaseModelGenerator {
-
- String basePackage;
- String modelPackage;
-
- public JbootServiceImplGenerator(String basePackage, String modelPackage) {
- super(basePackage + ".impl", PathKit.getWebRootPath() + "/src/main/java/" + (basePackage + ".impl").replace(".", "/"));
-
- this.basePackage = basePackage;
- this.modelPackage = modelPackage;
- this.template = "io/jboot/codegen/service/service_impl_template.jf";
-
-
- }
-
- @Override
- public void generate(List
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.jboot.codegen.service;
+
+import com.jfinal.kit.Kv;
+import com.jfinal.kit.PathKit;
+import com.jfinal.kit.StrKit;
+import com.jfinal.plugin.activerecord.generator.BaseModelGenerator;
+import com.jfinal.plugin.activerecord.generator.TableMeta;
+import com.jfinal.template.Engine;
+import com.jfinal.template.source.ClassPathSourceFactory;
+
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.List;
+
+public class JbootServiceImplGenerator extends BaseModelGenerator {
+
+ String basePackage;
+ String modelPackage;
+
+ public JbootServiceImplGenerator(String basePackage, String modelPackage) {
+ super(basePackage + ".impl", PathKit.getWebRootPath() + "/src/main/java/" + (basePackage + ".impl").replace(".", "/"));
+
+ this.basePackage = basePackage;
+ this.modelPackage = modelPackage;
+ this.template = "io/jboot/codegen/service/service_impl_template.jf";
+
+
+ }
+
+ @Override
+ public void generate(List
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package io.jboot.codegen.service;
-
-import com.jfinal.kit.Kv;
-import com.jfinal.kit.PathKit;
-import com.jfinal.kit.StrKit;
-import com.jfinal.plugin.activerecord.generator.BaseModelGenerator;
-import com.jfinal.plugin.activerecord.generator.TableMeta;
-import com.jfinal.template.Engine;
-import com.jfinal.template.source.ClassPathSourceFactory;
-
-import java.io.File;
-import java.io.FileWriter;
-import java.io.IOException;
-import java.util.List;
-
-public class JbootServiceInterfaceGenerator extends BaseModelGenerator {
-
- private String modelPacket;
- private String basePackage;
-
- public JbootServiceInterfaceGenerator(String basePackage, String modelPacket) {
- super(basePackage, PathKit.getWebRootPath() + "/src/main/java/" + basePackage.replace(".", "/"));
-
-
- this.modelPacket = modelPacket;
- this.basePackage = basePackage;
- this.template = "io/jboot/codegen/service/service_template.jf";
-
- }
-
- @Override
- public void generate(List
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.jboot.codegen.service;
+
+import com.jfinal.kit.Kv;
+import com.jfinal.kit.PathKit;
+import com.jfinal.kit.StrKit;
+import com.jfinal.plugin.activerecord.generator.BaseModelGenerator;
+import com.jfinal.plugin.activerecord.generator.TableMeta;
+import com.jfinal.template.Engine;
+import com.jfinal.template.source.ClassPathSourceFactory;
+
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.util.List;
+
+public class JbootServiceInterfaceGenerator extends BaseModelGenerator {
+
+ private String modelPacket;
+ private String basePackage;
+
+ public JbootServiceInterfaceGenerator(String basePackage, String modelPacket) {
+ super(basePackage, PathKit.getWebRootPath() + "/src/main/java/" + basePackage.replace(".", "/"));
+
+
+ this.modelPacket = modelPacket;
+ this.basePackage = basePackage;
+ this.template = "io/jboot/codegen/service/service_template.jf";
+
+ }
+
+ @Override
+ public void generate(List
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package io.jboot.core.http.jboot;
-
-import com.jfinal.log.Log;
-import io.jboot.core.http.JbootHttpBase;
-import io.jboot.core.http.JbootHttpRequest;
-import io.jboot.core.http.JbootHttpResponse;
-import io.jboot.exception.JbootException;
-import io.jboot.utils.ArrayUtils;
-import io.jboot.utils.StringUtils;
-
-import javax.net.ssl.*;
-import java.io.*;
-import java.net.HttpURLConnection;
-import java.net.ProtocolException;
-import java.net.URL;
-import java.security.KeyStore;
-import java.security.SecureRandom;
-import java.security.cert.X509Certificate;
-import java.util.Map;
-
-
-public class JbootHttpImpl extends JbootHttpBase {
-
- private static final Log LOG = Log.getLog(JbootHttpImpl.class);
-
-
- @Override
- public JbootHttpResponse handle(JbootHttpRequest request) {
-
- JbootHttpResponse response = request.getDownloadFile() == null
- ? new JbootHttpResponse()
- : new JbootHttpResponse(request.getDownloadFile());
- doProcess(request, response);
- return response;
- }
-
-
- private void doProcess(JbootHttpRequest request, JbootHttpResponse response) {
- HttpURLConnection connection = null;
- InputStream stream = null;
- try {
-
- connection = getConnection(request);
- configConnection(connection, request);
-
-
- if (request.isGetRquest()) {
-
- connection.setInstanceFollowRedirects(true);
- connection.connect();
- }
- /**
- * 处理 post请求
- */
- else if (request.isPostRquest()) {
-
- connection.setRequestMethod("POST");
- connection.setDoOutput(true);
-
- /**
- * 处理 非文件上传的 post 请求
- */
- if (!request.isMultipartFormData()) {
-
- String postContent = buildParams(request);
- if (StringUtils.isNotEmpty(postContent)) {
- DataOutputStream dos = new DataOutputStream(connection.getOutputStream());
- dos.write(postContent.getBytes(request.getCharset()));
- dos.flush();
- dos.close();
- }
-
- }
-
- /**
- * 处理文件上传的post请求
- */
- else {
-
- if (ArrayUtils.isNotEmpty(request.getParams())) {
- uploadData(request, connection);
- }
-
- }
- }
-
- stream = getInutStream(connection);
-
- response.setContentType(connection.getContentType());
- response.setResponseCode(connection.getResponseCode());
- response.setHeaders(connection.getHeaderFields());
-
- response.pipe(stream);
- response.finish();
-
- } catch (Throwable ex) {
- LOG.warn(ex.toString(), ex);
- response.setError(ex);
- } finally {
- if (connection != null) {
- connection.disconnect();
- }
- if (stream != null) {
- try {
- stream.close();
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- }
- }
-
- private InputStream getInutStream(HttpURLConnection connection) throws IOException {
- return connection.getResponseCode() >= 400 ? connection.getErrorStream() : connection.getInputStream();
- }
-
- private void uploadData(JbootHttpRequest request, HttpURLConnection connection) throws IOException {
- String endFlag = "\r\n";
- String boundary = "---------" + StringUtils.uuid();
- connection.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary);
- DataOutputStream dos = new DataOutputStream(connection.getOutputStream());
- for (Map.Entry entry : request.getParams().entrySet()) {
- if (entry.getValue() instanceof File) {
- File file = (File) entry.getValue();
- checkFileNormal(file);
- dos.writeBytes(boundary + endFlag);
- dos.writeBytes(String.format("Content-Disposition: form-data; name=\"%s\"; filename=\"%s\"", entry.getKey(), file.getName()) + endFlag);
- dos.writeBytes(endFlag);
- FileInputStream fStream = new FileInputStream(file);
- byte[] buffer = new byte[2028];
- for (int len = 0; (len = fStream.read(buffer)) > 0; ) {
- dos.write(buffer, 0, len);
- }
-
- dos.writeBytes(endFlag);
- } else {
- dos.writeBytes("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"");
- dos.writeBytes(endFlag);
- dos.writeBytes(endFlag);
- dos.writeBytes(String.valueOf(entry.getValue()));
- dos.writeBytes(endFlag);
- }
- }
-
- dos.writeBytes("--" + boundary + "--" + endFlag);
- }
-
- private static void checkFileNormal(File file) {
- if (!file.exists()) {
- throw new JbootException("file not exists!!!!" + file);
- }
- if (file.isDirectory()) {
- throw new JbootException("cannot upload directory!!!!" + file);
- }
- if (!file.canRead()) {
- throw new JbootException("cannnot read file!!!" + file);
- }
- }
-
-
- private static void configConnection(HttpURLConnection connection, JbootHttpRequest request) throws ProtocolException {
- if (connection == null)
- return;
- connection.setReadTimeout(request.getReadTimeOut());
- connection.setConnectTimeout(request.getConnectTimeOut());
- connection.setRequestMethod(request.getMethod());
-
-
- connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
- connection.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.146 Safari/537.36");
- if (request.getHeaders() != null && request.getHeaders().size() > 0) {
- for (Map.Entry
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.jboot.core.http.jboot;
+
+import com.jfinal.log.Log;
+import io.jboot.core.http.JbootHttpBase;
+import io.jboot.core.http.JbootHttpRequest;
+import io.jboot.core.http.JbootHttpResponse;
+import io.jboot.exception.JbootException;
+import io.jboot.utils.ArrayUtils;
+import io.jboot.utils.StringUtils;
+
+import javax.net.ssl.*;
+import java.io.*;
+import java.net.HttpURLConnection;
+import java.net.ProtocolException;
+import java.net.URL;
+import java.security.KeyStore;
+import java.security.SecureRandom;
+import java.security.cert.X509Certificate;
+import java.util.Map;
+
+
+public class JbootHttpImpl extends JbootHttpBase {
+
+ private static final Log LOG = Log.getLog(JbootHttpImpl.class);
+
+
+ @Override
+ public JbootHttpResponse handle(JbootHttpRequest request) {
+
+ JbootHttpResponse response = request.getDownloadFile() == null
+ ? new JbootHttpResponse()
+ : new JbootHttpResponse(request.getDownloadFile());
+ doProcess(request, response);
+ return response;
+ }
+
+
+ private void doProcess(JbootHttpRequest request, JbootHttpResponse response) {
+ HttpURLConnection connection = null;
+ InputStream stream = null;
+ try {
+
+ connection = getConnection(request);
+ configConnection(connection, request);
+
+
+ if (request.isGetRquest()) {
+
+ connection.setInstanceFollowRedirects(true);
+ connection.connect();
+ }
+ /**
+ * 处理 post请求
+ */
+ else if (request.isPostRquest()) {
+
+ connection.setRequestMethod("POST");
+ connection.setDoOutput(true);
+
+ /**
+ * 处理 非文件上传的 post 请求
+ */
+ if (!request.isMultipartFormData()) {
+
+ String postContent = buildParams(request);
+ if (StringUtils.isNotEmpty(postContent)) {
+ DataOutputStream dos = null;
+ try {
+ dos = new DataOutputStream(connection.getOutputStream());
+ dos.write(postContent.getBytes(request.getCharset()));
+ dos.flush();
+ } finally {
+ if (dos!=null) {
+ try {
+ dos.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+
+ }
+
+ }
+
+ /**
+ * 处理文件上传的post请求
+ */
+ else {
+
+ if (ArrayUtils.isNotEmpty(request.getParams())) {
+ uploadData(request, connection);
+ }
+
+ }
+ }
+
+ stream = getInutStream(connection);
+
+ response.setContentType(connection.getContentType());
+ response.setResponseCode(connection.getResponseCode());
+ response.setHeaders(connection.getHeaderFields());
+
+ response.pipe(stream);
+ response.finish();
+
+ } catch (Throwable ex) {
+ LOG.warn(ex.toString(), ex);
+ response.setError(ex);
+ } finally {
+ if (connection != null) {
+ connection.disconnect();
+ }
+ if (stream != null) {
+ try {
+ stream.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+
+ private InputStream getInutStream(HttpURLConnection connection) throws IOException {
+ return connection.getResponseCode() >= 400 ? connection.getErrorStream() : connection.getInputStream();
+ }
+
+ private void uploadData(JbootHttpRequest request, HttpURLConnection connection) throws IOException {
+ String endFlag = "\r\n";
+ String boundary = "---------" + StringUtils.uuid();
+ connection.setRequestProperty("Content-Type", "multipart/form-data;boundary=" + boundary);
+ DataOutputStream dos = new DataOutputStream(connection.getOutputStream());
+ for (Map.Entry entry : request.getParams().entrySet()) {
+ if (entry.getValue() instanceof File) {
+ File file = (File) entry.getValue();
+ checkFileNormal(file);
+ dos.writeBytes(boundary + endFlag);
+ dos.writeBytes(String.format("Content-Disposition: form-data; name=\"%s\"; filename=\"%s\"", entry.getKey(), file.getName()) + endFlag);
+ dos.writeBytes(endFlag);
+ try(FileInputStream fStream = new FileInputStream(file)){
+ byte[] buffer = new byte[2028];
+ for (int len = 0; (len = fStream.read(buffer)) > 0; ) {
+ dos.write(buffer, 0, len);
+ }
+ }
+ dos.writeBytes(endFlag);
+ } else {
+ dos.writeBytes("Content-Disposition: form-data; name=\"" + entry.getKey() + "\"");
+ dos.writeBytes(endFlag);
+ dos.writeBytes(endFlag);
+ dos.writeBytes(String.valueOf(entry.getValue()));
+ dos.writeBytes(endFlag);
+ }
+ }
+
+ dos.writeBytes("--" + boundary + "--" + endFlag);
+ }
+
+ private static void checkFileNormal(File file) {
+ if (!file.exists()) {
+ throw new JbootException("file not exists!!!!" + file);
+ }
+ if (file.isDirectory()) {
+ throw new JbootException("cannot upload directory!!!!" + file);
+ }
+ if (!file.canRead()) {
+ throw new JbootException("cannnot read file!!!" + file);
+ }
+ }
+
+
+ private static void configConnection(HttpURLConnection connection, JbootHttpRequest request) throws ProtocolException {
+ if (connection == null)
+ return;
+ connection.setReadTimeout(request.getReadTimeOut());
+ connection.setConnectTimeout(request.getConnectTimeOut());
+ connection.setRequestMethod(request.getMethod());
+
+
+ connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
+ connection.setRequestProperty("User-Agent", "Mozilla/5.0 (Windows NT 6.3; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/33.0.1750.146 Safari/537.36");
+ if (request.getHeaders() != null && request.getHeaders().size() > 0) {
+ for (Map.Entry
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package io.jboot.core.rpc;
-
-import io.jboot.Jboot;
-import io.jboot.core.rpc.annotation.JbootrpcService;
-import io.jboot.utils.StringUtils;
-
-import java.io.Serializable;
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @author Michael Yang 杨福海 （fuhai999@gmail.com）
- * @version V1.0
- * @Package io.jboot.core.rpc
- */
-public class JbootrpcServiceConfig implements Serializable {
-
-
- private int port = 0;
- private String group;
- private String version;
- private Integer timeout;
- private Integer retries;
- private Integer actives;
- private String loadbalance;
- private Boolean async;
- private Boolean check;
-
-
- private String proxy;
- private String filter;
-
- // 用于扩展，用户通过SPI扩展获取自定义的 Service的时候，
- // 若以字段不满足，此时通过 params 自行扩展
- private Map
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.jboot.core.rpc;
+
+import io.jboot.Jboot;
+import io.jboot.core.rpc.annotation.JbootrpcService;
+import io.jboot.utils.StringUtils;
+
+import java.io.Serializable;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author Michael Yang 杨福海 （fuhai999@gmail.com）
+ * @version V1.0
+ * @Package io.jboot.core.rpc
+ */
+public class JbootrpcServiceConfig implements Serializable {
+
+
+ private int port = 0;
+ private String group;
+ private String version;
+ private Integer timeout;
+ private Integer retries;
+ private Integer actives;
+ private String loadbalance;
+ private Boolean async;
+ private Boolean check;
+
+
+ private String proxy;
+ private String filter;
+
+ // 用于扩展，用户通过SPI扩展获取自定义的 Service的时候，
+ // 若以字段不满足，此时通过 params 自行扩展
+ private Map
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package io.jboot.utils;
-
-import com.jfinal.core.JFinal;
-import com.jfinal.kit.PathKit;
-
-import java.io.*;
-import java.util.Enumeration;
-import java.util.zip.ZipEntry;
-import java.util.zip.ZipFile;
-
-
-public class FileUtils {
-
- public static String getSuffix(String fileName) {
- if (fileName != null && fileName.contains(".")) {
- return fileName.substring(fileName.lastIndexOf("."));
- }
- return null;
- }
-
-
- public static String removePrefix(String src, String prefix) {
- if (src != null && src.startsWith(prefix)) {
- return src.substring(prefix.length());
- }
- return src;
- }
-
-
- public static String removeRootPath(String src){
- return removePrefix(src, PathKit.getWebRootPath());
- }
-
- public static String readString(File file) {
- ByteArrayOutputStream baos = null;
- FileInputStream fis = null;
- try {
- fis = new FileInputStream(file);
- baos = new ByteArrayOutputStream();
- byte[] buffer = new byte[1024];
- for (int len = 0; (len = fis.read(buffer)) > 0;) {
- baos.write(buffer, 0, len);
- }
- return new String(baos.toByteArray(), JFinal.me().getConstants().getEncoding());
- } catch (Exception e) {
- } finally {
- close(fis, baos);
- }
- return null;
- }
-
- public static void writeString(File file, String string) {
- FileOutputStream fos = null;
- try {
- fos = new FileOutputStream(file, false);
- fos.write(string.getBytes(JFinal.me().getConstants().getEncoding()));
- } catch (Exception e) {
- } finally {
- close(null, fos);
- }
- }
-
- private static void close(InputStream is, OutputStream os) {
- if (is != null)
- try {
- is.close();
- } catch (IOException e) {
- }
- if (os != null)
- try {
- os.close();
- } catch (IOException e) {
- }
- }
-
- public static void unzip(String zipFilePath) throws IOException {
- String targetPath = zipFilePath.substring(0, zipFilePath.lastIndexOf("."));
- unzip(zipFilePath, targetPath);
- }
-
- public static void unzip(String zipFilePath, String targetPath) throws IOException {
- ZipFile zipFile = new ZipFile(zipFilePath);
- try{
- Enumeration entryEnum = zipFile.entries();
- if (null != entryEnum) {
- while (entryEnum.hasMoreElements()) {
- OutputStream os = null;
- InputStream is = null;
- try {
- ZipEntry zipEntry = (ZipEntry) entryEnum.nextElement();
- if (!zipEntry.isDirectory()) {
- File targetFile = new File(targetPath + File.separator + zipEntry.getName());
- if (!targetFile.getParentFile().exists()) {
- targetFile.getParentFile().mkdirs();
- }
- os = new BufferedOutputStream(new FileOutputStream(targetFile));
- is = zipFile.getInputStream(zipEntry);
- byte[] buffer = new byte[4096];
- int readLen = 0;
- while ((readLen = is.read(buffer, 0, 4096)) > 0) {
- os.write(buffer, 0, readLen);
- }
- }
- } finally {
- if (is != null)
- is.close();
- if (os != null)
- os.close();
- }
- }
- }
- }finally{
- zipFile.close();
- }
- }
-
+/**
+ * Copyright (c) 2015-2018, Michael Yang 杨福海 (fuhai999@gmail.com).
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package io.jboot.utils;
+
+import com.jfinal.core.JFinal;
+import com.jfinal.kit.PathKit;
+
+import java.io.*;
+import java.util.Enumeration;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipFile;
+
+
+public class FileUtils {
+
+ public static String getSuffix(String fileName) {
+ if (fileName != null && fileName.contains(".")) {
+ return fileName.substring(fileName.lastIndexOf("."));
+ }
+ return null;
+ }
+
+
+ public static String removePrefix(String src, String prefix) {
+ if (src != null && src.startsWith(prefix)) {
+ return src.substring(prefix.length());
+ }
+ return src;
+ }
+
+
+ public static String removeRootPath(String src){
+ return removePrefix(src, PathKit.getWebRootPath());
+ }
+
+ public static String readString(File file) {
+ ByteArrayOutputStream baos = null;
+ FileInputStream fis = null;
+ try {
+ fis = new FileInputStream(file);
+ baos = new ByteArrayOutputStream();
+ byte[] buffer = new byte[1024];
+ for (int len = 0; (len = fis.read(buffer)) > 0;) {
+ baos.write(buffer, 0, len);
+ }
+ return new String(baos.toByteArray(), JFinal.me().getConstants().getEncoding());
+ } catch (Exception e) {
+ } finally {
+ close(fis, baos);
+ }
+ return null;
+ }
+
+ public static void writeString(File file, String string) {
+ FileOutputStream fos = null;
+ try {
+ fos = new FileOutputStream(file, false);
+ fos.write(string.getBytes(JFinal.me().getConstants().getEncoding()));
+ } catch (Exception e) {
+ } finally {
+ close(null, fos);
+ }
+ }
+
+ private static void close(InputStream is, OutputStream os) {
+ if (is != null)
+ try {
+ is.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ if (os != null)
+ try {
+ os.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public static void unzip(String zipFilePath) throws IOException {
+ String targetPath = zipFilePath.substring(0, zipFilePath.lastIndexOf("."));
+ unzip(zipFilePath, targetPath);
+ }
+
+ public static void unzip(String zipFilePath, String targetPath) throws IOException {
+ ZipFile zipFile = new ZipFile(zipFilePath);
+ try{
+ Enumeration entryEnum = zipFile.entries();
+ if (null != entryEnum) {
+ while (entryEnum.hasMoreElements()) {
+ OutputStream os = null;
+ InputStream is = null;
+ try {
+ ZipEntry zipEntry = (ZipEntry) entryEnum.nextElement();
+ if (!zipEntry.isDirectory()) {
+ File targetFile = new File(targetPath + File.separator + zipEntry.getName());
+ if (!targetFile.getParentFile().exists()) {
+ targetFile.getParentFile().mkdirs();
+ }
+ os = new BufferedOutputStream(new FileOutputStream(targetFile));
+ is = zipFile.getInputStream(zipEntry);
+ byte[] buffer = new byte[4096];
+ int readLen = 0;
+ while ((readLen = is.read(buffer, 0, 4096)) > 0) {
+ os.write(buffer, 0, readLen);
+ }
+ }
+ } finally {
+ close(is,os);
+ }
+ }
+ }
+ }finally{
+ if(zipFile != null) {
+ try {
+ zipFile.close();
+ } catch (IOException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ }
+
}
\ No newline at end of file