|
@@ -123,22 +123,10 @@ public class EartagServerHandler2 extends ChannelInboundHandlerAdapter {
|
|
int countPlus = regexUtil.countPlus(clientAskText);
|
|
int countPlus = regexUtil.countPlus(clientAskText);
|
|
if (countPlus < 4) {
|
|
if (countPlus < 4) {
|
|
System.out.println("当前数据为不完整数据,故丢弃.>>" + clientAskText);
|
|
System.out.println("当前数据为不完整数据,故丢弃.>>" + clientAskText);
|
|
- HashMap<String, String> paramsMap = new HashMap<>();
|
|
|
|
- JSONObject jsonObject = new JSONObject();
|
|
|
|
- jsonObject.put("result", clientAskText);
|
|
|
|
- paramsMap.put("Content-Type", "application/json;charset=utf-8");
|
|
|
|
- String post = HttpRequest.post("http://115.238.57.190:8010/test01/test3")
|
|
|
|
- .headerMap(paramsMap, false).body(jsonObject.toJSONString()).timeout(30 * 1000).execute().body();
|
|
|
|
} else {
|
|
} else {
|
|
//--处理客户端请求数据
|
|
//--处理客户端请求数据
|
|
//{拆分粘包数据}
|
|
//{拆分粘包数据}
|
|
JSONArray askJa = getPerData(clientAskText);
|
|
JSONArray askJa = getPerData(clientAskText);
|
|
- HashMap<String, String> paramsMap = new HashMap<>();
|
|
|
|
- JSONObject jsonObject = new JSONObject();
|
|
|
|
- jsonObject.put("result", askJa);
|
|
|
|
- paramsMap.put("Content-Type", "application/json;charset=utf-8");
|
|
|
|
- String post = HttpRequest.post("http://115.238.57.190:8010/test01/test3")
|
|
|
|
- .headerMap(paramsMap, false).body(jsonObject.toJSONString()).timeout(30 * 1000).execute().body();
|
|
|
|
for (int a = 0; a < askJa.size(); a++) {
|
|
for (int a = 0; a < askJa.size(); a++) {
|
|
String askText = askJa.getString(a);
|
|
String askText = askJa.getString(a);
|
|
//{处理请求内容2}
|
|
//{处理请求内容2}
|