From 43268426d1debf741d899695d660cdb8879daee5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=B0=8F=E5=82=85=E5=93=A5?= <184172133@qq.com> Date: Sat, 4 Nov 2023 16:43:01 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=8F=E5=82=85=E5=93=A5=EF=BC=8Cfeat?= =?UTF-8?q?=EF=BC=9A=E6=9B=B4=E6=96=B0=E8=AF=B4=E6=98=8E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/bugstack/trigger/http/Controller.java | 44 +++++++++++++++++++ .../bugstack/trigger/http/package-info.java | 4 -- .../cn/bugstack/trigger/job/package-info.java | 4 -- .../trigger/listener/package-info.java | 5 --- .../cn/bugstack/trigger/package-info.java | 7 +++ .../cn/bugstack/types/common/Constants.java | 19 ++++++++ .../cn/bugstack/types/enums/ResponseCode.java | 20 --------- .../cn/bugstack/types/model/Response.java | 22 ++++++++++ 8 files changed, 92 insertions(+), 33 deletions(-) create mode 100644 xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/Controller.java delete mode 100644 xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/package-info.java delete mode 100644 xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/job/package-info.java delete mode 100644 xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/listener/package-info.java create mode 100644 xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/package-info.java delete mode 100644 xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/enums/ResponseCode.java create mode 100644 xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/model/Response.java diff --git a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/Controller.java b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/Controller.java new file mode 100644 index 0000000..055f9b9 --- /dev/null +++ b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/Controller.java @@ -0,0 +1,44 @@ +package cn.bugstack.xfg.frame.trigger.http; + +import cn.bugstack.types.common.Constants; +import cn.bugstack.types.model.Response; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import javax.annotation.Resource; +import java.util.Random; +import java.util.concurrent.ThreadPoolExecutor; + +@Slf4j +@RestController +public class Controller { + + @Resource + private ThreadPoolExecutor threadPoolExecutor; + + /** + * http://localhost:8090/success + */ + @RequestMapping("/success") + public Response success() { + log.info("测试调用"); + try { + // 随机休眠 + Thread.sleep(new Random().nextInt(1000)); + // 开启线程 + threadPoolExecutor.execute(() -> { + log.info("开启线程"); + }); + } catch (InterruptedException e) { + throw new RuntimeException(e); + } + if (new Random().nextInt(100) == 1) throw new RuntimeException("异常"); + return Response.builder() + .code(Constants.ResponseCode.SUCCESS.getCode()) + .info(Constants.ResponseCode.SUCCESS.getInfo()) + .data("查询用户信息，小傅哥") + .build(); + } + +} diff --git a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/package-info.java b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/package-info.java deleted file mode 100644 index 78923e0..0000000 --- a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/http/package-info.java +++ /dev/null @@ -1,4 +0,0 @@ -/** - * HTTP 接口服务 - */ -package cn.bugstack.trigger.http; \ No newline at end of file diff --git a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/job/package-info.java b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/job/package-info.java deleted file mode 100644 index 1c1926c..0000000 --- a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/job/package-info.java +++ /dev/null @@ -1,4 +0,0 @@ -/** - * 任务服务，可以选择使用 Spring 默认提供的 Schedule https://bugstack.cn/md/road-map/quartz.html - */ -package cn.bugstack.trigger.job; \ No newline at end of file diff --git a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/listener/package-info.java b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/listener/package-info.java deleted file mode 100644 index c561ee9..0000000 --- a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/listener/package-info.java +++ /dev/null @@ -1,5 +0,0 @@ -/** - * 监听服务；在单体服务中，解耦流程。类似MQ的使用，如Spring的Event，Guava的事件总线都可以。如果使用了 Redis 那么也可以有发布/订阅使用。 - * Guava：https://bugstack.cn/md/road-map/guava.html - */ -package cn.bugstack.trigger.listener; \ No newline at end of file diff --git a/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/package-info.java b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/package-info.java new file mode 100644 index 0000000..801911f --- /dev/null +++ b/xfg-frame-archetype-std-trigger/src/main/java/cn/bugstack/trigger/package-info.java @@ -0,0 +1,7 @@ +/** + * http 提供服务 + * job xxl-job 任务调度 + * listener RocketMQ 监听 + * rpc Dubbo 接口，实现RPC服务 + */ +package cn.bugstack.trigger; \ No newline at end of file diff --git a/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/common/Constants.java b/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/common/Constants.java index 3e21a0d..a15efbe 100644 --- a/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/common/Constants.java +++ b/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/common/Constants.java @@ -1,7 +1,26 @@ package cn.bugstack.types.common; +import lombok.AllArgsConstructor; +import lombok.Getter; +import lombok.NoArgsConstructor; + public class Constants { public final static String SPLIT = ","; + @AllArgsConstructor + @NoArgsConstructor + @Getter + public enum ResponseCode { + + SUCCESS("0000", "成功"), + UN_ERROR("0001", "未知失败"), + ILLEGAL_PARAMETER("0002", "非法参数"), + ; + + private String code; + private String info; + + } + } diff --git a/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/enums/ResponseCode.java b/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/enums/ResponseCode.java deleted file mode 100644 index 7460d4b..0000000 --- a/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/enums/ResponseCode.java +++ /dev/null @@ -1,20 +0,0 @@ -package cn.bugstack.types.enums; - -import lombok.AllArgsConstructor; -import lombok.Getter; -import lombok.NoArgsConstructor; - -@AllArgsConstructor -@NoArgsConstructor -@Getter -public enum ResponseCode { - - SUCCESS("0000", "成功"), - UN_ERROR("0001", "未知失败"), - ILLEGAL_PARAMETER("0002", "非法参数"), - ; - - private String code; - private String info; - -} diff --git a/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/model/Response.java b/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/model/Response.java new file mode 100644 index 0000000..ab1dd73 --- /dev/null +++ b/xfg-frame-archetype-std-types/src/main/java/cn/bugstack/types/model/Response.java @@ -0,0 +1,22 @@ +package cn.bugstack.types.model; + +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; + +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class Response implements Serializable { + + private static final long serialVersionUID = 5130392244064623509L; + + private String code; + private String info; + private T data; + +} \ No newline at end of file -- GitLab