# TODAY Framework **Repository Path**: yangwulang_admin/today-framework ## Basic Information - **Project Name**: TODAY Framework - **Description**: 你问我优雅的代码长啥样？那我得好好展示一番！ - **Primary Language**: Java - **License**: GPL-3.0 - **Default Branch**: master - **Homepage**: https://taketoday.cn/articles/1565195388947.html - **GVP Project**: No ## Statistics - **Stars**: 1 - **Forks**: 5 - **Created**: 2022-05-05 - **Last Updated**: 2022-10-21 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # TODAY Infrastructure 🍎 A Java library for applications software infrastructure. ![Java17](https://img.shields.io/badge/JDK-17+-success.svg) [![GPLv3](https://img.shields.io/badge/License-GPLv3-blue.svg)](./LICENSE) [![Author](https://img.shields.io/badge/Author-TODAY-blue.svg)](https://github.com/TAKETODAY) [![GitHub CI](https://github.com/TAKETODAY/today-framework/workflows/GitHub%20CI/badge.svg)](https://github.com/TAKETODAY/today-framework/actions) [![Codacy Badge](https://app.codacy.com/project/badge/Grade/3ad5eed64065496fba9244d149820f67)](https://www.codacy.com/gh/TAKETODAY/today-framework/dashboard?utm_source=github.com&utm_medium=referral&utm_content=TAKETODAY/today-framework&utm_campaign=Badge_Grade) [![Coverage Status](https://coveralls.io/repos/github/TAKETODAY/today-framework/badge.svg?branch=master)](https://coveralls.io/github/TAKETODAY/today-framework?branch=master) **You ask me what the elegant code looks like? Then I have to show it!** ## 主要目的 主要为了学习技术，顺便给自己的博客网站 https://taketoday.cn 提供基础框架（其实写的博客网站也是为了学习练习技术）。 ## 背景 起源于大学的时候学习编程，后来用 Java Servlet 做了一个博客网站。在开发过程中发现有很多重复代码， 我觉得这样的代码很不优雅，尽管那个时候刚学编程不久，于是在我学习 [Struts2](https://struts.apache.org/) 的时候自己尝试着写了一个类似的 通过 `XML` 配置干掉了大量的重复代码的程序。于是初代的 [today-web](https://gitee.com/I-TAKE-TODAY/today-web/tree/v1.1.1/) 诞生并开源。 后面学习了 `Java 注解` 又实现了通过注解配置的版本 [today-web 注解版](https://gitee.com/I-TAKE-TODAY/today-web/tree/2.1.x/) [today-web 注解版](https://gitee.com/I-TAKE-TODAY/today-web/tree/2.1.x/) 刚出来时也正在学 `Spring` 感觉没有 `IoC` 容器感觉不是很方便。在网上看到很多自己写 什么 Mini Spring 之类，所以我大胆决定`我也要写一个`。有这个决心是因为我把 today-web 都写出来了， 再写个 IoC 应该不难吧。刚开始参考了各种 mini-spring，该说不说现在看来正是那个时候参考了他们的代码才导致我有些认知错误。在2021年6月-2021年12月期间 又去深入看 Spring 源码才纠正过来。事实证明写一个这样的东西确实不难，只是要优雅的话还是要点东西的。我自认为我的代码还是优雅的。不信？ [我的B站直播间欢迎你](https://live.bilibili.com/22702726) 。（在2021年开始直播写这个库，后面工作比较忙了就没怎么直播，后面有时间就会直播）。 刚开始写的时候（大概是2018年,我也是看的Git提交记录哈哈）有点无从下手，所以我去参考上文说到的各类 `Mini Spring`。 就这样又开启了一轮学习。 学习如何扫描类文件、学习Java注解、Java字节码、动态代理、重新认识接口、一些设计模式、学习使用Git、渐渐明白了单元测试的重要性 等。随着学习的深入框架经历了数次重构，自己也对依赖注入有了自己的看法。慢慢的我发现我居然能看得明白 Spring 源码了。 感觉Spring真心强大。 如果你问我怎么学习编程，我觉得造轮子是比较好的方式。自己还有很多要学的东西。比如分布式方面的知识，所以今后你定会看到诸如 [today-rpc](https://github.com/TAKETODAY/today-rpc), `today-distributed-*` 等项目诞生。 ## 🛠️ 安装 > 老版本 IoC ```xml cn.taketoday today-context 3.0.5.RELEASE ``` > 新版本正在加紧开发中 ## 开始 只需要 ```java @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); } } ``` # 在 Netty 里运行 ```java @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(); } } ``` # 在 Servlet 容器里运行 ```java @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 { 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------------------"); } } ``` ## 📝 使用说明 ### 标识一个Bean - 使用`@Component` - 任意注解只要注解上有`@Component`注解就会标识为一个Bean不论多少层 ```java @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` ```java @Component(scope = Scope.SINGLETON) @Target({ ElementType.TYPE, ElementType.METHOD }) public @interface Singleton { // bean name String[] value() default {}; String[] initMethods() default {}; String destroyMethods() default ""; } ``` `@Prototype` ```java @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` ```java @Target(ElementType.TYPE) @Component(scope = Scope.SINGLETON) public @interface Configuration { } ``` `@Service` ```java @Component(scope = Scope.SINGLETON) @Target({ ElementType.TYPE, ElementType.METHOD }) public @interface Service { String[] value() default {};// bean names } ``` ### 注入Bean - 使用`@Autowired`注入 - 使用`@Resource`注入 - 使用`@Inject`注入 - 可自定义注解和实现`PropertyValueResolver`： ```java @FunctionalInterface public interface PropertyValueResolver { default boolean supports(Field field) { return false; } PropertyValue resolveProperty(Field field) throws ContextException; } ``` - 注入示例： ```java @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(); } } ``` - 实现原理 ```java public class AutowiredPropertyResolver implements PropertyValueResolver { private static final Class NAMED_CLASS = ClassUtils.loadClass("jakarta.inject.Named"); private static final Class 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); } } ``` 看到这你应该明白了注入原理了 ### 使用`@Autowired`构造器注入 ```java // 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 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()); } } ``` ### 使用`@Props` 注入Properties或Bean - 构造器 ```java 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 ```java class DemoBean { @Props(prefix = "site.") Bean bean; @Props(prefix = "site.") Map properties; @Props(prefix = "site.") Properties properties; } ``` - 实现原理 ```java @Order(Ordered.HIGHEST_PRECEDENCE - 2) public class PropsPropertyResolver implements PropertyValueResolver { @Override public boolean supports(Field field) { return field.isAnnotationPresent(Props.class); } } ``` ### 使用`@Value` 支持EL表达式 - 和`@Props`一样同样支持构造器，Field注入 - `#{key}` 和Environment#getProperty(String key, Class targetType)效果一样 - `${1+1}` 支持EL表达式 ```java @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/"); } } ``` ### `@Configuration`注解 该注解标识一个配置Bean,示例： ```java @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 Queue loggerDetails(Redisson redisson) { return new ConcurrentLinkedQueue(); } @Singleton("cacheViews") public Map cacheViews(Redisson redisson) { return redisson.getMap("cacheViews", LongCodec.INSTANCE); } @Singleton("articleLabels") public Map> articleLabels(Redisson redisson, @Autowired("fstCodec") Codec codec) { return redisson.getMap("articleLabels", codec); } @Singleton("optionsMap") public Map optionsMap(Redisson redisson) { // redisson.getKeys().flushdb(); return redisson.getMap("optionsMap", StringCodec.INSTANCE); } @Singleton("categories") public List categories(Redisson redisson, @Autowired("fstCodec") Codec codec) { return redisson.getList("categories", codec); } @Singleton("labels") public Set