正文 

当前位置： 首页 > java > java框架

(十七)atp应用测试平台——自定义实现一个springboot2的线程池启动器starter

北溟溟      2022-05-10     319

关键词：

前言

启动器是springboot的一大特点，我们可以根据项目自身需求按需装配我们的组件。例如我们需要操作redis，项目中可以添加一个redis的启动器spring-boot-starter-data-redis，这样redis的一些客户端操作功能我们就集成好了，不用在繁琐的集成redis客户端的依赖，启动器会帮我们加载一切我们所需要的包。既然这么方便，那么我们如何定制自己的项目启动器呢？本节内容，我们以线程池为例，定制一个线程池的启动类，这样项目引入我们的线程池启动器，并加入相关配置，就可以使用我们自定义的线程池方法了。

正文

  • 通过idea工具创建一个springboot项目atp-thread-pool-spring-boot-starter启动器

  •  添加pom依赖
<?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>

	<groupId>com.yundi.atp</groupId>
	<artifactId>atp-thread-pool-spring-boot-starter</artifactId>
	<version>1.0.0</version>
	<name>atp-thread-pool-spring-boot-starter</name>
	<description>线程池启动器</description>

	<properties>
		<java.version>1.8</java.version>
		<spring.boot.starter.version>2.3.4.RELEASE</spring.boot.starter.version>
		<spring.boot.configuration.processor.version>2.3.4.RELEASE</spring.boot.configuration.processor.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter</artifactId>
			<version>$spring.boot.starter.version</version>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-configuration-processor</artifactId>
			<version>$spring.boot.configuration.processor.version</version>
			<optional>true</optional>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
				<configuration>
					<excludes>
						<exclude>
							<groupId>org.springframework.boot</groupId>
							<artifactId>spring-boot-configuration-processor</artifactId>
						</exclude>
					</excludes>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-compiler-plugin</artifactId>
				<configuration>
					<source>7</source>
					<target>7</target>
				</configuration>
			</plugin>
		</plugins>
	</build>

</project>

  • 创建properties属性配置类AtpThreadPoolProperties用于线程池核心配置参数的注入
package com.yundi.atp.config;

import org.springframework.boot.context.properties.ConfigurationProperties;

/**
 * @Author: 北溟溟
 * @Description:
 * @Date: 2022/5/6 18:17
 * @Version: 1.0.0
 */
@ConfigurationProperties(prefix = "atp.thread")
public class AtpThreadPoolProperties 
    /**
     * 是否开启
     */
    private Boolean enable = true;
    /**
     * 核心线程数量
     */
    private Integer corePoolSize;
    /**
     * 最大线程数
     */
    private Integer maximumPoolSize;
    /**
     * 空闲线程的最长时间
     */
    private Integer keepAliveTime;
    /**
     * 队列大小
     */
    private Integer queueSize;

    public Boolean getEnable() 
        return enable;
    

    public void setEnable(Boolean enable) 
        this.enable = enable;
    

    public Integer getCorePoolSize() 
        return corePoolSize;
    

    public void setCorePoolSize(Integer corePoolSize) 
        this.corePoolSize = corePoolSize;
    

    public Integer getMaximumPoolSize() 
        return maximumPoolSize;
    

    public void setMaximumPoolSize(Integer maximumPoolSize) 
        this.maximumPoolSize = maximumPoolSize;
    

    public Integer getKeepAliveTime() 
        return keepAliveTime;
    

    public void setKeepAliveTime(Integer keepAliveTime) 
        this.keepAliveTime = keepAliveTime;
    

    public Integer getQueueSize() 
        return queueSize;
    

    public void setQueueSize(Integer queueSize) 
        this.queueSize = queueSize;

  •  创建一个启动器的配置类AtpThreadPoolAutoConfiguration，根据条件规则加载线程池执行器ThreadPoolExecutor 
package com.yundi.atp.config;

import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.boot.autoconfigure.condition.ConditionalOnWebApplication;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @Author: 北溟溟
 * @Description: 线程池配置
 * @Date: 2021/5/13 10:38
 * @Version: 1.0.0
 */
@Configuration
@ConditionalOnWebApplication
@EnableConfigurationProperties(AtpThreadPoolProperties.class)
public class AtpThreadPoolAutoConfiguration 

    /**
     * matchIfMissing: 缺少该配置属性时是否可以加载。如果为true，没有该配置属性时也会正常加载；反之则不会生效
     * havingValue: 可与name组合使用，比较获取到的属性值与havingValue给定的值是否相同，相同才加载配置
     *
     * @param pool
     * @return
     */
    @ConditionalOnProperty(name = "atp.thread.enable", matchIfMissing = true, havingValue = "true")
    @Bean
    public ThreadPoolExecutor threadPoolExecutor(AtpThreadPoolProperties pool) 
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(pool.getCorePoolSize(),
                pool.getMaximumPoolSize(),
                pool.getKeepAliveTime(),
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<Runnable>(pool.getQueueSize()),
                Executors.defaultThreadFactory(),
                new ThreadPoolExecutor.AbortPolicy());
        return threadPoolExecutor;

  •  在/resources/META-INF目录下创建spring.factories文件，加载线程池启动器的配置类，在spring容器启动的时候可以将线程池加载到容器中
#spring.factories配置
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.yundi.atp.config.AtpThreadPoolAutoConfiguration

  •  将该线程池的启动器安装到maven的仓库，然后引入该启动器的pom就可以使用线程池的功能

  • 使用atp-portal-web项目的springboot工程测试，引入启动器的pom依赖 

  • application.yml填写自定义线程池配置

  •  调用线程池方法测试，启动器测试类StarterController
package com.yundi.atp.contoller;

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

/**
 * @Author: 北溟溟
 * @Description:
 * @Date: 2022/5/5 19:53
 * @Version: 1.0.0
 */
@Slf4j
@RestController
@RequestMapping(value = "/starter")
public class StarterController 
    @Autowired
    ThreadPoolExecutor threadPoolExecutor;

    @GetMapping(value = "/param")
    public String getStarterParam()
        threadPoolExecutor.execute(() -> 
            System.out.println(threadPoolExecutor.getCorePoolSize());
            System.out.println(threadPoolExecutor.getMaximumPoolSize());
            System.out.println(threadPoolExecutor.getKeepAliveTime(TimeUnit.SECONDS));
        );
        return "success";

  • 启动项目，访问声明的接口测试，发现线程池启动器可以调用 

结语

关于自定义实现一个springboot的线程池启动器starter到这里就结束了，本节内容只是启动器的一个小小的案例，我们可以根据实际应用场景，将常用的功能封装成一个个启动器，通过按需加载，完成相应功能的引入，是不是也很秀呢。本节内容到此结束，我们下期见。。。

(十七)atp应用测试平台——redis实现api接口访问限流(固定窗口限流算法)(代码片段)

前言开始正文之前，大多数情况下应该有这样一段场景。面试官：说说平常在项目中，你是如何使用redis的？我：我们就很简单啦，比如前后端分离token的存储、短信验证码的存储，权限列表的存储࿰... 查看详情

(十七)atp应用测试平台——redis实现api接口访问限流(固定窗口限流算法)(代码片段)

前言开始正文之前，大多数情况下应该有这样一段场景。面试官：说说平常在项目中，你是如何使用redis的？我：我们就很简单啦，比如前后端分离token的存储、短信验证码的存储，权限列表的存储࿰... 查看详情

(二十)atp应用测试平台——websocket实现微服务版在线客服聊天室实战案例(代码片段)

前言在前面的博客内容中我们介绍了如何使用websocket实现一个网页版的在线客服聊天室，众所周知，由于websocket是一个长连接，要和服务端保持会话连接，所以其本身并不适用于微服务环境，在微服务环境中&#... 查看详情

(十八)atp应用测试平台——关于springboot应用监控的那些事(代码片段)

...快告诉我你的绝招。本节内容我们主要介绍一下springboot应用的常见应用参数监控指标，从而更好的关注springboot应用的运行状况并实现应用的监控。除此之外，我们通过集成一 查看详情

(十八)atp应用测试平台——关于springboot应用监控的那些事(代码片段)

...快告诉我你的绝招。本节内容我们主要介绍一下springboot应用的常见应用参数监控指标，从而更好的关注springboot应用的运行状况并实现应用的监控。除此之外，我们通过集成一 查看详情

(十三)atp应用测试平台——springboot集成kafka案例实战(代码片段)

前言kafka消息中间键也是我们经常要用到的功能，尤其是在大数据、高并发的项目中，如日志收集、业务数据分发等等。其最核心的俩大功能作用是:①削峰填谷②异步解耦。本节我们主要介绍一下如何在springboot项目中集... 查看详情

atp应用测试平台——使用bat批处理实现springboot项目的启动与关闭(代码片段)

...停，并且自行配置java环境，这对于windows环境的单应用而言，批处理文件更加简洁，同时也可以实现开机 查看详情

(十四)atp应用测试平台——使用docker-compose一键式安装atp应用测试平台的依赖服务(代码片段)

前言关于ATP应用服务测试平台的相关内容已经更新不少，下载项目的小伙伴第一时间一定是想着怎么把这个平台项目跑起来，看下小编花里胡哨的效果是否能正常show。不过由于依赖的增多，项目的服务也随之多了起... 查看详情

atp应用测试平台——使用easyexcel实现excel导入导出多sheet填充模板下载等功能案例实战(代码片段)

前言Java开发中实现Excel的导入、导出、填充、多sheet页操作等常用功能也是我们经常要面对的开发需求，本文以easyexcel为例，将excel中的常用功能整理成一个个小案例，参考使用。案例源码地址：https://gitee.com/northc... 查看详情

atp应用测试平台——关于网页表格的打印及pdf下载的实战案例(代码片段)

前言在网站应用中，我们可能会有这样一个需求，将网页的部分内容，例如表格，网页片段下载打印或者导出PDF，本小节内容正是关于这样一个内容的实战，基于vue2环境开发，希望能够帮助到你。源码... 查看详情

atp应用测试平台——关于vue-router前端路由的配置使用案例(代码片段)

前言VueRouter是Vue.js(opensnewwindow)官方的路由管理器。它和Vue.js的核心功能深度集成，功能丰富，是我们构建vue前端项目中必不可少的的组件之一，本节我们简单介绍一下在vue项目中如何使用vue-router组件实现页面的路由... 查看详情

atp应用测试平台——使用vue-video-player视频播放组件实现网页视频流的播放案例实战(代码片段)

前言在网页中播放视频也是我们经常要使用到的功能，例如设备监控的视频流实时播放，MP4、m3u8等视频资源播放等等，在vue项目中，我们可以使用目前封装好的开源组件vue-video-player实现上述的要求。本节我们就... 查看详情

atp应用测试平台——关于vue中vue-quill-editormavon-editortinymce等多种富文本编辑器的集成使用(代码片段)

...or以及tinymce等的集成及使用。源代码依然托管在我们的ATP应用测试平台中，源码地址：https://gitee.com/northcangap/atp，仅供参考使用。富文本编辑器实现效果如下： 查看详情

atp应用测试平台——关于axios的配置使用(代码片段)

前言该篇是应某个粉丝的要求讲解一下关于axios请求组件的使用，其实axios组件类似我们以前使用过的jQuery中的ajax组件，都是用于进行http网络请求的组件。axios组件在前后端分离项目中使用的更加广泛，也更易集成... 查看详情

(二十四)atp应用测试平台——springboot集成fastdfs上传与下载功能(代码片段)

前言本节内容我们主要介绍一下如何在springboot项目中集成fastdfs组件，实现文件的上传与下载。关于fastdfs服务中间键的安装过程，本节内容不做介绍。fastdfs是一个轻量级的分布式文件系统，也是我们文件存储中常常... 查看详情

(二十二)atp应用测试平台——swagger2集成swagger-bootstrap-ui实现api文档访问(代码片段)

前言原生的swagger文档虽然也可以作为API文档输出，但是不够简洁优美，本节内容我们介绍一下swagger-bootstrap-ui组件，实现对swaggerAPI文档的二次封装，使用API文档更加简洁明了，无论是入参还是结果响应，... 查看详情

(十九)atp应用测试平台——springboot集成rocketmq案例实战(代码片段)

前言本节内容是关于RocketMQ消息中间键的实战内容，主要介绍在springboot项目中如何集成使用RocketMQ消息中间键，包括消息的发送、消息的接收以及RocketMQ的一些配置说明，以及效果说明。话不多说，开始实战内容。... 查看详情

(二十一)atp应用测试平台——vue实战之大红灯笼高高挂(代码片段)

前言2022年的最后一天班，好的开始，好的结束。把大红灯笼高高挂起来，欢度元旦的到来，兔年的到来。明年再战。明年再见。。。 正文正菜奉上lantern.vue灯笼源码<template><divclass="app"><divclass... 查看详情