---

CustomTomcatThreadPoolMBean

com.qww.config;public interface CustomTomcatThreadPoolMBean {String getStatus();
}

CustomTomcatThreadPool

package com.qww.config;import com.alibaba.fastjson.JSON;
import org.apache.tomcat.util.threads.ThreadPoolExecutor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.web.context.WebServerApplicationContext;
import org.springframework.boot.web.embedded.tomcat.TomcatWebServer;
import org.springframework.stereotype.Service;import javax.annotation.PostConstruct;
import javax.management.InstanceAlreadyExistsException;
import javax.management.MBeanRegistrationException;
import javax.management.MBeanServer;
import javax.management.MalformedObjectNameException;
import javax.management.NotCompliantMBeanException;
import javax.management.ObjectName;
import java.lang.management.ManagementFactory;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.concurrent.TimeUnit;@Service
public class CustomTomcatThreadPool implements CustomTomcatThreadPoolMBean {private final static Logger logger = LoggerFactory.getLogger(CustomTomcatThreadPool.class);@AutowiredWebServerApplicationContext webServerApplicationContext;@Overridepublic String getStatus() {return buildStatus();}private String buildStatus() {logger.info("==>>: webServerApplicationContext:{} ", webServerApplicationContext);ThreadPoolExecutor executor = (ThreadPoolExecutor) ((TomcatWebServer) webServerApplicationContext.getWebServer()).getTomcat().getConnector().getProtocolHandler().getExecutor();logger.info("==>>: 這行日志如果沒有輸出，就是上一行代碼報錯了。雖然報錯，但由于當前線程[RMP TCP Connection(x)-ip]的特殊性，并不會在控制臺打印堆棧");Map<String, String> returnMap = new LinkedHashMap<>();returnMap.put("核心線程數(corePoolSize)", String.valueOf(executor.getCorePoolSize()));returnMap.put("最大線程數(maximumPoolSize)", String.valueOf(executor.getMaximumPoolSize()));returnMap.put("活躍線程數(activeCount)", String.valueOf(executor.getActiveCount()));returnMap.put("池中當前線程數(poolSize)", String.valueOf(executor.getPoolSize()));returnMap.put("歷史最大線程數(largestPoolSize)", String.valueOf(executor.getLargestPoolSize()));returnMap.put("工作隊列任務數量(workQueue.size)", String.valueOf(executor.getQueue().size()));returnMap.put("線程允許空閑時間/s(keepAliveTime)", String.valueOf(executor.getKeepAliveTime(TimeUnit.SECONDS)));returnMap.put("核心線程數是否允許被回收(allowCoreThreadTimeOut)", String.valueOf(executor.allowsCoreThreadTimeOut()));returnMap.put("提交任務總數(submittedCount)", String.valueOf(executor.getSubmittedCount()));returnMap.put("歷史執行任務的總數(近似值)(taskCount)", String.valueOf(executor.getTaskCount()));returnMap.put("歷史完成任務的總數(近似值)(completedTaskCount)", String.valueOf(executor.getCompletedTaskCount()));returnMap.put("拒絕策略(ejectedExecutionHandler.class)", executor.getRejectedExecutionHandler().getClass().getCanonicalName());String res = JSON.toJSONString(returnMap);logger.info("==>>: {}", res);return res;}@PostConstructpublic void post() {MBeanServer server = ManagementFactory.getPlatformMBeanServer();ObjectName objectName = null;try {objectName = new ObjectName("qww:type=CustomTomcatThreadPool");} catch (MalformedObjectNameException e) {e.printStackTrace();}try {// 這里的key 必須使用Spring 中注冊的對象，也就是當前對象server.registerMBean(this, objectName);} catch (InstanceAlreadyExistsException | MBeanRegistrationException | NotCompliantMBeanException e) {e.printStackTrace();}}}