Merge pull request #279 from shining-stars-lk/develop

添加对hystrix线程池的监控

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterExtra.java

@@ -0,0 +1,57 @@
+/*
+ * 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.base;
+
+import lombok.extern.slf4j.Slf4j;
+
+import java.util.Map;
+import java.util.concurrent.ArrayBlockingQueue;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * thread pool adapter extra.
+ */
+@Slf4j
+public class ThreadPoolAdapterExtra {
+
+    private static final int BLOCKING_QUEUE_CAPACITY = 100;
+
+    private BlockingQueue<Map<String, ThreadPoolAdapter>> blockingQueue;
+
+    public ThreadPoolAdapterExtra() {
+        blockingQueue = new ArrayBlockingQueue(BLOCKING_QUEUE_CAPACITY);
+    }
+
+    public void offerQueue(Map<String, ThreadPoolAdapter> map) throws InterruptedException {
+        blockingQueue.offer(map, 5, TimeUnit.SECONDS);
+    }
+
+    public void extraStart(ThreadPoolAdapterExtraHandle threadPoolAdapterExtraHandle) {
+        new Thread(() -> {
+            try {
+                for (;;) {
+                    Map<String, ThreadPoolAdapter> map = blockingQueue.take();
+                    threadPoolAdapterExtraHandle.execute(map);
+                }
+            } catch (InterruptedException e) {
+                log.error("extraStart error", e);
+            }
+        }, "threadPoolAdapterExtra").start();
+    }
+}

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterExtraAutoConfiguration.java

@@ -0,0 +1,34 @@
+/*
+ * 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.base;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * thread pool adapter extra auto configuration.
+ */
+@Configuration(proxyBeanMethods = false)
+public class ThreadPoolAdapterExtraAutoConfiguration {
+
+    @Bean
+    public ThreadPoolAdapterExtra threadPoolAdapterExtra() {
+        return new ThreadPoolAdapterExtra();
+    }
+
+}

hippo4j-adapter/hippo4j-adapter-base/src/main/java/cn/hippo4j/adapter/base/ThreadPoolAdapterExtraHandle.java

@@ -0,0 +1,29 @@
+/*
+ * 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.base;
+
+import java.util.Map;
+
+/**
+ * Thread Pool Adapter Extra Handle
+ **/
+@FunctionalInterface
+public interface ThreadPoolAdapterExtraHandle {
+
+    void execute(Map<String, ThreadPoolAdapter> map);
+}

hippo4j-adapter/hippo4j-adapter-base/src/main/resources/META-INF/spring.factories

@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.adapter.base.ThreadPoolAdapterExtraAutoConfiguration

hippo4j-adapter/hippo4j-adapter-hystrix/pom.xml

@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>cn.hippo4j</groupId>
+        <artifactId>hippo4j-adapter</artifactId>
+        <version>${revision}</version>
+    </parent>
+    <artifactId>hippo4j-adapter-hystrix</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>cn.hippo4j</groupId>
+            <artifactId>hippo4j-adapter-base</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
+            <version>${spring-cloud-starter-netflix-hystrix.version}</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <configuration>
+                    <archive>
+                        <manifestEntries>
+                            <Implementation-Title>${project.artifactId}</Implementation-Title>
+                            <Implementation-Version>${project.version}</Implementation-Version>
+                            <Build-Time>${maven.build.timestamp}</Build-Time>
+                            <Built-By>chen.ma</Built-By>
+                        </manifestEntries>
+                    </archive>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-javadoc-plugin</artifactId>
+                <version>2.10.3</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>jar</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

hippo4j-adapter/hippo4j-adapter-hystrix/src/main/java/cn/hippo4j/adapter/hystrix/HystrixThreadPoolAdapter.java

@@ -0,0 +1,184 @@
+/*
+ * 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.hystrix;
+
+import cn.hippo4j.adapter.base.ThreadPoolAdapter;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterExtra;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterParameter;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterState;
+import cn.hippo4j.common.config.ApplicationContextHolder;
+import cn.hippo4j.common.toolkit.CollectionUtil;
+import com.google.common.collect.Maps;
+import com.google.common.util.concurrent.ThreadFactoryBuilder;
+import com.netflix.hystrix.HystrixThreadPool;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.context.event.ApplicationStartedEvent;
+import org.springframework.context.ApplicationListener;
+
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
+
+import static cn.hippo4j.common.constant.ChangeThreadPoolConstants.CHANGE_DELIMITER;
+
+/**
+ * hystrix thread-pool adapter.
+ */
+@Slf4j
+public class HystrixThreadPoolAdapter implements ThreadPoolAdapter, ApplicationListener<ApplicationStartedEvent> {
+
+    private static final String THREAD_POOL_FIELD = "threadPool";
+
+    private static final String THREAD_POOLS_FIELD = "threadPools";
+
+    private static final int TASK_INTERVAL_SECONDS = 2;
+
+    private final Map<String, ThreadPoolExecutor> HYSTRIX_CONSUME_EXECUTOR = Maps.newHashMap();
+
+    private final ScheduledExecutorService scheduler;
+
+    private ThreadPoolAdapterExtra threadPoolAdapterExtra;
+
+    public HystrixThreadPoolAdapter(ThreadPoolAdapterExtra threadPoolAdapterExtra) {
+
+        this.threadPoolAdapterExtra = threadPoolAdapterExtra;
+
+        scheduler = new ScheduledThreadPoolExecutor(2,
+                new ThreadFactoryBuilder()
+                        .setNameFormat("hystrixThreadPoolAdapter")
+                        .setDaemon(true)
+                        .build());
+    }
+
+    @Override
+    public String mark() {
+        return "hystrix";
+    }
+
+    @Override
+    public ThreadPoolAdapterState getThreadPoolState(String identify) {
+        ThreadPoolAdapterState result = new ThreadPoolAdapterState();
+        ThreadPoolExecutor threadPoolExecutor = HYSTRIX_CONSUME_EXECUTOR.get(identify);
+        if (threadPoolExecutor != null) {
+            result.setThreadPoolKey(identify);
+            result.setCoreSize(threadPoolExecutor.getCorePoolSize());
+            result.setMaximumSize(threadPoolExecutor.getMaximumPoolSize());
+            return result;
+        }
+        log.warn("[{}] hystrix thread pool not found.", identify);
+        return result;
+    }
+
+    @Override
+    public List<ThreadPoolAdapterState> getThreadPoolStates() {
+        List<ThreadPoolAdapterState> threadPoolAdapterStates = new ArrayList<>();
+        HYSTRIX_CONSUME_EXECUTOR.forEach((kel, val) -> threadPoolAdapterStates.add(getThreadPoolState(String.valueOf(val))));
+        return threadPoolAdapterStates;
+    }
+
+    @Override
+    public boolean updateThreadPool(ThreadPoolAdapterParameter threadPoolAdapterParameter) {
+        String threadPoolKey = threadPoolAdapterParameter.getThreadPoolKey();
+        ThreadPoolExecutor threadPoolExecutor = HYSTRIX_CONSUME_EXECUTOR.get(threadPoolKey);
+        if (threadPoolExecutor == null) {
+            log.warn("[{}] hystrix thread pool not found.", threadPoolKey);
+            return false;
+        }
+        int originalCoreSize = threadPoolExecutor.getCorePoolSize();
+        int originalMaximumPoolSize = threadPoolExecutor.getMaximumPoolSize();
+        threadPoolExecutor.setCorePoolSize(threadPoolAdapterParameter.getCorePoolSize());
+        threadPoolExecutor.setMaximumPoolSize(threadPoolAdapterParameter.getMaximumPoolSize());
+        log.info("[{}] hystrix thread pool parameter change. coreSize :: {}, maximumSize :: {}",
+                threadPoolKey,
+                String.format(CHANGE_DELIMITER, originalCoreSize, threadPoolExecutor.getCorePoolSize()),
+                String.format(CHANGE_DELIMITER, originalMaximumPoolSize, threadPoolExecutor.getMaximumPoolSize()));
+        return true;
+    }
+
+    @Override
+    public void onApplicationEvent(ApplicationStartedEvent event) {
+        HystrixThreadPoolRefreshTask hystrixThreadPoolRefreshTask = new HystrixThreadPoolRefreshTask(scheduler);
+        scheduler.schedule(hystrixThreadPoolRefreshTask, TASK_INTERVAL_SECONDS, TimeUnit.SECONDS);
+    }
+
+    public void hystrixThreadPoolRefresh() {
+        try {
+            boolean addExtraFlag = false;
+            Class<HystrixThreadPool.Factory> factoryClass = HystrixThreadPool.Factory.class;
+            Field threadPoolsField = factoryClass.getDeclaredField(THREAD_POOLS_FIELD);
+            threadPoolsField.setAccessible(true);
+            ConcurrentHashMap<String, HystrixThreadPool> threadPools =
+                    (ConcurrentHashMap<String, HystrixThreadPool>) threadPoolsField.get(factoryClass);
+            if (CollectionUtil.isNotEmpty(threadPools)) {
+                for (Map.Entry<String, HystrixThreadPool> stringHystrixThreadPoolEntry : threadPools.entrySet()) {
+                    String key = stringHystrixThreadPoolEntry.getKey();
+                    HystrixThreadPool value = stringHystrixThreadPoolEntry.getValue();
+                    if (value instanceof HystrixThreadPool.HystrixThreadPoolDefault) {
+                        HystrixThreadPool.HystrixThreadPoolDefault hystrixThreadPoolDefault =
+                                (HystrixThreadPool.HystrixThreadPoolDefault) value;
+                        Class<? extends HystrixThreadPool.HystrixThreadPoolDefault> hystrixThreadPoolDefaultClass = hystrixThreadPoolDefault.getClass();
+                        Field threadPoolField = hystrixThreadPoolDefaultClass.getDeclaredField(THREAD_POOL_FIELD);
+                        threadPoolField.setAccessible(true);
+                        ThreadPoolExecutor threadPoolExecutor =
+                                (ThreadPoolExecutor) threadPoolField.get(hystrixThreadPoolDefault);
+                        if (threadPoolExecutor != null && HYSTRIX_CONSUME_EXECUTOR.get(key) == null) {
+                            HYSTRIX_CONSUME_EXECUTOR.put(key, threadPoolExecutor);
+                            addExtraFlag = true;
+                        }
+                    }
+                }
+            }
+            if (addExtraFlag) {
+                Map<String, ThreadPoolAdapter> map = Maps.newHashMap();
+                map.putAll(ApplicationContextHolder.getBeansOfType(HystrixThreadPoolAdapter.class));
+                threadPoolAdapterExtra.offerQueue(map);
+            }
+        } catch (Exception e) {
+            log.error("Failed to get Hystrix thread pool.", e);
+        }
+
+    }
+
+    class HystrixThreadPoolRefreshTask implements Runnable {
+
+        private ScheduledExecutorService scheduler;
+
+        public HystrixThreadPoolRefreshTask(ScheduledExecutorService scheduler) {
+            this.scheduler = scheduler;
+        }
+
+        @Override
+        public void run() {
+            try {
+                hystrixThreadPoolRefresh();
+            } finally {
+                if (!scheduler.isShutdown()) {
+                    scheduler.schedule(this, TASK_INTERVAL_SECONDS, TimeUnit.MILLISECONDS);
+                }
+            }
+        }
+    }
+}

hippo4j-adapter/pom.xml

@@ -16,6 +16,7 @@
         <module>hippo4j-adapter-kafka</module>
         <module>hippo4j-adapter-rabbitmq</module>
         <module>hippo4j-adapter-rocketmq</module>
+        <module>hippo4j-adapter-hystrix</module>
         <module>hippo4j-adapter-spring-cloud-stream-rocketmq</module>
         <module>hippo4j-adapter-spring-cloud-stream-kafka</module>
     </modules>

hippo4j-config/src/main/java/cn/hippo4j/config/config/NettyServerConfig.java

@@ -1,3 +1,20 @@
+/*
+ * 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.config;
 
 import cn.hippo4j.config.netty.MonitorNettyServer;
@@ -11,12 +28,12 @@ import org.springframework.context.annotation.Configuration;
 public class NettyServerConfig {
 
     @Bean
-    public EventLoopGroup bossGroup(){
+    public EventLoopGroup bossGroup() {
         return new NioEventLoopGroup();
     }
 
     @Bean
-    public EventLoopGroup workGroup(){
+    public EventLoopGroup workGroup() {
         return new NioEventLoopGroup();
     }
 
@@ -24,9 +41,7 @@ public class NettyServerConfig {
     public MonitorNettyServer monitorNettyServer(ServerBootstrapProperties serverBootstrapProperties,
                                                  HisRunDataService hisRunDataService,
                                                  EventLoopGroup bossGroup,
-                                                 EventLoopGroup workGroup){
+                                                 EventLoopGroup workGroup) {
-        return new MonitorNettyServer(serverBootstrapProperties,hisRunDataService,bossGroup,workGroup);
+        return new MonitorNettyServer(serverBootstrapProperties, hisRunDataService, bossGroup, workGroup);
     }
 }
-
-

hippo4j-config/src/main/java/cn/hippo4j/config/netty/MonitorNettyServer.java

@@ -1,3 +1,20 @@
+/*
+ * 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.netty;
 
 import cn.hippo4j.config.config.ServerBootstrapProperties;
@@ -44,16 +61,17 @@ public class MonitorNettyServer {
     private EventLoopGroup workGroup;
 
     @PostConstruct
-    public void nettyServerInit(){
+    public void nettyServerInit() {
         new Thread(() -> {
             try {
                 ServerBootstrap serverBootstrap = new ServerBootstrap();
-                serverBootstrap.group(bossGroup,workGroup)
+                serverBootstrap.group(bossGroup, workGroup)
                         .channel(NioServerSocketChannel.class)
                         .handler(new LoggingHandler(LogLevel.INFO))
-                        //childHandler的任务由workGroup来执行
+                        // childHandler的任务由workGroup来执行
-                        //如果是handler，则由bossGroup来执行
+                        // 如果是handler，则由bossGroup来执行
-                        .childHandler(new ChannelInitializer<SocketChannel>(){
+                        .childHandler(new ChannelInitializer<SocketChannel>() {
+
                             @Override
                             protected void initChannel(SocketChannel ch) throws Exception {
                                 ChannelPipeline pipeline = ch.pipeline();
@@ -66,13 +84,13 @@ public class MonitorNettyServer {
                 ChannelFuture channelFuture = serverBootstrap.bind(Integer.parseInt(serverBootstrapProperties.getNettyServerPort())).sync();
                 channelFuture.channel().closeFuture().sync();
             } catch (Exception e) {
-                log.error("nettyServerInit error",e);
+                log.error("nettyServerInit error", e);
             }
-        },"nettyServerInit thread").start();
+        }, "nettyServerInit thread").start();
     }
 
     @PreDestroy
-    public void destroy(){
+    public void destroy() {
         bossGroup.shutdownGracefully();
         workGroup.shutdownGracefully();
     }

hippo4j-config/src/main/java/cn/hippo4j/config/netty/ServerHandler.java

@@ -1,3 +1,20 @@
+/*
+ * 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.netty;
 
 import cn.hippo4j.common.monitor.Message;

hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/Hippo4jAdapterKafkaExampleApplication.java

@@ -1,3 +1,20 @@
+/*
+ * 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;

hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/consumer/KafkaMessageConsumer.java

@@ -1,3 +1,20 @@
+/*
+ * 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;

hippo4j-example/hippo4j-spring-boot-starter-adapter-kafka-example/src/main/java/cn/hippo4j/springboot/starter/adapter/kafka/example/produce/KafkaMessageProduce.java

@@ -1,3 +1,20 @@
+/*
+ * 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.JSONUtil;

hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-all/pom.xml

@@ -33,6 +33,12 @@
             <artifactId>hippo4j-spring-boot-starter-adapter-dubbo</artifactId>
             <version>${revision}</version>
         </dependency>
+
+        <dependency>
+            <groupId>cn.hippo4j</groupId>
+            <artifactId>hippo4j-spring-boot-starter-adapter-hystrix</artifactId>
+            <version>${revision}</version>
+        </dependency>
     </dependencies>
 
     <build>

hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-hystrix/pom.xml

@@ -0,0 +1,50 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>cn.hippo4j</groupId>
+        <artifactId>hippo4j-spring-boot-starter-adapter</artifactId>
+        <version>${revision}</version>
+    </parent>
+    <artifactId>hippo4j-spring-boot-starter-adapter-hystrix</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>cn.hippo4j</groupId>
+            <artifactId>hippo4j-adapter-hystrix</artifactId>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <configuration>
+                    <archive>
+                        <manifestEntries>
+                            <Implementation-Title>${project.artifactId}</Implementation-Title>
+                            <Implementation-Version>${project.version}</Implementation-Version>
+                            <Build-Time>${maven.build.timestamp}</Build-Time>
+                            <Built-By>chen.ma</Built-By>
+                        </manifestEntries>
+                    </archive>
+                </configuration>
+            </plugin>
+
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-javadoc-plugin</artifactId>
+                <version>2.10.3</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>jar</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+</project>

hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-hystrix/src/main/java/cn/hippo4j/springboot/starter/adapter/hystrix/HystrixAdapterAutoConfiguration.java

@@ -0,0 +1,49 @@
+/*
+ * 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.hystrix;
+
+import cn.hippo4j.adapter.base.ThreadPoolAdapterExtra;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterExtraAutoConfiguration;
+import cn.hippo4j.adapter.hystrix.HystrixThreadPoolAdapter;
+import cn.hippo4j.common.config.ApplicationContextHolder;
+import org.springframework.boot.autoconfigure.AutoConfigureAfter;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @program: hippo4j
+ * @description:
+ * @author: lk
+ * @create: 2022-07-15
+ **/
+@Configuration(proxyBeanMethods = false)
+@AutoConfigureAfter(ThreadPoolAdapterExtraAutoConfiguration.class)
+public class HystrixAdapterAutoConfiguration {
+
+    @Bean
+    @ConditionalOnMissingBean
+    public ApplicationContextHolder simpleApplicationContextHolder() {
+        return new ApplicationContextHolder();
+    }
+
+    @Bean
+    public HystrixThreadPoolAdapter hystrixThreadPoolAdapter(ThreadPoolAdapterExtra threadPoolAdapterExtra) {
+        return new HystrixThreadPoolAdapter(threadPoolAdapterExtra);
+    }
+}

hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/hippo4j-spring-boot-starter-adapter-hystrix/src/main/resources/META-INF/spring.factories

@@ -0,0 +1 @@
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=cn.hippo4j.springboot.starter.adapter.hystrix.HystrixAdapterAutoConfiguration

hippo4j-spring-boot/hippo4j-spring-boot-starter-adapter/pom.xml

@@ -18,6 +18,7 @@
         <module>hippo4j-spring-boot-starter-adapter-kafka</module>
         <module>hippo4j-spring-boot-starter-adapter-rabbitmq</module>
         <module>hippo4j-spring-boot-starter-adapter-rocketmq</module>
+        <module>hippo4j-spring-boot-starter-adapter-hystrix</module>
         <module>hippo4j-spring-boot-starter-adapter-spring-cloud-stream-kafka</module>
         <module>hippo4j-spring-boot-starter-adapter-spring-cloud-stream-rocketmq</module>
     </modules>

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/DynamicThreadPoolAutoConfiguration.java

@@ -18,6 +18,7 @@
 package cn.hippo4j.springboot.starter.config;
 
 import cn.hippo4j.adapter.base.ThreadPoolAdapterBeanContainer;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterExtra;
 import cn.hippo4j.common.api.ThreadDetailState;
 import cn.hippo4j.common.config.ApplicationContextHolder;
 import cn.hippo4j.core.config.UtilAutoConfiguration;
@@ -64,7 +65,8 @@ import org.springframework.core.env.ConfigurableEnvironment;
 @ConditionalOnBean(MarkerConfiguration.Marker.class)
 @EnableConfigurationProperties(BootstrapProperties.class)
 @ConditionalOnProperty(prefix = BootstrapProperties.PREFIX, value = "enable", matchIfMissing = true, havingValue = "true")
-@ImportAutoConfiguration({HttpClientConfiguration.class, NettyClientConfiguration.class, DiscoveryConfiguration.class, MessageNotifyConfiguration.class, UtilAutoConfiguration.class, WebThreadPoolConfiguration.class})
+@ImportAutoConfiguration({HttpClientConfiguration.class, NettyClientConfiguration.class, DiscoveryConfiguration.class, MessageNotifyConfiguration.class, UtilAutoConfiguration.class,
+        WebThreadPoolConfiguration.class})
 public class DynamicThreadPoolAutoConfiguration {
 
     private final BootstrapProperties properties;
@@ -116,7 +118,6 @@ public class DynamicThreadPoolAutoConfiguration {
         return new WebThreadPoolRunStateController(threadPoolRunStateHandler, threadDetailState);
     }
 
-
     @Bean
     @ConditionalOnMissingBean
     @SuppressWarnings("all")
@@ -165,7 +166,7 @@ public class DynamicThreadPoolAutoConfiguration {
 
     @Bean
     @SuppressWarnings("all")
-    public ThreadPoolAdapterRegister threadPoolAdapterRegister(HttpAgent httpAgent, InetUtils hippo4JInetUtils) {
+    public ThreadPoolAdapterRegister threadPoolAdapterRegister(HttpAgent httpAgent, InetUtils hippo4JInetUtils, ThreadPoolAdapterExtra threadPoolAdapterExtra) {
-        return new ThreadPoolAdapterRegister(httpAgent, properties, environment, hippo4JInetUtils);
+        return new ThreadPoolAdapterRegister(httpAgent, properties, environment, hippo4JInetUtils, threadPoolAdapterExtra);
     }
 }

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/config/NettyClientConfiguration.java

@@ -1,3 +1,20 @@
+/*
+ * 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.config;
 
 import cn.hippo4j.springboot.starter.monitor.send.netty.NettyConnectSender;
@@ -22,7 +39,7 @@ public class NettyClientConfiguration {
     }
 
     @Bean
-    public MessageSender messageSender(ServerNettyAgent serverNettyAgent){
+    public MessageSender messageSender(ServerNettyAgent serverNettyAgent) {
         return new NettyConnectSender(serverNettyAgent);
     }
 }

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/DiscoveryClient.java

@@ -17,6 +17,7 @@
 
 package cn.hippo4j.springboot.starter.core;
 
+import cn.hippo4j.adapter.base.ThreadPoolAdapter;
 import cn.hippo4j.common.api.ClientCloseHookExecute;
 import cn.hippo4j.common.config.ApplicationContextHolder;
 import cn.hippo4j.common.constant.Constants;
@@ -31,6 +32,7 @@ import cn.hutool.core.util.StrUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
 
+import java.util.Map;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -141,7 +143,8 @@ public class DiscoveryClient implements DisposableBean {
                 boolean success = register();
                 // TODO Abstract server registration logic
                 ThreadPoolAdapterRegister adapterRegister = ApplicationContextHolder.getBean(ThreadPoolAdapterRegister.class);
-                adapterRegister.register();
+                Map<String, ThreadPoolAdapter> threadPoolAdapterMap = ApplicationContextHolder.getBeansOfType(ThreadPoolAdapter.class);
+                adapterRegister.register(threadPoolAdapterMap);
                 if (success) {
                     instanceInfo.unsetIsDirty(timestamp);
                 }

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/core/ThreadPoolAdapterRegister.java

@@ -19,6 +19,7 @@ package cn.hippo4j.springboot.starter.core;
 
 import cn.hippo4j.adapter.base.ThreadPoolAdapter;
 import cn.hippo4j.adapter.base.ThreadPoolAdapterCacheConfig;
+import cn.hippo4j.adapter.base.ThreadPoolAdapterExtra;
 import cn.hippo4j.adapter.base.ThreadPoolAdapterState;
 import cn.hippo4j.common.config.ApplicationContextHolder;
 import cn.hippo4j.common.toolkit.CollectionUtil;
@@ -56,13 +57,17 @@ public class ThreadPoolAdapterRegister implements ApplicationRunner {
 
     private final InetUtils hippo4JInetUtils;
 
+    private final ThreadPoolAdapterExtra threadPoolAdapterExtra;
+
     @Override
     public void run(ApplicationArguments args) throws Exception {
-        register();
+        Map<String, ThreadPoolAdapter> threadPoolAdapterMap = ApplicationContextHolder.getBeansOfType(ThreadPoolAdapter.class);
+        register(threadPoolAdapterMap);
+        threadPoolAdapterExtra.extraStart(map -> register(map));
     }
 
-    public void register() {
+    public void register(Map<String, ThreadPoolAdapter> threadPoolAdapterMap) {
-        Map<String, ThreadPoolAdapter> threadPoolAdapterMap = ApplicationContextHolder.getBeansOfType(ThreadPoolAdapter.class);
+
         List<ThreadPoolAdapterCacheConfig> cacheConfigList = Lists.newArrayList();
         threadPoolAdapterMap.forEach((key, val) -> {
             List<ThreadPoolAdapterState> threadPoolStates = val.getThreadPoolStates();

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java

@@ -1,3 +1,20 @@
+/*
+ * 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.monitor.send.netty;
 
 import cn.hippo4j.common.monitor.Message;
@@ -39,7 +56,8 @@ public class NettyConnectSender implements MessageSender {
             Bootstrap bootstrap = new Bootstrap();
             bootstrap.group(eventLoopGroup)
                     .channel(NioSocketChannel.class)
-                    .handler(new ChannelInitializer<SocketChannel>(){
+                    .handler(new ChannelInitializer<SocketChannel>() {
+
                         @Override
                         protected void initChannel(SocketChannel ch) throws Exception {
                             ChannelPipeline pipeline = ch.pipeline();
@@ -52,9 +70,9 @@ public class NettyConnectSender implements MessageSender {
 
             bootstrap.connect(serverNettyAgent.getNettyServerAddress(), serverNettyAgent.getNettyServerPort()).sync();
         } catch (Exception e) {
-            log.error("netty send error ",e);
+            log.error("netty send error ", e);
-        } /*finally {
+        } /*
-            eventLoopGroup.shutdownGracefully();
+           * finally { eventLoopGroup.shutdownGracefully(); }
-        }*/
+           */
     }
 }

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/SenderHandler.java

@@ -1,3 +1,20 @@
+/*
+ * 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.monitor.send.netty;
 
 import cn.hippo4j.common.monitor.MessageWrapper;

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerListManager.java

@@ -79,7 +79,7 @@ public class ServerListManager {
         return currentServerAddr;
     }
 
-    public String getNettyServerPort(){
+    public String getNettyServerPort() {
         return nettyServerPort;
     }
 

hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/remote/ServerNettyAgent.java

@@ -1,3 +1,20 @@
+/*
+ * 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.remote;
 
 import cn.hippo4j.springboot.starter.config.BootstrapProperties;
@@ -18,21 +35,21 @@ public class ServerNettyAgent {
 
     private EventLoopGroup eventLoopGroup;
 
-    public ServerNettyAgent(BootstrapProperties properties){
+    public ServerNettyAgent(BootstrapProperties properties) {
         this.dynamicThreadPoolProperties = properties;
         this.serverListManager = new ServerListManager(dynamicThreadPoolProperties);
         this.eventLoopGroup = new NioEventLoopGroup();
     }
 
-    public EventLoopGroup getEventLoopGroup(){
+    public EventLoopGroup getEventLoopGroup() {
         return eventLoopGroup;
     }
 
     public String getNettyServerAddress() {
-        return serverListManager.getCurrentServerAddr().split(":")[1].replace("//","");
+        return serverListManager.getCurrentServerAddr().split(":")[1].replace("//", "");
     }
 
-    public Integer getNettyServerPort(){
+    public Integer getNettyServerPort() {
         return Integer.parseInt(serverListManager.getNettyServerPort());
     }
 }

pom.xml

@@ -51,6 +51,7 @@
         <tomcat-embed-core.version>9.0.55</tomcat-embed-core.version>
         <spring-cloud-starter-stream-rocketmq.version>2.2.6.RELEASE</spring-cloud-starter-stream-rocketmq.version>
         <netty.version>4.1.10.Final</netty.version>
+        <spring-cloud-starter-netflix-hystrix.version>2.2.9.RELEASE</spring-cloud-starter-netflix-hystrix.version>
 
         <maven.javadoc.failOnError>false</maven.javadoc.failOnError>
         <maven.compiler.encoding>UTF-8</maven.compiler.encoding>
@@ -172,6 +173,12 @@
                 <version>${revision}</version>
             </dependency>
 
+            <dependency>
+                <groupId>cn.hippo4j</groupId>
+                <artifactId>hippo4j-adapter-hystrix</artifactId>
+                <version>${revision}</version>
+            </dependency>
+
             <dependency>
                 <groupId>cn.hippo4j</groupId>
                 <artifactId>hippo4j-adapter-spring-cloud-stream-kafka</artifactId>