|
|
|
@ -4,6 +4,8 @@ import cn.hutool.json.JSONObject;
|
|
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
|
|
import com.dsideal.gw.GwApplication;
|
|
|
|
|
import com.jfinal.handler.Handler;
|
|
|
|
|
import com.jfinal.upload.MultipartRequest;
|
|
|
|
|
import com.jfinal.upload.UploadFile;
|
|
|
|
|
import okhttp3.*;
|
|
|
|
|
|
|
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
|
@ -11,6 +13,7 @@ import javax.servlet.http.HttpServletResponse;
|
|
|
|
|
import javax.servlet.http.Part;
|
|
|
|
|
import java.io.*;
|
|
|
|
|
import java.util.Enumeration;
|
|
|
|
|
import java.util.List;
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
public class RouterHandler extends Handler {
|
|
|
|
@ -39,9 +42,12 @@ public class RouterHandler extends Handler {
|
|
|
|
|
* GET
|
|
|
|
|
* http://10.10.21.20:8000/dsBase/dm/getDmSchoolProperty
|
|
|
|
|
* http://10.10.21.20:8000/dsBase/global/getGlobalList?page=1&limit=10
|
|
|
|
|
* <p>
|
|
|
|
|
* POST
|
|
|
|
|
* http://10.10.21.20:8000/dsBase/global/testPost?a=100
|
|
|
|
|
* 上传文件
|
|
|
|
|
* http://10.10.21.20:8000/dsBase/global/testUpload
|
|
|
|
|
* form-data
|
|
|
|
|
* upfile --->参数值:选择一个文件 类型:file
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
//OkHttp的实例,单例模式
|
|
|
|
@ -122,70 +128,74 @@ public class RouterHandler extends Handler {
|
|
|
|
|
} else {
|
|
|
|
|
//路由到哪个微服务
|
|
|
|
|
String FORWARD_URL = GwApplication.routeList.get(prefix) + "/" + prefix + "/" + action;
|
|
|
|
|
//处理GET请求
|
|
|
|
|
if (req.getMethod().equals("GET")) {
|
|
|
|
|
//参数:queryString
|
|
|
|
|
Request request;
|
|
|
|
|
if (queryString != null) {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL + "?" + queryString).get().build();
|
|
|
|
|
} else {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL).get().build();
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
executeRequest(request, res);
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
JSONObject jo = new JSONObject();
|
|
|
|
|
jo.put("success", false);
|
|
|
|
|
jo.put("message", "请求失败!" + e);
|
|
|
|
|
renderJson(res, jo);
|
|
|
|
|
}
|
|
|
|
|
}//处理POST请求
|
|
|
|
|
else if (req.getMethod().equals("POST")) {
|
|
|
|
|
RequestBody body = createRequestBody(req);
|
|
|
|
|
Request request;
|
|
|
|
|
if (queryString != null) {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL + "?" + queryString).post(body).build();
|
|
|
|
|
} else {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL).post(body).build();
|
|
|
|
|
}
|
|
|
|
|
//上传文件
|
|
|
|
|
if (req.getContentType().startsWith("multipart/form-data")) {
|
|
|
|
|
// 指定文件类型
|
|
|
|
|
MediaType mediaType = MediaType.parse("multipart/form-data");
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
MultipartRequest mp = new MultipartRequest(req);
|
|
|
|
|
List<UploadFile> files = mp.getFiles();
|
|
|
|
|
if (files.isEmpty()) {
|
|
|
|
|
JSONObject jo = new JSONObject();
|
|
|
|
|
jo.put("success", false);
|
|
|
|
|
jo.put("message", "没有上传文件!");
|
|
|
|
|
renderJson(res, jo);
|
|
|
|
|
isHandled[0] = true;//停止filter
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
UploadFile fu = files.getFirst();
|
|
|
|
|
// 获取文件流
|
|
|
|
|
RequestBody requestBody = RequestBody.create(fu.getFile(), mediaType);
|
|
|
|
|
// 构建MultipartBody
|
|
|
|
|
MultipartBody body = new MultipartBody.Builder()
|
|
|
|
|
.setType(MultipartBody.FORM)
|
|
|
|
|
.addFormDataPart("file", fu.getFileName(), requestBody)
|
|
|
|
|
.build();
|
|
|
|
|
|
|
|
|
|
// 构建Request
|
|
|
|
|
Request request = new Request.Builder()
|
|
|
|
|
.url(FORWARD_URL)
|
|
|
|
|
.post(body)
|
|
|
|
|
.build();
|
|
|
|
|
executeRequest(request, res);
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
JSONObject jo = new JSONObject();
|
|
|
|
|
jo.put("success", false);
|
|
|
|
|
jo.put("message", "请求失败!" + e);
|
|
|
|
|
renderJson(res, jo);
|
|
|
|
|
}
|
|
|
|
|
} else //上传文件
|
|
|
|
|
if (req.getContentType().startsWith("multipart/form-data")) {
|
|
|
|
|
// 指定文件类型
|
|
|
|
|
MediaType mediaType = MediaType.parse("multipart/form-data");
|
|
|
|
|
|
|
|
|
|
} else
|
|
|
|
|
//处理GET请求
|
|
|
|
|
if (req.getMethod().equals("GET")) {
|
|
|
|
|
//参数:queryString
|
|
|
|
|
Request request;
|
|
|
|
|
if (queryString != null) {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL + "?" + queryString).get().build();
|
|
|
|
|
} else {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL).get().build();
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
executeRequest(request, res);
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
JSONObject jo = new JSONObject();
|
|
|
|
|
jo.put("success", false);
|
|
|
|
|
jo.put("message", "请求失败!" + e);
|
|
|
|
|
renderJson(res, jo);
|
|
|
|
|
}
|
|
|
|
|
}//处理POST请求
|
|
|
|
|
else if (req.getMethod().equals("POST")) {
|
|
|
|
|
RequestBody body = createRequestBody(req);
|
|
|
|
|
Request request;
|
|
|
|
|
if (queryString != null) {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL + "?" + queryString).post(body).build();
|
|
|
|
|
} else {
|
|
|
|
|
request = new Request.Builder().url(FORWARD_URL).post(body).build();
|
|
|
|
|
}
|
|
|
|
|
try {
|
|
|
|
|
// 获取上传的文件
|
|
|
|
|
Part filePart = req.getPart("file");
|
|
|
|
|
if (filePart == null) {
|
|
|
|
|
res.setStatus(HttpServletResponse.SC_BAD_REQUEST);
|
|
|
|
|
res.getWriter().write("No file uploaded");
|
|
|
|
|
//停止filter
|
|
|
|
|
isHandled[0] = true;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
// 获取文件流
|
|
|
|
|
RequestBody requestBody = RequestBody.create(convertPartToByteArray(filePart), mediaType, (int) filePart.getSize());
|
|
|
|
|
// 构建MultipartBody
|
|
|
|
|
MultipartBody body = new MultipartBody.Builder()
|
|
|
|
|
.setType(MultipartBody.FORM)
|
|
|
|
|
.addFormDataPart("file", filePart.getSubmittedFileName(), requestBody)
|
|
|
|
|
.build();
|
|
|
|
|
|
|
|
|
|
// 构建Request
|
|
|
|
|
Request request = new Request.Builder()
|
|
|
|
|
.url(FORWARD_URL)
|
|
|
|
|
.post(body)
|
|
|
|
|
.build();
|
|
|
|
|
executeRequest(request, res);
|
|
|
|
|
} catch (Exception e) {
|
|
|
|
|
} catch (IOException e) {
|
|
|
|
|
JSONObject jo = new JSONObject();
|
|
|
|
|
jo.put("success", false);
|
|
|
|
|
jo.put("message", "请求失败!" + e);
|
|
|
|
|