[Java知识库] springboot自定义starter

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> Java知识库 -> springboot自定义starter -> 正文阅读

[Java知识库]springboot自定义starter

本章我们介绍如果自定义一个starter
创建springboot 项目
创建factoryAutoConfiguration 自动配置类

package com.example.factorystart.auto;

import com.example.factorystart.bean.FactoryProperties;
import com.example.factorystart.server.Taskfactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;

@EnableConfigurationProperties(FactoryProperties.class)
public class factoryAutoConfiguration {


    @ConditionalOnMissingBean(Taskfactory.class)
    @Bean
    public Taskfactory getTaskFactory(){
        System.out.printf("加载自动发配置");
        return new Taskfactory();
    }


}



@Component
@ConfigurationProperties("hy.task")
@Data
public class FactoryProperties {

   private   int ThreadCore;
   private int MaxThread;
   private int keepAliveTime;

}

public class Taskfactory {

    class MyFactory implements ThreadFactory {

        @Override
        public Thread newThread(Runnable r) {
            return new Thread();
        }
    }

    private ThreadPoolExecutor executor;
    public Taskfactory(){
        System.out.printf("创建了对象\n");
        executor=new ThreadPoolExecutor(
               properties.getThreadCore(),
                properties.getMaxThread(),
                20,
                TimeUnit.MILLISECONDS,
                new ArrayBlockingQueue<>(properties.getMaxThread()),
                new MyFactory()
        );
    }

    @Autowired
    FactoryProperties properties;

    public void Sumbit(Runnable runnable){
        executor.execute(runnable);
        System.out.printf("你提交了一个任务");
    }
}

创建spring.factories

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
com.example.factorystart.auto.factoryAutoConfiguration

引入该starter

		<dependency>
            <groupId>com.example</groupId>
            <artifactId>factoryStart</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

填写文件

hy.task.MaxCore=100
hy.task.MaxThread=1000

创建个控制器测试

@RestController
@RequestMapping("/Api/Login")
public class LoginController {
    @Autowired
    Taskfactory taskfactory;
   

    @RequestMapping(value = "/SendCode",method ={RequestMethod.GET})
    public String SendCode(@RequestParam String email){
        taskfactory.Sumbit(new Runnable() {
            @Override
            public void run() {
				
            }
        });
        return "发送成功";
    }


}