From 4757e00c4a6b342fad596569715e7594eb31f39c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=A9=AC=E7=A7=B0=20Ma=20Chen?= Date: Sat, 5 Nov 2022 12:19:02 +0800 Subject: [PATCH] Code optimization and logic refactoring (#909) * Code optimization and logic refactoring * Code optimization and logic refactoring * Remove useless modules and refactor code * Remove kafka modules * Remove kafka code --- .../base/ThreadPoolAdapterBeanContainer.java | 2 +- .../base/ThreadPoolAdapterRegisterAction.java | 5 +- .../hystrix/ThreadPoolAdapterScheduler.java | 11 ++-- hippo4j-adapter/hippo4j-adapter-kafka/pom.xml | 18 ------ .../adapter/kafka/KafkaThreadPoolAdapter.java | 52 ---------------- .../rabbitmq/RabbitMQThreadPoolAdapter.java | 1 - .../pom.xml | 18 ------ ...ringCloudStreamKafkaThreadPoolAdapter.java | 59 ------------------- ...gCloudStreamRabbitMQThreadPoolAdapter.java | 2 +- .../web/AbstractWebThreadPoolService.java | 4 +- .../web/WebThreadPoolHandlerChoose.java | 2 +- .../web/WebThreadPoolRunStateHandler.java | 4 +- hippo4j-adapter/pom.xml | 2 - .../pom.xml | 56 ------------------ .../ServerAdapterKafkaExampleApplication.java | 31 ---------- .../consumer/KafkaMessageConsumer.java | 43 -------------- .../example/produce/KafkaMessageProduce.java | 55 ----------------- .../src/main/resources/application.properties | 23 -------- hippo4j-example/pom.xml | 1 - .../base/AbstractRobotSendMessageHandler.java | 2 +- .../message/service/AlarmControlHandler.java | 4 +- .../robot/dynamic-thread-pool/ding-alarm.txt | 2 +- .../dynamic-thread-pool/wechat-alarm.txt | 2 +- .../AbstractDynamicThreadPoolMonitor.java | 5 +- .../base/AdapterThreadPoolMonitor.java | 1 - .../base/DynamicThreadPoolMonitor.java | 1 - .../monitor/base/WebThreadPoolMonitor.java | 1 - ...terThreadPoolMicrometerMonitorHandler.java | 6 +- ...micThreadPoolMicrometerMonitorHandler.java | 6 +- ...WebThreadPoolMicrometerMonitorHandler.java | 6 +- .../cn/hippo4j/auth/config/FilterConfig.java | 2 +- .../auth/filter/JWTAuthorizationFilter.java | 2 - .../auth/security/JwtTokenManager.java | 19 +++++- .../auth/service/impl/UserServiceImpl.java | 3 - .../cn/hippo4j/auth/toolkit/JwtTokenUtil.java | 2 + .../java/cn/hippo4j/auth/toolkit/ReturnT.java | 4 ++ .../config/event/ConfigDataChangeEvent.java | 44 -------------- .../AbstractMonitorDataExecuteStrategy.java | 4 +- .../monitor/QueryMonitorExecuteChoose.java | 2 +- .../config/notify/DefaultPublisher.java | 5 +- .../hippo4j/config/notify/EventPublisher.java | 14 ++--- .../hippo4j/config/notify/NotifyCenter.java | 4 +- .../notify/listener/AbstractSubscriber.java | 5 ++ .../config/service/ConfigChangePublisher.java | 2 +- .../config/service/LongPollingService.java | 16 ++--- ...ConfigModificationVerifyServiceChoose.java | 5 +- .../java/cn/hippo4j/discovery/core/Lease.java | 34 ++--------- .../hippo4j/other/alibaba-dubbo/index.vue | 2 - .../src/views/hippo4j/other/dubbo/index.vue | 2 - .../src/views/hippo4j/other/hystrix/index.vue | 2 - .../src/views/hippo4j/other/index.vue | 2 - .../hippo4j/other/rabbitmq-stream/index.vue | 2 - .../views/hippo4j/other/rabbitmq/index.vue | 2 - .../hippo4j/other/rocketmq-stream/index.vue | 2 - .../views/hippo4j/other/rocketmq/index.vue | 2 - .../pom.xml | 19 ------ .../kafka/KafkaAdapterAutoConfiguration.java | 45 -------------- .../main/resources/META-INF/spring.factories | 1 - .../pom.xml | 19 ------ ...udStreamKafkaAdapterAutoConfiguration.java | 45 -------------- .../main/resources/META-INF/spring.factories | 1 - .../pom.xml | 2 - 62 files changed, 85 insertions(+), 655 deletions(-) delete mode 100644 hippo4j-adapter/hippo4j-adapter-kafka/pom.xml delete mode 100644 hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java delete mode 100644 hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml delete mode 100644 hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java delete mode 100644 hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml delete mode 100644 hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java delete mode 100644 hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java delete mode 100644 hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java delete mode 100644 hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties delete mode 100644 hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/pom.xml delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/KafkaAdapterAutoConfiguration.java delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/resources/META-INF/spring.factories delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/pom.xml delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaAdapterAutoConfiguration.java delete mode 100644 hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/resources/META-INF/spring.factories diff --git a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java index 92d555f2..a87b4743 100644 --- a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java +++ b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterBeanContainer.java @@ -29,7 +29,7 @@ import java.util.concurrent.ConcurrentHashMap; public class ThreadPoolAdapterBeanContainer implements InitializingBean { /** - * Store three-party thread pool framework bean instances. + * Store three-party thread pool framework bean instances */ public static final Map THREAD_POOL_ADAPTER_BEAN_CONTAINER = new ConcurrentHashMap<>(); diff --git a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java index 0d380f15..0dda7fa3 100644 --- a/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java +++ b/hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterRegisterAction.java @@ -28,7 +28,7 @@ public interface ThreadPoolAdapterRegisterAction { /** * Get thread pool adapter cache configs. * - * @param threadPoolAdapterMap + * @param threadPoolAdapterMap thread-pool adapter map * @return List */ List getThreadPoolAdapterCacheConfigs(Map threadPoolAdapterMap); @@ -36,8 +36,7 @@ public interface ThreadPoolAdapterRegisterAction { /** * Do register. * - * @param cacheConfigList - * @return + * @param cacheConfigList cache config list */ void doRegister(List cacheConfigList); } diff --git a/hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java b/hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java index d71cf267..143b285e 100644 --- a/hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java +++ b/hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/ThreadPoolAdapterScheduler.java @@ -18,6 +18,7 @@ package cn.hippo4j.adapter.hystrix; import cn.hippo4j.common.design.builder.ThreadFactoryBuilder; +import lombok.Getter; import lombok.extern.slf4j.Slf4j; import java.util.concurrent.ScheduledExecutorService; @@ -31,6 +32,7 @@ public class ThreadPoolAdapterScheduler { private static final int TASK_INTERVAL_SECONDS = 10; + @Getter private final ScheduledExecutorService scheduler; public ThreadPoolAdapterScheduler() { @@ -41,10 +43,11 @@ public class ThreadPoolAdapterScheduler { .build()); } - public ScheduledExecutorService getScheduler() { - return scheduler; - } - + /** + * Gt task interval seconds. + * + * @return task interval seconds + */ public int getTaskIntervalSeconds() { return TASK_INTERVAL_SECONDS; } diff --git a/hippo4j-adapter/hippo4j-adapter-kafka/pom.xml b/hippo4j-adapter/hippo4j-adapter-kafka/pom.xml deleted file mode 100644 index f193cc75..00000000 --- a/hippo4j-adapter/hippo4j-adapter-kafka/pom.xml +++ /dev/null @@ -1,18 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-adapter - ${revision} - - hippo4j-adapter-kafka - - - - cn.hippo4j - hippo4j-adapter-base - - - diff --git a/hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java deleted file mode 100644 index e27ced8a..00000000 --- a/hippo4j-adapter/hippo4j-adapter-kafka/src/main/java/cn/hippo4j/adapter/kafka/KafkaThreadPoolAdapter.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.adapter.kafka; - -import cn.hippo4j.adapter.base.ThreadPoolAdapter; -import cn.hippo4j.adapter.base.ThreadPoolAdapterParameter; -import cn.hippo4j.adapter.base.ThreadPoolAdapterState; -import lombok.extern.slf4j.Slf4j; -import org.springframework.boot.context.event.ApplicationStartedEvent; -import org.springframework.context.ApplicationListener; - -/** - * Kafka thread-pool adapter. - */ -@Slf4j -public class KafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener { - - @Override - public String mark() { - return "Kafka"; - } - - @Override - public ThreadPoolAdapterState getThreadPoolState(String identify) { - return null; - } - - @Override - public boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter) { - return false; - } - - @Override - public void onApplicationEvent(ApplicationStartedEvent event) { - - } -} diff --git a/hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java index ccaab2b1..a05ac956 100644 --- a/hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java +++ b/hippo4j-adapter/hippo4j-adapter-rabbitmq/src/main/java/cn/hippo4j/adapter/rabbitmq/RabbitMQThreadPoolAdapter.java @@ -105,7 +105,6 @@ public class RabbitMQThreadPoolAdapter implements ThreadPoolAdapter, Application log.warn("Custom thread pools only support ThreadPoolExecutor"); } } - }); } } diff --git a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml deleted file mode 100644 index 25be8e39..00000000 --- a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/pom.xml +++ /dev/null @@ -1,18 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-adapter - ${revision} - - hippo4j-adapter-spring-cloud-stream-kafka - - - - cn.hippo4j - hippo4j-adapter-base - - - diff --git a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java deleted file mode 100644 index 4cc49356..00000000 --- a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaThreadPoolAdapter.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.adapter.springcloud.stream.kafka; - -import cn.hippo4j.adapter.base.ThreadPoolAdapter; -import cn.hippo4j.adapter.base.ThreadPoolAdapterParameter; -import cn.hippo4j.adapter.base.ThreadPoolAdapterState; -import lombok.extern.slf4j.Slf4j; -import org.springframework.boot.context.event.ApplicationStartedEvent; -import org.springframework.context.ApplicationListener; - -import java.util.List; - -/** - * Spring cloud stream kafka thread-pool adapter. - */ -@Slf4j -public class SpringCloudStreamKafkaThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener { - - @Override - public String mark() { - return "KafkaSpringCloudStream"; - } - - @Override - public ThreadPoolAdapterState getThreadPoolState(String identify) { - return null; - } - - @Override - public List getThreadPoolStates() { - return null; - } - - @Override - public boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter) { - return false; - } - - @Override - public void onApplicationEvent(ApplicationStartedEvent event) { - - } -} diff --git a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java index cb04cf6b..02c034cc 100644 --- a/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java +++ b/hippo4j-adapter/hippo4j-adapter-spring-cloud-stream-rabbitmq/src/main/java/cn/hippo4j/adapter/springcloud/stream/rabbitmq/SpringCloudStreamRabbitMQThreadPoolAdapter.java @@ -39,7 +39,7 @@ import java.util.*; import static cn.hippo4j.common.constant.ChangeThreadPoolConstants.CHANGE_DELIMITER; /** - * Spring cloud stream rabbimq thread-pool adapter. + * Spring cloud stream rabbit-mq thread-pool adapter. */ @Slf4j public class SpringCloudStreamRabbitMQThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener { diff --git a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/AbstractWebThreadPoolService.java b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/AbstractWebThreadPoolService.java index 771d6699..bafdf678 100644 --- a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/AbstractWebThreadPoolService.java +++ b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/AbstractWebThreadPoolService.java @@ -34,12 +34,12 @@ import java.util.concurrent.Executor; public abstract class AbstractWebThreadPoolService implements WebThreadPoolService, ApplicationRunner { /** - * Thread pool executor. + * Thread pool executor */ protected volatile Executor executor; /** - * Get web thread pool by server. + * Get web thread pool by server * * @param webServer * @return diff --git a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolHandlerChoose.java b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolHandlerChoose.java index f88f4d54..1d94d379 100644 --- a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolHandlerChoose.java +++ b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolHandlerChoose.java @@ -30,7 +30,7 @@ public class WebThreadPoolHandlerChoose { /** * Choose the web thread pool service bean. * - * @return + * @return web thread pool service bean */ public WebThreadPoolService choose() { WebThreadPoolService webThreadPoolService; diff --git a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java index 2727e52c..a30c16c8 100644 --- a/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java +++ b/hippo4j-adapter/hippo4j-adapter-web/src/main/java/cn/hippo4j/adapter/web/WebThreadPoolRunStateHandler.java @@ -35,9 +35,9 @@ public class WebThreadPoolRunStateHandler extends AbstractThreadPoolRuntime { long used = MemoryUtil.heapMemoryUsed(); long max = MemoryUtil.heapMemoryMax(); String memoryProportion = StringUtil.newBuilder( - "已分配: ", + "Allocation: ", ByteConvertUtil.getPrintSize(used), - " / 最大可用: ", + " / Maximum available: ", ByteConvertUtil.getPrintSize(max)); poolRunStateInfo.setCurrentLoad(poolRunStateInfo.getCurrentLoad() + "%"); poolRunStateInfo.setPeakLoad(poolRunStateInfo.getPeakLoad() + "%"); diff --git a/hippo4j-adapter/pom.xml b/hippo4j-adapter/pom.xml index d1c0624a..1993176c 100644 --- a/hippo4j-adapter/pom.xml +++ b/hippo4j-adapter/pom.xml @@ -14,12 +14,10 @@ hippo4j-adapter-base hippo4j-adapter-dubbo hippo4j-adapter-alibaba-dubbo - hippo4j-adapter-kafka hippo4j-adapter-rabbitmq hippo4j-adapter-rocketmq hippo4j-adapter-hystrix hippo4j-adapter-spring-cloud-stream-rocketmq - hippo4j-adapter-spring-cloud-stream-kafka hippo4j-adapter-spring-cloud-stream-rabbitmq hippo4j-adapter-web diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml deleted file mode 100644 index 40bcca10..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/pom.xml +++ /dev/null @@ -1,56 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-example - ${revision} - - hippo4j-spring-boot-starter-adapter-kafka-example - - - - org.springframework.boot - spring-boot-starter - - - - org.springframework.boot - spring-boot-starter-web - - - - org.springframework.boot - spring-boot-starter-json - - - - org.projectlombok - lombok - - - - cn.hippo4j - hippo4j-spring-boot-starter-adapter-kafka - ${project.version} - - - - cn.hippo4j - hippo4j-spring-boot-starter - ${project.version} - - - - cn.hippo4j - hippo4j-example-core - ${revision} - - - - org.springframework.kafka - spring-kafka - - - diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java deleted file mode 100644 index 89b8c40b..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/ServerAdapterKafkaExampleApplication.java +++ /dev/null @@ -1,31 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example; - -import cn.hippo4j.core.enable.EnableDynamicThreadPool; -import org.springframework.boot.SpringApplication; -import org.springframework.boot.autoconfigure.SpringBootApplication; - -@SpringBootApplication -@EnableDynamicThreadPool -public class ServerAdapterKafkaExampleApplication { - - public static void main(String[] args) { - SpringApplication.run(ServerAdapterKafkaExampleApplication.class, args); - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java deleted file mode 100644 index 43087cc9..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java +++ /dev/null @@ -1,43 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example.consumer; - -import lombok.extern.slf4j.Slf4j; -import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.springframework.kafka.annotation.KafkaListener; -import org.springframework.kafka.support.Acknowledgment; -import org.springframework.kafka.support.KafkaHeaders; -import org.springframework.messaging.handler.annotation.Header; -import org.springframework.stereotype.Component; - -import java.util.Optional; - -/** - * Kafka message consumer. - */ -@Slf4j -@Component -public class KafkaMessageConsumer { - - @KafkaListener(topics = "kafka_message_hippo4j", groupId = "hippo4j") - public void onMessage(ConsumerRecord record, Acknowledgment ack, @Header(KafkaHeaders.RECEIVED_TOPIC) String topic) { - Optional message = Optional.ofNullable(record.value()); - message.ifPresent(each -> log.info(each.toString())); - ack.acknowledge(); - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java deleted file mode 100644 index 9cfbddbd..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java +++ /dev/null @@ -1,55 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka.example.produce; - -import cn.hippo4j.common.toolkit.IdUtil; -import cn.hippo4j.common.toolkit.JSONUtil; -import cn.hippo4j.example.core.dto.SendMessageDTO; -import lombok.AllArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.kafka.core.KafkaTemplate; -import org.springframework.stereotype.Component; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RestController; - -/** - * Kafka message produce. - */ -@Slf4j -@Component -@RestController -@AllArgsConstructor -public class KafkaMessageProduce { - - private final KafkaTemplate kafkaTemplate; - - private final String TOPIC = "kafka_message_hippo4j"; - - @GetMapping("/message/send") - public String sendMessage(Integer count) { - for (int i = 0; i < count; i++) { - String keys = IdUtil.randomUUID(); - SendMessageDTO payload = SendMessageDTO.builder() - .receiver("156011xxx91") - .uid(keys) - .build(); - kafkaTemplate.send(TOPIC, JSONUtil.toJSONString(payload)); - } - return "success"; - } -} diff --git a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties b/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties deleted file mode 100644 index fe298e76..00000000 --- a/hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/resources/application.properties +++ /dev/null @@ -1,23 +0,0 @@ -server.port=8092 - -spring.profiles.active=dev -spring.dynamic.thread-pool.server-addr=http://localhost:6691 -spring.dynamic.thread-pool.namespace=prescription -spring.dynamic.thread-pool.item-id=dynamic-threadpool-example -spring.dynamic.thread-pool.username=admin -spring.dynamic.thread-pool.password=123456 - -spring.kafka.bootstrap-servers=127.0.0.1:9092 -spring.kafka.producer.retries=0 -spring.kafka.producer.batch-size=16384 -spring.kafka.producer.buffer-memory=33554432 -spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer -spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer -spring.kafka.producer.acks=1 -spring.kafka.consumer.auto-offset-reset=latest -spring.kafka.consumer.enable-auto-commit=false -spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer -spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer -spring.kafka.listener.concurrency=2 -spring.kafka.listener.ack-mode=manual_immediate -spring.kafka.listener.missing-topics-fatal=false diff --git a/hippo4j-example/pom.xml b/hippo4j-example/pom.xml index 8672119d..80999ea3 100644 --- a/hippo4j-example/pom.xml +++ b/hippo4j-example/pom.xml @@ -21,7 +21,6 @@ hippo4j-config-nacos-spring-boot-starter-example hippo4j-config-apollo-spring-boot-starter-example hippo4j-config-zookeeper-spring-boot-starter-example - hippo4j-spring-boot-starter-adapter-kafka-example hippo4j-spring-boot-starter-adapter-rabbitmq-example hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rabbitmq-example hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq-example diff --git a/hippo4j-message/src/main/java/cn/hippo4j/message/platform/base/AbstractRobotSendMessageHandler.java b/hippo4j-message/src/main/java/cn/hippo4j/message/platform/base/AbstractRobotSendMessageHandler.java index 209c2db9..f8acca94 100644 --- a/hippo4j-message/src/main/java/cn/hippo4j/message/platform/base/AbstractRobotSendMessageHandler.java +++ b/hippo4j-message/src/main/java/cn/hippo4j/message/platform/base/AbstractRobotSendMessageHandler.java @@ -72,7 +72,7 @@ public abstract class AbstractRobotSendMessageHandler implements SendMessageHand } else { replaceTxt = ""; } - alarmContentTxt = StringUtil.replace(alarmContentTxt, "${timout-content}", replaceTxt); + alarmContentTxt = StringUtil.replace(alarmContentTxt, "${timeout-content}", replaceTxt); String text = String.format( alarmContentTxt, alarmNotifyRequest.getActive(), diff --git a/hippo4j-message/src/main/java/cn/hippo4j/message/service/AlarmControlHandler.java b/hippo4j-message/src/main/java/cn/hippo4j/message/service/AlarmControlHandler.java index ea86e0f2..4d94b6bc 100644 --- a/hippo4j-message/src/main/java/cn/hippo4j/message/service/AlarmControlHandler.java +++ b/hippo4j-message/src/main/java/cn/hippo4j/message/service/AlarmControlHandler.java @@ -18,7 +18,6 @@ package cn.hippo4j.message.service; import cn.hippo4j.common.constant.Constants; -import cn.hippo4j.common.toolkit.IdUtil; import cn.hippo4j.common.toolkit.StringUtil; import cn.hippo4j.message.dto.AlarmControlDTO; import com.github.benmanes.caffeine.cache.Cache; @@ -58,8 +57,7 @@ public class AlarmControlHandler { try { pkId = cache.getIfPresent(alarmControl.getTypeEnum().name()); if (StringUtil.isBlank(pkId)) { - // Val meaningless. - cache.put(alarmControl.getTypeEnum().name(), IdUtil.simpleUUID()); + cache.put(alarmControl.getTypeEnum().name(), "-"); return true; } } finally { diff --git a/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/ding-alarm.txt b/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/ding-alarm.txt index 7fda29d7..094e4505 100644 --- a/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/ding-alarm.txt +++ b/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/ding-alarm.txt @@ -34,7 +34,7 @@ --- - ${timout-content} + ${timeout-content} 拒绝策略：%s diff --git a/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/wechat-alarm.txt b/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/wechat-alarm.txt index 00dd33b2..1e1aa9c4 100644 --- a/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/wechat-alarm.txt +++ b/hippo4j-message/src/main/resources/message/robot/dynamic-thread-pool/wechat-alarm.txt @@ -14,7 +14,7 @@ > 队列元素个数：%s > 队列剩余个数：%s > 拒绝策略：%s -> 拒绝策略执行次数：%s ${timout-content} +> 拒绝策略执行次数：%s ${timeout-content} > OWNER：<@%s> > 提示：%d 分钟内此线程池不会重复告警（可配置） diff --git a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AbstractDynamicThreadPoolMonitor.java b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AbstractDynamicThreadPoolMonitor.java index 81943cbd..2e8a77ac 100644 --- a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AbstractDynamicThreadPoolMonitor.java +++ b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AbstractDynamicThreadPoolMonitor.java @@ -42,9 +42,6 @@ public abstract class AbstractDynamicThreadPoolMonitor implements DynamicThreadP @Override public void collect() { List listDynamicThreadPoolId = GlobalThreadPoolManage.listThreadPoolId(); - for (String each : listDynamicThreadPoolId) { - ThreadPoolRunStateInfo poolRunState = threadPoolRunStateHandler.getPoolRunState(each); - execute(poolRunState); - } + listDynamicThreadPoolId.forEach(each -> execute(threadPoolRunStateHandler.getPoolRunState(each))); } } diff --git a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AdapterThreadPoolMonitor.java b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AdapterThreadPoolMonitor.java index cebdc7e2..520b4ffd 100644 --- a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AdapterThreadPoolMonitor.java +++ b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/AdapterThreadPoolMonitor.java @@ -21,5 +21,4 @@ package cn.hippo4j.monitor.base; * Adapter thread-pool monitor. */ public interface AdapterThreadPoolMonitor extends ThreadPoolMonitor { - } diff --git a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/DynamicThreadPoolMonitor.java b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/DynamicThreadPoolMonitor.java index e3135db4..7e8c7452 100644 --- a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/DynamicThreadPoolMonitor.java +++ b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/DynamicThreadPoolMonitor.java @@ -21,5 +21,4 @@ package cn.hippo4j.monitor.base; * Dynamic thread-pool monitor. */ public interface DynamicThreadPoolMonitor extends ThreadPoolMonitor { - } diff --git a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/WebThreadPoolMonitor.java b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/WebThreadPoolMonitor.java index 333c0dbd..75b40fb7 100644 --- a/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/WebThreadPoolMonitor.java +++ b/hippo4j-monitor/hippo4j-monitor-base/src/main/java/cn/hippo4j/monitor/base/WebThreadPoolMonitor.java @@ -21,5 +21,4 @@ package cn.hippo4j.monitor.base; * Web thread-pool monitor. */ public interface WebThreadPoolMonitor extends ThreadPoolMonitor { - } diff --git a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/AdapterThreadPoolMicrometerMonitorHandler.java b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/AdapterThreadPoolMicrometerMonitorHandler.java index 697ca2cf..0db66c68 100644 --- a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/AdapterThreadPoolMicrometerMonitorHandler.java +++ b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/AdapterThreadPoolMicrometerMonitorHandler.java @@ -46,10 +46,10 @@ public class AdapterThreadPoolMicrometerMonitorHandler extends AbstractAdapterTh @Override protected void execute(ThreadPoolAdapterState threadPoolAdapterState) { ThreadPoolAdapterState stateInfo = RUN_STATE_CACHE.get(threadPoolAdapterState.getThreadPoolKey()); - if (stateInfo == null) { - RUN_STATE_CACHE.put(threadPoolAdapterState.getThreadPoolKey(), threadPoolAdapterState); - } else { + if (stateInfo != null) { BeanUtil.convert(threadPoolAdapterState, stateInfo); + } else { + RUN_STATE_CACHE.put(threadPoolAdapterState.getThreadPoolKey(), threadPoolAdapterState); } Environment environment = ApplicationContextHolder.getInstance().getEnvironment(); String applicationName = environment.getProperty("spring.application.name", "application"); diff --git a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/DynamicThreadPoolMicrometerMonitorHandler.java b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/DynamicThreadPoolMicrometerMonitorHandler.java index 5b2cc068..f9c9f1d8 100644 --- a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/DynamicThreadPoolMicrometerMonitorHandler.java +++ b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/DynamicThreadPoolMicrometerMonitorHandler.java @@ -46,10 +46,10 @@ public class DynamicThreadPoolMicrometerMonitorHandler extends AbstractDynamicTh @Override protected void execute(ThreadPoolRunStateInfo poolRunStateInfo) { ThreadPoolRunStateInfo stateInfo = RUN_STATE_CACHE.get(poolRunStateInfo.getTpId()); - if (stateInfo == null) { - RUN_STATE_CACHE.put(poolRunStateInfo.getTpId(), poolRunStateInfo); - } else { + if (stateInfo != null) { BeanUtil.convert(poolRunStateInfo, stateInfo); + } else { + RUN_STATE_CACHE.put(poolRunStateInfo.getTpId(), poolRunStateInfo); } Environment environment = ApplicationContextHolder.getInstance().getEnvironment(); String applicationName = environment.getProperty("spring.application.name", "application"); diff --git a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/WebThreadPoolMicrometerMonitorHandler.java b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/WebThreadPoolMicrometerMonitorHandler.java index e7042a04..3c0795d9 100644 --- a/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/WebThreadPoolMicrometerMonitorHandler.java +++ b/hippo4j-monitor/hippo4j-monitor-micrometer/src/main/java/cn/hippo4j/monitor/micrometer/WebThreadPoolMicrometerMonitorHandler.java @@ -46,10 +46,10 @@ public class WebThreadPoolMicrometerMonitorHandler extends AbstractWebThreadPool Environment environment = ApplicationContextHolder.getInstance().getEnvironment(); String applicationName = environment.getProperty("spring.application.name", "application"); ThreadPoolRunStateInfo stateInfo = RUN_STATE_CACHE.get(applicationName); - if (stateInfo == null) { - RUN_STATE_CACHE.put(applicationName, webThreadPoolRunStateInfo); - } else { + if (stateInfo != null) { BeanUtil.convert(webThreadPoolRunStateInfo, stateInfo); + } else { + RUN_STATE_CACHE.put(applicationName, webThreadPoolRunStateInfo); } Iterable tags = CollectionUtil.newArrayList(Tag.of(APPLICATION_NAME_TAG, applicationName)); Metrics.gauge(metricName("current.load"), tags, webThreadPoolRunStateInfo, ThreadPoolRunStateInfo::getSimpleCurrentLoad); diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/config/FilterConfig.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/config/FilterConfig.java index 76aa3602..ae53a759 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/config/FilterConfig.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/config/FilterConfig.java @@ -23,7 +23,7 @@ import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** - * + * Filter config. */ @Configuration public class FilterConfig { diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/filter/JWTAuthorizationFilter.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/filter/JWTAuthorizationFilter.java index 3b6cf69e..78f3bee5 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/filter/JWTAuthorizationFilter.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/filter/JWTAuthorizationFilter.java @@ -68,14 +68,12 @@ public class JWTAuthorizationFilter extends BasicAuthenticationFilter { chain.doFilter(request, response); return; } - // If there is no Authorization information in the request header, it will be released directly. String tokenHeader = request.getHeader(JwtTokenUtil.TOKEN_HEADER); if (tokenHeader == null || !tokenHeader.startsWith(JwtTokenUtil.TOKEN_PREFIX)) { chain.doFilter(request, response); return; } - // If there is a Token in the request header, it is parsed and the authentication information is set. try { SecurityContextHolder.getContext().setAuthentication(getAuthentication(tokenHeader)); diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/security/JwtTokenManager.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/security/JwtTokenManager.java index 17f52aaa..2abd58d6 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/security/JwtTokenManager.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/security/JwtTokenManager.java @@ -41,15 +41,30 @@ import static cn.hippo4j.common.constant.Constants.AUTHORITIES_KEY; @Component public class JwtTokenManager { + /** + * Create token. + * + * @param userName user-name + * @return new token + */ public String createToken(String userName) { long now = System.currentTimeMillis(); Date validity; validity = new Date(now + TOKEN_VALIDITY_IN_SECONDS * 1000L); Claims claims = Jwts.claims().setSubject(userName); - return Jwts.builder().setClaims(claims).setExpiration(validity) - .signWith(SignatureAlgorithm.HS512, SECRET).compact(); + String token = Jwts.builder() + .setClaims(claims) + .setExpiration(validity) + .signWith(SignatureAlgorithm.HS512, SECRET) + .compact(); + return token; } + /** + * Validate token. + * + * @param token token + */ public void validateToken(String token) { Jwts.parser().setSigningKey(SECRET).parseClaimsJws(token); } diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/service/impl/UserServiceImpl.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/service/impl/UserServiceImpl.java index b500fa06..c2cf1988 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/service/impl/UserServiceImpl.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/service/impl/UserServiceImpl.java @@ -22,7 +22,6 @@ import cn.hippo4j.auth.model.UserInfo; import cn.hippo4j.auth.model.biz.user.UserQueryPageReqDTO; import cn.hippo4j.auth.model.biz.user.UserReqDTO; import cn.hippo4j.auth.model.biz.user.UserRespDTO; -import cn.hippo4j.auth.service.RoleService; import cn.hippo4j.auth.service.UserService; import cn.hippo4j.common.toolkit.BeanUtil; import cn.hippo4j.common.toolkit.StringUtil; @@ -49,8 +48,6 @@ public class UserServiceImpl implements UserService { private final UserMapper userMapper; - private final RoleService roleService; - private final BCryptPasswordEncoder bCryptPasswordEncoder; @Override diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/JwtTokenUtil.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/JwtTokenUtil.java index c78af646..40a831c0 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/JwtTokenUtil.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/JwtTokenUtil.java @@ -36,9 +36,11 @@ import static cn.hippo4j.common.constant.Constants.MAP_INITIAL_CAPACITY; public class JwtTokenUtil { public static final String TOKEN_HEADER = "Authorization"; + public static final String TOKEN_PREFIX = "Bearer "; public static final String SECRET = "SecretKey039245678901232039487623456783092349288901402967890140939827"; + public static final String ISS = "admin"; /** diff --git a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/ReturnT.java b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/ReturnT.java index ccc1ab1c..47743239 100644 --- a/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/ReturnT.java +++ b/hippo4j-server/hippo4j-auth/src/main/java/cn/hippo4j/auth/toolkit/ReturnT.java @@ -32,13 +32,17 @@ public class ReturnT implements Serializable { public static final long serialVersionUID = 42L; public static final int SUCCESS_CODE = 200; + public static final int FAIL_CODE = 500; public static final ReturnT SUCCESS = new ReturnT<>(null); + public static final ReturnT FAIL = new ReturnT<>(FAIL_CODE, null); private int code; + private String msg; + private T content; public ReturnT(int code, String msg) { diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java deleted file mode 100644 index 0c3cd1e1..00000000 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/event/ConfigDataChangeEvent.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.config.event; - -import org.springframework.util.StringUtils; - -/** - * Config data change event. - */ -public class ConfigDataChangeEvent extends AbstractEvent { - - public final String tenantId; - - public final String itemId; - - public final String tpId; - - public final long lastModifiedTs; - - public ConfigDataChangeEvent(String tenantId, String itemId, String tpId, Long gmtModified) { - if (StringUtils.isEmpty(tenantId) || StringUtils.isEmpty(itemId) || StringUtils.isEmpty(tpId)) { - throw new IllegalArgumentException("DataId is null or group is null"); - } - this.tenantId = tenantId; - this.itemId = itemId; - this.tpId = tpId; - this.lastModifiedTs = gmtModified; - } -} diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/AbstractMonitorDataExecuteStrategy.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/AbstractMonitorDataExecuteStrategy.java index ae0dc032..78d89bcf 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/AbstractMonitorDataExecuteStrategy.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/AbstractMonitorDataExecuteStrategy.java @@ -27,14 +27,14 @@ public abstract class AbstractMonitorDataExecuteStrategy { /** * Mark. * - * @return + * @return mark */ public abstract String mark(); /** * Execute. * - * @param message + * @param message message */ public abstract void execute(T message); } diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/QueryMonitorExecuteChoose.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/QueryMonitorExecuteChoose.java index 2dfd9a6b..525ee8ee 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/QueryMonitorExecuteChoose.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/monitor/QueryMonitorExecuteChoose.java @@ -33,7 +33,7 @@ import java.util.Map; public class QueryMonitorExecuteChoose implements CommandLineRunner { /** - * Storage monitoring data execution container. + * Storage monitoring data execution container */ private Map monitorDataExecuteStrategyChooseMap = new HashMap<>(); diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java index 7b8f67e6..39612b11 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/DefaultPublisher.java @@ -63,7 +63,6 @@ public class DefaultPublisher extends Thread implements EventPublisher { @Override public synchronized void start() { if (!initialized) { - // start just called once super.start(); if (queueMaxSize == -1) { queueMaxSize = NotifyCenter.ringBufferSize; @@ -100,7 +99,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { UPDATER.compareAndSet(this, lastEventSequence, Math.max(lastEventSequence, event.sequence())); } } catch (Throwable ex) { - log.error("Event listener exception: {}", ex); + log.error("Event listener exception.", ex); } } @@ -123,9 +122,7 @@ public class DefaultPublisher extends Thread implements EventPublisher { @Override public void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event) { final Runnable job = () -> subscriber.onEvent(event); - final Executor executor = subscriber.executor(); - if (executor != null) { executor.execute(job); } else { diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java index 858b30f2..1a726308 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/EventPublisher.java @@ -28,31 +28,31 @@ public interface EventPublisher { /** * Init. * - * @param type - * @param bufferSize + * @param type type + * @param bufferSize buffer size */ void init(Class type, int bufferSize); /** * Add subscriber. * - * @param subscriber + * @param subscriber subscriber */ void addSubscriber(AbstractSubscriber subscriber); /** * Publish. * - * @param event - * @return + * @param event event + * @return publish result */ boolean publish(AbstractEvent event); /** * Notify subscriber. * - * @param subscriber - * @param event + * @param subscriber subscriber + * @param event event */ void notifySubscriber(AbstractSubscriber subscriber, AbstractEvent event); } diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java index 0fce3453..78101e86 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/NotifyCenter.java @@ -43,11 +43,9 @@ public class NotifyCenter { private DefaultSharePublisher sharePublisher; - private static Class clazz = null; - private static EventPublisher eventPublisher = new DefaultPublisher(); - private static BiFunction, Integer, EventPublisher> publisherFactory = null; + private static BiFunction, Integer, EventPublisher> publisherFactory; private final Map publisherMap = new ConcurrentHashMap(16); diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java index 16357b47..50705b97 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/notify/listener/AbstractSubscriber.java @@ -40,6 +40,11 @@ public abstract class AbstractSubscriber { */ public abstract Class subscribeType(); + /** + * Executor. + * + * @return executor + */ public Executor executor() { return null; } diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/ConfigChangePublisher.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/ConfigChangePublisher.java index 084c8925..7ae44a12 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/ConfigChangePublisher.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/ConfigChangePublisher.java @@ -28,7 +28,7 @@ public class ConfigChangePublisher { /** * Notify configChange. * - * @param event + * @param event event */ public static void notifyConfigChange(LocalDataChangeEvent event) { NotifyCenter.publishEvent(event); diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java index b5d667a0..a485048c 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/service/LongPollingService.java @@ -68,13 +68,9 @@ public class LongPollingService { @Override public void onEvent(AbstractEvent event) { - if (isFixedPolling()) { - // Ignore. - } else { - if (event instanceof LocalDataChangeEvent) { - LocalDataChangeEvent evt = (LocalDataChangeEvent) event; - ConfigExecutor.executeLongPolling(new DataChangeTask(evt.identify, evt.groupKey)); - } + if (!isFixedPolling() && event instanceof LocalDataChangeEvent) { + LocalDataChangeEvent evt = (LocalDataChangeEvent) event; + ConfigExecutor.executeLongPolling(new DataChangeTask(evt.identify, evt.groupKey)); } } @@ -300,11 +296,11 @@ public class LongPollingService { /** * Is support long polling. * - * @param req + * @param request * @return */ - public static boolean isSupportLongPolling(HttpServletRequest req) { - return null != req.getHeader(LONG_POLLING_HEADER); + public static boolean isSupportLongPolling(HttpServletRequest request) { + return request.getHeader(LONG_POLLING_HEADER) != null; } /** diff --git a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/verify/ConfigModificationVerifyServiceChoose.java b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/verify/ConfigModificationVerifyServiceChoose.java index 98769559..2eb72589 100644 --- a/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/verify/ConfigModificationVerifyServiceChoose.java +++ b/hippo4j-server/hippo4j-config/src/main/java/cn/hippo4j/config/verify/ConfigModificationVerifyServiceChoose.java @@ -33,7 +33,7 @@ import java.util.Map; public class ConfigModificationVerifyServiceChoose implements CommandLineRunner { /** - * Storage config change verify service container. + * Storage config change verify service container */ private Map configChangeVerifyServiceChooseMap = new HashMap<>(); @@ -44,8 +44,7 @@ public class ConfigModificationVerifyServiceChoose implements CommandLineRunner * @return */ public ConfigModificationVerifyService choose(Integer type) { - ConfigModificationVerifyService verifyService = configChangeVerifyServiceChooseMap.get(type); - return verifyService; + return configChangeVerifyServiceChooseMap.get(type); } @Override diff --git a/hippo4j-server/hippo4j-discovery/src/main/java/cn/hippo4j/discovery/core/Lease.java b/hippo4j-server/hippo4j-discovery/src/main/java/cn/hippo4j/discovery/core/Lease.java index e604760b..ea76264a 100644 --- a/hippo4j-server/hippo4j-discovery/src/main/java/cn/hippo4j/discovery/core/Lease.java +++ b/hippo4j-server/hippo4j-discovery/src/main/java/cn/hippo4j/discovery/core/Lease.java @@ -17,32 +17,19 @@ package cn.hippo4j.discovery.core; +import lombok.Getter; + /** * Lease. */ public class Lease { - enum Action { - /** - * REGISTER - */ - REGISTER, - - /** - * CANCEL - */ - CANCEL, - - /** - * RENEW - */ - RENEW - } - private T holder; + @Getter private long evictionTimestamp; + @Getter private long registrationTimestamp; private long serviceUpTimestamp; @@ -50,6 +37,7 @@ public class Lease { /** * Make it volatile so that the expiration task would see this quicker */ + @Getter private volatile long lastUpdateTimestamp; private long duration; @@ -91,18 +79,6 @@ public class Lease { return (evictionTimestamp > 0 || System.currentTimeMillis() > (lastUpdateTimestamp + additionalLeaseMs)); } - public long getRegistrationTimestamp() { - return registrationTimestamp; - } - - public long getLastRenewalTimestamp() { - return lastUpdateTimestamp; - } - - public long getEvictionTimestamp() { - return evictionTimestamp; - } - public long getServiceUpTimestamp() { return serviceUpTimestamp; } diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue index 9cef3ce2..da1e1761 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/alibaba-dubbo/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue index a7422930..530275f6 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/dubbo/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue index 4d9c41f9..1162ed67 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/hystrix/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue index ab6b6790..64cea308 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/index.vue @@ -227,8 +227,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue index 47384c5b..b2c4918c 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq-stream/index.vue @@ -214,8 +214,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue index 0579bfd7..9dabd398 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rabbitmq/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue index f0dfb75b..f64b9c78 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq-stream/index.vue @@ -214,8 +214,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue index dfac0769..17c4fb9a 100755 --- a/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue +++ b/hippo4j-server/hippo4j-ui/src/views/hippo4j/other/rocketmq/index.vue @@ -215,8 +215,6 @@ export default { runTimeTemp: {}, typeOptions: [ { key: 'Dubbo', display_name: 'Dubbo' }, - { key: 'Kafka', display_name: 'Kafka' }, - { key: 'KafkaSpringCloudStream', display_name: 'KafkaSpringCloudStream' }, { key: 'RocketMQ', display_name: 'RocketMQ' }, { key: 'RocketMQSpringCloudStream', display_name: 'RocketMQSpringCloudStream' }, { key: 'RabbitMQ', display_name: 'RabbitMQ' }, diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/pom.xml b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/pom.xml deleted file mode 100644 index 85b4f49d..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/pom.xml +++ /dev/null @@ -1,19 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-spring-boot-starter-adapter - ${revision} - - hippo4j-spring-boot-starter-adapter-kafka - - - - cn.hippo4j - hippo4j-adapter-kafka - ${revision} - - - diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/KafkaAdapterAutoConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/KafkaAdapterAutoConfiguration.java deleted file mode 100644 index b362f0b4..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/KafkaAdapterAutoConfiguration.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.kafka; - -import cn.hippo4j.adapter.kafka.KafkaThreadPoolAdapter; -import cn.hippo4j.common.config.ApplicationContextHolder; -import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; -import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - * Kafka adapter auto configuration. - */ -@Configuration -public class KafkaAdapterAutoConfiguration { - - @Bean - @ConditionalOnMissingBean - public ApplicationContextHolder simpleApplicationContextHolder() { - return new ApplicationContextHolder(); - } - - @Bean - @SuppressWarnings("all") - @ConditionalOnProperty(name = "spring.kafka.bootstrap-servers") - public KafkaThreadPoolAdapter kafkaMQThreadPoolAdapter(ApplicationContextHolder applicationContextHolder) { - return new KafkaThreadPoolAdapter(); - } -} diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/resources/META-INF/spring.factories b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/resources/META-INF/spring.factories deleted file mode 100644 index 592fba93..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-kafka/src/main/resources/META-INF/spring.factories +++ /dev/null @@ -1 +0,0 @@ -org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.springboot.starter.adapter.kafka.KafkaAdapterAutoConfiguration diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/pom.xml b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/pom.xml deleted file mode 100644 index 85d57b0c..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/pom.xml +++ /dev/null @@ -1,19 +0,0 @@ - - - 4.0.0 - - cn.hippo4j - hippo4j-spring-boot-starter-adapter - ${revision} - - hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka - - - - cn.hippo4j - hippo4j-adapter-spring-cloud-stream-kafka - ${revision} - - - diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaAdapterAutoConfiguration.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaAdapterAutoConfiguration.java deleted file mode 100644 index cc8ddb6e..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/java/cn/hippo4j/springboot/starter/adapter/springcloud/stream/kafka/SpringCloudStreamKafkaAdapterAutoConfiguration.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package cn.hippo4j.springboot.starter.adapter.springcloud.stream.kafka; - -import cn.hippo4j.adapter.springcloud.stream.kafka.SpringCloudStreamKafkaThreadPoolAdapter; -import cn.hippo4j.common.config.ApplicationContextHolder; -import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; -import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - * Spring cloud stream kafka adapter auto configuration. - */ -@Configuration -public class SpringCloudStreamKafkaAdapterAutoConfiguration { - - @Bean - @ConditionalOnMissingBean - public ApplicationContextHolder simpleApplicationContextHolder() { - return new ApplicationContextHolder(); - } - - @Bean - @SuppressWarnings("all") - @ConditionalOnProperty(name = "xxx") - public SpringCloudStreamKafkaThreadPoolAdapter springCloudStreamKafkaThreadPoolAdapter(ApplicationContextHolder applicationContextHolder) { - return new SpringCloudStreamKafkaThreadPoolAdapter(); - } -} diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/resources/META-INF/spring.factories b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/resources/META-INF/spring.factories deleted file mode 100644 index 065332d1..00000000 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka/src/main/resources/META-INF/spring.factories +++ /dev/null @@ -1 +0,0 @@ -org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.springboot.starter.adapter.springcloud.stream.kafka.SpringCloudStreamKafkaAdapterAutoConfiguration diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/pom.xml b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/pom.xml index 337ef55b..258c092e 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/pom.xml +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/pom.xml @@ -14,11 +14,9 @@ hippo4j-spring-boot-starter-adapter-all hippo4j-spring-boot-starter-adapter-dubbo hippo4j-spring-boot-starter-adapter-alibaba-dubbo - hippo4j-spring-boot-starter-adapter-kafka hippo4j-spring-boot-starter-adapter-rabbitmq hippo4j-spring-boot-starter-adapter-rocketmq hippo4j-spring-boot-starter-adapter-hystrix - hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rabbitmq hippo4j-spring-boot-starter-adapter-web