Spring Boot 示例项目

项目特色：

启动类添加注解@ServletComponentScan

编写servlet：

@WebServlet("/web")

public class BootSevlet implements Servlet {

...

2. Interceptor:

编写：

/**

 * BootInterceptor

 */

public class BootInterceptor implements HandlerInterceptor {

...

@Configuration

public class ApplicationConfig {

    @Configuration

    public class WebMvcConfigurer extends WebMvcConfigurerAdapter {

        public void addInterceptors(InterceptorRegistry registry) {

            registry.addInterceptor(new BootInterceptor()).addPathPatterns("/**");

            super.addInterceptors(registry);

        }

...

3. listenenr：实现各种listener

@WebListener

public class BootListener implements ServletContextListener {

...

datasource:

    local:

        url: $[datasource.local.url]

        username: $[datasource.local.user]

        password: $[datasource.local.password]

        driverClassName: com.mysql.jdbc.Driver

        type: org.apache.commons.dbcp.BasicDataSource

        max-active: 30

        max-idle: 10

        max-wait: 10

        test-while-idle: true

    remote:

        url: $[datasource.remote.url]

        username: $[datasource.remote.user]

        password: $[datasource.remote.password]

        driverClassName: com.mysql.jdbc.Driver

        type: org.apache.commons.dbcp.BasicDataSource

        max-active: 30

        max-idle: 10

        max-wait: 10

        test-while-idle: true

/**

 * Created by windwant on 2016/12/30.

 * implements EnvironmentAware, ApplicationContextAware

 */

@Configuration

public class MybatisConfig {

//    private Environment environment;

//

//    @Override

//    public void setEnvironment(Environment environment) {

//        this.environment = environment;

//    }

    @Primary

    @Bean(name = "localDataSource")

    @Order(value = 1)

    @ConfigurationProperties(prefix = "datasource.local")

    public DataSource localDataSource(){

        return DataSourceBuilder.create().build();

    }

    @Order(value = 2)

    @Bean(name = "remoteDataSource")

    @ConfigurationProperties(prefix = "datasource.remote")

    public DataSource remoteDataSource() {

        return DataSourceBuilder.create().build();

    }

    @Bean(name = "routingDataSource")

    @Order(value = 3)

    public DataSource routingDataSource(@Qualifier("localDataSource") DataSource localDataSource,

                                        @Qualifier("remoteDataSource") BasicDataSource remoteDataSource){

        RoutingDataSource routingDataSource = new RoutingDataSource();

        Map<Object, Object> dataSources = new HashMap<>();

        dataSources.put(Type.LOCAL.name(), localDataSource);

        dataSources.put(Type.REMOTE.name(), remoteDataSource);

        routingDataSource.setTargetDataSources(dataSources);

        routingDataSource.setDefaultTargetDataSource(localDataSource);

        return routingDataSource;

    }

    @Bean

    @Order(value = 4)

    @Lazy

    public SqlSessionFactory sqlSessionFactory(@Qualifier("remoteDataSource") DataSource remoteDataSource,

                                               @Qualifier("localDataSource") DataSource localDataSource,

                                               @Qualifier("routingDataSource") DataSource routingDataSource) throws Exception {

        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();

        factoryBean.setDataSource(routingDataSource);

        factoryBean.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);

        factoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mybatis/*.xml"));

        factoryBean.afterPropertiesSet();

        return factoryBean.getObject();

    }

//    private ApplicationContext ctx;

//

//    @Override

//    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {

//        this.ctx = applicationContext;

//    }

}

@Bean

public MapperScannerConfigurer mapperScannerConfigurer() {

    MapperScannerConfigurerProxy mapperScannerConfigurerProxy = new MapperScannerConfigurerProxy();

    mapperScannerConfigurerProxy.setBasePackage("org.windwant.spring.mapper");

    return mapperScannerConfigurerProxy;

}

/**

 * Created by windwant on 2017/4/6.

 * JMX Mbean 监控 可以通过jconsole进行mbean暴露操作

 */

@Component

@ManagedResource(description = "sboot svr")

public class WAMBean {

    // 属性

    private String name;

    private int age;

    private String message;

    @ManagedAttribute

    public String getName() {

        System.out.println("name: " + name);

        return name;

    }

    @ManagedAttribute

    public void setName(String name) {

        this.name = name;

    }

    @ManagedAttribute

    public int getAge() {

        System.out.println("age: "+age);

        return age;

    }

    @ManagedAttribute

    public void setAge(int age) {

        this.age = age;

    }

    @ManagedAttribute

    public String getMessage() {

        System.out.println("message: " + message);

        return message;

    }

    @ManagedAttribute

    public void setMessage(String message) {

        this.message = message;

    }

    @ManagedOperation

    @ManagedOperationParameter(name = "message", description = "message")

    public void call(String message) {

        System.out.println("call：" + message);

    }

    @ManagedOperation

    @ManagedOperationParameter(name = "who", description = "who")

    @ManagedOperationParameter(name = "what", description = "what")

    public void look(String who, String what){

        System.out.println(who + " 发现了 " + what);

    }

    @Autowired

    FTPTransport ftpTransport;

    @ManagedOperation

    public void upload() throws FileNotFoundException {

        FileInputStream f = null;

        try {

            f = new FileInputStream(new File("D:\\a.json"));

            ftpTransport.uploadFile("ajson", f);

        }catch (Exception e){

            e.printStackTrace();

        }finally {

            try {

                if(f != null){

                    f.close();

                }

            }catch (Exception e){

                e.printStackTrace();

            }

        }

        System.out.println("to play....");

    }

}

四：定时任务配置 Scheduled 

@Component

public class BootJob {

    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

    @Scheduled(fixedRate = 1000)

    public void reportTime(){

        System.out.println("current time is: " +  dateFormat.format(new Date()));

    }

}

五：参数验证

参数Bean：验证注解 @NotBlank @NotNull等

public class Guest {

    @NotBlank(message = "{guest.name}")

    private String name;

    private Integer sex;

@RequestMapping("/hellox")

Map<String, Object> hellox(@Valid Guest guest, BindingResult result){

    if(result.hasErrors()){

        return Response.response(-1, Constants.FAILED, result.getAllErrors());

    }

使用lang验证提示信息：

@Bean

public LocalValidatorFactoryBean localValidatorFactoryBean(){

    LocalValidatorFactoryBean localValidatorFactoryBean = new LocalValidatorFactoryBean();

    localValidatorFactoryBean.setProviderClass(HibernateValidator.class);

    ReloadableResourceBundleMessageSource rrbms = new ReloadableResourceBundleMessageSource();

    rrbms.setBasename("classpath:/lang/messages");

    rrbms.setUseCodeAsDefaultMessage(false);

    rrbms.setDefaultEncoding("UTF-8");

    localValidatorFactoryBean.setValidationMessageSource(rrbms);

    return localValidatorFactoryBean;

}

六：跨域处理 Cors 

配置WebMvcConfigureAdapter addCorsMappings

addMapping：请求拦截

allowedOrigins：拦截请求源

allowedMethods：拦截方法

@Configuration

public class WebMvcConfigurer extends WebMvcConfigurerAdapter {

    public void addInterceptors(InterceptorRegistry registry) {

        registry.addInterceptor(new BootInterceptor()).addPathPatterns("/**");

            super.addInterceptors(registry);

        }

        /**

         * 跨域处理 映射所有路径 允许所有来源 以下方法请求

         * @param registry

         */

        @Override

        public void addCorsMappings(CorsRegistry registry) {

            registry.addMapping("/**")

                    .allowedOrigins("*")

                    .allowedMethods("GET", "POST", "PUT", "OPTIONS", "DELETE", "PATCH");

        }

七：shiro权限配置

@Configuration

public class ShiroConfig implements EnvironmentAware {

	private final static int REMEMBER_ME_MAX_AGE = 365 * 24 * 3600;

	// 这是个DestructionAwareBeanPostProcessor的子类，负责org.apache.shiro.util.Initializable类型bean的生命周期的，

	// 初始化和销毁。主要是AuthorizingRealm类的子类，以及EhCacheManager类

	@Bean(name = "lifecycleBeanPostProcessor")

    public LifecycleBeanPostProcessor lifecycleBeanPostProcessor() {

        return new LifecycleBeanPostProcessor();

    }

	@Bean

	public SimpleCookie rememberMeCookie(){

	      SimpleCookie simpleCookie = new SimpleCookie("rememberMe");

	      simpleCookie.setMaxAge(REMEMBER_ME_MAX_AGE);

	      return simpleCookie;

	}

	@Bean

	public CookieRememberMeManager rememberMeManager(){

	      CookieRememberMeManager cookieRememberMeManager = new CookieRememberMeManager();

	      cookieRememberMeManager.setCookie(rememberMeCookie());

	      //rememberMe cookie加密的密钥 建议每个项目都不一样 默认AES算法 密钥长度(128 256 512 位)

	      cookieRememberMeManager.setCipherKey(Base64.decode("2AvVhdsgUs0FSA3SDFAdag=="));

	      return cookieRememberMeManager;

	}

	// 为了对密码进行编码的，防止密码在数据库里明码保存，当然在登陆认证，这个类也负责对form里输入的密码进行编码。

	@Bean(name = "hashedCredentialsMatcher")

	public HashedCredentialsMatcher hashedCredentialsMatcher() {

		HashedCredentialsMatcher credentialsMatcher = new ComHashedCredentialsMatcher();

		credentialsMatcher.setHashAlgorithmName("MD5");//散列算法:这里使用MD5算法;

		credentialsMatcher.setHashIterations(1);//散列的次数，比如散列两次，相当于 md5(md5(""));

		credentialsMatcher.setStoredCredentialsHexEncoded(true);//true时密码加密用的是Hex编码；false时用Base64编码

		return credentialsMatcher;

	}

	// 增加缓存减少对数据库的查询压力

	@Bean(name = "ehcacheManager")

    public EhCacheManager getEhCacheManager() {  

        EhCacheManager em = new EhCacheManager();  

        em.setCacheManagerConfigFile("classpath:ehcache-shiro.xml");  

        return em;  

    }  

	// 自定义的认证类，继承自AuthorizingRealm，负责用户的认证和权限的处理

	@Bean(name = "shiroRealm")

    public MyAuthorizingRealm shiroRealm() {

		MyAuthorizingRealm realm = new MyAuthorizingRealm();

		realm.setCredentialsMatcher(hashedCredentialsMatcher());

        realm.setCachingEnabled(true);

        realm.setCacheManager(getEhCacheManager());

        return realm;

    }

	//权限管理，这个类组合了登陆，登出，权限，session的处理

	@Bean(name = "securityManager")

	public DefaultWebSecurityManager securityManager(){

		DefaultWebSecurityManager securityManager = new DefaultWebSecurityManager();

		securityManager.setRealm(shiroRealm());

		securityManager.setCacheManager(getEhCacheManager());

		securityManager.setRememberMeManager(rememberMeManager());

        DefaultWebSessionManager defaultWebSessionManager = new DefaultWebSessionManager();

        defaultWebSessionManager.setGlobalSessionTimeout(Long.parseLong(environment.getProperty("session.timeout")));

        securityManager.setSessionManager(defaultWebSessionManager);

        return securityManager;

	}

	// 开启Shiro的注解(如@RequiresRoles,@RequiresPermissions),需借助SpringAOP扫描使用Shiro注解的类,并在必要时进行安全逻辑验证 * 配置以下

	// 两个bean(DefaultAdvisorAutoProxyCreator(可选)和AuthorizationAttributeSourceAdvisor)即可实现此功能

	@Bean(name = "advisorAutoProxyCreator")

    @DependsOn({"lifecycleBeanPostProcessor"})

    public DefaultAdvisorAutoProxyCreator advisorAutoProxyCreator(){

        DefaultAdvisorAutoProxyCreator advisorAutoProxyCreator = new DefaultAdvisorAutoProxyCreator();

        advisorAutoProxyCreator.setProxyTargetClass(true);

        return advisorAutoProxyCreator;

    }

	@Bean(name = "authorizationAttributeSourceAdvisor")