太原建设厅网站,网站开发摊销期,2023年不用做核酸了吗,开发板编程软件前言最近有些读者私信我说希望后面多分享spring方面的文章#xff0c;这样能够在实际工作中派上用场。正好我对spring源码有过一定的研究#xff0c;并结合我这几年实际的工作经验#xff0c;把spring中我认为不错的知识点总结一下#xff0c;希望对您有所帮助。一 如何获取… 前言最近有些读者私信我说希望后面多分享spring方面的文章这样能够在实际工作中派上用场。正好我对spring源码有过一定的研究并结合我这几年实际的工作经验把spring中我认为不错的知识点总结一下希望对您有所帮助。一 如何获取spring容器对象1.实现BeanFactoryAware接口Service
public class PersonService implements BeanFactoryAware {private BeanFactory beanFactory;Overridepublic void setBeanFactory(BeanFactory beanFactory) throws BeansException {this.beanFactory beanFactory;}public void add() {Person person (Person) beanFactory.getBean(person);}
}
实现BeanFactoryAware接口然后重写setBeanFactory方法就能从该方法中获取到spring容器对象。2.实现ApplicationContextAware接口Service
public class PersonService2 implements ApplicationContextAware {private ApplicationContext applicationContext;Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {this.applicationContext applicationContext;}public void add() {Person person (Person) applicationContext.getBean(person);}}
实现ApplicationContextAware接口然后重写setApplicationContext方法也能从该方法中获取到spring容器对象。3.实现ApplicationListener接口Service
public class PersonService3 implements ApplicationListenerContextRefreshedEvent {private ApplicationContext applicationContext;Overridepublic void onApplicationEvent(ContextRefreshedEvent event) {applicationContext event.getApplicationContext();}public void add() {Person person (Person) applicationContext.getBean(person);}}
实现ApplicationListener接口需要注意的是该接口接收的泛型是ContextRefreshedEvent类然后重写onApplicationEvent方法也能从该方法中获取到spring容器对象。此外不得不提一下Aware接口它其实是一个空接口里面不包含任何方法。它表示已感知的意思通过这类接口可以获取指定对象比如通过BeanFactoryAware获取BeanFactory通过ApplicationContextAware获取ApplicationContext通过BeanNameAware获取BeanName等Aware接口是很常用的功能目前包含如下功能二 如何初始化beanspring中支持3种初始化bean的方法xml中指定init-method方法使用PostConstruct注解实现InitializingBean接口第一种方法太古老了现在用的人不多具体用法就不介绍了。1.使用PostConstruct注解Service
public class AService {PostConstructpublic void init() {System.out.println(初始化);}
}
在需要初始化的方法上增加PostConstruct注解这样就有初始化的能力。2.实现InitializingBean接口Service
public class BService implements InitializingBean {Overridepublic void afterPropertiesSet() throws Exception {System.out.println(初始化);}
}
实现InitializingBean接口重写afterPropertiesSet方法该方法中可以完成初始化功能。这里顺便抛出一个有趣的问题init-method、PostConstruct 和 InitializingBean 的执行顺序是什么样的决定他们调用顺序的关键代码在AbstractAutowireCapableBeanFactory类的initializeBean方法中。这段代码中会先调用BeanPostProcessor的postProcessBeforeInitialization方法而PostConstruct是通过InitDestroyAnnotationBeanPostProcessor实现的它就是一个BeanPostProcessor所以PostConstruct先执行。而invokeInitMethods方法中的代码决定了先调用InitializingBean再调用init-method。所以得出结论他们的调用顺序是三 自定义自己的Scope我们都知道spring默认支持的Scope只有两种singleton 单例每次从spring容器中获取到的bean都是同一个对象。prototype 多例每次从spring容器中获取到的bean都是不同的对象。spring web又对Scope进行了扩展增加了RequestScope 同一次请求从spring容器中获取到的bean都是同一个对象。SessionScope 同一个会话从spring容器中获取到的bean都是同一个对象。即便如此有些场景还是无法满足我们的要求。比如我们想在同一个线程中从spring容器获取到的bean都是同一个对象该怎么办这就需要自定义Scope了。第一步实现Scope接口public class ThreadLocalScope implements Scope {private static final ThreadLocal THREAD_LOCAL_SCOPE new ThreadLocal();Overridepublic Object get(String name, ObjectFactory? objectFactory) {Object value THREAD_LOCAL_SCOPE.get();if (value ! null) {return value;}Object object objectFactory.getObject();THREAD_LOCAL_SCOPE.set(object);return object;}Overridepublic Object remove(String name) {THREAD_LOCAL_SCOPE.remove();return null;}Overridepublic void registerDestructionCallback(String name, Runnable callback) {}Overridepublic Object resolveContextualObject(String key) {return null;}Overridepublic String getConversationId() {return null;}
}
第二步将新定义的Scope注入到spring容器中Component
public class ThreadLocalBeanFactoryPostProcessor implements BeanFactoryPostProcessor {Overridepublic void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {beanFactory.registerScope(threadLocalScope, new ThreadLocalScope());}
}
第三步使用新定义的ScopeScope(threadLocalScope)
Service
public class CService {public void add() {}
}
四 别说FactoryBean没用说起FactoryBean就不得不提BeanFactory因为面试官老喜欢问它们的区别。BeanFactoryspring容器的顶级接口管理bean的工厂。FactoryBean并非普通的工厂bean它隐藏了实例化一些复杂Bean的细节给上层应用带来了便利。如果你看过spring源码会发现它有70多个地方在用FactoryBean接口。上面这张图足以说明该接口的重要性请勿忽略它好吗特别提一句mybatis的SqlSessionFactory对象就是通过SqlSessionFactoryBean类创建的。我们一起定义自己的FactoryBeanComponent
public class MyFactoryBean implements FactoryBean {Overridepublic Object getObject() throws Exception {String data1 buildData1();String data2 buildData2();return buildData3(data1, data2);}private String buildData1() {return data1;}private String buildData2() {return data2;}private String buildData3(String data1, String data2) {return data1 data2;}Overridepublic Class? getObjectType() {return null;}
}
获取FactoryBean实例对象Service
public class MyFactoryBeanService implements BeanFactoryAware {private BeanFactory beanFactory;Overridepublic void setBeanFactory(BeanFactory beanFactory) throws BeansException {this.beanFactory beanFactory;}public void test() {Object myFactoryBean beanFactory.getBean(myFactoryBean);System.out.println(myFactoryBean);Object myFactoryBean1 beanFactory.getBean(myFactoryBean);System.out.println(myFactoryBean1);}
}
getBean(myFactoryBean);获取的是MyFactoryBeanService类中getObject方法返回的对象getBean(myFactoryBean);获取的才是MyFactoryBean对象。五 轻松自定义类型转换spring目前支持3中类型转换器ConverterS,T将 S 类型对象转为 T 类型对象ConverterFactoryS, R将 S 类型对象转为 R 类型及子类对象GenericConverter它支持多个source和目标类型的转化同时还提供了source和目标类型的上下文这个上下文能让你实现基于属性上的注解或信息来进行类型转换。这3种类型转换器使用的场景不一样我们以ConverterS,T为例。假如接口中接收参数的实体对象中有个字段的类型是Date但是实际传参的是字符串类型2021-01-03 10:20:15要如何处理呢第一步定义一个实体UserData
public class User {private Long id;private String name;private Date registerDate;
}
第二步实现Converter接口public class DateConverter implements ConverterString, Date {private SimpleDateFormat simpleDateFormat new SimpleDateFormat(yyyy-MM-dd HH:mm:ss);Overridepublic Date convert(String source) {if (source ! null !.equals(source)) {try {simpleDateFormat.parse(source);} catch (ParseException e) {e.printStackTrace();}}return null;}
}
第三步将新定义的类型转换器注入到spring容器中Configuration
public class WebConfig extends WebMvcConfigurerAdapter {Overridepublic void addFormatters(FormatterRegistry registry) {registry.addConverter(new DateConverter());}
}第四步调用接口RequestMapping(/user)
RestController
public class UserController {RequestMapping(/save)public String save(RequestBody User user) {return success;}
}
请求接口时User对象中registerDate字段会被自动转换成Date类型。六 spring mvc拦截器用过的都说好spring mvc拦截器根spring拦截器相比它里面能够获取HttpServletRequest和HttpServletResponse 等web对象实例。spring mvc拦截器的顶层接口是HandlerInterceptor包含三个方法preHandle 目标方法执行前执行postHandle 目标方法执行后执行afterCompletion 请求完成时执行为了方便我们一般情况会用HandlerInterceptor接口的实现类HandlerInterceptorAdapter类。假如有权限认证、日志、统计的场景可以使用该拦截器。第一步继承HandlerInterceptorAdapter类定义拦截器public class AuthInterceptor extends HandlerInterceptorAdapter {Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)throws Exception {String requestUrl request.getRequestURI();if (checkAuth(requestUrl)) {return true;}return false;}private boolean checkAuth(String requestUrl) {System.out.println(权限校验);return true;}
}第二步将该拦截器注册到spring容器Configuration
public class WebAuthConfig extends WebMvcConfigurerAdapter {Beanpublic AuthInterceptor getAuthInterceptor() {return new AuthInterceptor();}Overridepublic void addInterceptors(InterceptorRegistry registry) {registry.addInterceptor(new AuthInterceptor());}
}
第三步在请求接口时spring mvc通过该拦截器能够自动拦截该接口并且校验权限。该拦截器其实相对来说比较简单可以在DispatcherServlet类的doDispatch方法中看到调用过程顺便说一句这里只讲了spring mvc的拦截器并没有讲spring的拦截器是因为我有点小私心后面就会知道。七 Enable开关真香不知道你有没有用过Enable开头的注解比如EnableAsync、EnableCaching、EnableAspectJAutoProxy等这类注解就像开关一样只要在Configuration定义的配置类上加上这类注解就能开启相关的功能。是不是很酷让我们一起实现一个自己的开关第一步定义一个LogFilterpublic class LogFilter implements Filter {Overridepublic void init(FilterConfig filterConfig) throws ServletException {}Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {System.out.println(记录请求日志);chain.doFilter(request, response);System.out.println(记录响应日志);}Overridepublic void destroy() {}
}
第二步注册LogFilterConditionalOnWebApplication
public class LogFilterWebConfig {Beanpublic LogFilter timeFilter() {return new LogFilter();}
}
注意这里用了ConditionalOnWebApplication注解没有直接使用Configuration注解。第三步定义开关EnableLog注解Target(ElementType.TYPE)
Retention(RetentionPolicy.RUNTIME)
Documented
Import(LogFilterWebConfig.class)
public interface EnableLog {}
第四步只需在springboot启动类加上EnableLog注解即可开启LogFilter记录请求和响应日志的功能。八 RestTemplate拦截器的春天我们使用RestTemplate调用远程接口时有时需要在header中传递信息比如traceIdsource等便于在查询日志时能够串联一次完整的请求链路快速定位问题。这种业务场景就能通过ClientHttpRequestInterceptor接口实现具体做法如下第一步实现ClientHttpRequestInterceptor接口public class RestTemplateInterceptor implements ClientHttpRequestInterceptor {Overridepublic ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {request.getHeaders().set(traceId, MdcUtil.get());return execution.execute(request, body);}
}
第二步定义配置类Configuration
public class RestTemplateConfiguration {Beanpublic RestTemplate restTemplate() {RestTemplate restTemplate new RestTemplate();restTemplate.setInterceptors(Collections.singletonList(restTemplateInterceptor()));return restTemplate;}Beanpublic RestTemplateInterceptor restTemplateInterceptor() {return new RestTemplateInterceptor();}
}
其中MdcUtil其实是利用MDC工具在ThreadLocal中存储和获取traceIdpublic class MdcUtil {private static final String TRACE_ID TRACE_ID;public static String get() {return MDC.get(TRACE_ID);}public static void add(String value) {MDC.put(TRACE_ID, value);}
}
当然这个例子中没有演示MdcUtil类的add方法具体调的地方我们可以在filter中执行接口方法之前生成traceId调用MdcUtil类的add方法添加到MDC中然后在同一个请求的其他地方就能通过MdcUtil类的get方法获取到该traceId。九 统一异常处理以前我们在开发接口时如果出现异常为了给用户一个更友好的提示例如RequestMapping(/test)
RestController
public class TestController {GetMapping(/add)public String add() {int a 10 / 0;return 成功;}
}
如果不做任何处理请求add接口结果直接报错what用户能直接看到错误信息这种交互方式给用户的体验非常差为了解决这个问题我们通常会在接口中捕获异常 GetMapping(/add)
public String add() {String result 成功;try {int a 10 / 0;} catch (Exception e) {result 数据异常;}return result;
}
接口改造后出现异常时会提示“数据异常”对用户来说更友好。看起来挺不错的但是有问题。。。如果只是一个接口还好但是如果项目中有成百上千个接口都要加上异常捕获代码吗答案是否定的这时全局异常处理就派上用场了RestControllerAdvice。RestControllerAdvice
public class GlobalExceptionHandler {ExceptionHandler(Exception.class)public String handleException(Exception e) {if (e instanceof ArithmeticException) {return 数据异常;}if (e instanceof Exception) {return 服务器内部异常;}retur n null;}
}
只需在handleException方法中处理异常情况业务接口中可以放心使用不再需要捕获异常有人统一处理了。真是爽歪歪。十 异步也可以这么优雅以前我们在使用异步功能时通常情况下有三种方式继承Thread类实现Runable接口使用线程池让我们一起回顾一下继承Thread类public class MyThread extends Thread {Overridepublic void run() {System.out.println(call MyThread);}public static void main(String[] args) {new MyThread().start();}
}
实现Runable接口public class MyWork implements Runnable {Overridepublic void run() {System.out.println(call MyWork);}public static void main(String[] args) {new Thread(new MyWork()).start();}
}
使用线程池public class MyThreadPool {private static ExecutorService executorService new ThreadPoolExecutor(1, 5, 60, TimeUnit.SECONDS, new ArrayBlockingQueue(200));static class Work implements Runnable {Overridepublic void run() {System.out.println(call work);}}public static void main(String[] args) {try {executorService.submit(new MyThreadPool.Work());} finally {executorService.shutdown();}}
}
这三种实现异步的方法不能说不好但是spring已经帮我们抽取了一些公共的地方我们无需再继承Thread类或实现Runable接口它都搞定了。如何spring异步功能呢第一步springboot项目启动类上加EnableAsync注解。EnableAsync
SpringBootApplication
public class Application {public static void main(String[] args) {new SpringApplicationBuilder(Application.class).web(WebApplicationType.SERVLET).run(args);}
}
第二步在需要使用异步的方法上加上Async注解Service
public class PersonService {Asyncpublic String get() {System.out.println(add);return data;}
}
然后在使用的地方调用一下personService.get();就拥有了异步功能是不是很神奇。默认情况下spring会为我们的异步方法创建一个线程去执行如果该方法被调用次数非常多的话需要创建大量的线程会导致资源浪费。这时我们可以定义一个线程池异步方法将会被自动提交到线程池中执行。Configuration
public class ThreadPoolConfig {Value(${thread.pool.corePoolSize:5})private int corePoolSize;Value(${thread.pool.maxPoolSize:10})private int maxPoolSize;Value(${thread.pool.queueCapacity:200})private int queueCapacity;Value(${thread.pool.keepAliveSeconds:30})private int keepAliveSeconds;Value(${thread.pool.threadNamePrefix:ASYNC_})private String threadNamePrefix;Beanpublic Executor MessageExecutor() {ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor();executor.setCorePoolSize(corePoolSize);executor.setMaxPoolSize(maxPoolSize);executor.setQueueCapacity(queueCapacity);executor.setKeepAliveSeconds(keepAliveSeconds);executor.setThreadNamePrefix(threadNamePrefix);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());executor.initialize();return executor;}
}
spring异步的核心方法根据返回值不同处理情况也不太一样具体分为如下情况十一 听说缓存好用没想到这么好用spring cache架构图它目前支持多种缓存我们在这里以caffeine为例它是spring官方推荐的。第一步引入caffeine的相关jar包dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-cache/artifactId
/dependency
dependencygroupIdcom.github.ben-manes.caffeine/groupIdartifactIdcaffeine/artifactIdversion2.6.0/version
/dependency
第二步配置CacheManager开启EnableCaching
Configuration
EnableCaching
public class CacheConfig {Beanpublic CacheManager cacheManager(){CaffeineCacheManager cacheManager new CaffeineCacheManager();//Caffeine配置CaffeineObject, Object caffeine Caffeine.newBuilder()//最后一次写入后经过固定时间过期.expireAfterWrite(10, TimeUnit.SECONDS)//缓存的最大条数.maximumSize(1000);cacheManager.setCaffeine(caffeine);return cacheManager;}
}
第三步使用Cacheable注解获取数据Service
public class CategoryService {//category是缓存名称,#type是具体的key可支持el表达式Cacheable(value category, key #type)public CategoryModel getCategory(Integer type) {return getCategoryByType(type);}private CategoryModel getCategoryByType(Integer type) {System.out.println(根据不同的type: type 获取不同的分类数据);CategoryModel categoryModel new CategoryModel();categoryModel.setId(1L);categoryModel.setParentId(0L);categoryModel.setName(电器);categoryModel.setLevel(3);return categoryModel;}
}
调用categoryService.getCategory()方法时先从caffine缓存中获取数据如果能够获取到数据则直接返回该数据不会进入方法体。如果不能获取到数据则直接方法体中的代码获取到数据然后放到caffine缓存中。
