From 5008ebdf22f4c2dfec7aced08b99a883fc6e408c Mon Sep 17 00:00:00 2001
From: zhangdaiscott <zhangdaiscott@163.com>
Date: Sun, 21 Feb 2021 14:45:49 +0800
Subject: [PATCH] 删除jeecg-cloud-example例子模块，测试示例重构到jeecg-cloud-system-start中
---
jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/controller/JcloudDemoController.java | 48 ++++++++++++++++++++++++++++++++++++++++++++++++
jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/provider/JcloudDemoProvider.java | 27 +++++++++++++++++++++++++++
jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/JcloudDemoService.java | 7 +++++++
jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/impl/JcloudDemoServiceImpl.java | 13 +++++++++++++
jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/handler/DemoJobHandler.java | 234 ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/Dockerfile | 16 ----------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/pom.xml | 53 -----------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/JeecgCloudExampleApplication.java | 17 -----------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/bus/DemoBusEvent.java | 26 --------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/job/DemoJobHandler.java | 234 ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/lock/DemoLockTest.java | 61 -------------------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener2.java | 28 ----------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener3.java | 29 -----------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/controller/JeecgDemoController.java | 48 ------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/provider/JeecgDemoProvider.java | 27 ---------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/JeecgDemoService.java | 7 -------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/impl/JeecgDemoServiceImpl.java | 13 -------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/resources/application.yml | 5 -----
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml | 19 +++++++++++++------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/JeecgSystemCloudApplication.java | 7 +++----
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/constant/CloudConstant.java | 30 ++++++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java | 27 +++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java | 61 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignTest.java | 39 ---------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/DemoFallback.java | 16 ----------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient.java | 4 +++-
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient2.java | 14 --------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClientDyn.java | 14 ++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/fallback/JeecgTestClientFallback.java | 17 +++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java | 65 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java | 11 +++++++++--
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java | 11 +++++++++--
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java | 35 +++++++++++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java | 7 +++++--
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/Demo2JobHandler.java | 57 ---------------------------------------------------------
jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/DemoJobHandler.java | 235 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
jeecg-boot/jeecg-cloud-module/pom.xml | 2 --
37 files changed, 621 insertions(+), 943 deletions(-)
create mode 100644 jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/controller/JcloudDemoController.java
create mode 100644 jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/provider/JcloudDemoProvider.java
create mode 100644 jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/JcloudDemoService.java
create mode 100644 jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/impl/JcloudDemoServiceImpl.java
delete mode 100644 jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/handler/DemoJobHandler.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/Dockerfile
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/pom.xml
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/JeecgCloudExampleApplication.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/bus/DemoBusEvent.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/job/DemoJobHandler.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/lock/DemoLockTest.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener2.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener3.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/controller/JeecgDemoController.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/provider/JeecgDemoProvider.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/JeecgDemoService.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/impl/JeecgDemoServiceImpl.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/resources/application.yml
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/constant/CloudConstant.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignTest.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/DemoFallback.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient2.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClientDyn.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/fallback/JeecgTestClientFallback.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java
delete mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/Demo2JobHandler.java
create mode 100644 jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/DemoJobHandler.java
diff --git a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/controller/JcloudDemoController.java b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/controller/JcloudDemoController.java
new file mode 100644
index 0000000..3dc3169
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/controller/JcloudDemoController.java
@@ -0,0 +1,48 @@
+//package org.jeecg.modules.demo.cloud.controller;
+//
+//import io.swagger.annotations.Api;
+//import io.swagger.annotations.ApiOperation;
+//import lombok.extern.slf4j.Slf4j;
+//import org.jeecg.common.api.vo.Result;
+//import org.jeecg.common.system.api.ISysBaseAPI;
+//import org.jeecg.common.system.vo.DictModel;
+//import org.springframework.web.bind.annotation.GetMapping;
+//import org.springframework.web.bind.annotation.RequestMapping;
+//import org.springframework.web.bind.annotation.RestController;
+//
+//import javax.annotation.Resource;
+//import java.util.List;
+//
+///**
+// *
+// */
+//@Slf4j
+//@Api(tags = "Cloud示例")
+//@RestController
+//@RequestMapping("/test")
+//public class JcloudDemoController {
+//
+//
+// @Resource
+// private ISysBaseAPI sysBaseAPI;
+//
+// /**
+// * 测试
+// *
+// * @return
+// */
+// @GetMapping("/remote")
+// @ApiOperation(value = "测试feign", notes = "测试feign")
+// public Result remoteDict() {
+//// try{
+//// //睡5秒，网关Hystrix3秒超时，会触发熔断降级操作
+//// Thread.sleep(5000);
+//// }catch (Exception e){
+//// e.printStackTrace();
+//// }
+// List<DictModel> list = sysBaseAPI.queryAllDict();
+// return Result.OK(list);
+// }
+//
+//
+//}
diff --git a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/provider/JcloudDemoProvider.java b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/provider/JcloudDemoProvider.java
new file mode 100644
index 0000000..760d710
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/provider/JcloudDemoProvider.java
@@ -0,0 +1,27 @@
+package org.jeecg.modules.demo.cloud.provider;
+
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.demo.cloud.service.JcloudDemoService;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+/**
+ * feign服务端接口
+ */
+@RestController
+@RequestMapping("/test")
+public class JcloudDemoProvider {
+
+ @Resource
+ private JcloudDemoService jcloudDemoService;
+
+ @GetMapping("/getMessage")
+ public Result<String> getMessage(@RequestParam String name) {
+ return jcloudDemoService.getMessage(name);
+ }
+
+}
diff --git a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/JcloudDemoService.java b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/JcloudDemoService.java
new file mode 100644
index 0000000..cb8227e
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/JcloudDemoService.java
@@ -0,0 +1,7 @@
+package org.jeecg.modules.demo.cloud.service;
+
+import org.jeecg.common.api.vo.Result;
+
+public interface JcloudDemoService {
+ Result<String> getMessage(String name);
+}
diff --git a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/impl/JcloudDemoServiceImpl.java b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/impl/JcloudDemoServiceImpl.java
new file mode 100644
index 0000000..fd09950
--- /dev/null
+++ b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/cloud/service/impl/JcloudDemoServiceImpl.java
@@ -0,0 +1,13 @@
+package org.jeecg.modules.demo.cloud.service.impl;
+
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.demo.cloud.service.JcloudDemoService;
+import org.springframework.stereotype.Service;
+
+@Service
+public class JcloudDemoServiceImpl implements JcloudDemoService {
+ @Override
+ public Result<String> getMessage(String name) {
+ return Result.OK("Hello，" + name);
+ }
+}
diff --git a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/handler/DemoJobHandler.java b/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/handler/DemoJobHandler.java
deleted file mode 100644
index 1d66f27..0000000
--- a/jeecg-boot/jeecg-boot-module-demo/src/main/java/org/jeecg/modules/demo/handler/DemoJobHandler.java
+++ /dev/null
@@ -1,234 +0,0 @@
-//
-//package org.jeecg.modules.demo.handler;
-//
-//
-//import com.xxl.job.core.biz.model.ReturnT;
-//import com.xxl.job.core.handler.IJobHandler;
-//import com.xxl.job.core.handler.annotation.XxlJob;
-//import com.xxl.job.core.log.XxlJobLogger;
-//import com.xxl.job.core.util.ShardingUtil;
-//import lombok.extern.slf4j.Slf4j;
-//import org.springframework.stereotype.Component;
-//
-//import java.io.BufferedInputStream;
-//import java.io.BufferedReader;
-//import java.io.DataOutputStream;
-//import java.io.InputStreamReader;
-//import java.net.HttpURLConnection;
-//import java.net.URL;
-//import java.util.Arrays;
-//
-//
-///**
-// * xxl-job定时任务测试
-// */
-//@Component
-//@Slf4j
-//public class DemoJobHandler {
-//
-//
-// /**
-// * 简单任务
-// *
-// * @param params
-// * @return
-// */
-//
-// @XxlJob(value = "demoJob")
-// public ReturnT<String> demoJobHandler(String params) {
-// log.info("我是定时任务,我执行了...............................");
-// return ReturnT.SUCCESS;
-// }
-//
-// /**
-// * 2、分片广播任务
-// */
-//
-// @XxlJob("shardingJobHandler")
-// public ReturnT<String> shardingJobHandler(String param) throws Exception {
-//
-// // 分片参数
-// ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
-// XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
-//
-// // 业务逻辑
-// for (int i = 0; i < shardingVO.getTotal(); i++) {
-// if (i == shardingVO.getIndex()) {
-// XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
-// } else {
-// XxlJobLogger.log("第 {} 片, 忽略", i);
-// }
-// }
-//
-// return ReturnT.SUCCESS;
-// }
-//
-//
-// /**
-// * 3、命令行任务
-// */
-//
-// @XxlJob("commandJobHandler")
-// public ReturnT<String> commandJobHandler(String param) throws Exception {
-// String command = param;
-// int exitValue = -1;
-//
-// BufferedReader bufferedReader = null;
-// try {
-// // command process
-// Process process = Runtime.getRuntime().exec(command);
-// BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream());
-// bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream));
-//
-// // command log
-// String line;
-// while ((line = bufferedReader.readLine()) != null) {
-// XxlJobLogger.log(line);
-// }
-//
-// // command exit
-// process.waitFor();
-// exitValue = process.exitValue();
-// } catch (Exception e) {
-// XxlJobLogger.log(e);
-// } finally {
-// if (bufferedReader != null) {
-// bufferedReader.close();
-// }
-// }
-//
-// if (exitValue == 0) {
-// return IJobHandler.SUCCESS;
-// } else {
-// return new ReturnT<String>(IJobHandler.FAIL.getCode(), "command exit value(" + exitValue + ") is failed");
-// }
-// }
-//
-//
-// /**
-// * 4、跨平台Http任务
-// * 参数示例：
-// * "url: http://www.baidu.com\n" +
-// * "method: get\n" +
-// * "data: content\n";
-// */
-//
-// @XxlJob("httpJobHandler")
-// public ReturnT<String> httpJobHandler(String param) throws Exception {
-//
-// // param parse
-// if (param == null || param.trim().length() == 0) {
-// XxlJobLogger.log("param[" + param + "] invalid.");
-// return ReturnT.FAIL;
-// }
-// String[] httpParams = param.split("\n");
-// String url = null;
-// String method = null;
-// String data = null;
-// for (String httpParam : httpParams) {
-// if (httpParam.startsWith("url:")) {
-// url = httpParam.substring(httpParam.indexOf("url:") + 4).trim();
-// }
-// if (httpParam.startsWith("method:")) {
-// method = httpParam.substring(httpParam.indexOf("method:") + 7).trim().toUpperCase();
-// }
-// if (httpParam.startsWith("data:")) {
-// data = httpParam.substring(httpParam.indexOf("data:") + 5).trim();
-// }
-// }
-//
-// // param valid
-// if (url == null || url.trim().length() == 0) {
-// XxlJobLogger.log("url[" + url + "] invalid.");
-// return ReturnT.FAIL;
-// }
-// if (method == null || !Arrays.asList("GET", "POST").contains(method)) {
-// XxlJobLogger.log("method[" + method + "] invalid.");
-// return ReturnT.FAIL;
-// }
-//
-// // request
-// HttpURLConnection connection = null;
-// BufferedReader bufferedReader = null;
-// try {
-// // connection
-// URL realUrl = new URL(url);
-// connection = (HttpURLConnection) realUrl.openConnection();
-//
-// // connection setting
-// connection.setRequestMethod(method);
-// connection.setDoOutput(true);
-// connection.setDoInput(true);
-// connection.setUseCaches(false);
-// connection.setReadTimeout(5 * 1000);
-// connection.setConnectTimeout(3 * 1000);
-// connection.setRequestProperty("connection", "Keep-Alive");
-// connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
-// connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8");
-//
-// // do connection
-// connection.connect();
-//
-// // data
-// if (data != null && data.trim().length() > 0) {
-// DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
-// dataOutputStream.write(data.getBytes("UTF-8"));
-// dataOutputStream.flush();
-// dataOutputStream.close();
-// }
-//
-// // valid StatusCode
-// int statusCode = connection.getResponseCode();
-// if (statusCode != 200) {
-// throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid.");
-// }
-//
-// // result
-// bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
-// StringBuilder result = new StringBuilder();
-// String line;
-// while ((line = bufferedReader.readLine()) != null) {
-// result.append(line);
-// }
-// String responseMsg = result.toString();
-//
-// XxlJobLogger.log(responseMsg);
-// return ReturnT.SUCCESS;
-// } catch (Exception e) {
-// XxlJobLogger.log(e);
-// return ReturnT.FAIL;
-// } finally {
-// try {
-// if (bufferedReader != null) {
-// bufferedReader.close();
-// }
-// if (connection != null) {
-// connection.disconnect();
-// }
-// } catch (Exception e2) {
-// XxlJobLogger.log(e2);
-// }
-// }
-//
-// }
-//
-//
-// /**
-// * 5、生命周期任务示例：任务初始化与销毁时，支持自定义相关逻辑；
-// */
-//
-// @XxlJob(value = "demoJobHandler2", init = "init", destroy = "destroy")
-// public ReturnT<String> demoJobHandler2(String param) throws Exception {
-// XxlJobLogger.log("XXL-JOB, Hello World.");
-// return ReturnT.SUCCESS;
-// }
-//
-// public void init() {
-// log.info("init");
-// }
-//
-// public void destroy() {
-// log.info("destory");
-// }
-//}
-//
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/Dockerfile b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/Dockerfile
deleted file mode 100644
index 489deb9..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/Dockerfile
+++ /dev/null
@@ -1,16 +0,0 @@
-FROM anapsix/alpine-java:8_server-jre_unlimited
-
-MAINTAINER jeecgos@163.com
-
-RUN ln -sf /usr/share/zoneinfo/Asia/Shanghai /etc/localtime
-
-RUN mkdir -p /jeecg-cloud-example
-
-WORKDIR /jeecg-cloud-example
-
-EXPOSE 7001
-
-ADD ./target/jeecg-cloud-example-2.4.2.jar ./
-
-CMD java -Dfile.encoding=utf-8 -Djava.security.egd=file:/dev/./urandom -jar jeecg-cloud-example-2.4.2.jar
-
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/pom.xml b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/pom.xml
deleted file mode 100644
index 568a747..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/pom.xml
+++ /dev/null
@@ -1,53 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<project xmlns="http://maven.apache.org/POM/4.0.0"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
- <parent>
- <artifactId>jeecg-cloud-module</artifactId>
- <groupId>org.jeecgframework.boot</groupId>
- <version>2.4.2</version>
- </parent>
- <modelVersion>4.0.0</modelVersion>
- <artifactId>jeecg-cloud-example</artifactId>
- <description>jeecg-cloud-example 微服务测试例子</description>
- <dependencies>
- <!-- 引入jeecg-boot-starter-cloud依赖-->
- <dependency>
- <groupId>org.jeecgframework.boot</groupId>
- <artifactId>jeecg-boot-starter-cloud</artifactId>
- </dependency>
- <!-- 引入定时任务依赖 -->
- <dependency>
- <groupId>org.jeecgframework.boot</groupId>
- <artifactId>jeecg-boot-starter-job</artifactId>
- </dependency>
-
- <!-- 引入分布式锁依赖 -->
- <dependency>
- <groupId>org.jeecgframework.boot</groupId>
- <artifactId>jeecg-boot-starter-lock</artifactId>
- </dependency>
-
- <!--rabbitmq消息队列-->
- <dependency>
- <groupId>org.jeecgframework.boot</groupId>
- <artifactId>jeecg-boot-starter-rabbitmq</artifactId>
- </dependency>
-
- </dependencies>
- <build>
- <plugins>
- <plugin>
- <groupId>org.springframework.boot</groupId>
- <artifactId>spring-boot-maven-plugin</artifactId>
- </plugin>
- </plugins>
- <resources>
- <resource>
- <directory>src/main/resources</directory>
- <filtering>true</filtering>
- </resource>
- </resources>
- </build>
-
-</project>
\ No newline at end of file
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/JeecgCloudExampleApplication.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/JeecgCloudExampleApplication.java
deleted file mode 100644
index 3f41e3d..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/JeecgCloudExampleApplication.java
+++ /dev/null
@@ -1,17 +0,0 @@
-
-package org.jeecg;
-
-import org.springframework.boot.SpringApplication;
-import org.springframework.boot.autoconfigure.SpringBootApplication;
-import org.springframework.cloud.openfeign.EnableFeignClients;
-import org.springframework.scheduling.annotation.EnableScheduling;
-
-@EnableScheduling
-@EnableFeignClients(basePackages = {"org.jeecg"})
-@SpringBootApplication(scanBasePackages = "org.jeecg")
-public class JeecgCloudExampleApplication {
-
- public static void main(String[] args) {
- SpringApplication.run(JeecgCloudExampleApplication.class, args);
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/bus/DemoBusEvent.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/bus/DemoBusEvent.java
deleted file mode 100644
index c4d0203..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/bus/DemoBusEvent.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package org.jeecg.cloud.demo.bus;
-
-import cn.hutool.core.util.ObjectUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.boot.starter.rabbitmq.event.EventObj;
-import org.jeecg.boot.starter.rabbitmq.event.JeecgBusEventHandler;
-import org.jeecg.common.base.BaseMap;
-import org.springframework.stereotype.Component;
-
-/**
- * 消息处理器【发布订阅】
- */
-@Slf4j
-@Component("demoBusEvent")
-public class DemoBusEvent implements JeecgBusEventHandler {
-
-
- @Override
- public void onMessage(EventObj obj) {
- if (ObjectUtil.isNotEmpty(obj)) {
- BaseMap baseMap = obj.getBaseMap();
- String orderId = baseMap.get("orderId");
- log.info("业务处理----订单ID:" + orderId);
- }
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/job/DemoJobHandler.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/job/DemoJobHandler.java
deleted file mode 100644
index 0099040..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/job/DemoJobHandler.java
+++ /dev/null
@@ -1,234 +0,0 @@
-
-package org.jeecg.cloud.demo.job;
-
-
-import com.xxl.job.core.biz.model.ReturnT;
-import com.xxl.job.core.handler.IJobHandler;
-import com.xxl.job.core.handler.annotation.XxlJob;
-import com.xxl.job.core.log.XxlJobLogger;
-import com.xxl.job.core.util.ShardingUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-import java.io.BufferedInputStream;
-import java.io.BufferedReader;
-import java.io.DataOutputStream;
-import java.io.InputStreamReader;
-import java.net.HttpURLConnection;
-import java.net.URL;
-import java.util.Arrays;
-
-
-/**
- * xxl-job定时任务测试
- */
-@Component
-@Slf4j
-public class DemoJobHandler {
-
-
- /**
- * 简单任务
- *
- * @param params
- * @return
- */
-
- @XxlJob(value = "demoJob")
- public ReturnT<String> demoJobHandler(String params) {
- log.info("我是定时任务,我执行了...............................");
- return ReturnT.SUCCESS;
- }
-
- /**
- * 2、分片广播任务
- */
-
- @XxlJob("shardingJobHandler")
- public ReturnT<String> shardingJobHandler(String param) throws Exception {
-
- // 分片参数
- ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
- XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
-
- // 业务逻辑
- for (int i = 0; i < shardingVO.getTotal(); i++) {
- if (i == shardingVO.getIndex()) {
- XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
- } else {
- XxlJobLogger.log("第 {} 片, 忽略", i);
- }
- }
-
- return ReturnT.SUCCESS;
- }
-
-
- /**
- * 3、命令行任务
- */
-
- @XxlJob("commandJobHandler")
- public ReturnT<String> commandJobHandler(String param) throws Exception {
- String command = param;
- int exitValue = -1;
-
- BufferedReader bufferedReader = null;
- try {
- // command process
- Process process = Runtime.getRuntime().exec(command);
- BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream());
- bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream));
-
- // command log
- String line;
- while ((line = bufferedReader.readLine()) != null) {
- XxlJobLogger.log(line);
- }
-
- // command exit
- process.waitFor();
- exitValue = process.exitValue();
- } catch (Exception e) {
- XxlJobLogger.log(e);
- } finally {
- if (bufferedReader != null) {
- bufferedReader.close();
- }
- }
-
- if (exitValue == 0) {
- return IJobHandler.SUCCESS;
- } else {
- return new ReturnT<String>(IJobHandler.FAIL.getCode(), "command exit value(" + exitValue + ") is failed");
- }
- }
-
-
- /**
- * 4、跨平台Http任务
- * 参数示例：
- * "url: http://www.baidu.com\n" +
- * "method: get\n" +
- * "data: content\n";
- */
-
- @XxlJob("httpJobHandler")
- public ReturnT<String> httpJobHandler(String param) throws Exception {
-
- // param parse
- if (param == null || param.trim().length() == 0) {
- XxlJobLogger.log("param[" + param + "] invalid.");
- return ReturnT.FAIL;
- }
- String[] httpParams = param.split("\n");
- String url = null;
- String method = null;
- String data = null;
- for (String httpParam : httpParams) {
- if (httpParam.startsWith("url:")) {
- url = httpParam.substring(httpParam.indexOf("url:") + 4).trim();
- }
- if (httpParam.startsWith("method:")) {
- method = httpParam.substring(httpParam.indexOf("method:") + 7).trim().toUpperCase();
- }
- if (httpParam.startsWith("data:")) {
- data = httpParam.substring(httpParam.indexOf("data:") + 5).trim();
- }
- }
-
- // param valid
- if (url == null || url.trim().length() == 0) {
- XxlJobLogger.log("url[" + url + "] invalid.");
- return ReturnT.FAIL;
- }
- if (method == null || !Arrays.asList("GET", "POST").contains(method)) {
- XxlJobLogger.log("method[" + method + "] invalid.");
- return ReturnT.FAIL;
- }
-
- // request
- HttpURLConnection connection = null;
- BufferedReader bufferedReader = null;
- try {
- // connection
- URL realUrl = new URL(url);
- connection = (HttpURLConnection) realUrl.openConnection();
-
- // connection setting
- connection.setRequestMethod(method);
- connection.setDoOutput(true);
- connection.setDoInput(true);
- connection.setUseCaches(false);
- connection.setReadTimeout(5 * 1000);
- connection.setConnectTimeout(3 * 1000);
- connection.setRequestProperty("connection", "Keep-Alive");
- connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
- connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8");
-
- // do connection
- connection.connect();
-
- // data
- if (data != null && data.trim().length() > 0) {
- DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
- dataOutputStream.write(data.getBytes("UTF-8"));
- dataOutputStream.flush();
- dataOutputStream.close();
- }
-
- // valid StatusCode
- int statusCode = connection.getResponseCode();
- if (statusCode != 200) {
- throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid.");
- }
-
- // result
- bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
- StringBuilder result = new StringBuilder();
- String line;
- while ((line = bufferedReader.readLine()) != null) {
- result.append(line);
- }
- String responseMsg = result.toString();
-
- XxlJobLogger.log(responseMsg);
- return ReturnT.SUCCESS;
- } catch (Exception e) {
- XxlJobLogger.log(e);
- return ReturnT.FAIL;
- } finally {
- try {
- if (bufferedReader != null) {
- bufferedReader.close();
- }
- if (connection != null) {
- connection.disconnect();
- }
- } catch (Exception e2) {
- XxlJobLogger.log(e2);
- }
- }
-
- }
-
-
- /**
- * 5、生命周期任务示例：任务初始化与销毁时，支持自定义相关逻辑；
- */
-
- @XxlJob(value = "demoJobHandler2", init = "init", destroy = "destroy")
- public ReturnT<String> demoJobHandler2(String param) throws Exception {
- XxlJobLogger.log("XXL-JOB, Hello World.");
- return ReturnT.SUCCESS;
- }
-
- public void init() {
- log.info("init");
- }
-
- public void destroy() {
- log.info("destory");
- }
-}
-
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/lock/DemoLockTest.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/lock/DemoLockTest.java
deleted file mode 100644
index a22fa14..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/lock/DemoLockTest.java
+++ /dev/null
@@ -1,61 +0,0 @@
-package org.jeecg.cloud.demo.lock;
-
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.boot.starter.lock.annotation.DistributedLock;
-import org.jeecg.boot.starter.lock.client.RedissonLockClient;
-import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * 分布式锁测试demo
- */
-@Slf4j
-@Component
-public class DemoLockTest {
- @Autowired
- RedissonLockClient redissonLock;
-
- @Autowired
- RabbitMqClient rabbitMqClient;
-
- /**
- * 注解方式测试分布式锁
- */
- //@Scheduled(cron = "0/5 * * * * ?")
- @DistributedLock(lockKey = "redis-lock", expireSeconds = 11)
- public void execute() throws InterruptedException {
- log.info("执行execute任务开始，休眠三秒");
- Thread.sleep(3000);
- System.out.println("=======================业务逻辑1=============================");
- Map map = new HashMap();
- map.put("orderId", "12345");
- rabbitMqClient.sendMessage("test", map);
- //延迟10秒发送
- map.put("orderId", "555555");
- rabbitMqClient.sendMessage("test", map, 10000);
- log.info("execute任务结束，休眠三秒");
- }
-
- /**
- * 编码方式测试分布式锁
- */
- //@Scheduled(cron = "0/10 * * * * ?")
- public void execute2() throws InterruptedException {
- if (redissonLock.tryLock("redisson", -1, 10)) {
- log.info("执行任务execute2开始，休眠三秒");
- Thread.sleep(3000);
- System.out.println("=======================业务逻辑2=============================");
- log.info("定时execute2结束，休眠三秒");
- redissonLock.unlock("redisson");
- } else {
- log.info("execute2获取锁失败");
- }
- }
-
-
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener2.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener2.java
deleted file mode 100644
index 4ff5c07..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener2.java
+++ /dev/null
@@ -1,28 +0,0 @@
-package org.jeecg.cloud.demo.rabbitmq;
-
-import com.rabbitmq.client.Channel;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
-import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
-import org.jeecg.common.annotation.RabbitComponent;
-import org.jeecg.common.base.BaseMap;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.amqp.support.AmqpHeaders;
-import org.springframework.messaging.handler.annotation.Header;
-
-@Slf4j
-@RabbitComponent(value = "testListener2")
-public class DemoRabbitMqListener2 extends BaseRabbiMqHandler<BaseMap> {
-
- @RabbitListener(queues = "test2")
- public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
- super.onMessage(baseMap, deliveryTag, channel, new MqListener<BaseMap>() {
- @Override
- public void handler(BaseMap map, Channel channel) {
- String orderId = map.get("orderId");
- log.info("业务处理2：orderId:" + orderId);
- }
- });
- }
-
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener3.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener3.java
deleted file mode 100644
index 75c4868..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/rabbitmq/DemoRabbitMqListener3.java
+++ /dev/null
@@ -1,29 +0,0 @@
-package org.jeecg.cloud.demo.rabbitmq;
-
-import com.rabbitmq.client.Channel;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
-import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
-import org.jeecg.common.annotation.RabbitComponent;
-import org.jeecg.common.base.BaseMap;
-import org.springframework.amqp.rabbit.annotation.RabbitHandler;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.amqp.support.AmqpHeaders;
-import org.springframework.messaging.handler.annotation.Header;
-
-@Slf4j
-@RabbitListener(queues = "test3")
-@RabbitComponent(value = "testListener3")
-public class DemoRabbitMqListener3 extends BaseRabbiMqHandler<BaseMap> {
-
- @RabbitHandler
- public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
- super.onMessage(baseMap, deliveryTag, channel, new MqListener<BaseMap>() {
- @Override
- public void handler(BaseMap map, Channel channel) {
- String orderId = map.get("orderId").toString();
- log.info("业务处理3：orderId:" + orderId);
- }
- });
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/controller/JeecgDemoController.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/controller/JeecgDemoController.java
deleted file mode 100644
index 3373325..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/controller/JeecgDemoController.java
+++ /dev/null
@@ -1,48 +0,0 @@
-package org.jeecg.cloud.demo.test.controller;
-
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import lombok.extern.slf4j.Slf4j;
-import org.jeecg.common.api.vo.Result;
-import org.jeecg.common.system.api.ISysBaseAPI;
-import org.jeecg.common.system.vo.DictModel;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.annotation.Resource;
-import java.util.List;
-
-/**
- *
- */
-@Slf4j
-@Api(tags = "jeecg-demo")
-@RestController
-@RequestMapping("/test")
-public class JeecgDemoController {
-
-
- @Resource
- private ISysBaseAPI sysBaseAPI;
-
- /**
- * 测试
- *
- * @return
- */
- @GetMapping("/demo")
- @ApiOperation(value = "测试方法", notes = "测试方法")
- public Result mockChange2() {
-// try{
-// //睡5秒，网关Hystrix3秒超时，会触发熔断降级操作
-// Thread.sleep(5000);
-// }catch (Exception e){
-// e.printStackTrace();
-// }
- List<DictModel> list = sysBaseAPI.queryAllDict();
- return Result.OK(list);
- }
-
-
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/provider/JeecgDemoProvider.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/provider/JeecgDemoProvider.java
deleted file mode 100644
index beaa9e2..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/provider/JeecgDemoProvider.java
+++ /dev/null
@@ -1,27 +0,0 @@
-package org.jeecg.cloud.demo.test.provider;
-
-import org.jeecg.cloud.demo.test.service.JeecgDemoService;
-import org.jeecg.common.api.vo.Result;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-import javax.annotation.Resource;
-
-/**
- * feign服务端接口
- */
-@RestController
-@RequestMapping("/test")
-public class JeecgDemoProvider {
-
- @Resource
- private JeecgDemoService jeecgDemoService;
-
- @GetMapping("/getMessage")
- public Result<String> getMessage(@RequestParam String name) {
- return jeecgDemoService.getMessage(name);
- }
-
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/JeecgDemoService.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/JeecgDemoService.java
deleted file mode 100644
index 43c2140..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/JeecgDemoService.java
+++ /dev/null
@@ -1,7 +0,0 @@
-package org.jeecg.cloud.demo.test.service;
-
-import org.jeecg.common.api.vo.Result;
-
-public interface JeecgDemoService {
- Result<String> getMessage(String name);
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/impl/JeecgDemoServiceImpl.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/impl/JeecgDemoServiceImpl.java
deleted file mode 100644
index a3c0e98..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/java/org/jeecg/cloud/demo/test/service/impl/JeecgDemoServiceImpl.java
+++ /dev/null
@@ -1,13 +0,0 @@
-package org.jeecg.cloud.demo.test.service.impl;
-
-import org.jeecg.cloud.demo.test.service.JeecgDemoService;
-import org.jeecg.common.api.vo.Result;
-import org.springframework.stereotype.Service;
-
-@Service
-public class JeecgDemoServiceImpl implements JeecgDemoService {
- @Override
- public Result<String> getMessage(String name) {
- return Result.OK("Hello" + name);
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/resources/application.yml b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/resources/application.yml
deleted file mode 100644
index 8a15d58..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-example/src/main/resources/application.yml
+++ /dev/null
@@ -1,5 +0,0 @@
-server:
- port: 7003
-spring:
- application:
- name: jeecg-cloud-example
\ No newline at end of file
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml
index 6d0d38b..7a3974a 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/pom.xml
@@ -9,14 +9,9 @@
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>jeecg-cloud-system-start</artifactId>
- <description>jeecg-cloud-system-start基础启动模块</description>
+ <description>System项目微服务启动</description>
<dependencies>
- <!-- 引入jeecg-boot-module-system依赖 -->
- <dependency>
- <groupId>org.jeecgframework.boot</groupId>
- <artifactId>jeecg-boot-module-system</artifactId>
- </dependency>
<!-- 引入jeecg-boot-starter-cloud依赖 -->
<dependency>
<groupId>org.jeecgframework.boot</groupId>
@@ -29,6 +24,12 @@
</exclusion>
</exclusions>
</dependency>
+ <!-- 引入jeecg-boot-module-system依赖 -->
+ <dependency>
+ <groupId>org.jeecgframework.boot</groupId>
+ <artifactId>jeecg-boot-module-system</artifactId>
+ </dependency>
+
<!--rabbitmq消息队列-->
<dependency>
<groupId>org.jeecgframework.boot</groupId>
@@ -39,6 +40,12 @@
<groupId>org.jeecgframework.boot</groupId>
<artifactId>jeecg-boot-starter-job</artifactId>
</dependency>
+ <!-- 分布式锁依赖 -->
+ <dependency>
+ <groupId>org.jeecgframework.boot</groupId>
+ <artifactId>jeecg-boot-starter-lock</artifactId>
+ </dependency>
+
</dependencies>
<build>
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/JeecgSystemCloudApplication.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/JeecgSystemCloudApplication.java
index f40b5f9..9aab6bb 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/JeecgSystemCloudApplication.java
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/JeecgSystemCloudApplication.java
@@ -1,18 +1,15 @@
package org.jeecg;
import lombok.extern.slf4j.Slf4j;
-import org.apache.catalina.Context;
-import org.apache.tomcat.util.scan.StandardJarScanner;
import org.jeecg.common.util.oConvertUtils;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
-import org.springframework.boot.web.embedded.tomcat.TomcatServletWebServerFactory;
import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.ConfigurableApplicationContext;
-import org.springframework.context.annotation.Bean;
import org.springframework.core.env.Environment;
+import org.springframework.scheduling.annotation.EnableScheduling;
import java.net.InetAddress;
import java.net.UnknownHostException;
@@ -24,6 +21,7 @@ import java.net.UnknownHostException;
@Slf4j
@SpringBootApplication
@EnableFeignClients(basePackages = {"org.jeecg"})
+@EnableScheduling
public class JeecgSystemCloudApplication extends SpringBootServletInitializer {
@Override
@@ -45,4 +43,5 @@ public class JeecgSystemCloudApplication extends SpringBootServletInitializer {
"----------------------------------------------------------");
}
+
}
\ No newline at end of file
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/constant/CloudConstant.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/constant/CloudConstant.java
new file mode 100644
index 0000000..cfdd282
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/constant/CloudConstant.java
@@ -0,0 +1,30 @@
+package org.jeecg.modules.cloud.constant;
+
+/**
+ * 微服务单元测试常量定义
+ */
+public interface CloudConstant {
+
+ /**
+ * 微服务名【对应模块jeecg-boot-module-demo】
+ */
+ public final static String SERVER_NAME_JEECGDEMO = "jeecg-demo";
+
+ /**
+ * MQ测试队列名字
+ */
+ public final static String MQ_JEECG_PLACE_ORDER = "jeecg_place_order";
+ public final static String MQ_JEECG_PLACE_ORDER_TIME = "jeecg_place_order_time";
+
+ /**
+ * MQ测试消息总线
+ */
+ public final static String MQ_DEMO_BUS_EVENT = "demoBusEvent";
+
+ /**
+ * 分布式锁lock key
+ */
+ public final static String REDISSON_DEMO_LOCK_KEY1 = "demoLockKey1";
+ public final static String REDISSON_DEMO_LOCK_KEY2 = "demoLockKey2";
+
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java
new file mode 100644
index 0000000..2e45542
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/ebus/DemoBusEvent.java
@@ -0,0 +1,27 @@
+package org.jeecg.modules.cloud.ebus;
+
+import cn.hutool.core.util.ObjectUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.boot.starter.rabbitmq.event.EventObj;
+import org.jeecg.boot.starter.rabbitmq.event.JeecgBusEventHandler;
+import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
+import org.springframework.stereotype.Component;
+
+/**
+ * 消息处理器【发布订阅】
+ */
+@Slf4j
+@Component(CloudConstant.MQ_DEMO_BUS_EVENT)
+public class DemoBusEvent implements JeecgBusEventHandler {
+
+
+ @Override
+ public void onMessage(EventObj obj) {
+ if (ObjectUtil.isNotEmpty(obj)) {
+ BaseMap baseMap = obj.getBaseMap();
+ String orderId = baseMap.get("orderId");
+ log.info("业务处理----订单ID:" + orderId);
+ }
+ }
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java
new file mode 100644
index 0000000..1f34c9e
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignController.java
@@ -0,0 +1,61 @@
+package org.jeecg.modules.cloud.feign.controller;
+
+
+import cn.hutool.core.util.RandomUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
+import org.jeecg.common.api.vo.Result;
+import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
+import org.jeecg.modules.cloud.feign.feign.JeecgTestClient;
+import org.jeecg.modules.cloud.feign.feign.JeecgTestClientDyn;
+import org.jeecg.starter.cloud.feign.impl.JeecgFeignService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+@RestController
+@RequestMapping("/sys/test")
+@Api(tags = "【微服务】单元测试")
+public class JeecgTestFeignController {
+
+ @Autowired
+ private JeecgFeignService jeecgFeignService;
+ @Autowired
+ private JeecgTestClient jeecgTestClient;
+ @Autowired
+ private RabbitMqClient rabbitMqClient;
+
+ @GetMapping("getMessage")
+ @ApiOperation(value = "测试feign", notes = "测试feign")
+ public Result<String> getMessage() {
+ return jeecgTestClient.getMessage("jeecg-boot");
+ }
+
+ @GetMapping("getMessage2")
+ @ApiOperation(value = "测试动态feign", notes = "测试动态feign")
+ public Result<String> getMessage2() {
+ JeecgTestClientDyn myClientDyn = jeecgFeignService.newInstance(JeecgTestClientDyn.class, CloudConstant.SERVER_NAME_JEECGDEMO);
+ return myClientDyn.getMessage("动态fegin——jeecg-boot2");
+ }
+
+ @GetMapping(value = "/rabbitmq")
+ @ApiOperation(value = "测试rabbitmq", notes = "测试rabbitmq")
+ public Result<?> rabbitMqClientTest(HttpServletRequest req) {
+ //rabbitmq消息队列测试
+ BaseMap map = new BaseMap();
+ map.put("orderId", RandomUtil.randomNumbers(10));
+ rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map);
+ rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER_TIME, map,10);
+
+ //rabbitmq消息总线测试
+ BaseMap params = new BaseMap();
+ params.put("orderId", "123456");
+ rabbitMqClient.publishEvent(CloudConstant.MQ_DEMO_BUS_EVENT, params);
+ return Result.OK("MQ发送消息成功");
+ }
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignTest.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignTest.java
deleted file mode 100644
index cd3fc0e..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/controller/JeecgTestFeignTest.java
+++ /dev/null
@@ -1,39 +0,0 @@
-package org.jeecg.modules.cloud.feign.controller;
-
-
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import org.jeecg.common.api.vo.Result;
-import org.jeecg.modules.cloud.feign.feign.JeecgTestClient;
-import org.jeecg.modules.cloud.feign.feign.JeecgTestClient2;
-import org.jeecg.starter.cloud.feign.impl.JeecgFeignService;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
-
-@RestController
-@RequestMapping("/sys/test")
-@Api(tags = "feign测试")
-public class JeecgTestFeignTest {
-
- @Autowired
- private JeecgFeignService jeecgFeignService;
-
- @Autowired
- private JeecgTestClient jeecgTestClient;
-
-
- @GetMapping("getMessage")
- @ApiOperation(value = "测试feign", notes = "测试feign")
- public Result<String> getMessage() {
- return jeecgTestClient.getMessage("jeecg-boot");
- }
-
- @GetMapping("getMessage2")
- @ApiOperation(value = "测试动态feign", notes = "测试动态feign")
- public Result<String> getMessage2() {
- JeecgTestClient2 jeecgTestClient = jeecgFeignService.newInstance(JeecgTestClient2.class, "jeecg-demo");
- return jeecgTestClient.getMessage("jeecg-boot2");
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/DemoFallback.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/DemoFallback.java
deleted file mode 100644
index a23c72a..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/DemoFallback.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package org.jeecg.modules.cloud.feign.feign;
-
-import feign.hystrix.FallbackFactory;
-import org.springframework.stereotype.Component;
-
-/**
- * @author qinfeng
- */
-@Component
-public class DemoFallback implements FallbackFactory<JeecgTestClient> {
-
- @Override
- public JeecgTestClient create(Throwable throwable) {
- return null;
- }
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient.java
index 3bfa451..85d995c 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient.java
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient.java
@@ -1,6 +1,8 @@
package org.jeecg.modules.cloud.feign.feign;
import org.jeecg.common.api.vo.Result;
+import org.jeecg.modules.cloud.constant.CloudConstant;
+import org.jeecg.modules.cloud.feign.feign.fallback.JeecgTestClientFallback;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
@@ -9,7 +11,7 @@ import org.springframework.web.bind.annotation.RequestParam;
/**
* 常规feign接口定义
*/
-@FeignClient(value = "jeecg-demo", fallbackFactory = DemoFallback.class)
+@FeignClient(value = CloudConstant.SERVER_NAME_JEECGDEMO, fallbackFactory = JeecgTestClientFallback.class)
@Component
public interface JeecgTestClient {
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient2.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient2.java
deleted file mode 100644
index 46f1750..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClient2.java
+++ /dev/null
@@ -1,14 +0,0 @@
-package org.jeecg.modules.cloud.feign.feign;
-
-import org.jeecg.common.api.vo.Result;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-
-/**
- * 动态feign接口定义
- */
-public interface JeecgTestClient2 {
-
- @GetMapping(value = "/test/getMessage")
- Result<String> getMessage(@RequestParam("name") String name);
-}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClientDyn.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClientDyn.java
new file mode 100644
index 0000000..c4f646f
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/JeecgTestClientDyn.java
@@ -0,0 +1,14 @@
+package org.jeecg.modules.cloud.feign.feign;
+
+import org.jeecg.common.api.vo.Result;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+/**
+ * 动态feign接口定义
+ */
+public interface JeecgTestClientDyn {
+
+ @GetMapping(value = "/test/getMessage")
+ Result<String> getMessage(@RequestParam("name") String name);
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/fallback/JeecgTestClientFallback.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/fallback/JeecgTestClientFallback.java
new file mode 100644
index 0000000..cc22023
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/feign/feign/fallback/JeecgTestClientFallback.java
@@ -0,0 +1,17 @@
+package org.jeecg.modules.cloud.feign.feign.fallback;
+
+import feign.hystrix.FallbackFactory;
+import org.jeecg.modules.cloud.feign.feign.JeecgTestClient;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author qinfeng
+ */
+@Component
+public class JeecgTestClientFallback implements FallbackFactory<JeecgTestClient> {
+
+ @Override
+ public JeecgTestClient create(Throwable throwable) {
+ return null;
+ }
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java
new file mode 100644
index 0000000..1b6e08f
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/lock/DemoLockTest.java
@@ -0,0 +1,65 @@
+package org.jeecg.modules.cloud.lock;
+
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.boot.starter.lock.annotation.DistributedLock;
+import org.jeecg.boot.starter.lock.client.RedissonLockClient;
+import org.jeecg.boot.starter.rabbitmq.client.RabbitMqClient;
+import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * 分布式锁测试demo
+ */
+@Slf4j
+@Component
+public class DemoLockTest {
+ @Autowired
+ RedissonLockClient redissonLock;
+ @Autowired
+ RabbitMqClient rabbitMqClient;
+
+ /**
+ * 测试分布式锁【注解方式】
+ */
+ @Scheduled(cron = "0/5 * * * * ?")
+ @DistributedLock(lockKey = CloudConstant.REDISSON_DEMO_LOCK_KEY1)
+ public void execute() throws InterruptedException {
+ log.info("执行execute任务开始，休眠三秒");
+ Thread.sleep(3000);
+ System.out.println("=======================业务逻辑1=============================");
+ Map map = new BaseMap();
+ map.put("orderId", "BJ0001");
+ rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map);
+ //延迟10秒发送
+ map.put("orderId", "NJ0002");
+ rabbitMqClient.sendMessage(CloudConstant.MQ_JEECG_PLACE_ORDER, map, 10000);
+ log.info("execute任务结束，休眠三秒");
+ }
+
+ public DemoLockTest() {
+ }
+
+ /**
+ * 测试分布式锁【编码方式】
+ */
+ //@Scheduled(cron = "0/5 * * * * ?")
+ public void execute2() throws InterruptedException {
+ if (redissonLock.tryLock(CloudConstant.REDISSON_DEMO_LOCK_KEY2, -1, 6000)) {
+ log.info("执行任务execute2开始，休眠十秒");
+ Thread.sleep(10000);
+ System.out.println("=======================业务逻辑2=============================");
+ log.info("定时execute2结束，休眠十秒");
+
+ redissonLock.unlock(CloudConstant.REDISSON_DEMO_LOCK_KEY2);
+ } else {
+ log.info("execute2获取锁失败");
+ }
+ }
+
+}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java
index 1bd1812..29de6ef 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver1.java
@@ -1,16 +1,23 @@
package org.jeecg.modules.cloud.rabbitmq;
import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
import org.jeecg.common.annotation.RabbitComponent;
import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
-@RabbitListener(queues = "jeecg_place_order")
+/**
+ * RabbitMq接受者1
+ * （@RabbitListener声明类上，一个类只能监听一个队列）
+ */
+@Slf4j
+@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER)
@RabbitComponent(value = "helloReceiver1")
public class HelloReceiver1 extends BaseRabbiMqHandler<BaseMap> {
@@ -21,7 +28,7 @@ public class HelloReceiver1 extends BaseRabbiMqHandler<BaseMap> {
public void handler(BaseMap map, Channel channel) {
//业务处理
String orderId = map.get("orderId").toString();
- System.out.println("Receiver1 : " + orderId);
+ log.info("MQ Receiver1，orderId : " + orderId);
}
});
}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java
index eba796a..abc8391 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver2.java
@@ -1,16 +1,23 @@
package org.jeecg.modules.cloud.rabbitmq;
import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
import org.jeecg.common.annotation.RabbitComponent;
import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
-@RabbitListener(queues = "jeecg_place_order")
+/**
+ * RabbitMq接受者2
+ * （@RabbitListener声明类上，一个类只能监听一个队列）
+ */
+@Slf4j
+@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER)
@RabbitComponent(value = "helloReceiver2")
public class HelloReceiver2 extends BaseRabbiMqHandler<BaseMap> {
@@ -21,7 +28,7 @@ public class HelloReceiver2 extends BaseRabbiMqHandler<BaseMap> {
public void handler(BaseMap map, Channel channel) {
//业务处理
String orderId = map.get("orderId").toString();
- System.out.println("Receiver2 : " + orderId);
+ log.info("MQ Receiver2，orderId : " + orderId);
}
});
}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java
new file mode 100644
index 0000000..5289c3a
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloReceiver3.java
@@ -0,0 +1,35 @@
+package org.jeecg.modules.cloud.rabbitmq;
+
+import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
+import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
+import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
+import org.jeecg.common.annotation.RabbitComponent;
+import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
+import org.springframework.amqp.rabbit.annotation.RabbitHandler;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.amqp.support.AmqpHeaders;
+import org.springframework.messaging.handler.annotation.Header;
+
+/**
+ * RabbitMq接受者3
+ * （@RabbitListener声明类方法上，一个类可以多监听多个队列）
+ */
+@Slf4j
+@RabbitComponent(value = "helloReceiver3")
+public class HelloReceiver3 extends BaseRabbiMqHandler<BaseMap> {
+
+ @RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER)
+ public void onMessage(BaseMap baseMap, Channel channel, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) {
+ super.onMessage(baseMap, deliveryTag, channel, new MqListener<BaseMap>() {
+ @Override
+ public void handler(BaseMap map, Channel channel) {
+ //业务处理
+ String orderId = map.get("orderId").toString();
+ log.info("MQ Receiver3，orderId : " + orderId);
+ }
+ });
+ }
+
+}
\ No newline at end of file
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java
index 97fa05d..649c9cc 100644
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/rabbitmq/HelloTimeReceiver.java
@@ -1,16 +1,19 @@
package org.jeecg.modules.cloud.rabbitmq;
import com.rabbitmq.client.Channel;
+import lombok.extern.slf4j.Slf4j;
import org.jeecg.boot.starter.rabbitmq.core.BaseRabbiMqHandler;
import org.jeecg.boot.starter.rabbitmq.listenter.MqListener;
import org.jeecg.common.annotation.RabbitComponent;
import org.jeecg.common.base.BaseMap;
+import org.jeecg.modules.cloud.constant.CloudConstant;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.support.AmqpHeaders;
import org.springframework.messaging.handler.annotation.Header;
-@RabbitListener(queues = "jeecg_place_order_time")
+@Slf4j
+@RabbitListener(queues = CloudConstant.MQ_JEECG_PLACE_ORDER_TIME)
@RabbitComponent(value = "helloTimeReceiver")
public class HelloTimeReceiver extends BaseRabbiMqHandler<BaseMap> {
@@ -21,7 +24,7 @@ public class HelloTimeReceiver extends BaseRabbiMqHandler<BaseMap> {
public void handler(BaseMap map, Channel channel) {
//业务处理
String orderId = map.get("orderId").toString();
- System.out.println("Receiver1 : " + orderId);
+ log.info("Time Receiver1，orderId : " + orderId);
}
});
}
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/Demo2JobHandler.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/Demo2JobHandler.java
deleted file mode 100644
index ef06a9d..0000000
--- a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/Demo2JobHandler.java
+++ /dev/null
@@ -1,57 +0,0 @@
-
-package org.jeecg.modules.cloud.xxljob;;
-
-
-import com.xxl.job.core.biz.model.ReturnT;
-import com.xxl.job.core.handler.annotation.XxlJob;
-import com.xxl.job.core.log.XxlJobLogger;
-import com.xxl.job.core.util.ShardingUtil;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Component;
-
-
-/**
- * xxl-job定时任务测试
- */
-@Component
-@Slf4j
-public class Demo2JobHandler {
-
-
- /**
- * 简单任务
- *
- * @param params
- * @return
- */
-
- @XxlJob(value = "demoJob2")
- public ReturnT<String> demoJobHandler(String params) {
- log.info("我是定时任务,我执行了...............................");
- return ReturnT.SUCCESS;
- }
-
- /**
- * 2、分片广播任务
- */
-
- @XxlJob("shardingJobHandler3")
- public ReturnT<String> shardingJobHandler(String param) throws Exception {
-
- // 分片参数
- ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
- XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
-
- // 业务逻辑
- for (int i = 0; i < shardingVO.getTotal(); i++) {
- if (i == shardingVO.getIndex()) {
- XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
- } else {
- XxlJobLogger.log("第 {} 片, 忽略", i);
- }
- }
-
- return ReturnT.SUCCESS;
- }
-}
-
diff --git a/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/DemoJobHandler.java b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/DemoJobHandler.java
new file mode 100644
index 0000000..528dd52
--- /dev/null
+++ b/jeecg-boot/jeecg-cloud-module/jeecg-cloud-system-start/src/main/java/org/jeecg/modules/cloud/xxljob/DemoJobHandler.java
@@ -0,0 +1,235 @@
+
+package org.jeecg.modules.cloud.xxljob;;
+
+
+import com.xxl.job.core.biz.model.ReturnT;
+import com.xxl.job.core.handler.IJobHandler;
+import com.xxl.job.core.handler.annotation.XxlJob;
+import com.xxl.job.core.log.XxlJobLogger;
+import com.xxl.job.core.util.ShardingUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.io.BufferedInputStream;
+import java.io.BufferedReader;
+import java.io.DataOutputStream;
+import java.io.InputStreamReader;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.util.Arrays;
+
+
+/**
+ * xxl-job定时任务测试
+ */
+@Component
+@Slf4j
+public class DemoJobHandler {
+
+
+ /**
+ * 简单任务
+ *
+ * @param params
+ * @return
+ */
+
+ @XxlJob(value = "demoJob")
+ public ReturnT<String> demoJobHandler(String params) {
+ log.info("我是定时任务,我执行了...............................");
+ return ReturnT.SUCCESS;
+ }
+
+ /**
+ * 2、分片广播任务
+ */
+
+ @XxlJob("shardingJobHandler")
+ public ReturnT<String> shardingJobHandler(String param) throws Exception {
+
+ // 分片参数
+ ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
+ XxlJobLogger.log("分片参数：当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
+
+ // 业务逻辑
+ for (int i = 0; i < shardingVO.getTotal(); i++) {
+ if (i == shardingVO.getIndex()) {
+ XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
+ } else {
+ XxlJobLogger.log("第 {} 片, 忽略", i);
+ }
+ }
+
+ return ReturnT.SUCCESS;
+ }
+
+
+ /**
+ * 3、命令行任务
+ */
+
+ @XxlJob("commandJobHandler")
+ public ReturnT<String> commandJobHandler(String param) throws Exception {
+ String command = param;
+ int exitValue = -1;
+
+ BufferedReader bufferedReader = null;
+ try {
+ // command process
+ Process process = Runtime.getRuntime().exec(command);
+ BufferedInputStream bufferedInputStream = new BufferedInputStream(process.getInputStream());
+ bufferedReader = new BufferedReader(new InputStreamReader(bufferedInputStream));
+
+ // command log
+ String line;
+ while ((line = bufferedReader.readLine()) != null) {
+ XxlJobLogger.log(line);
+ }
+
+ // command exit
+ process.waitFor();
+ exitValue = process.exitValue();
+ } catch (Exception e) {
+ XxlJobLogger.log(e);
+ } finally {
+ if (bufferedReader != null) {
+ bufferedReader.close();
+ }
+ }
+
+ if (exitValue == 0) {
+ return IJobHandler.SUCCESS;
+ } else {
+ return new ReturnT<String>(IJobHandler.FAIL.getCode(), "command exit value(" + exitValue + ") is failed");
+ }
+ }
+
+
+ /**
+ * 4、跨平台Http任务
+ * 参数示例：
+ * "url: http://www.baidu.com\n" +
+ * "method: get\n" +
+ * "data: content\n";
+ */
+
+ @XxlJob("httpJobHandler")
+ public ReturnT<String> httpJobHandler(String param) throws Exception {
+
+ // param parse
+ if (param == null || param.trim().length() == 0) {
+ XxlJobLogger.log("param[" + param + "] invalid.");
+ return ReturnT.FAIL;
+ }
+ String[] httpParams = param.split("\n");
+ String url = null;
+ String method = null;
+ String data = null;
+ for (String httpParam : httpParams) {
+ if (httpParam.startsWith("url:")) {
+ url = httpParam.substring(httpParam.indexOf("url:") + 4).trim();
+ }
+ if (httpParam.startsWith("method:")) {
+ method = httpParam.substring(httpParam.indexOf("method:") + 7).trim().toUpperCase();
+ }
+ if (httpParam.startsWith("data:")) {
+ data = httpParam.substring(httpParam.indexOf("data:") + 5).trim();
+ }
+ }
+
+ // param valid
+ if (url == null || url.trim().length() == 0) {
+ XxlJobLogger.log("url[" + url + "] invalid.");
+ return ReturnT.FAIL;
+ }
+ if (method == null || !Arrays.asList("GET", "POST").contains(method)) {
+ XxlJobLogger.log("method[" + method + "] invalid.");
+ return ReturnT.FAIL;
+ }
+
+ // request
+ HttpURLConnection connection = null;
+ BufferedReader bufferedReader = null;
+ try {
+ // connection
+ URL realUrl = new URL(url);
+ connection = (HttpURLConnection) realUrl.openConnection();
+
+ // connection setting
+ connection.setRequestMethod(method);
+ connection.setDoOutput(true);
+ connection.setDoInput(true);
+ connection.setUseCaches(false);
+ connection.setReadTimeout(5 * 1000);
+ connection.setConnectTimeout(3 * 1000);
+ connection.setRequestProperty("connection", "Keep-Alive");
+ connection.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
+ connection.setRequestProperty("Accept-Charset", "application/json;charset=UTF-8");
+
+ // do connection
+ connection.connect();
+
+ // data
+ if (data != null && data.trim().length() > 0) {
+ DataOutputStream dataOutputStream = new DataOutputStream(connection.getOutputStream());
+ dataOutputStream.write(data.getBytes("UTF-8"));
+ dataOutputStream.flush();
+ dataOutputStream.close();
+ }
+
+ // valid StatusCode
+ int statusCode = connection.getResponseCode();
+ if (statusCode != 200) {
+ throw new RuntimeException("Http Request StatusCode(" + statusCode + ") Invalid.");
+ }
+
+ // result
+ bufferedReader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "UTF-8"));
+ StringBuilder result = new StringBuilder();
+ String line;
+ while ((line = bufferedReader.readLine()) != null) {
+ result.append(line);
+ }
+ String responseMsg = result.toString();
+
+ XxlJobLogger.log(responseMsg);
+ return ReturnT.SUCCESS;
+ } catch (Exception e) {
+ XxlJobLogger.log(e);
+ return ReturnT.FAIL;
+ } finally {
+ try {
+ if (bufferedReader != null) {
+ bufferedReader.close();
+ }
+ if (connection != null) {
+ connection.disconnect();
+ }
+ } catch (Exception e2) {
+ XxlJobLogger.log(e2);
+ }
+ }
+
+ }
+
+
+ /**
+ * 5、生命周期任务示例：任务初始化与销毁时，支持自定义相关逻辑；
+ */
+
+ @XxlJob(value = "demoJobHandler2", init = "init", destroy = "destroy")
+ public ReturnT<String> demoJobHandler2(String param) throws Exception {
+ XxlJobLogger.log("XXL-JOB, Hello World.");
+ return ReturnT.SUCCESS;
+ }
+
+ public void init() {
+ log.info("init");
+ }
+
+ public void destroy() {
+ log.info("destory");
+ }
+
+}
+
diff --git a/jeecg-boot/jeecg-cloud-module/pom.xml b/jeecg-boot/jeecg-cloud-module/pom.xml
index ec1e33d..a240afa 100644
--- a/jeecg-boot/jeecg-cloud-module/pom.xml
+++ b/jeecg-boot/jeecg-cloud-module/pom.xml
@@ -16,8 +16,6 @@
<module>jeecg-cloud-gateway</module>
<module>jeecg-cloud-monitor</module>
<module>jeecg-cloud-xxljob</module>
- <!-- 微服务测试学习例子
- <module>jeecg-cloud-example</module>-->
</modules>
--
libgit2 0.22.2