🍎 A Java library for dependency injection and aspect oriented programing and building high-performance web applications like Spring Boot.
You ask me what the elegant code looks like? Then I have to show it!
主要为了学习技术，顺便给自己的博客网站 https://taketoday.cn 提供基础框架（其实写的博客网站也是为了学习练习技术）。
起源于大学的时候学习编程，后来用 Java Servlet 做了一个博客网站。在开发过程中发现有很多重复代码，
我觉得这样的代码很不优雅，尽管那个时候刚学编程不久，于是在我学习 Struts2 的时候自己尝试着写了一个类似的
通过 XML 配置干掉了大量的重复代码的程序。于是初代的 today-web 诞生并开源。
后面学习了 Java 注解 又实现了通过注解配置的版本 today-web 注解版
today-web 注解版 刚出来时也正在学 Spring 感觉没有 IoC
容器感觉不是很方便。在网上看到很多自己写 什么 Mini Spring 之类，所以我大胆决定我也要写一个。有这个决心是因为我把 today-web 都写出来了，
再写个 IoC 应该不难吧。刚开始参考了各种 mini-spring，该说不说现在看来正是那个时候参考了他们的代码才导致我有些认知错误。在2021年6月-2021年12月期间
又去深入看 Spring 源码才纠正过来。事实证明写一个这样的东西确实不难，只是要优雅的话还是要点东西的。我自认为我的代码还是优雅的。不信？
我的B站直播间欢迎你 。（在2021年开始直播写这个库，后面工作比较忙了就没怎么直播，后面有时间就会直播）。
刚开始写的时候（大概是2018年,我也是看的Git提交记录哈哈）有点无从下手，所以我去参考上文说到的各类 Mini Spring。 就这样又开启了一轮学习。
学习如何扫描类文件、学习Java注解、Java字节码、动态代理、重新认识接口、一些设计模式、学习使用Git、渐渐明白了单元测试的重要性
等。随着学习的深入框架经历了数次重构，自己也对依赖注入有了自己的看法。慢慢的我发现我居然能看得明白 Spring 源码了。 感觉Spring真心强大。
如果你问我怎么学习编程，我觉得造轮子是比较好的方式。自己还有很多要学的东西。比如分布式方面的知识，所以今后你定会看到诸如
today-rpc, today-distributed-* 等项目诞生。
老版本 IoC
<dependency>
<groupId>cn.taketoday</groupId>
<artifactId>today-context</artifactId>
<version>3.0.5.RELEASE</version>
</dependency>新版本正在加紧开发中
只需要
@RestController
public class DemoApplication {
@GET("/index/{q}")
public String index(String q) {
return q;
}
public static void main(String[] args) {
WebApplication.run(DemoApplication.class, args);
}
}@Slf4j
@RestController // rest 控制器
@RestControllerAdvice
@Import(NettyApplication.AppConfig.class) // 导入配置
public class NettyApplication {
public static void main(String[] args) {
WebApplication.runReactive(NettyApplication.class, args);
}
@GET("/index")
public String index() {
return "Hello";
}
@GET("/body/{name}/{age}")
public Body index(String name, int age) {
return new Body(name, age);
}
@GET("/publish-event")
public void index(String name, @Autowired ApplicationEventPublisher publisher) {
publisher.publishEvent(new MyEvent(name));
}
@GET("/request-context")
public String context(RequestContext context) {
final String requestURL = context.requestURL();
final String queryString = context.queryString();
System.out.println(requestURL);
System.out.println(queryString);
return queryString;
}
@Getter
static class Body {
final String name;
final int age;
Body(String name, int age) {
this.name = name;
this.age = age;
}
}
@Configuration
@EnableNettyHandling
@EnableMethodEventDriven
static class AppConfig {
@EventListener(MyEvent.class)
public void event(MyEvent event) {
log.info("event :{}", event);
}
}
@ToString
static class MyEvent {
final String name;
MyEvent(String name) {
this.name = name;
}
}
@ExceptionHandler(Throwable.class)
public void throwable(Throwable throwable) {
throwable.printStackTrace();
}
}@Slf4j
@Configuration
@RequestMapping
@EnableDefaultMybatis
@EnableRedissonCaching
@EnableTomcatHandling
@ComponentScan("cn.taketoday.blog")
@PropertiesSource("classpath:info.properties")
@MultipartConfig(maxFileSize = 10240000, fileSizeThreshold = 1000000000, maxRequestSize = 1024000000)
public class TestApplication implements WebMvcConfiguration, ApplicationListener<ContextStartedEvent> {
public static void main(String[] args) {
WebApplication.run(TestApplication.class, args);
}
@GET("index/{q}")
public String index(String q) {
return q;
}
@Singleton
@Profile("prod")
public ResourceHandlerRegistry prodResourceMappingRegistry() {
final ResourceHandlerRegistry registry = new ResourceHandlerRegistry();
registry.addResourceMapping(LoginInterceptor.class)//
.setPathPatterns("/assets/admin/**")//
.setOrder(Ordered.HIGHEST_PRECEDENCE)//
.addLocations("/assets/admin/");
return registry;
}
@Singleton
@Profile("dev")
public ResourceHandlerRegistry devRsourceMappingRegistry(@Env("site.uploadPath") String upload,
@Env("site.assetsPath") String assetsPath) //
{
final ResourceHandlerRegistry registry = new ResourceHandlerRegistry();
registry.addResourceMapping("/assets/**")//
.addLocations(assetsPath);
registry.addResourceMapping("/upload/**")//
.addLocations(upload);
registry.addResourceMapping("/logo.png")//
.addLocations("file:///D:/dev/www.yhj.com/webapps/assets/images/logo.png");
registry.addResourceMapping("/favicon.ico")//
.addLocations("classpath:/favicon.ico");
return registry;
}
@Override
public void onApplicationEvent(ContextStartedEvent event) {
log.info("----------------Application Started------------------");
}
}- 使用
@Component - 任意注解只要注解上有
@Component注解就会标识为一个Bean不论多少层
@Target({ ElementType.TYPE, ElementType.METHOD })
public @interface Component {
/** @return bean name */
String[] value() default {};
/** @return bean's scope */
Scope scope() default Scope.SINGLETON;
String[] initMethods() default {};
String destroyMethods() default "";
}@Singleton
@Component(scope = Scope.SINGLETON)
@Target({ ElementType.TYPE, ElementType.METHOD })
public @interface Singleton {
// bean name
String[] value() default {};
String[] initMethods() default {};
String destroyMethods() default "";
}@Prototype
@Retention(RetentionPolicy.RUNTIME)
@Component(scope = Scope.PROTOTYPE)
@Target({ ElementType.TYPE, ElementType.METHOD })
public @interface Prototype {
// bean name
String[] value() default {};
String[] initMethods() default {};
String destroyMethods() default "";
}@Configuration
@Target(ElementType.TYPE)
@Component(scope = Scope.SINGLETON)
public @interface Configuration {
}@Service
@Component(scope = Scope.SINGLETON)
@Target({ ElementType.TYPE, ElementType.METHOD })
public @interface Service {
String[] value() default {};// bean names
}- 使用
@Autowired注入 - 使用
@Resource注入 - 使用
@Inject注入 - 可自定义注解和实现
PropertyValueResolver：
@FunctionalInterface
public interface PropertyValueResolver {
default boolean supports(Field field) {
return false;
}
PropertyValue resolveProperty(Field field) throws ContextException;
}- 注入示例：
@Controller
@SuppressWarnings("serial")
public class LoginController implements Constant, ServletContextAware {
private String contextPath;
@Autowired
private UserService userService;
//@Inject
@Resource
private BloggerService bloggerService;
@GET("/login")
public String login(@Cookie String email, String forward, Model model) {
model.attribute(KEY_EMAIL, email);
model.attribute("forward", forward);
return "/login/index";
}
@POST("/login")
@Logger(value = "登录", //
content = "email:[${email}] " //
+ "passwd:[${passwd}] "//
+ "input code:[${randCode}] "//
+ "in session:[${randCodeInSession}] "//
+ "forward to:[${forward}] "//
+ "msg:[${redirectModel.attribute('msg')}]"//
)
public String login(HttpSession session,
@Cookie(KEY_EMAIL) String emailInCookie,
@RequestParam(required = true) String email,
@RequestParam(required = true) String passwd,
@RequestParam(required = true) String randCode,
@RequestParam(required = false) String forward,
@Session(RAND_CODE) String randCodeInSession, RedirectModel redirectModel) //
{
session.removeAttribute(RAND_CODE);
if (!randCode.equalsIgnoreCase(randCodeInSession)) {
redirectModel.attribute(KEY_MSG, "验证码错误!");
redirectModel.attribute(KEY_EMAIL, email);
redirectModel.attribute(KEY_FORWARD, forward);
return redirectLogin(forward);
}
User loginUser = userService.login(new User().setEmail(email));
if (loginUser == null) {
redirectModel.attribute(KEY_EMAIL, email);
redirectModel.attribute(KEY_FORWARD, forward);
redirectModel.attribute(KEY_MSG, email + " 账号不存在!");
return redirectLogin(forward);
}
// 😋 略
}
@GET("/logout")
public String logout(HttpSession session) {
session.invalidate();
return "redirect:/index";
}
@Override
public void setServletContext(ServletContext servletContext) {
this.contextPath = servletContext.getContextPath();
}
}- 实现原理
public class AutowiredPropertyResolver implements PropertyValueResolver {
private static final Class<? extends Annotation> NAMED_CLASS = ClassUtils.loadClass("jakarta.inject.Named");
private static final Class<? extends Annotation> INJECT_CLASS = ClassUtils.loadClass("jakarta.inject.Inject");
@Override
public boolean supports(Field field) {
return field.isAnnotationPresent(Autowired.class)
|| field.isAnnotationPresent(Resource.class)
|| (NAMED_CLASS != null && field.isAnnotationPresent(NAMED_CLASS))
|| (INJECT_CLASS != null && field.isAnnotationPresent(INJECT_CLASS));
}
@Override
public PropertyValue resolveProperty(Field field) {
final Autowired autowired = field.getAnnotation(Autowired.class); // auto wired
String name = null;
boolean required = true;
final Class<?> propertyClass = field.getType();
if (autowired != null) {
name = autowired.value();
required = autowired.required();
}
else if (field.isAnnotationPresent(Resource.class)) {
name = field.getAnnotation(Resource.class).name(); // Resource.class
}
else if (NAMED_CLASS != null && field.isAnnotationPresent(NAMED_CLASS)) {// @Named
name = AnnotationUtils.getAnnotationAttributes(NAMED_CLASS, field).getString(Constant.VALUE);
} // @Inject or name is empty
if (StringUtils.isEmpty(name)) {
name = byType(propertyClass);
}
return new PropertyValue(new BeanReference(name, required, propertyClass), field);
}
}看到这你应该明白了注入原理了
// cn.taketoday.web.servlet.DispatcherServlet
public class DispatcherServlet implements Servlet, Serializable {
private static final Logger log = LoggerFactory.getLogger(DispatcherServlet.class);
/** exception resolver */
private final ExceptionResolver exceptionResolver;
/** Action mapping registry */
private final HandlerMappingRegistry handlerMappingRegistry;
/** intercepter registry */
private final HandlerInterceptorRegistry handlerInterceptorRegistry;
private final WebServletApplicationContext applicationContext;
private ServletConfig servletConfig;
@Autowired
public DispatcherServlet(//
ExceptionResolver exceptionResolver, //
HandlerMappingRegistry handlerMappingRegistry, //
WebServletApplicationContext applicationContext,
HandlerInterceptorRegistry handlerInterceptorRegistry) //
{
if (exceptionResolver == null) {
throw new ConfigurationException("You must provide an 'exceptionResolver'");
}
this.exceptionResolver = exceptionResolver;
this.applicationContext = applicationContext;
this.handlerMappingRegistry = handlerMappingRegistry;
this.handlerInterceptorRegistry = handlerInterceptorRegistry;
}
public static RequestContext prepareContext(final ServletRequest request, final ServletResponse response) {
return RequestContextHolder.prepareContext(//
new ServletRequestContext((HttpServletRequest) request, (HttpServletResponse) response)//
);
}
@Override
public void service(final ServletRequest req, final ServletResponse res) //
throws ServletException, IOException //
{
// Lookup handler mapping
final HandlerMapping mapping = lookupHandlerMapping((HttpServletRequest) req);
if (mapping == null) {
((HttpServletResponse) res).sendError(404);
return;
}
final RequestContext context = prepareContext(req, res);
try {
final Object result;
// Handler Method
final HandlerMethod method;// = requestMapping.getHandlerMethod();
if (mapping.hasInterceptor()) {
// get intercepter s
final int[] its = mapping.getInterceptors();
// invoke intercepter
final HandlerInterceptorRegistry registry = getHandlerInterceptorRegistry();
for (final int i : its) {
if (!registry.get(i).beforeProcess(context, mapping)) {
if (log.isDebugEnabled()) {
log.debug("Interceptor: [{}] return false", registry.get(i));
}
return;
}
}
result = invokeHandler(context, method = mapping.getHandlerMethod(), mapping);
for (final int i : its) {
registry.get(i).afterProcess(context, mapping, result);
}
}
else {
result = invokeHandler(context, method = mapping.getHandlerMethod(), mapping);
}
method.resolveResult(context, result);
}
catch (Throwable e) {
ResultUtils.resolveException(context, exceptionResolver, mapping, e);
}
}
protected Object invokeHandler(final RequestContext request,
final HandlerMethod method, final HandlerMapping mapping) throws Throwable //
{
// log.debug("set parameter start");
return method.getMethod()//
.invoke(mapping.getBean(), method.resolveParameters(request)); // invoke
}
protected HandlerMapping lookupHandlerMapping(final HttpServletRequest req) {
// The key of handler
String uri = req.getMethod() + req.getRequestURI();
final HandlerMappingRegistry registry = getHandlerMappingRegistry();
final Integer i = registry.getIndex(uri); // index of handler mapping
if (i == null) {
// path variable
uri = StringUtils.decodeUrl(uri);// decode
for (final RegexMapping regex : registry.getRegexMappings()) {
// TODO path matcher pathMatcher.match(requestURI, requestURI)
if (regex.pattern.matcher(uri).matches()) {
return registry.get(regex.index);
}
}
log.debug("NOT FOUND -> [{}]", uri);
return null;
}
return registry.get(i.intValue());
}
@Override
public void init(ServletConfig servletConfig) throws ServletException {
this.servletConfig = servletConfig;
}
@Override
public ServletConfig getServletConfig() {
return servletConfig;
}
public String getServletName() {
return "DispatcherServlet";
}
@Override
public String getServletInfo() {
return "DispatcherServlet, Copyright © TODAY & 2017 - 2020 All Rights Reserved";
}
@Override
public void destroy() {
if (applicationContext != null) {
final State state = applicationContext.getState();
if (state != State.CLOSING && state != State.CLOSED) {
applicationContext.close();
final DateFormat dateFormat = new SimpleDateFormat(Constant.DEFAULT_DATE_FORMAT);//
final String msg = new StringBuffer()//
.append("Your application destroyed at: [")//
.append(dateFormat.format(new Date()))//
.append("] on startup date: [")//
.append(dateFormat.format(applicationContext.getStartupDate()))//
.append("]")//
.toString();
log.info(msg);
applicationContext.getServletContext().log(msg);
}
}
}
public final HandlerInterceptorRegistry getHandlerInterceptorRegistry() {
return this.handlerInterceptorRegistry;
}
public final HandlerMappingRegistry getHandlerMappingRegistry() {
return this.handlerMappingRegistry;
}
public final ExceptionResolver getExceptionResolver() {
return this.exceptionResolver;
}
}
//cn.taketoday.web.view.FreeMarkerViewResolver
@Props(prefix = "web.mvc.view.")
@MissingBean(value = Constant.VIEW_RESOLVER, type = ViewResolver.class)
public class FreeMarkerViewResolver extends AbstractViewResolver implements InitializingBean, WebMvcConfiguration {
private final ObjectWrapper wrapper;
@Getter
private final Configuration configuration;
private final TaglibFactory taglibFactory;
private final TemplateLoader templateLoader;
private final ServletContextHashModel applicationModel;
public FreeMarkerViewResolver(Configuration configuration, //
TaglibFactory taglibFactory, TemplateLoader templateLoader, Properties settings) //
{
this(new DefaultObjectWrapper(Configuration.VERSION_2_3_28), //
configuration, taglibFactory, templateLoader, settings);
}
@Autowired
public FreeMarkerViewResolver(//
@Autowired(required = false) ObjectWrapper wrapper, //
@Autowired(required = false) Configuration configuration, //
@Autowired(required = false) TaglibFactory taglibFactory, //
@Autowired(required = false) TemplateLoader templateLoader, //
@Props(prefix = "freemarker.", replace = true) Properties settings) //
{
WebServletApplicationContext webApplicationContext = //
(WebServletApplicationContext) WebUtils.getWebApplicationContext();
if (configuration == null) {
configuration = new Configuration(Configuration.VERSION_2_3_28);
webApplicationContext.registerSingleton(configuration.getClass().getName(), configuration);
}
this.configuration = configuration;
if (wrapper == null) {
wrapper = new DefaultObjectWrapper(Configuration.VERSION_2_3_28);
}
this.wrapper = wrapper;
ServletContext servletContext = webApplicationContext.getServletContext();
if (taglibFactory == null) {
taglibFactory = new TaglibFactory(servletContext);
}
this.taglibFactory = taglibFactory;
this.configuration.setObjectWrapper(wrapper);
// Create hash model wrapper for servlet context (the application)
this.applicationModel = new ServletContextHashModel(servletContext, wrapper);
webApplicationContext.getBeansOfType(TemplateModel.class).forEach(configuration::setSharedVariable);
this.templateLoader = templateLoader;
try {
if (settings != null && !settings.isEmpty()) {
this.configuration.setSettings(settings);
}
}
catch (TemplateException e) {
throw new ConfigurationException("Set FreeMarker's Properties Error, With Msg: [" + e.getMessage() + "]", e);
}
}
@Override
public void afterPropertiesSet() throws ConfigurationException {
this.configuration.setLocale(locale);
this.configuration.setDefaultEncoding(encoding);
if (templateLoader == null) {
this.configuration.setServletContextForTemplateLoading(servletContext, prefix); // prefix -> /WEB-INF/..
}
else {
configuration.setTemplateLoader(templateLoader);
}
LoggerFactory.getLogger(getClass()).info("Configuration FreeMarker View Resolver Success.");
}
@Override
public void configureParameterResolver(List<ParameterResolver> resolvers) {
resolvers.add(new DelegatingParameterResolver((m) -> m.isAssignableFrom(Configuration.class), //
(ctx, m) -> configuration//
));
resolvers.add(new DelegatingParameterResolver((m) -> m.isAnnotationPresent(SharedVariable.class), (ctx, m) -> {
final TemplateModel sharedVariable = configuration.getSharedVariable(m.getName());
if (m.isInstance(sharedVariable)) {
return sharedVariable;
}
if (sharedVariable instanceof WrapperTemplateModel) {
final Object wrappedObject = ((WrapperTemplateModel) sharedVariable).getWrappedObject();
if (m.isInstance(wrappedObject)) {
return wrappedObject;
}
throw ExceptionUtils.newConfigurationException(null, "Not a instance of: " + m.getParameterClass());
}
return null;
}));
}
protected TemplateHashModel createModel(RequestContext requestContext) {
final ObjectWrapper wrapper = this.wrapper;
final HttpServletRequest request = requestContext.nativeRequest();
final AllHttpScopesHashModel allHttpScopesHashModel = //
new AllHttpScopesHashModel(wrapper, servletContext, request);
allHttpScopesHashModel.putUnlistedModel(FreemarkerServlet.KEY_JSP_TAGLIBS, taglibFactory);
allHttpScopesHashModel.putUnlistedModel(FreemarkerServlet.KEY_APPLICATION, applicationModel);
// Create hash model wrapper for request
allHttpScopesHashModel.putUnlistedModel(FreemarkerServlet.KEY_REQUEST, new HttpRequestHashModel(request, wrapper));
allHttpScopesHashModel.putUnlistedModel(FreemarkerServlet.KEY_REQUEST_PARAMETERS, new HttpRequestParametersHashModel(request));
// Create hash model wrapper for session
allHttpScopesHashModel.putUnlistedModel(FreemarkerServlet.KEY_SESSION,
new HttpSessionHashModel(requestContext.nativeSession(), wrapper));
return allHttpScopesHashModel;
}
/**
* Resolve FreeMarker View.
*/
@Override
public void resolveView(final String template, final RequestContext requestContext) throws Throwable {
configuration.getTemplate(template + suffix, locale, encoding)//
.process(createModel(requestContext), requestContext.getWriter());
}
}- 构造器
class PropsBean {
@Autowired
public PropsBean(@Props(prefix = "site.") Bean bean) {
//---------
}
@Autowired
public PropsBean(@Props(prefix = "site.") Properties properties) {
//-------
}
@Autowired
public PropsBean(@Props(prefix = "site.") Map properties) {
//-------
}
}- Field
class DemoBean {
@Props(prefix = "site.")
Bean bean;
@Props(prefix = "site.")
Map properties;
@Props(prefix = "site.")
Properties properties;
}- 实现原理
@Order(Ordered.HIGHEST_PRECEDENCE - 2)
public class PropsPropertyResolver implements PropertyValueResolver {
@Override
public boolean supports(Field field) {
return field.isAnnotationPresent(Props.class);
}
}- 和
@Props一样同样支持构造器，Field注入 #{key}和Environment#getProperty(String key, Class targetType)效果一样${1+1}支持EL表达式
@Configuration
public class WebMvc implements WebMvcConfiguration {
private final String serverPath;
@Autowired
public WebMvc(@Value("#{site.serverPath}") String serverPath) {
this.serverPath = serverPath;
}
@Override
public void configureResourceMappings(ResourceMappingRegistry registry) {
registry.addResourceMapping("/assets/**")//
// .enableGzip()//
// .gzipMinLength(10240)//
// G:\Projects\Git\today-technology\blog
.addLocations("file:///G:/Projects/Git/today-technology/blog/blog-web/src/main/webapp/assets/");
registry.addResourceMapping("/webjars/**")//
.addLocations("classpath:/META-INF/resources/webjars/");
registry.addResourceMapping("/swagger/**")//
.cacheControl(CacheControl.newInstance().publicCache())//
.addLocations("classpath:/META-INF/resources/");
registry.addResourceMapping("/upload/**")//
.addLocations("file:///" + serverPath + "/upload/");
registry.addResourceMapping("/favicon.ico")//
.addLocations("classpath:/favicon.ico")//
.cacheControl(CacheControl.newInstance().publicCache());
registry.addResourceMapping(AdminInterceptor.class)//
.setPathPatterns("/assets/admin/**")//
.setOrder(Ordered.HIGHEST_PRECEDENCE)//
.addLocations("file:///G:/Projects/Git/today-technology/blog/blog-web/src/main/webapp/assets/admin/");
}
}该注解标识一个配置Bean,示例：
@Configuration
@Props(prefix = { "redis.pool.", "redis." })
public class RedisConfiguration {
private int maxIdle;
private int minIdle;
private int timeout;
private int maxTotal;
private int database;
private String address;
private String password;
private String clientName;
private int connectTimeout;
@Singleton("fstCodec")
public Codec codec() {
return new FstCodec();
}
// @Singleton("limitLock")
// public Lock limitLock(Redisson redisson) {
// return redisson.getLock("limitLock");
// }
@Singleton(destroyMethods = "shutdown")
public Redisson redisson(@Autowired("fstCodec") Codec codec) {
Config config = new Config();
config.setCodec(codec)//
.useSingleServer()//
.setAddress(address)//
.setTimeout(timeout)//
.setPassword(password)//
.setDatabase(database)//
.setClientName(clientName)//
.setConnectionPoolSize(maxTotal)//
.setConnectTimeout(connectTimeout)//
.setConnectionMinimumIdleSize(minIdle)//
.setConnectionMinimumIdleSize(maxIdle);
return (Redisson) Redisson.create(config);
}
@Singleton("loggerDetails")
public <T> Queue<T> loggerDetails(Redisson redisson) {
return new ConcurrentLinkedQueue<T>();
}
@Singleton("cacheViews")
public Map<Long, Long> cacheViews(Redisson redisson) {
return redisson.getMap("cacheViews", LongCodec.INSTANCE);
}
@Singleton("articleLabels")
public Map<Long, Set<Label>> articleLabels(Redisson redisson, @Autowired("fstCodec") Codec codec) {
return redisson.getMap("articleLabels", codec);
}
@Singleton("optionsMap")
public Map<String, String> optionsMap(Redisson redisson) {
// redisson.getKeys().flushdb();
return redisson.getMap("optionsMap", StringCodec.INSTANCE);
}
@Singleton("categories")
public List<Category> categories(Redisson redisson, @Autowired("fstCodec") Codec codec) {
return redisson.getList("categories", codec);
}
@Singleton("labels")
public Set<Label> labels(Redisson redisson, @Autowired("fstCodec") Codec codec) {
return redisson.getSet("labels", codec);
}
@Value(value = "#{limit.time.out}", required = false)
private int limitTimeOut = Constant.ACCESS_TIME_OUT;
@Singleton("limitCache")
public Map<String, Long> limitCache(Redisson redisson) {
final RMapCache<String, Long> mapCache = redisson.getMapCache("limitCache", LongCodec.INSTANCE);
mapCache.expire(limitTimeOut, TimeUnit.MILLISECONDS);
return mapCache;
}
}package test.context;
import java.util.Map;
import jakarta.annotation.PostConstruct;
import jakarta.annotation.PreDestroy;
import cn.taketoday.context.support.StandardApplicationContext;
import cn.taketoday.lang.Singleton;
import cn.taketoday.context.bean.BeanDefinition;
import cn.taketoday.beans.factory.DisposableBean;
import cn.taketoday.beans.factory.InitializingBean;
import lombok.extern.slf4j.Slf4j;
/**
* @author TODAY <br>
* 2019-07-25 22:44
*/
@Slf4j
@Singleton
public class LifecycleBean implements InitializingBean, DisposableBean {
@PostConstruct
public void initData() {
log.info("@PostConstruct");
}
@Override
public void afterPropertiesSet() throws Exception {
log.info("afterPropertiesSet");
}
@PreDestroy
public void preDestroy() {
log.info("preDestroy");
}
@Override
public void destroy() throws Exception {
log.info("destroy");
}
@Test
public void testLifecycle() {
try (StandardApplicationContext context = new StandardApplicationContext("info.properties")) {
context.register(LifecycleBean.class);
BeanDefinitionRegistry registry = context.unwrapFactory(BeanDefinitionRegistry.class);
Map<String, BeanDefinition> beanDefinitionsMap = registry.getBeanDefinitions();
System.out.println(beanDefinitionsMap);
}
}
}2019-07-25 23:14:37.712 INFO - [ main] c.t.context.AbstractApplicationContext 150 - Starting Application Context at [2019-07-25 23:14:37.707].
2019-07-25 23:14:37.751 INFO - [ main] c.t.context.env.StandardEnvironment 236 - Found Properties Resource: [file:/G:/Projects/Git/github/today-context/target/test-classes/info.properties]
2019-07-25 23:14:37.771 INFO - [ main] c.t.context.env.StandardEnvironment 129 - Active profiles: [test, dev]
2019-07-25 23:14:37.858 DEBUG - [ main] c.t.context.AbstractApplicationContext 325 - Loading Application Listeners.
2019-07-25 23:14:37.896 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.BeanDefinitionLoadingEvent]
2019-07-25 23:14:37.918 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.LoadingMissingBeanEvent]
2019-07-25 23:14:37.921 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.BeanDefinitionLoadedEvent]
2019-07-25 23:14:37.922 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.DependenciesHandledEvent]
2019-07-25 23:14:37.923 DEBUG - [ main] c.t.beans.factory.AbstractBeanFactory 581 - Start loading BeanPostProcessor.
2019-07-25 23:14:37.926 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.ContextPreRefreshEvent]
2019-07-25 23:14:37.927 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.ContextRefreshEvent]
2019-07-25 23:14:37.928 DEBUG - [ main] c.t.beans.factory.AbstractBeanFactory 1002 - Initialization of singleton objects.
2019-07-25 23:14:37.929 DEBUG - [ main] c.t.beans.factory.AbstractBeanFactory 651 - Initializing bean named: [lifecycleBean].
2019-07-25 23:14:37.929 INFO - [ main] test.context.LifecycleBean 59 - setBeanName: lifecycleBean
2019-07-25 23:14:37.930 INFO - [ main] test.context.LifecycleBean 69 - setBeanFactory: cn.taketoday.beans.factory.support.StandardBeanFactory@5ce81285
2019-07-25 23:14:37.930 INFO - [ main] test.context.LifecycleBean 74 - setApplicationContext: cn.taketoday.context.support.StandardApplicationContext@78c03f1f
2019-07-25 23:14:37.930 INFO - [ main] test.context.LifecycleBean 64 - setEnvironment: cn.taketoday.context.StandardEnvironment@5ec0a365
2019-07-25 23:14:37.931 INFO - [ main] test.context.LifecycleBean 79 - @PostConstruct
2019-07-25 23:14:37.931 INFO - [ main] test.context.LifecycleBean 84 - afterPropertiesSet
2019-07-25 23:14:37.931 DEBUG - [ main] c.t.beans.factory.AbstractBeanFactory 511 - Singleton bean is being stored in the name of [lifecycleBean]
2019-07-25 23:14:37.932 DEBUG - [ main] c.t.beans.factory.AbstractBeanFactory 1008 - The singleton objects are initialized.
2019-07-25 23:14:37.932 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.ContextStartedEvent]
2019-07-25 23:14:37.941 INFO - [ main] c.t.context.AbstractApplicationContext 210 - Application Context Startup in 234ms
{lifecycleBean={
"name":"lifecycleBean",
"scope":"SINGLETON",
"beanClass":"class test.context.LifecycleBean",
"initMethods":"[public void test.context.LifecycleBean.initData()]",
"destroyMethods":"[]",
"dependencySetters":"[]",
"initialized":"true",
"factoryBean":"false",
"abstract":"false"
}}
2019-07-25 23:14:37.943 DEBUG - [ main] c.t.context.AbstractApplicationContext 480 - Publish event: [cn.taketoday.context.event.ContextClosedEvent]
context is closing
2019-07-25 23:14:37.945 INFO - [ main] c.t.c.listener.ContextCloseListener 52 - Closing: [cn.taketoday.context.support.StandardApplicationContext@78c03f1f] at [2019-07-25 23:14:37.943]
2019-07-25 23:14:37.947 INFO - [ main] test.context.LifecycleBean 89 - preDestroy
2019-07-25 23:14:37.947 INFO - [ main] test.context.LifecycleBean 94 - destroy
底层使用CGLIB，JDK动态代理，或自己写的StandardAopProxy ,CGLIB,JDK 版本功能最完善,来自Spring Aop使用了Spring的抽象接口，自己用字节码技术实现了StandardAopProxy 自以为性能更优。
使用@Aspect标注一个切面
@Aspect
@Component
@EnableAspectAutoProxy
@Order(Ordered.HIGHEST_PRECEDENCE)
public class LogAspect {
@AfterReturning(Logger.class)
public void afterReturning(@Returning Object returnValue) {
log.debug("@AfterReturning returnValue: [{}]", returnValue);
}
@AfterThrowing(Logger.class)
public void afterThrowing(@Throwing Throwable throwable) {
log.error("@AfterThrowing With Msg: [{}]", throwable.getMessage(), throwable);
}
@Before(Logger.class)
public void before(@Annotated Logger logger, @Argument User user) {
log.debug("@Before method in class with logger: [{}] , Argument:[{}]", logger, user);
}
@After(Logger.class)
public Object after(@Returning User returnValue, @Arguments Object[] arguments) {
log.debug("@After method in class");
return returnValue.setSex("女");
}
@Around(Logger.class)
public Object around(@JoinPoint Joinpoint joinpoint) throws Throwable {
log.debug("@Around Before method");
// int i = 1 / 0;
Object proceed = joinpoint.proceed();
log.debug("@Around After method");
return proceed;
}
}
public @interface Logger {
/** operation */
String value() default "";
}
@Service
public class DefaultUserService implements UserService {
@Autowired
private UserDao userDao;
@Logger("登录")
@Override
public User login(User user) {
log.debug("login");
// int i = 1 / 0;
return userDao.login(user);
}
@Logger("注册")
@Override
public boolean register(User user) {
return userDao.save(user);
}
}
@Repository
public class UserDaoImpl implements UserDao {
private Map<String, User> users = new HashMap<>();
public UserDaoImpl() {
users.put("666", new User(1, "Harry Yang", 20, "666", "666", "男", new Date()));
users.put("6666", new User(2, "Harry Yang1", 20, "6666", "6666", "男", new Date()));
users.put("66666", new User(3, "Harry Yang2", 20, "66666", "66666", "男", new Date()));
users.put("666666", new User(4, "Harry Yang3", 20, "666666", "666666", "男", new Date()));
}
@Override
public boolean save(User user) {
users.put(user.getUserId(), user);
return true;
}
@Override
public User login(User user) {
User user_ = users.get(user.getUserId());
if (user_ == null) {
return null;
}
if (!user_.getPasswd().equals(user.getPasswd())) {
return null;
}
return user_;
}
}
class Test {
@Test
public void test_Login() throws NoSuchBeanDefinitionException {
try (ApplicationContext applicationContext = new StandardApplicationContext("", "")) {
UserService bean = applicationContext.getBean(UserServiceImpl.class);
User user = new User();
user.setPasswd("666");
user.setUserId("666");
long start = System.currentTimeMillis();
User login = bean.login(user);
log.debug("{}ms", System.currentTimeMillis() - start);
log.debug("Result:[{}]", login);
log.debug("{}ms", System.currentTimeMillis() - start);
}
}
}/**
* @author TODAY 2021/2/20 21:26
*/
public class ProxyFactoryBeanTests {
static final Logger log = LoggerFactory.getLogger(ProxyFactoryBeanTests.class);
//需要实现接口，确定哪个通知，及告诉Aop应该执行哪个方法
@Singleton
static class MyAspect implements MethodInterceptor {
public Object invoke(MethodInvocation mi) throws Throwable {
log.debug("方法执行之前");
// 0
Object obj = mi.proceed();
// test == 0
final TargetBean obj1 = (TargetBean) mi.getThis();
obj1.test = 10;
obj = mi.proceed(); // toString
log.debug("方法执行之后");
return obj;
}
}
@Singleton
static class MyAfterReturning implements AfterReturningAdvice {
@Override
public void afterReturning(Object returnValue, MethodInvocation invocation) throws Throwable {
// test == 0
log.debug("方法执行之后 返回值： " + returnValue);
}
}
@Singleton
static class MyBefore implements MethodBeforeAdvice {
@Override
public void before(MethodInvocation invocation) throws Throwable {
log.info("之前");
}
}
@Singleton
static class MyThrows implements ThrowsAdvice {
@Override
public Object afterThrowing(Throwable ex, MethodInvocation invocation) {
log.info(ex.toString());
return "异常数据";
}
}
@ToString
@Singleton
static class TargetBean {
int test;
String throwsTest() {
int i = 1 / 0;
return "ok";
}
}
@Test
public void test() {
try (StandardApplicationContext context = new StandardApplicationContext("", "cn.taketoday.aop.support")) {
final ProxyFactoryBean proxyFactoryBean = new ProxyFactoryBean();
proxyFactoryBean.setProxyTargetClass(true);
proxyFactoryBean.setBeanFactory(context);
proxyFactoryBean.setExposeProxy(true);
proxyFactoryBean.setInterceptorNames("myAspect", "myAfterReturning", "myBefore", "myThrows");
proxyFactoryBean.setTargetName("targetBean");
final Object bean = proxyFactoryBean.getBean();
log.debug(bean.toString());
final String ret = ((TargetBean) bean).throwsTest();
assert ret.equals("异常数据");
}
}
}class Demo {
@Retention(RetentionPolicy.RUNTIME)
@Target({ ElementType.METHOD, ElementType.TYPE })
public @interface Aware { }
static class PrinterBean {
@Aware
void print() {
System.out.println("print");
}
void none() {
System.out.println("none");
}
void none(String arg) {
System.out.println("none" + arg);
}
@Aware
int none(Integer input) {
System.out.println("none" + input);
return input;
}
}
static class LoggingInterceptor implements MethodInterceptor {
@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
log.debug("LoggingInterceptor @Around Before method");
final Object proceed = invocation.proceed();
log.debug("LoggingInterceptor @Around After method");
return proceed;
}
}
static class MyInterceptor implements MethodInterceptor {
@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
final Object proceed = invocation.proceed();
final Object aThis = invocation.getThis();
System.out.println(aThis);
return proceed;
}
}
@Import({ LoggingInterceptor.class, MyInterceptor.class })
static class LoggingConfig {
@Singleton
public DefaultPointcutAdvisor loggingAdvisor(LoggingInterceptor loggingAspect) {
AnnotationMatchingPointcut pointcut = new AnnotationMatchingPointcut(null, Aware.class);
DefaultPointcutAdvisor advisor = new DefaultPointcutAdvisor();
advisor.setPointcut(pointcut);
advisor.setAdvice(loggingAspect);
return advisor;
}
@Singleton
public DefaultPointcutAdvisor advisor(MyInterceptor interceptor) {
AnnotationMatchingPointcut pointcut = new AnnotationMatchingPointcut(null, Aware.class);
DefaultPointcutAdvisor advisor = new DefaultPointcutAdvisor();
advisor.setPointcut(pointcut);
advisor.setAdvice(interceptor);
return advisor;
}
}
@Test
public void testNewVersionAop() throws Throwable {
try (StandardApplicationContext context = new StandardApplicationContext()) {
final TargetSourceCreator targetSourceCreator = new TargetSourceCreator() {
@Override
public TargetSource getTargetSource(BeanDefinition def) {
return new PrototypeTargetSource() {
@Override
public Class<?> getTargetClass() {
return PrinterBean.class;
}
@Override
protected Object newPrototypeInstance() {
return new PrinterBean();
}
};
}
};
final StandardBeanFactory beanFactory = context.getBeanFactory();
final DefaultAutoProxyCreator autoProxyCreator = new DefaultAutoProxyCreator();
context.addBeanPostProcessor(autoProxyCreator);
autoProxyCreator.setBeanFactory(beanFactory);
autoProxyCreator.setFrozen(true);
autoProxyCreator.setExposeProxy(true);
beanFactory.importBeans(LoggingConfig.class, PrinterBean.class);
final PrinterBean bean = beanFactory.getBean(PrinterBean.class);
final DefaultPointcutAdvisor pointcutAdvisor = beanFactory.getBean(DefaultPointcutAdvisor.class);
System.out.println(pointcutAdvisor);
bean.print();
bean.none();
bean.none("TODAY");
final int none = bean.none(1);
assertThat(none).isEqualTo(1);
System.out.println(none);
// Advised advised = (Advised) bean;
// System.out.println(Arrays.toString(advised.getAdvisors()));
}
}
}本项目的诞生离不开以下项目：
- Spring: Spring Framework
TODAY Framework 使用 GNU GENERAL PUBLIC LICENSE 开源协议