Commit 4b4be57a authored by 赵啸非's avatar 赵啸非

修改配置文件

parent 85de867e
package com.mortals.xhx.busiz.web; package com.mortals.xhx.busiz.web;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.mortals.framework.annotation.UnAuth; import com.mortals.framework.annotation.UnAuth;
import com.mortals.framework.common.Rest; import com.mortals.framework.common.Rest;
import com.mortals.xhx.busiz.rsp.ApiResp; import com.mortals.xhx.busiz.rsp.ApiResp;
...@@ -104,7 +105,14 @@ public class ProxyController { ...@@ -104,7 +105,14 @@ public class ProxyController {
log.info("proxyPost params: {}, body: {}, headers: {}", params, body, headers); log.info("proxyPost params: {}, body: {}, headers: {}", params, body, headers);
ApiResp<String> rsp = new ApiResp<>(); ApiResp<String> rsp = new ApiResp<>();
String path = params.getOrDefault("path", ""); // String path = params.getOrDefault("path", "");
JSONObject req = JSON.parseObject(body);
String method = req.getString("method");
String path = req.getString("path");
if (ObjectUtils.isEmpty(path)) { if (ObjectUtils.isEmpty(path)) {
rsp.setCode(ApiRespCodeEnum.FAILED.getValue()); rsp.setCode(ApiRespCodeEnum.FAILED.getValue());
rsp.setMsg("path is empty!"); rsp.setMsg("path is empty!");
...@@ -114,9 +122,17 @@ public class ProxyController { ...@@ -114,9 +122,17 @@ public class ProxyController {
// return ResponseEntity.ok().body(JSON.toJSONString(rsp)); // return ResponseEntity.ok().body(JSON.toJSONString(rsp));
} }
String method = params.getOrDefault("method", "post");
/* String method = params.getOrDefault("method", "post");
params.remove("method"); params.remove("method");
params.remove("path"); params.remove("path");*/
req.remove("method");
req.remove("path");
String targetUrl = "http://127.0.0.1:11078/basics_api" + path; // 目标 URL String targetUrl = "http://127.0.0.1:11078/basics_api" + path; // 目标 URL
// 拼接 Query 参数 // 拼接 Query 参数
...@@ -125,8 +141,8 @@ public class ProxyController { ...@@ -125,8 +141,8 @@ public class ProxyController {
HttpUrl url = urlBuilder.build(); HttpUrl url = urlBuilder.build();
// 构造请求体 // 构造请求体
okhttp3.RequestBody requestBody = body != null ? okhttp3.RequestBody requestBody = req.toJSONString() != null ?
okhttp3.RequestBody.create(MediaType.parse("application/json"), body) : okhttp3.RequestBody.create(MediaType.parse("application/json"), req.toJSONString()) :
okhttp3.RequestBody.create(null, new byte[0]); okhttp3.RequestBody.create(null, new byte[0]);
if ("post".equalsIgnoreCase(method)) { if ("post".equalsIgnoreCase(method)) {
...@@ -148,7 +164,7 @@ public class ProxyController { ...@@ -148,7 +164,7 @@ public class ProxyController {
return Rest.fail(response.code(), response.message()); return Rest.fail(response.code(), response.message());
// return ResponseEntity.status(response.code()).body(response.message()); // return ResponseEntity.status(response.code()).body(response.message());
} }
return Rest.ok("透传请求成功!",response.body().string()); return Rest.ok("透传请求成功!", response.body().string());
// return ResponseEntity.status(response.code()).body(response.body().string()); // return ResponseEntity.status(response.code()).body(response.body().string());
} catch (IOException e) { } catch (IOException e) {
...@@ -158,7 +174,10 @@ public class ProxyController { ...@@ -158,7 +174,10 @@ public class ProxyController {
// return ResponseEntity.ok().body(JSON.toJSONString(rsp)); // return ResponseEntity.ok().body(JSON.toJSONString(rsp));
} }
} else if ("get".equalsIgnoreCase(method)) { } else if ("get".equalsIgnoreCase(method)) {
//url拼接参数
Request.Builder requestBuilder = new Request.Builder() Request.Builder requestBuilder = new Request.Builder()
.put(requestBody)
.url(url) .url(url)
.get(); .get();
// 透传 Headers(过滤掉 Host 避免冲突) // 透传 Headers(过滤掉 Host 避免冲突)
...@@ -168,13 +187,15 @@ public class ProxyController { ...@@ -168,13 +187,15 @@ public class ProxyController {
} }
}); });
log.info("get透传请求地址:{}", JSON.toJSONString(requestBuilder));
// 发送请求 // 发送请求
try (Response response = client.newCall(requestBuilder.build()).execute()) { try (Response response = client.newCall(requestBuilder.build()).execute()) {
if (!response.isSuccessful()) { if (!response.isSuccessful()) {
return Rest.fail(response.code(), response.message()); return Rest.fail(response.code(), response.message());
//return ResponseEntity.status(response.code()).body(response.message()); //return ResponseEntity.status(response.code()).body(response.message());
} }
return Rest.ok("透传请求成功!",response.body().string()); return Rest.ok("透传请求成功!", response.body().string());
// return ResponseEntity.status(response.code()).body(response.body().string()); // return ResponseEntity.status(response.code()).body(response.body().string());
} catch (IOException e) { } catch (IOException e) {
rsp.setCode(ApiRespCodeEnum.FAILED.getValue()); rsp.setCode(ApiRespCodeEnum.FAILED.getValue());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment