msb-public
/
hippo4j
mirror of https://github.com/longtai-cn/hippo4j
1
0
Code Issues Projects Releases Wiki Activity

Refactored example modules

Browse Source
pull/512/head
chen.ma 2 years ago
parent a9f6bb9835
commit d27eeba812
14 changed files with 60 additions and 112 deletions
Show Stats Download Patch File Download Diff File

1
hippo4j-example/hippo4j-core-apollo-spring-boot-starter-example/src/main/java/cn/hippo4j/example/core/apollo/Hippo4jCoreApolloExampleApplication.java
Unescape View File

@ -28,5 +28,4 @@ public class Hippo4jCoreApolloExampleApplication {
public static void main(String[] args) {
SpringApplication.run(Hippo4jCoreApolloExampleApplication.class, args);
}
}

5
hippo4j-example/hippo4j-core-apollo-spring-boot-starter-example/src/main/resources/bootstrap.properties
Unescape View File

@ -40,9 +40,8 @@ spring.dynamic.thread-pool.executors[0].rejected-handler=AbortPolicy
spring.dynamic.thread-pool.executors[0].keep-alive-time=1000
spring.dynamic.thread-pool.executors[0].allow-core-thread-time-out=true
spring.dynamic.thread-pool.executors[0].thread-name-prefix=message-consume
spring.dynamic.thread-pool.executors[0].notify.is-alarm=true
spring.dynamic.thread-pool.executors[0].notify.alarm=true
spring.dynamic.thread-pool.executors[0].notify.active-alarm=80
spring.dynamic.thread-pool.executors[0].notify.capacity-alarm=80
spring.dynamic.thread-pool.executors[0].notify.interval=8
spring.dynamic.thread-pool.executors[0].notify.receives.WECHAT=xxx
spring.dynamic.thread-pool.executors[0].notify.receives.DING=xxx
spring.dynamic.thread-pool.executors[0].notify.receive=chen.ma

6
hippo4j-example/hippo4j-core-nacos-spring-boot-starter-example/src/main/resources/bootstrap.properties
Unescape View File

@ -42,10 +42,8 @@ spring.dynamic.thread-pool.executors[0].rejected-handler=AbortPolicy
spring.dynamic.thread-pool.executors[0].keep-alive-time=6691
spring.dynamic.thread-pool.executors[0].allow-core-thread-time-out=true
spring.dynamic.thread-pool.executors[0].thread-name-prefix=message-consume
spring.dynamic.thread-pool.executors[0].notify.is-alarm=true
spring.dynamic.thread-pool.executors[0].notify.alarm=true
spring.dynamic.thread-pool.executors[0].notify.active-alarm=80
spring.dynamic.thread-pool.executors[0].notify.capacity-alarm=80
spring.dynamic.thread-pool.executors[0].notify.interval=8
spring.dynamic.thread-pool.executors[0].notify.receives.WECHAT=xxx
spring.dynamic.thread-pool.executors[0].notify.receives.DING=xxx
spring.dynamic.thread-pool.executors[0].notify.receives.LARK=xxx
spring.dynamic.thread-pool.executors[0].notify.receive=chen.ma

4
hippo4j-example/hippo4j-core-zookeeper-spring-boot-starter-example/src/main/java/cn/hippo4j/example/core/zookeeper/Hippo4jCoreZookeeperExampleApplication.java
Unescape View File

@ -21,10 +21,6 @@ import cn.hippo4j.core.enable.EnableDynamicThreadPool;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* @author Redick01
* @date 2022/3/14 20:40
*/
@EnableDynamicThreadPool
@SpringBootApplication(scanBasePackages = "cn.hippo4j.example.core")
public class Hippo4jCoreZookeeperExampleApplication {

49
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/ThreadPoolConfig.java → hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/config/DynamicThreadPoolConfig.java
Unescape View File

@ -33,18 +33,15 @@ import static cn.hippo4j.example.core.constant.GlobalTestConstant.MESSAGE_CONSUM
import static cn.hippo4j.example.core.constant.GlobalTestConstant.MESSAGE_PRODUCE;
/**
* Thread pool config.
*
* @author chen.ma
* @date 2021/6/20 17:16
* Dynamic thread-pool config.
*/
@Slf4j
@Configuration
public class ThreadPoolConfig {
public class DynamicThreadPoolConfig {
@Bean
@DynamicThreadPool
public ThreadPoolExecutor messageConsumeDynamicThreadPool() {
public Executor messageConsumeTtlDynamicThreadPool() {
String threadPoolId = MESSAGE_CONSUME;
ThreadPoolExecutor customExecutor = ThreadPoolBuilder.builder()
.dynamicPool()
@ -55,7 +52,9 @@ public class ThreadPoolConfig {
.awaitTerminationMillis(5000L)
.taskDecorator(new TaskTraceBuilderHandler())
.build();
return customExecutor;
// Ali ttl adaptation use case.
Executor ttlExecutor = TtlExecutors.getTtlExecutor(customExecutor);
return ttlExecutor;
}
@Bean
@ -70,44 +69,10 @@ public class ThreadPoolConfig {
.waitForTasksToCompleteOnShutdown(true)
.awaitTerminationMillis(5000L)
/**
* 上下文传递，测试用例：{@link TaskDecoratorTest}
* Context passing, test cases: {@link TaskDecoratorTest}
*/
.taskDecorator(new TaskDecoratorTest.ContextCopyingDecorator())
.build();
return produceExecutor;
}
@Bean
@DynamicThreadPool
public Executor messageConsumeTtlDynamicThreadPool() {
String threadPoolId = MESSAGE_CONSUME;
ThreadPoolExecutor customExecutor = ThreadPoolBuilder.builder()
.dynamicPool()
.threadFactory(threadPoolId)
.threadPoolId(threadPoolId)
.executeTimeOut(800L)
.waitForTasksToCompleteOnShutdown(true)
.awaitTerminationMillis(5000L)
.taskDecorator(new TaskTraceBuilderHandler())
.build();
Executor ttlExecutor = TtlExecutors.getTtlExecutor(customExecutor);
return ttlExecutor;
}
@Bean
@DynamicThreadPool
public Executor messageConsumeTtlServiceDynamicThreadPool() {
String threadPoolId = MESSAGE_CONSUME;
ThreadPoolExecutor customExecutor = ThreadPoolBuilder.builder()
.dynamicPool()
.threadFactory(threadPoolId)
.threadPoolId(threadPoolId)
.executeTimeOut(800L)
.waitForTasksToCompleteOnShutdown(true)
.awaitTerminationMillis(5000L)
.taskDecorator(new TaskTraceBuilderHandler())
.build();
Executor ttlExecutor = TtlExecutors.getTtlExecutorService(customExecutor);
return ttlExecutor;
}
}

3
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/constant/GlobalTestConstant.java
Unescape View File

@ -19,9 +19,6 @@ package cn.hippo4j.example.core.constant;
/**
* Global test variables.
*
* @author chen.ma
* @date 2021/8/15 21:06
*/
public class GlobalTestConstant {

5
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/ErrorLogRejectedExecutionHandler.java
Unescape View File

@ -25,10 +25,7 @@ import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
/**
* 自定义拒绝策略.
*
* @author chen.ma
* @date 2022/1/4 22:19
* Custom Deny Policy.
*/
public class ErrorLogRejectedExecutionHandler implements CustomRejectedExecutionHandler {

5
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/handler/TaskTraceBuilderHandler.java
Unescape View File

@ -25,9 +25,6 @@ import static cn.hippo4j.common.constant.Constants.EXECUTE_TIMEOUT_TRACE;
/**
* Task trace builder handler.
*
* @author chen.ma
* @date 2022/3/2 20:46
*/
public final class TaskTraceBuilderHandler implements TaskDecorator {
@ -39,7 +36,7 @@ public final class TaskTraceBuilderHandler implements TaskDecorator {
MDC.put(EXECUTE_TIMEOUT_TRACE, executeTimeoutTrace);
}
runnable.run();
// 此处不用进行清理操作, 统一在线程任务执行后清理
// There is no need to clean up here, and it will be cleaned up after the thread task is executed.
};
return taskRun;
}

7
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/AlarmSendMessageTest.java
Unescape View File

@ -31,17 +31,14 @@ import java.util.concurrent.TimeUnit;
/**
* Test alarm send message.
*
* @author chen.ma
* @date 2021/8/15 21:03
*/
@Slf4j
@Component
public class AlarmSendMessageTest {
/**
* 测试报警通知.
* 如果需要运行此单测, 方法上添加 @PostConstruct
* Test alarm notification.
* If you need to run this single test, add @PostConstruct to the method.
*/
@SuppressWarnings("all")
public void alarmSendMessageTest() {

28
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RegisterDynamicThreadPoolTest.java
Unescape View File

@ -19,8 +19,11 @@ package cn.hippo4j.example.core.inittest;
import cn.hippo4j.common.model.register.DynamicThreadPoolRegisterParameter;
import cn.hippo4j.common.model.register.DynamicThreadPoolRegisterWrapper;
import cn.hippo4j.common.model.register.notify.DynamicThreadPoolRegisterCoreNotifyParameter;
import cn.hippo4j.common.model.register.notify.DynamicThreadPoolRegisterServerNotifyParameter;
import cn.hippo4j.common.toolkit.JSONUtil;
import cn.hippo4j.core.executor.manage.GlobalThreadPoolManage;
import cn.hippo4j.message.enums.NotifyPlatformEnum;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
@ -39,18 +42,37 @@ public class RegisterDynamicThreadPoolTest {
String threadPoolId = "register-dynamic-thread-pool";
DynamicThreadPoolRegisterParameter parameterInfo = new DynamicThreadPoolRegisterParameter();
parameterInfo.setThreadPoolId(threadPoolId);
parameterInfo.setThreadNamePrefix(threadPoolId);
parameterInfo.setCorePoolSize(3);
parameterInfo.setMaximumPoolSize(14);
parameterInfo.setQueueType(9);
parameterInfo.setCapacity(110);
parameterInfo.setKeepAliveTime(110);
parameterInfo.setKeepAliveTime(110L);
parameterInfo.setRejectedType(2);
parameterInfo.setIsAlarm(0);
parameterInfo.setCapacityAlarm(90);
parameterInfo.setLivenessAlarm(90);
parameterInfo.setAllowCoreThreadTimeOut(0);
parameterInfo.setActiveAlarm(90);
parameterInfo.setAllowCoreThreadTimeOut(Boolean.TRUE);
// core 模式和 server 模式，各选其一即可
DynamicThreadPoolRegisterCoreNotifyParameter coreNotifyParameter = DynamicThreadPoolRegisterCoreNotifyParameter.builder()
.activeAlarm(80)
.capacityAlarm(80)
.receives("chen.ma")
.alarm(true)
.interval(5)
.build();
DynamicThreadPoolRegisterServerNotifyParameter serverNotifyParameter = DynamicThreadPoolRegisterServerNotifyParameter.builder()
.platform(NotifyPlatformEnum.WECHAT.name())
.secretKey("xxx")
.threadPoolId(threadPoolId)
.interval(5)
.receives("chen.ma")
.build();
DynamicThreadPoolRegisterWrapper registerWrapper = DynamicThreadPoolRegisterWrapper.builder()
.dynamicThreadPoolRegisterParameter(parameterInfo)
.dynamicThreadPoolRegisterCoreNotifyParameter(coreNotifyParameter)
.dynamicThreadPoolRegisterServerNotifyParameter(serverNotifyParameter)
.build();
ThreadPoolExecutor dynamicThreadPool = GlobalThreadPoolManage.dynamicRegister(registerWrapper);
log.info("Dynamic registration thread pool parameter details: {}", JSONUtil.toJSONString(dynamicThreadPool));

32
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/RunStateHandlerTest.java
Unescape View File

@ -25,25 +25,19 @@ import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
import javax.annotation.Resource;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.*;
import static cn.hippo4j.common.constant.Constants.EXECUTE_TIMEOUT_TRACE;
/**
* Test run time metrics.
*
* @author chen.ma
* @date 2021/8/15 21:00
* Run state handler test.
*/
@Slf4j
@Component
public class RunStateHandlerTest {
@Resource
private ThreadPoolExecutor messageConsumeDynamicThreadPool;
private Executor messageConsumeTtlDynamicThreadPool;
@Resource
private ThreadPoolExecutor messageProduceDynamicThreadPool;
@ -66,24 +60,22 @@ public class RunStateHandlerTest {
@SuppressWarnings("all")
public void runStateHandlerTest() {
log.info("Test thread pool runtime state interface...");
// 启动动态线程池模拟运行任务
runTask(messageConsumeDynamicThreadPool);
// 启动动态线程池模拟运行任务
// Start the dynamic thread pool to simulate running tasks
runTask(messageConsumeTtlDynamicThreadPool);
runTask(messageProduceDynamicThreadPool);
}
private void runTask(ExecutorService executorService) {
// 模拟任务运行
private void runTask(Executor executor) {
// Simulate task run
runStateHandlerTestExecutor.execute(() -> {
/**
* 当线程池任务执行超时, 向 MDC 放入 Trace 标识, 报警时打印出来.
* When the execution of the thread pool task times out, the Trace flag is put into the MDC, and it is printed out when an alarm occurs.
*/
MDC.put(EXECUTE_TIMEOUT_TRACE, "https://github.com/opengoofy/hippo4j 感觉不错来个 Star.");
ThreadUtil.sleep(5000);
for (int i = 0; i < Integer.MAX_VALUE; i++) {
try {
executorService.execute(() -> {
executor.execute(() -> {
try {
int maxRandom = 10;
int temp = 2;
@ -94,12 +86,10 @@ public class RunStateHandlerTest {
} else {
Thread.sleep(3000);
}
} catch (InterruptedException e) {
// ignore
} catch (InterruptedException ignored) {
}
});
} catch (Exception ex) {
// ignore
} catch (Exception ignored) {
}
ThreadUtil.sleep(500);
}

15
hippo4j-example/hippo4j-example-core/src/main/java/cn/hippo4j/example/core/inittest/TaskDecoratorTest.java
Unescape View File

@ -32,9 +32,6 @@ import java.util.concurrent.TimeUnit;
/**
* TaskDecorator test.
*
* @author chen.ma
* @date 2021/11/28 13:01
*/
@Slf4j
@Component
@ -57,21 +54,17 @@ public class TaskDecoratorTest {
new ThreadPoolExecutor.AbortPolicy());
/**
* 测试动态线程池传递 {@link TaskDecorator}
* 如果需要运行此单测, 方法上添加 @PostConstruct
* Test dynamic thread pool passing {@link TaskDecorator}
* If you need to run this single test, add @PostConstruct to the method.
*/
public void taskDecoratorTest() {
taskDecoratorTestExecutor.execute(() -> {
MDC.put(PLACEHOLDER, "查看官网: https://www.hippox.cn");
MDC.put(PLACEHOLDER, "View the official website: https://www.hippo4j.cn");
ThreadUtil.sleep(5000);
DynamicThreadPoolWrapper poolWrapper = GlobalThreadPoolManage.getExecutorService(GlobalTestConstant.MESSAGE_PRODUCE);
ThreadPoolExecutor threadPoolExecutor = poolWrapper.getExecutor();
threadPoolExecutor.execute(() -> {
/**
* 此处打印不为空, taskDecorator 即为生效.
* taskDecorator 配置查看 {@link ThreadPoolConfig#messageConsumeDynamicThreadPool()}
*/
log.info("通过 taskDecorator MDC 传递上下文: {}", MDC.get(PLACEHOLDER));
log.info("Pass context via taskDecorator MDC: {}", MDC.get(PLACEHOLDER));
});
});
}

10
hippo4j-example/hippo4j-spring-boot-starter-adapter-rabbitmq-example/src/main/java/cn/hippo4j/springboot/starter/adapter/rabbitmq/example/config/RabbitMQThreadPoolConfig.java
Unescape View File

@ -26,9 +26,7 @@ import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
/**
* @author : wh
* @date : 2022/5/24 10:02
* @description:
* RabbitMQ thread-pool config.
*/
@Configuration
public class RabbitMQThreadPoolConfig {
@ -36,11 +34,11 @@ public class RabbitMQThreadPoolConfig {
@Bean
public ThreadPoolTaskExecutor rabbitListenerTaskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 指定线程的最大数量
// Specify the maximum number of threads.
executor.setMaxPoolSize(5);
// 指定线程池维护线程的最少数量
// Specifies the minimum number of thread pool maintenance threads.
executor.setCorePoolSize(5);
// 指定等待处理的任务数
// Specifies the number of tasks waiting to be processed.
executor.setQueueCapacity(1000);
executor.setThreadNamePrefix("RabbitListenerTaskExecutor-");
return executor;

2
hippo4j-example/hippo4j-spring-boot-starter-es-monitor-example/src/main/resources/application.properties
Unescape View File

@ -35,7 +35,7 @@ spring.dynamic.thread-pool.executors[0].rejected-handler=CallerRunsPolicy
spring.dynamic.thread-pool.executors[0].keep-alive-time=1024
spring.dynamic.thread-pool.executors[0].allow-core-thread-time-out=true
spring.dynamic.thread-pool.executors[0].thread-name-prefix=untimely-thread-pool
spring.dynamic.thread-pool.executors[0].notify.is-alarm=true
spring.dynamic.thread-pool.executors[0].notify.alarm=true
spring.dynamic.thread-pool.executors[0].notify.capacity-alarm=20
spring.dynamic.thread-pool.executors[0].notify.interval=2
spring.dynamic.thread-pool.executors[0].notify.receive=xxx

Write Preview
Loading…
Cancel
Save