diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java index eeb8e3cd..ea44695e 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/jobhandler/HttpJobHandler.java @@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); // request HttpURLConnection connection = null; @@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush(); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java index 08a5d015..68a27b39 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-jboot/src/main/java/com/xuxueli/executor/sample/jboot/jobhandler/HttpJobHandler.java @@ -51,8 +51,9 @@ public class HttpJobHandler extends IJobHandler { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); - // request + // request HttpURLConnection connection = null; BufferedReader bufferedReader = null; try { @@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush(); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java index 414d8e25..ae1dbb65 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-jfinal/src/main/java/com/xuxueli/executor/sample/jfinal/jobhandler/HttpJobHandler.java @@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); // request HttpURLConnection connection = null; @@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush(); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java index c09dd590..837000be 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-nutz/src/main/java/com/xuxueli/executor/sample/nutz/jobhandler/HttpJobHandler.java @@ -51,6 +51,7 @@ public class HttpJobHandler extends IJobHandler { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); // request HttpURLConnection connection = null; @@ -62,7 +63,7 @@ public class HttpJobHandler extends IJobHandler { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -75,7 +76,7 @@ public class HttpJobHandler extends IJobHandler { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush(); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java index bde06693..666d2d3e 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-spring/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java @@ -151,6 +151,7 @@ public class SampleXxlJob { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); // request HttpURLConnection connection = null; @@ -162,7 +163,7 @@ public class SampleXxlJob { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -175,7 +176,7 @@ public class SampleXxlJob { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush(); diff --git a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java index bde06693..666d2d3e 100644 --- a/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java +++ b/xxl-job-executor-samples/xxl-job-executor-sample-springboot/src/main/java/com/xxl/job/executor/service/jobhandler/SampleXxlJob.java @@ -151,6 +151,7 @@ public class SampleXxlJob { XxlJobLogger.log("method["+ method +"] invalid."); return ReturnT.FAIL; } + boolean isPostMethod = method.equals("POST"); // request HttpURLConnection connection = null; @@ -162,7 +163,7 @@ public class SampleXxlJob { // connection setting connection.setRequestMethod(method); - connection.setDoOutput(true); + connection.setDoOutput(isPostMethod); connection.setDoInput(true); connection.setUseCaches(false); connection.setReadTimeout(5 * 1000); @@ -175,7 +176,7 @@ public class SampleXxlJob { connection.connect(); // data - if (data!=null && data.trim().length()>0) { + if (isPostMethod && data!=null && data.trim().length()>0) { DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream()); dataOutputStream.write(data.getBytes("UTF-8")); dataOutputStream.flush();