多数据源,logback,发邮件,I18N

Author: AaronVip

pom.xml

@@ -87,6 +87,10 @@
 			<artifactId>mybatisplus-spring-boot-starter</artifactId>
 			<version>${mybatisplus-spring-boot-starter.version}</version>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-aop</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>com.baomidou</groupId>
 			<artifactId>mybatis-plus</artifactId>
@@ -158,12 +162,7 @@
 		</dependency>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
-			<artifactId>spring-boot-test</artifactId>
-		</dependency>
-		<dependency>
-			<groupId>org.springframework</groupId>
-			<artifactId>spring-test</artifactId>
-			<version>4.2.0.RELEASE</version>
+			<artifactId>spring-boot-starter-test</artifactId>
 		</dependency>
 	</dependencies>
 

src/main/java/com/victor/common/aop/WebLogAspect.java

@@ -0,0 +1,71 @@
+package com.victor.common.aop;
+
+import java.util.Arrays;
+import java.util.Enumeration;
+import javax.servlet.http.HttpServletRequest;
+import org.aspectj.lang.JoinPoint;
+import org.aspectj.lang.annotation.AfterReturning;
+import org.aspectj.lang.annotation.Aspect;
+import org.aspectj.lang.annotation.Before;
+import org.aspectj.lang.annotation.Pointcut;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.annotation.Order;
+import org.springframework.stereotype.Component;
+import org.springframework.web.context.request.RequestContextHolder;
+import org.springframework.web.context.request.ServletRequestAttributes;
+
+/**
+ * Created by Aaron on 2017/12/20.
+ * 实现Web层的日志切面
+ */
+@Aspect
+@Component
+@Order(-5)
+public class WebLogAspect {
+
+	private Logger logger =  LoggerFactory.getLogger(this.getClass());
+
+	/**
+	 * 定义一个切入点.
+	 * 解释下：
+	 *
+	 * ~ 第一个 * 代表任意修饰符及任意返回值.
+	 * ~ 第二个 * 任意包名
+	 * ~ 第三个 * 代表任意方法.
+	 * ~ 第四个 * 定义在web包或者子包
+	 * ~ 第五个 * 任意方法
+	 * ~ .. 匹配任意数量的参数.
+	 */
+	@Pointcut("execution(public * com.victor.*.controller..*.*(..))")
+	public void webLog(){}
+
+	@Before("webLog()")
+	public void doBefore(JoinPoint joinPoint){
+
+		// 接收到请求，记录请求内容
+		logger.info("WebLogAspect.doBefore()");
+		ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
+		HttpServletRequest request = attributes.getRequest();
+
+
+		// 记录下请求内容
+		logger.info("URL : " + request.getRequestURL().toString());
+		logger.info("HTTP_METHOD : " + request.getMethod());
+		logger.info("IP : " + request.getRemoteAddr());
+		logger.info("CLASS_METHOD : " + joinPoint.getSignature().getDeclaringTypeName() + "." + joinPoint.getSignature().getName());
+		logger.info("ARGS : " + Arrays.toString(joinPoint.getArgs()));
+		//获取所有参数方法一：
+		Enumeration<String> enu=request.getParameterNames();
+		while(enu.hasMoreElements()){
+			String paraName=(String)enu.nextElement();
+			System.out.println(paraName+": "+request.getParameter(paraName));
+		}
+	}
+
+	@AfterReturning("webLog()")
+	public void  doAfterReturning(JoinPoint joinPoint){
+		// 处理完请求，返回内容
+		logger.info("WebLogAspect.doAfterReturning()");
+	}
+}

src/main/java/com/victor/config/datasource/DynamicDataSource.java

@@ -8,7 +8,20 @@
  */
 public class DynamicDataSource  extends AbstractRoutingDataSource {
 
-	@Override protected Object determineCurrentLookupKey() {
+	/**
+	 *   /*
+	 * 代码中的determineCurrentLookupKey方法取得一个字符串，
+	 * 该字符串将与配置文件中的相应字符串进行匹配以定位数据源，配置文件，即applicationContext.xml文件中需要要如下代码：(non-Javadoc)
+	 * @see org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource#determineCurrentLookupKey()
+	 */
+	@Override
+	protected Object determineCurrentLookupKey() {
+
+		/**
+		 * DynamicDataSourceContextHolder代码中使用setDataSourceType
+		 * 设置当前的数据源，在路由类中使用getDataSourceType进行获取，
+		 *  交给AbstractRoutingDataSource进行注入使用。
+		 */
 		return   DynamicDataSourceContextHolder.getDataSourceType();
 	}
 }

src/main/java/com/victor/config/datasource/DynamicDataSourceAspect.java

@@ -20,19 +20,32 @@ public class DynamicDataSourceAspect {
 
 	private static final Logger logger = LoggerFactory.getLogger(DynamicDataSourceAspect.class);
 
+	 /**
+     * @Before("@annotation(ds)")
+     * 的意思是：
+     *
+     * @Before：在方法执行之前进行执行：
+     * @annotation(targetDataSource)：
+     * 会拦截注解targetDataSource的方法，否则不拦截;
+     */
+
 	@Before("@annotation(ds)")
 	public void changeDataSource(JoinPoint point, TargetDataSource ds) throws Throwable {
+		//获取当前的指定的数据源;
 		String dsId = ds.name();
+		//如果不在我们注入的所有的数据源范围之内，那么输出警告信息，系统自动使用默认的数据源。
 		if (!DynamicDataSourceContextHolder.containsDataSource(dsId)) {
 			logger.error("数据源[{}]不存在，使用默认数据源 > {}", ds.name(), point.getSignature());
 		} else {
 			logger.debug("Use DataSource : {} > {}", ds.name(), point.getSignature());
+			//找到的话，那么设置到动态数据源上下文中。
 			DynamicDataSourceContextHolder.setDataSourceType(ds.name());
 		}
 	}
 
 	@After("@annotation(ds)")
 	public void restoreDataSource(JoinPoint point, TargetDataSource ds) {
+		//方法执行完毕之后，销毁当前数据源信息，进行垃圾回收。
 		logger.debug("Revert DataSource : {} > {}", ds.name(), point.getSignature());
 		DynamicDataSourceContextHolder.clearDataSourceType();
 	}

src/main/java/com/victor/config/datasource/DynamicDataSourceRegister.java

@@ -107,19 +107,16 @@ public void setEnvironment(Environment env) {
 
 	/**
 	 * 初始化主数据源
-	 *
-	 * @author SHANHY
-	 * @create 2016年1月24日
 	 */
 	private void initDefaultDataSource(Environment env) {
 		// 读取主数据源
 		RelaxedPropertyResolver propertyResolver = new RelaxedPropertyResolver(env, "spring.datasource.");
 		Map<String, Object> dsMap = new HashMap<>();
 		dsMap.put("type", propertyResolver.getProperty("type"));
-		dsMap.put("driver-class-name", propertyResolver.getProperty("driver-class-name"));
-		dsMap.put("url", propertyResolver.getProperty("url"));
-		dsMap.put("username", propertyResolver.getProperty("username"));
-		dsMap.put("password", propertyResolver.getProperty("password"));
+		dsMap.put("driver-class-name", propertyResolver.getProperty("base.driver-class-name"));
+		dsMap.put("url", propertyResolver.getProperty("base.url"));
+		dsMap.put("username", propertyResolver.getProperty("base.username"));
+		dsMap.put("password", propertyResolver.getProperty("base.password"));
 
 		defaultDataSource = buildDataSource(dsMap);
 
@@ -131,8 +128,6 @@ private void initDefaultDataSource(Environment env) {
 	 *
 	 * @param dataSource
 	 * @param env
-	 * @author SHANHY
-	 * @create  2016年1月25日
 	 */
 	private void dataBinder(DataSource dataSource, Environment env){
 		RelaxedDataBinder dataBinder = new RelaxedDataBinder(dataSource);
@@ -157,13 +152,10 @@ private void dataBinder(DataSource dataSource, Environment env){
 
 	/**
 	 * 初始化更多数据源
-	 *
-	 * @author SHANHY
-	 * @create 2016年1月24日
 	 */
 	private void initCustomDataSources(Environment env) {
 		// 读取配置文件获取更多数据源，也可以通过defaultDataSource读取数据库获取更多数据源
-		RelaxedPropertyResolver propertyResolver = new RelaxedPropertyResolver(env, "custom.datasource.");
+		RelaxedPropertyResolver propertyResolver = new RelaxedPropertyResolver(env, "spring.datasource.");
 		String dsPrefixs = propertyResolver.getProperty("names");
 		for (String dsPrefix : dsPrefixs.split(",")) {// 多个数据源
 			Map<String, Object> dsMap = propertyResolver.getSubProperties(dsPrefix + ".");

src/main/java/com/victor/config/datasource/MultipleDataSourceBeanDefinitionRegistryPostProcessor.java

@@ -142,10 +142,7 @@ private void beanDefinitionRegistry(BeanDefinitionRegistry beanDefinitionRegistr
            /*
             * 获取到子属性，对应一个map;
             * 也就是这个map的key就是
-            *
             * type、driver-class-name等;
-            *
-            *
             */
 			Map<String, Object> dsMap = propertyResolver.getSubProperties(dsPrefix + ".");
 			//存放到一个map集合中，之后在注入进行使用.

src/main/java/com/victor/config/i18n/I18NConfig.java

@@ -0,0 +1,42 @@
+package com.victor.config.i18n;
+
+import java.util.Locale;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.web.servlet.LocaleResolver;
+import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
+import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
+import org.springframework.web.servlet.i18n.LocaleChangeInterceptor;
+import org.springframework.web.servlet.i18n.SessionLocaleResolver;
+
+/**
+ * Created by Aaron on 2017/12/20.
+ */
+@Configuration
+@EnableAutoConfiguration
+@ComponentScan
+public class I18NConfig extends WebMvcConfigurerAdapter {
+
+	@Bean
+	public LocaleResolver localeResolver() {
+		SessionLocaleResolver slr = new SessionLocaleResolver();
+		// 默认语言
+		slr.setDefaultLocale(Locale.US);
+		return slr;
+	}
+
+	@Bean
+	public LocaleChangeInterceptor localeChangeInterceptor() {
+		LocaleChangeInterceptor lci = new LocaleChangeInterceptor();
+		// 参数名
+		lci.setParamName("lang");
+		return lci;
+	}
+
+	@Override
+	public void addInterceptors(InterceptorRegistry registry) {
+		registry.addInterceptor(localeChangeInterceptor());
+	}
+}

src/main/java/com/victor/config/javaCode/MyBeanDefinitionRegistryPostProcessor.java

@@ -61,7 +61,7 @@ public ShiroFilterFactoryBean shiroFilter(SecurityManager securityManager) {
 		filterChainDefinitionMap.put("/admin/logout", "logout");
 
 		// 过滤链
-		filterChainDefinitionMap.put("/**", "user");
+		//filterChainDefinitionMap.put("/**", "user");
 		filterChainDefinitionMap.put("/css/**", "anon");
 		filterChainDefinitionMap.put("/fonts/**", "anon");
 		filterChainDefinitionMap.put("/img/**", "anon");