Skip to content

X
XXL-JOB
提交 17b416ca authored 作者: xuxueli's avatar xuxueli
浏览文件
操作

通用HTTP任务Handler（httpJobHandler）优化：修复 "setDoOutput(true)" 导致任务请求GetMethod失效问题；

上级 16ba18ea
隐藏空白字符变更
内嵌 并排
正在显示 包含 19 行增加 和 13 行删除
xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java
浏览文件 @ 17b416ca
...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java
浏览文件 @ 17b416ca
...@@ -51,8 +51,9 @@ public class HttpJobHandler extends IJobHandler { ...@@ -51,8 +51,9 @@ public class HttpJobHandler extends IJobHandler {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
BufferedReader bufferedReader = null; BufferedReader bufferedReader = null;
try { try {
...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java
浏览文件 @ 17b416ca
...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java
浏览文件 @ 17b416ca
...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { ...@@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java
浏览文件 @ 17b416ca
...@@ -151,6 +151,7 @@ public class SampleXxlJob { ...@@ -151,6 +151,7 @@ public class SampleXxlJob {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
...@@ -162,7 +163,7 @@ public class SampleXxlJob { ...@@ -162,7 +163,7 @@ public class SampleXxlJob {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -175,7 +176,7 @@ public class SampleXxlJob { ...@@ -175,7 +176,7 @@ public class SampleXxlJob {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java
浏览文件 @ 17b416ca
...@@ -151,6 +151,7 @@ public class SampleXxlJob { ...@@ -151,6 +151,7 @@ public class SampleXxlJob {
XxlJobLogger.log("method["+ method +"] invalid."); XxlJobLogger.log("method["+ method +"] invalid.");
return ReturnT.FAIL; return ReturnT.FAIL;
} }
boolean isPostMethod = method.equals("POST");
// request // request
HttpURLConnection connection = null; HttpURLConnection connection = null;
...@@ -162,7 +163,7 @@ public class SampleXxlJob { ...@@ -162,7 +163,7 @@ public class SampleXxlJob {
// connection setting // connection setting
connection.setRequestMethod(method); connection.setRequestMethod(method);
connection.setDoOutput(true); connection.setDoOutput(isPostMethod);
connection.setDoInput(true); connection.setDoInput(true);
connection.setUseCaches(false); connection.setUseCaches(false);
connection.setReadTimeout(5 * 1000); connection.setReadTimeout(5 * 1000);
...@@ -175,7 +176,7 @@ public class SampleXxlJob { ...@@ -175,7 +176,7 @@ public class SampleXxlJob {
connection.connect(); connection.connect();
// data // data
if (data!=null && data.trim().length()>0) { if (isPostMethod && data!=null && data.trim().length()>0) {
DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.write(data.getBytes("UTF-8"));
dataOutputStream.flush(); dataOutputStream.flush();
......
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论