devbox
代码世界探险家
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

demo（二）SpringBoot+dubbo+Spring Sercurity+VUE实例----（后端）_springboot+vue+dubbo

作者：代码世界探险家 | 2024-02-01 13:20:51

赞

踩

springboot+vue+dubbo

下面写个简单的token单一点登录系统来验证下。当访问系统未登录时，跳转到登录页，登录后进入首页，左侧导航栏展示默认菜单（首页）和有权限的菜单。

一、写在前面：关于session和token的使用，网上争议一直很大。总的来说争议在这里：

（1）session是空间换时间，而token是时间换空间。session占用空间，但是可以管理过期时间，token管理部了过期时间，但是不占用空间.
（2）sessionId失效问题和token内包含。
（3）session基于cookie，app请求并没有cookie 。
（4）token更加安全(每次请求都需要带上)。
 

二、效果：

前端：vue；

后端：springboot+dubbo+mybatis+spring sercurity+JWT+ token单一点登录。

效果：

分别启动前后端服务，访问首页http://localhost:9528/#/index，由于未登录，跳转到登录页

登录后跳转到首页，http://localhost:9528/#/dashboard

左侧菜单栏展开，显示所有的权限：

此时在postman调用一次登录接口，再次回到浏览器刷新或者调用接口（如点击用户管理页），跳转到登录页面。证明单一点登录实现。 

三、数据库：

1、t_user:

2、t_role:

3、t_authority:

4、t_user_role：

5、t_role_authoriy：

四、后端代码：

  • api:

1、pom:

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  2.   <modelVersion>4.0.0</modelVersion>
  3.   <groupId>com.demo</groupId>
  4.   <artifactId>mysercurity-api</artifactId>
  5.   <version>1.0.0-SNAPSHOT</version>
  6. </project>

2、dto：

  1. public class AuthorityDTO implements Serializable {
  2.  
  3.     private Integer id;
  4.  
  5.     private String authorityName;
  6.  
  7.     private String authorityCode;
  8. }
  1. public class RoleDTO implements Serializable {
  2.  
  3.     private Integer id;
  4.  
  5.     private String roleCode;
  6.  
  7.     private String roleName;
  8. }
  1. public class UserDTO implements Serializable {
  2.  
  3.     private Integer id;
  4.  
  5.     private String userName;
  6.  
  7.     private String password;
  8.  
  9.     private String userNickName;
  10.  
  11.     //验证码
  12.     private String code;
  13.  
  14.     private List<RoleDTO> roles;
  15. }
  • service:

1、pom:

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  2.   <modelVersion>4.0.0</modelVersion>
  3.   <groupId>com.demo</groupId>
  4.   <artifactId>mysercurity-service</artifactId>
  5.   <version>0.0.1-SNAPSHOT</version>
  6.  
  7.   <!-- springBoot -->
  8.   <parent>
  9.     <groupId>org.springframework.boot</groupId>
  10.     <artifactId>spring-boot-starter-parent</artifactId>
  11.     <version>1.4.1.RELEASE</version>
  12.   </parent>
  13.   <dependencies>
  14.     <dependency>
  15.       <groupId>org.springframework.boot</groupId>
  16.       <artifactId>spring-boot-starter-web</artifactId>
  17.     </dependency>
  18.     <!-- api -->
  19.     <dependency>
  20.       <groupId>com.demo</groupId>
  21.       <artifactId>mysercurity-api</artifactId>
  22.       <version>1.0.0-SNAPSHOT</version>
  23.     </dependency>
  24.  
  25.     <!-- mybatis -->
  26.     <dependency>
  27.       <groupId>org.mybatis.spring.boot</groupId>
  28.       <artifactId>mybatis-spring-boot-starter</artifactId>
  29.       <version>1.1.1</version>
  30.     </dependency>
  31.     <dependency>
  32.       <groupId>mysql</groupId>
  33.       <artifactId>mysql-connector-java</artifactId>
  34.       <version>5.1.21</version>
  35.     </dependency>
  36.  
  37.  
  38.     <!-- dubbo -->
  39.     <dependency>
  40.       <groupId>com.alibaba.spring.boot</groupId>
  41.       <artifactId>dubbo-spring-boot-starter</artifactId>
  42.       <version>2.0.0</version>
  43.     </dependency>
  44.  
  45.     <dependency>
  46.       <groupId>commons-collections</groupId>
  47.       <artifactId>commons-collections</artifactId>
  48.       <version>3.2.1</version>
  49.     </dependency>
  50.     <dependency>
  51.       <groupId>commons-lang</groupId>
  52.       <artifactId>commons-lang</artifactId>
  53.       <version>2.5</version>
  54.     </dependency>
  55.  
  56.     <!--zk-->
  57.         <dependency>
  58.             <groupId>com.github.sgroschupf</groupId>
  59.             <artifactId>zkclient</artifactId>
  60.             <version>0.1</version>
  61.             <exclusions>
  62.                 <exclusion>
  63.                     <artifactId>log4j</artifactId>
  64.                     <groupId>log4j</groupId>
  65.                 </exclusion>
  66.                 <exclusion>
  67.                     <artifactId>slf4j-log4j12</artifactId>
  68.                     <groupId>org.slf4j</groupId>
  69.                 </exclusion>
  70.             </exclusions>
  71.         </dependency>
  72.  
  73.   </dependencies>
  74.  
  75. </project>

2、application.properties:

  1. spring.datasource.driver-class-name=com.mysql.jdbc.Driver
  2. spring.datasource.url=jdbc:mysql://localhost:3306/demo?useUnicode=true&characterEncoding=utf-8&useSSL=false
  3. spring.datasource.username=root
  4. spring.datasource.password=wtyy
  5.  
  6. mybatis.mapper-locations=classpath*:Mapper/*Mapper.xml
  7.  
  8. server.port=9998
  9.

 3、provider.xml：

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans xmlns="http://www.springframework.org/schema/beans"
  3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
  4.        xsi:schemaLocation="http://www.springframework.org/schema/beans
  5.      http://www.springframework.org/schema/beans/spring-beans.xsd
  6.      http://code.alibabatech.com/schema/dubbo
  7.      http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  8.     <dubbo:application name="mysercurity-service"/>
  9.     <dubbo:provider timeout="3000" retries="0"/>
  10.     <!-- register改为false不注册到注册中心 -->
  11.     <dubbo:registry protocol="zookeeper" address="192.168.57.xxx:2181,192.168.57.xx:2181,192.168.59.xxx:2181"
  12.                     register="false"   check="false"/>
  13.     <dubbo:protocol name="dubbo" port="20881"/>
  14.  
  15.     <dubbo:service interface="com.demo.service.UserService" ref="userService"></dubbo:service>
  16.     <dubbo:service interface="com.demo.service.RoleService" ref="roleService"></dubbo:service>
  17. </beans>

4、serviceImpl:

  1. package com.demo.service.impl;
  2. import com.demo.dao.UserRoleDao;
  3. import com.demo.dto.RoleDTO;
  4. import com.demo.service.RoleService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.stereotype.Service;
  7. import java.util.List;
  8.  
  9. @Service("roleService")
  10. public class RoleServiceImpl implements RoleService {
  11.  
  12.     @Autowired
  13.     private UserRoleDao userRoleDao;
  14.  
  15.     @Override
  16.     public List<RoleDTO> findRoleByUserId(Integer id) {
  17.         return userRoleDao.findRoleByUserId(id);
  18.     }
  19. }
  1. package com.demo.service.impl;
  2. import com.demo.dao.AuthorityDao;
  3. import com.demo.dao.UserDao;
  4. import com.demo.dao.UserRoleDao;
  5. import com.demo.dto.AuthorityDTO;
  6. import com.demo.dto.RoleDTO;
  7. import com.demo.dto.UserDTO;
  8. import com.demo.exception.UsernameNotFoundException;
  9. import com.demo.service.RoleService;
  10. import com.demo.service.UserService;
  11. import org.apache.commons.collections.CollectionUtils;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.stereotype.Service;
  14. import java.util.ArrayList;
  15. import java.util.Collections;
  16. import java.util.List;
  17. import java.util.stream.Collectors;
  18.  
  19. @Service("userService")
  20. public class UserServiceImpl implements UserService {
  21.  
  22.     @Autowired
  23.     private UserDao userDao;
  24.  
  25.     @Autowired
  26.     private UserRoleDao userRoleDao;
  27.  
  28.     @Autowired
  29.     private AuthorityDao authorityDao;
  30.  
  31.     @Autowired
  32.     private RoleService roleService;
  33.  
  34.     @Override
  35.     public UserDTO findByUserName(String username) {
  36.  
  37.         UserDTO user = userDao.findByUserName(username);
  38.         if(user == null){
  39.             throw new UsernameNotFoundException("用户不存在");
  40.         }
  41.         List<RoleDTO> roles = roleService.findRoleByUserId(user.getId());
  42.         user.setRoles(roles);
  43.         return user;
  44.     }
  45.  
  46.     @Override
  47.     public List<UserDTO> getAllUsers() {
  48.         return userDao.getAllUsers();
  49.     }
  50.  
  51.     @Override
  52.     public List<AuthorityDTO> getAuthortiesByUserId(Integer userId) {
  53.         List<RoleDTO> roles = userRoleDao.findRoleByUserId(userId);
  54.         if(CollectionUtils.isNotEmpty(roles)){
  55.             List<Integer> roleIds = roles.stream().map(RoleDTO::getId).collect(Collectors.toList());
  56.             return authorityDao.getAuthortiesByRoleIds(roleIds);
  57.         }
  58.         return new ArrayList<>();
  59.     }
  60.  
  61. }

 5、dao:

  1. public interface AuthorityDao {
  2.     List<AuthorityDTO> getAuthortiesByRoleIds(@Param("roleIds") List<Integer> roleIds);
  3. }
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.demo.dao.AuthorityDao">
  4.     <select id="getAuthortiesByRoleIds" resultType="com.demo.dto.AuthorityDTO">
  5.         select
  6.         a.id id,
  7.         a.authority_code authorityCode,
  8.         a.authority_name authorityName
  9.         from t_role_authoriy ra left join t_authority a on ra.authority_id = a.id
  10.         where ra.role_id in
  11.         <foreach collection="roleIds" item="item" open="(" close=")" separator=",">
  12.           #{item}
  13.         </foreach>
  14.         and ra.is_delete = 0
  15.     </select>
  16. </mapper>
  1. public interface UserDao {
  2.     public UserDTO findByUserName(@Param("userName") String userAccount);
  3.     List<UserDTO> getAllUsers();
  4. }
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.demo.dao.UserDao">
  4.     <select id="findByUserName" resultType="com.demo.dto.UserDTO">
  5.         select
  6.         id,
  7.         user_nick_name  userNickName,
  8.         user_name userName,
  9.         user_nick_name userNickName,
  10.         user_password password
  11.         from t_user where user_name = #{userName}
  12.         and is_delete = 0
  13.     </select>
  14.  
  15.     <select id="getAllUsers" resultType="com.demo.dto.UserDTO">
  16.          select
  17.         id,
  18.         user_nick_name  userNickName,
  19.         user_name userName,
  20.         user_nick_name userNickName
  21.         from t_user
  22.     </select>
  23. </mapper>
  1. public interface UserRoleDao {
  2.     List<RoleDTO> findRoleByUserId(@Param("userId") Integer userId);
  3. }
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  3. <mapper namespace="com.demo.dao.UserRoleDao">
  4.     <select id="findRoleByUserId" resultType="com.demo.dto.RoleDTO">
  5.         select
  6.         r.id id,
  7.         r.role_code roleCode,
  8.         r.role_name roleName
  9.         from t_user_role ur
  10.         left join t_role r
  11.         on ur.role_id = r.id
  12.         where ur.user_id = #{userId}
  13.         and is_delete = 0
  14.     </select>
  15. </mapper>

6、启动类：

  1. package com.demo;
  2.  
  3. import org.mybatis.spring.annotation.MapperScan;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.context.annotation.ImportResource;
  7.  
  8. @SpringBootApplication
  9. @MapperScan("com.demo.dao")
  10. @ImportResource("classpath:provider.xml")
  11. public class ServiceStart {
  12.     public static void main(String args[]){
  13.         SpringApplication.run(ServiceStart.class,args);
  14.     }
  15. }
  • rest:

1、pom:

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  2.   <modelVersion>4.0.0</modelVersion>
  3.   <groupId>com.demo</groupId>
  4.   <artifactId>mysercurity-rest</artifactId>
  5.   <version>0.0.1-SNAPSHOT</version>
  6.  
  7.   <parent>
  8.     <groupId>org.springframework.boot</groupId>
  9.     <artifactId>spring-boot-starter-parent</artifactId>
  10.     <version>1.4.1.RELEASE</version>
  11.   </parent>
  12.   <dependencies>
  13.  
  14.     <!--api-->
  15.     <dependency>
  16.       <groupId>com.demo</groupId>
  17.       <artifactId>mysercurity-api</artifactId>
  18.       <version>1.0.0-SNAPSHOT</version>
  19.     </dependency>
  20.  
  21.     <!-- dubbo -->
  22.     <dependency>
  23.       <groupId>com.alibaba.spring.boot</groupId>
  24.       <artifactId>dubbo-spring-boot-starter</artifactId>
  25.       <version>2.0.0</version>
  26.     </dependency>
  27.  
  28.  
  29.     <dependency>
  30.       <groupId>org.springframework.boot</groupId>
  31.       <artifactId>spring-boot-starter-web</artifactId>
  32.     </dependency>
  33.  
  34.     <dependency>
  35.       <groupId>org.springframework.boot</groupId>
  36.       <artifactId>spring-boot-starter-security</artifactId>
  37.     </dependency>
  38.  
  39.  
  40.  
  41.     <dependency>
  42.       <groupId>io.jsonwebtoken</groupId>
  43.       <artifactId>jjwt</artifactId>
  44.       <version>0.9.0</version>
  45.     </dependency>
  46.  
  47.     <!-- redis -->
  48.     <dependency>
  49.       <groupId>org.springframework.boot</groupId>
  50.       <artifactId>spring-boot-starter-data-redis</artifactId>
  51.     </dependency>
  52.  
  53.     <dependency>
  54.       <groupId>org.springframework.session</groupId>
  55.       <artifactId>spring-session-data-redis</artifactId>
  56.     </dependency>
  57.  
  58.     <dependency>
  59.       <groupId>redis.clients</groupId>
  60.       <artifactId>jedis</artifactId>
  61.     </dependency>
  62.     <!--httpclient -->
  63.     <dependency>
  64.       <groupId>org.apache.httpcomponents</groupId>
  65.       <artifactId>httpclient</artifactId>
  66.       <version>4.5.6</version>
  67.     </dependency>
  68.  
  69.     <dependency>
  70.       <groupId>com.alibaba</groupId>
  71.       <artifactId>fastjson</artifactId>
  72.       <version>1.2.31</version>
  73.     </dependency>
  74.  
  75.     <dependency>
  76.       <groupId>commons-collections</groupId>
  77.       <artifactId>commons-collections</artifactId>
  78.       <version>3.2.1</version>
  79.     </dependency>
  80.     <dependency>
  81.       <groupId>commons-lang</groupId>
  82.       <artifactId>commons-lang</artifactId>
  83.       <version>2.5</version>
  84.     </dependency>
  85.  
  86.  
  87.    <!--zk-->
  88.     <dependency>
  89.       <groupId>com.github.sgroschupf</groupId>
  90.       <artifactId>zkclient</artifactId>
  91.       <version>0.1</version>
  92.       <exclusions>
  93.         <exclusion>
  94.           <artifactId>log4j</artifactId>
  95.           <groupId>log4j</groupId>
  96.         </exclusion>
  97.         <exclusion>
  98.           <artifactId>slf4j-log4j12</artifactId>
  99.           <groupId>org.slf4j</groupId>
  100.         </exclusion>
  101.       </exclusions>
  102.     </dependency>
  103.  
  104.   </dependencies>
  105. </project>

2、配置文件：

（1）application.properties:

  1. server.port=9999
  2. server.context-path=/demo
  3. spring.redis.host=localhost
  4. spring.redis.port=6379
  5. #spring.redis.password=
  6. spring.redis.database=1
  7. spring.redis.pool.max-active=8
  8. spring.redis.pool.max-wait=-1
  9. spring.redis.pool.max-idle=500
  10. spring.redis.pool.min-idle=0
  11. spring.redis.timeout=0
  12.

(2) consumer.xml:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <beans
  3.         xmlns="http://www.springframework.org/schema/beans"
  4.         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  5.         xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation="http://www.springframework.org/schema/beans            http://www.springframework.org/schema/beans/spring-beans-3.1.xsd            http://code.alibabatech.com/schema/dubbo            http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
  6.     <dubbo:application name="mysercurity-test" />
  7.     <dubbo:consumer timeout="3000" retries="0" check="false"/>
  8.     <dubbo:registry protocol="zookeeper" address="192.168.57.xxx:2181,192.168.57.xx:2181,192.168.59.xxx:2181" register="true"  timeout="100000"/>
  9.  
  10.     <!-- 加上 url="dubbo://127.0.0.1:20881" 表示直连本地-->
  11.     <dubbo:reference interface="com.demo.service.UserService" id="userService"
  12.                      url="dubbo://127.0.0.1:20881"/>
  13.     <dubbo:reference interface="com.demo.service.RoleService" id="roleService"
  14.                      url="dubbo://127.0.0.1:20881"/>
  15. </beans>
  16.

 3、config:

  1. package com.demo.config;
  2. import org.springframework.context.annotation.Configuration;
  3. import org.springframework.web.servlet.config.annotation.CorsRegistry;
  4. import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
  5.  
  6. @Configuration
  7. public class WebMvcConfig extends WebMvcConfigurerAdapter {
  8.  
  9.     @Override
  10.     public void addCorsMappings(CorsRegistry registry) {
  11.         registry.addMapping("/**").allowedHeaders("*")
  12.                 .allowedMethods("*")
  13.                 .allowedOrigins("*")
  14.                 .allowCredentials(true);
  15.     }
  16. }

 4、常量：

（1）CommonEnums：

  1. package com.demo.constants;
  2.  
  3. public enum CommonEnums {
  4.  
  5.     CODE_200(200,"请求成功"),
  6.     CODE_300(300,"登录成功"),
  7.     CODE_301(301,"登录失败"),
  8.     CODE_302(302,"退出成功"),
  9.     CODE_303(303,"退出失败"),
  10.     CODE_304(304,"用户或密码错误"),
  11.     CODE_305(305,"账户已被锁定"),
  12.     CODE_401(401,"授权失败"),
  13.     CODE_400(400,"业务异常"),
  14.     CODE_402(402,"非法请求"),
  15.     CODE_403(403,"验证码错误"),
  16.     CODE_405(405,"验证码无效"),
  17.     CODE_500(500,"系统异常"),
  18.  
  19.     ;
  20.     public final int code;
  21.  
  22.     public final String message;
  23.  
  24.     CommonEnums(int code, String message ) {
  25.         this.code = code;
  26.         this.message = message;
  27.     }
  28.  
  29.     public int getCode() {
  30.         return this.code;
  31.     }
  32.  
  33.     public String getMessage() {
  34.         return message;
  35.     }
  36.  
  37.     public static String getEnumToValue(int code){
  38.         for (CommonEnums statusEnum: CommonEnums.values()) {
  39.             if (statusEnum.code == code){
  40.                 return statusEnum.message;
  41.             }
  42.         }
  43.         return "";
  44.     }
  45. }

 （2）Constants :

  1. package com.demo.constants;
  2. public class Constants {
  3.  
  4.     public static final long EXPIRATIONTIME = (long)1000 * 60 * 60 * 24 * 1; //1 days
  5.     public static final String SECRET = "spring-security-jwt";
  6.     public static final String HEADER_STRING = "token";
  7.     public static final String TOKEN_PREFIX = "Bearer";
  8.     public static final String TOKEN_JWT="token_jwt:";
  9.     public static final String JWT_USER="jwt_user:";
  10.     public static final String LOCK="lock:";
  11.     public static final String ERROR_NUM="error_num:";
  12. }

 5、dto:

(1)JWTUserDTO:

  1. package com.demo.dto;
  2.  
  3. import org.springframework.security.core.GrantedAuthority;
  4. import org.springframework.security.core.userdetails.UserDetails;
  5.  
  6. import java.util.ArrayList;
  7. import java.util.Collection;
  8. import java.util.List;
  9.  
  10. /**
  11.  * 登录用户
  12.  */
  13. public class JWTUserDTO  implements UserDetails {
  14.  
  15.     private Integer id;
  16.     private String userName;
  17.     private String password;
  18.     private String userNickName;
  19.     private List<RoleDTO> roles = new ArrayList<>();
  20.     private Collection<? extends GrantedAuthority> authorities;
  21.  
  22.     public JWTUserDTO(){
  23.  
  24.     }
  25.  
  26.     public JWTUserDTO(Integer id, String userName, String password, String userNickName,
  27.                    Collection<? extends GrantedAuthority> authorities, List<RoleDTO> roles){
  28.         this.id = id;
  29.         this.userName = userName;
  30.         this.userNickName = userNickName;
  31.         this.password = password;
  32.         this.authorities = authorities;
  33.         this.roles = roles;
  34.     }
  35.  
  36.     @Override
  37.     public String getUsername() {
  38.         return userName;
  39.     }
  40.  
  41.     @Override
  42.     public boolean isAccountNonExpired() {
  43.         return false;
  44.     }
  45.  
  46.     @Override
  47.     public boolean isAccountNonLocked() {
  48.         return false;
  49.     }
  50.  
  51.     @Override
  52.     public boolean isCredentialsNonExpired() {
  53.         return false;
  54.     }
  55.  
  56.     @Override
  57.     public boolean isEnabled() {
  58.         return false;
  59.     }
  60.  
  61.     public void setUsername(String username) {
  62.         this.userName = username;
  63.     }
  64.  
  65.     @Override
  66.     public Collection<? extends GrantedAuthority> getAuthorities() {
  67.         return authorities;
  68.     }
  69.  
  70.     @Override
  71.     public String getPassword() {
  72.         return password;
  73.     }
  74.  
  75.  
  76.     public Integer getId() {
  77.         return id;
  78.     }
  79.  
  80.     public void setId(Integer id) {
  81.         this.id = id;
  82.     }
  83.  
  84.     public void setPassword(String password) {
  85.         this.password = password;
  86.     }
  87.  
  88.     public void setAuthorities(Collection<? extends GrantedAuthority> authorities) {
  89.         this.authorities = authorities;
  90.     }
  91.  
  92.     public List<RoleDTO> getRoles() {
  93.         return roles;
  94.     }
  95.  
  96.     public void setRoles(List<RoleDTO> roles) {
  97.         this.roles = roles;
  98.     }
  99.  
  100.     public String getUserName() {
  101.         return userName;
  102.     }
  103.  
  104.     public void setUserName(String userName) {
  105.         this.userName = userName;
  106.     }
  107.  
  108.     public String getUserNickName() {
  109.         return userNickName;
  110.     }
  111.  
  112.     public void setUserNickName(String userNickName) {
  113.         this.userNickName = userNickName;
  114.     }
  115. }

(2)ResponseMessage:

  1. package com.demo.dto;
  2.  
  3. import com.demo.constants.CommonEnums;
  4.  
  5. public class ResponseMessage {
  6.  
  7.     private int code;
  8.  
  9.     private String status;
  10.  
  11.     private String message;
  12.  
  13.     private String errorMessage;
  14.  
  15.     private String errorExceptionMessage;
  16.  
  17.     private Object data;
  18.  
  19.     public ResponseMessage(int code,String status,Object data){
  20.         this.code = code;
  21.         this.status = status;
  22.         this.data = data;
  23.     }
  24.  
  25.     public ResponseMessage(int code,String status,String message){
  26.         this.code = code;
  27.         this.status = status;
  28.         this.message = message;
  29.     }
  30.  
  31.     public ResponseMessage(int code,String status,String message,Object data){
  32.         this.code = code;
  33.         this.status = status;
  34.         this.message = message;
  35.         this.data = data;
  36.     }
  37.  
  38.  
  39.  
  40.  
  41.     public ResponseMessage(int code,String status,String message,String errorMessage){
  42.         this.code = code;
  43.         this.status = status;
  44.         this.message = message;
  45.         this.errorMessage = errorMessage;
  46.     }
  47.  
  48.     public ResponseMessage(int code,String status,String message,String errorMessage,String errorExceptionMessage){
  49.         this.code = code;
  50.         this.status = status;
  51.         this.message = message;
  52.         this.errorMessage = errorMessage;
  53.         this.errorExceptionMessage = errorExceptionMessage;
  54.     }
  55.  
  56.  
  57.     public static ResponseMessage  success(String message){
  58.         return new ResponseMessage(CommonEnums.CODE_200.code,"success",message);
  59.     }
  60.     public static ResponseMessage  success(Object data){
  61.         return new ResponseMessage(CommonEnums.CODE_200.code,"success",data);
  62.     }
  63.  
  64.  
  65.     public static ResponseMessage  success(String message,Object data){
  66.         return new ResponseMessage(CommonEnums.CODE_200.code,"success",message,data);
  67.     }
  68.  
  69.     public static ResponseMessage  success(int code,String message,Object data){
  70.         return new ResponseMessage(code,"success",message,data);
  71.     }
  72.  
  73.     public static ResponseMessage  success(){
  74.         return new ResponseMessage(CommonEnums.CODE_200.code,null,CommonEnums.CODE_200.message);
  75.     }
  76.  
  77.     public static  ResponseMessage success(int code,Object data){
  78.         return new ResponseMessage(code,"success",data);
  79.     }
  80.  
  81.  
  82.     public static ResponseMessage success(int code,String message){
  83.         return new ResponseMessage(code,"success",message);
  84.     }
  85.  
  86.     public static  ResponseMessage error(int code,String message){
  87.         return new ResponseMessage(code,"error",message);
  88.     }
  89.  
  90.     public static  ResponseMessage error(int code,String message,String errorMessage){
  91.         return new ResponseMessage(code,"error",message,errorMessage);
  92.     }
  93.  
  94.     public static  ResponseMessage error(int code,String message,String errorMessage,String errorExceptionMessage){
  95.         return new ResponseMessage(code,"error",message,errorMessage,errorExceptionMessage);
  96.     }
  97.  
  98.  
  99.     public static  ResponseMessage error(String message,String errorMessage){
  100.         return new ResponseMessage(CommonEnums.CODE_500.code,"error",message,errorMessage);
  101.     }
  102.  
  103.     public static  ResponseMessage error(String message){
  104.         return new ResponseMessage(CommonEnums.CODE_400.code,"error",message);
  105.     }
  106.  
  107.     public static  ResponseMessage infor(int code,String message){
  108.         return new ResponseMessage(code,"infor",message);
  109.     }
  110.  
  111.     public String getStatus() {
  112.         return status;
  113.     }
  114.  
  115.     public void setStatus(String status) {
  116.         this.status = status;
  117.     }
  118.  
  119.     public String getMessage() {
  120.         return message;
  121.     }
  122.  
  123.     public void setMessage(String message) {
  124.         this.message = message;
  125.     }
  126.  
  127.     public Object getData() {
  128.         return data;
  129.     }
  130.  
  131.     public void setData(Object data) {
  132.         this.data = data;
  133.     }
  134.  
  135.     public String getErrorMessage() {
  136.         return errorMessage;
  137.     }
  138.  
  139.     public void setErrorMessage(String errorMessage) {
  140.         this.errorMessage = errorMessage;
  141.     }
  142.  
  143.     public String getErrorExceptionMessage() {
  144.         return errorExceptionMessage;
  145.     }
  146.  
  147.     public void setErrorExceptionMessage(String errorExceptionMessage) {
  148.         this.errorExceptionMessage = errorExceptionMessage;
  149.     }
  150.  
  151.     public int getCode() {
  152.         return code;
  153.     }
  154.  
  155.     public void setCode(int code) {
  156.         this.code = code;
  157.     }
  158. }

6、exception:

(1):

  1. package com.demo.exception;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import com.demo.constants.CommonEnums;
  5. import com.demo.dto.ResponseMessage;
  6. import org.apache.http.entity.ContentType;
  7. import org.springframework.security.core.AuthenticationException;
  8. import org.springframework.security.web.authentication.AuthenticationFailureHandler;
  9. import org.springframework.stereotype.Component;
  10.  
  11. import javax.servlet.ServletException;
  12. import javax.servlet.http.HttpServletRequest;
  13. import javax.servlet.http.HttpServletResponse;
  14. import java.io.IOException;
  15.  
  16. @Component
  17. public class CustomAuthenticationFailureHandler implements AuthenticationFailureHandler {
  18.  
  19.   @Override
  20.   public void onAuthenticationFailure(HttpServletRequest httpServletRequest,
  21.                                       HttpServletResponse httpServletResponse, AuthenticationException e)
  22.       throws IOException, ServletException {
  23.     httpServletResponse.setContentType(ContentType.APPLICATION_JSON.toString());
  24.     httpServletResponse.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_304.code,CommonEnums.CODE_304.message)));
  25.   }
  26. }

 (2):

  1. package com.demo.exception;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import com.demo.constants.CommonEnums;
  5. import com.demo.dto.ResponseMessage;
  6. import org.apache.http.entity.ContentType;
  7. import org.springframework.security.core.AuthenticationException;
  8. import org.springframework.security.web.AuthenticationEntryPoint;
  9. import javax.servlet.ServletException;
  10. import javax.servlet.http.HttpServletRequest;
  11. import javax.servlet.http.HttpServletResponse;
  12. import java.io.IOException;
  13.  
  14. public class Http401AuthenticationEntryPoint implements AuthenticationEntryPoint {
  15.  
  16.  
  17.     @Override
  18.     public void commence(HttpServletRequest request, HttpServletResponse response, AuthenticationException authException) throws IOException, ServletException {
  19.         response.setContentType(ContentType.APPLICATION_JSON.toString());
  20.         response.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_401.code,CommonEnums.CODE_401.message)));
  21.     }
  22.  
  23. }

(3):

  1. package com.demo.exception;
  2.  
  3.  
  4. public class TokenException extends RuntimeException {
  5.  
  6.     private static final long serialVersionUID = 1L;
  7.  
  8.     public TokenException(String message) {
  9.         super(message);
  10.     }
  11. }

 7、factory：主要是全局上下文：

（1）：

  1. package com.demo.factory;
  2.  
  3.  
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6. import org.springframework.beans.BeansException;
  7. import org.springframework.context.ApplicationContext;
  8. import org.springframework.context.ApplicationContextAware;
  9. import org.springframework.stereotype.Component;
  10.  
  11.  
  12. @Component
  13. public class ApplicationContextRegister implements ApplicationContextAware {
  14.     private static Logger logger = LoggerFactory.getLogger(ApplicationContextRegister.class);
  15.     private static ApplicationContext APPLICATION_CONTEXT;
  16.     /**
  17.      * 设置spring上下文
  18.      * @param applicationContext spring上下文
  19.      * @throws BeansException
  20.      * */
  21.     @Override
  22.     public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
  23.         logger.debug("ApplicationContext registed-->{}", applicationContext);
  24.         DefaultBeanFactory.setSpringApplicationContext(applicationContext);
  25.         APPLICATION_CONTEXT = applicationContext;
  26.     }
  27.  
  28.     /**
  29.      * 获取容器
  30.      * @return
  31.      */
  32.     public static ApplicationContext getApplicationContext() {
  33.         return APPLICATION_CONTEXT;
  34.     }
  35.  
  36.     /**
  37.      * 获取容器对象
  38.      * @param type
  39.      * @param <T>
  40.      * @return
  41.      */
  42.     public static <T> T getBean(Class<T> type) {
  43.         return APPLICATION_CONTEXT.getBean(type);
  44.     }
  45. }

（2）：

  1. package com.demo.factory;
  2.  
  3. import org.springframework.context.ApplicationContext;
  4. import org.springframework.context.support.ClassPathXmlApplicationContext;
  5.  
  6. public class DefaultBeanFactory {
  7. 	private static ApplicationContext context = null;
  8. 	private static DefaultBeanFactory instance = null;
  9. 	private static Object lock = new Object();
  10.  
  11. 	private DefaultBeanFactory(String filepath){
  12. 		try {
  13. 			context = new ClassPathXmlApplicationContext(filepath);
  14. 		} catch (Exception e) {
  15. 		}
  16. 	}
  17. 	@SuppressWarnings("static-access")
  18. 	private DefaultBeanFactory(ApplicationContext context){
  19. 		try {
  20. 			this.context = context;
  21. 		} catch (Exception e) {
  22. 		}
  23. 	}
  24.  
  25. 	public static void setSpringApplicationContext(ApplicationContext context){
  26. 		synchronized (lock) {
  27. 			instance = new DefaultBeanFactory(context);
  28. 		}
  29. 	}
  30. 	public static DefaultBeanFactory getInstance() {
  31. 		if(instance == null || context == null){
  32. 			throw new RuntimeException("Spring context is null!");
  33. 		}
  34. 		return instance;
  35. 	}
  36.  
  37. 	public static DefaultBeanFactory getInstance(String filepath) {
  38. 		synchronized (lock) {
  39. 			instance = new DefaultBeanFactory(filepath);
  40. 		}
  41. 		return instance;
  42. 	}
  43. 	public Object getBean(String name) {
  44. 		return context.getBean(name);
  45. 	}
  46. }

（3）：

  1. package com.demo.factory;
  2.  
  3. import com.demo.util.RedisClient;
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6.  
  7.  
  8. public class ServiceFactory {
  9.  
  10.     private static Logger logger = LoggerFactory.getLogger(ServiceFactory.class);
  11.  
  12.     private static ServiceFactory instance = new ServiceFactory();
  13.  
  14.     private final String REDIS_CLIENT_BEAN="redisClient";
  15.  
  16.     private final String USER_ACTION_LOG_SERVICE = "userActionLogService";
  17.  
  18.  
  19.     public ServiceFactory() {
  20.         // TODO Auto-generated constructor stub
  21.     }
  22.  
  23.     public static ServiceFactory getInstance() {
  24.         if (instance == null) {
  25.             instance = new ServiceFactory();
  26.         }
  27.         return instance;
  28.     }
  29.  
  30.     public RedisClient createRedisClient() {
  31.         try {
  32.             return (RedisClient) DefaultBeanFactory.getInstance().getBean(REDIS_CLIENT_BEAN);
  33.         } catch (Exception e) {
  34.             throw new RuntimeException("创建 createRedisClient BEAN 异常", e);
  35.         }
  36.     }
  37.  
  38.  
  39. }

8、filter：

（1）：

  1. package com.demo.filter;
  2.  
  3.  
  4. import com.alibaba.fastjson.JSON;
  5. import com.alibaba.fastjson.JSONObject;
  6. import com.demo.constants.CommonEnums;
  7. import com.demo.constants.Constants;
  8. import com.demo.dto.JWTUserDTO;
  9. import com.demo.dto.ResponseMessage;
  10. import com.demo.dto.UserDTO;
  11. import com.demo.factory.ServiceFactory;
  12. import com.demo.service.UserService;
  13. import com.demo.util.JwtProvider;
  14. import com.demo.util.RedisClient;
  15. import org.slf4j.Logger;
  16. import org.slf4j.LoggerFactory;
  17. import org.springframework.http.HttpStatus;
  18. import org.springframework.security.authentication.AuthenticationManager;
  19. import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
  20. import org.springframework.security.core.context.SecurityContextHolder;
  21. import org.springframework.security.core.userdetails.UserDetails;
  22. import org.springframework.security.core.userdetails.UserDetailsService;
  23. import org.springframework.security.web.authentication.WebAuthenticationDetailsSource;
  24. import org.springframework.security.web.authentication.www.BasicAuthenticationFilter;
  25. import org.springframework.util.StringUtils;
  26.  
  27. import javax.servlet.FilterChain;
  28. import javax.servlet.ServletException;
  29. import javax.servlet.http.HttpServletRequest;
  30. import javax.servlet.http.HttpServletResponse;
  31. import java.io.IOException;
  32. import java.util.Objects;
  33. import org.apache.http.entity.ContentType;
  34.  
  35. /**非登录接口拦截
  36.  *
  37.  * 自定义JWT认证过滤器
  38.  * 该类继承自BasicAuthenticationFilter，在doFilterInternal方法中，
  39.  * 从http头的Authorization 项读取token数据，然后用Jwts包提供的方法校验token的合法性。
  40.  * 如果校验通过，就认为这是一个取得授权的合法请求
  41.  */
  42. public class JWTAuthenticationFilter extends BasicAuthenticationFilter{
  43.  
  44.     private static final Logger logger = LoggerFactory.getLogger(JWTAuthenticationFilter.class);
  45.  
  46.     private static  RedisClient redisClient;
  47.  
  48.     static {
  49.         redisClient = ServiceFactory.getInstance().createRedisClient();
  50.     }
  51.     private UserService userService;
  52.  
  53.  
  54.     public JWTAuthenticationFilter(AuthenticationManager authenticationManager,
  55.                                    UserService userService) {
  56.         super(authenticationManager);
  57.         this.userService = userService;
  58.     }
  59.  
  60.  
  61.     @Override
  62.     protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain chain) throws IOException, ServletException {
  63.  
  64.         String token = request.getHeader(Constants.HEADER_STRING);
  65.         String username = JwtProvider.getAuthentication(request);
  66.         if(StringUtils.isEmpty(username)){
  67.             response.sendError(HttpStatus.UNAUTHORIZED.value(), "Authentication Failed: username not found");
  68.             return;
  69.         }
  70.  
  71.         //效验token是否过期
  72.  
  73.         String tokenReids = redisClient.get(Constants.TOKEN_JWT+username);
  74.         if (StringUtils.isEmpty(tokenReids)){
  75.             logger.error("Token已过期: {} ",token);
  76.             response.setContentType(ContentType.APPLICATION_JSON.toString());
  77.             response.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_401.code,"Token已过期")));
  78.             return;
  79.         }
  80.  
  81.         if (!Objects.equals(tokenReids,token)){
  82.             logger.error("Token不匹配: {} " + tokenReids);
  83.             response.setContentType(ContentType.APPLICATION_JSON.toString());
  84.             response.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_401.code,"Token不匹配")));
  85.             return;
  86.         }
  87.  
  88.        // if(SecurityContextHolder.getContext().getAuthentication() == null) {
  89.             String userJson = redisClient.get(Constants.JWT_USER+username);
  90.             UserDetails userDetails = null;
  91.             if (!StringUtils.isEmpty(userJson)){
  92.                 JWTUserDTO jwtUser =  JSONObject.parseObject(userJson,JWTUserDTO.class);
  93.                 userDetails = jwtUser;
  94.             }else{
  95.                 UserDTO user = userService.findByUserName(username);
  96.                 userDetails = new JWTUserDTO(user.getId(),user.getUserName(),user.getPassword(),
  97.                         user.getUserNickName(),null,user.getRoles());
  98.                 redisClient.set(Constants.JWT_USER+username, JSONObject.toJSONString(userDetails));
  99.             }
  100.             UsernamePasswordAuthenticationToken authentication = new UsernamePasswordAuthenticationToken(userDetails, null, userDetails.getAuthorities());
  101.             authentication.setDetails(new WebAuthenticationDetailsSource().buildDetails(request));
  102.             SecurityContextHolder.getContext().setAuthentication(authentication);
  103.        // }
  104.         chain.doFilter(request, response);
  105.  
  106.     }
  107. }

（2）：

  1. package com.demo.filter;
  2.  
  3. import com.alibaba.fastjson.JSON;
  4. import com.alibaba.fastjson.JSONObject;
  5. import com.demo.constants.CommonEnums;
  6. import com.demo.constants.Constants;
  7. import com.demo.dto.JWTUserDTO;
  8. import com.demo.dto.ResponseMessage;
  9. import com.demo.dto.UserDTO;
  10. import com.demo.exception.CustomAuthenticationFailureHandler;
  11. import com.demo.factory.ServiceFactory;
  12. import com.demo.service.UserService;
  13. import com.demo.util.JwtProvider;
  14. import com.demo.util.RedisClient;
  15. import com.fasterxml.jackson.databind.ObjectMapper;
  16. import org.apache.commons.lang.StringUtils;
  17. import org.apache.http.entity.ContentType;
  18. import org.slf4j.Logger;
  19. import org.slf4j.LoggerFactory;
  20. import org.springframework.security.authentication.AuthenticationManager;
  21. import org.springframework.security.authentication.BadCredentialsException;
  22. import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
  23. import org.springframework.security.core.Authentication;
  24. import org.springframework.security.core.AuthenticationException;
  25. import org.springframework.security.core.userdetails.UserDetails;
  26. import org.springframework.security.core.userdetails.UserDetailsService;
  27. import org.springframework.security.core.userdetails.UsernameNotFoundException;
  28. import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
  29.  
  30. import javax.servlet.FilterChain;
  31. import javax.servlet.ServletException;
  32. import javax.servlet.http.HttpServletRequest;
  33. import javax.servlet.http.HttpServletResponse;
  34. import javax.servlet.http.HttpSession;
  35. import java.io.IOException;
  36. import java.util.ArrayList;
  37. import java.util.Objects;
  38.  
  39. /**登录接口(/login)拦截
  40.  *
  41.  * 验证用户名密码正确后，生成一个token，并将token返回给客户端
  42.  * 该类继承自UsernamePasswordAuthenticationFilter，重写了其中的2个方法
  43.  * attemptAuthentication ：接收并解析用户凭证。
  44.  * successfulAuthentication ：用户成功登录后，这个方法会被调用，我们在这个方法里生成token。
  45.  */
  46. public class JWTLoginFilter extends UsernamePasswordAuthenticationFilter{
  47.  
  48.     private static Logger logger = LoggerFactory.getLogger(JWTLoginFilter.class);
  49.     private AuthenticationManager authenticationManager;
  50.     private CustomAuthenticationFailureHandler customAuthenticationFailureHandler;
  51.     private UserService userService;
  52.     private static  RedisClient redisClient;
  53.  
  54.     static {
  55.         redisClient = ServiceFactory.getInstance().createRedisClient();
  56.     }
  57.  
  58.  
  59.  
  60.     public JWTLoginFilter(AuthenticationManager authenticationManager,
  61.                           CustomAuthenticationFailureHandler customAuthenticationFailureHandler,
  62.                           UserService userService) {
  63.         this.authenticationManager = authenticationManager;
  64.         this.customAuthenticationFailureHandler = customAuthenticationFailureHandler;
  65.         this.userService = userService;
  66.         setAuthenticationManager(authenticationManager);
  67.     }
  68.  
  69.     // 接收并解析用户凭证
  70.     @Override
  71.     public Authentication attemptAuthentication(HttpServletRequest req, HttpServletResponse res) throws AuthenticationException {
  72.         String userName = "";
  73.         HttpSession httpSession = req.getSession();
  74.  
  75.         try {
  76.             UserDTO user = new ObjectMapper().readValue(req.getInputStream(), UserDTO.class);
  77.  
  78.             //判断用户是否多次登录失败被锁定
  79.             String lock = redisClient.get(Constants.LOCK+user.getUserName());
  80.             if (StringUtils.isNotEmpty(lock)) {
  81.                 httpSession.setAttribute("code",null);
  82.                 Long time = redisClient.ttl(Constants.LOCK+user.getUserName());
  83.                 res.setContentType(ContentType.APPLICATION_JSON.toString());
  84.                 res.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_305.code, CommonEnums.CODE_305.message+":"+time+"秒后解锁")));
  85.                 return null;
  86.             }
  87.  
  88.  
  89.                 //校验验证码
  90.             if (StringUtils.isNotEmpty(user.getCode())){
  91.                 if (!Objects.equals(user.getCode(),"1111")){
  92.                     String code = (String) httpSession.getAttribute("code");
  93.                     if(StringUtils.isEmpty(code)){
  94.                         httpSession.setAttribute("code",null);
  95.                         res.setContentType(ContentType.APPLICATION_JSON.toString());
  96.                         res.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_405.code,CommonEnums.CODE_405.message)));
  97.                         return null;
  98.                     }
  99.                     if (!Objects.equals(user.getCode().toLowerCase(),code.toLowerCase())){
  100.                         httpSession.setAttribute("code",null);
  101.                         res.setContentType(ContentType.APPLICATION_JSON.toString());
  102.                         res.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_403.code,CommonEnums.CODE_403.message)));
  103.                         return null;
  104.                     }
  105.                 }
  106.             }else{
  107.                 httpSession.setAttribute("code",null);
  108.                 res.setContentType(ContentType.APPLICATION_JSON.toString());
  109.                 res.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_405.code,CommonEnums.CODE_405.message)));
  110.             }
  111.             userName = user.getUserName();
  112.             return authenticationManager.authenticate(
  113.                     new UsernamePasswordAuthenticationToken(
  114.                             user.getUserName(),
  115.                             user.getPassword(),
  116.                             new ArrayList<>())
  117.             );
  118.         }catch (IOException e) {
  119.             throw new RuntimeException(e);
  120.         }catch (UsernameNotFoundException | BadCredentialsException  e){
  121.             try {
  122.                 if (StringUtils.isNotEmpty(userName)){
  123.                     String errorNum = redisClient.get(Constants.ERROR_NUM+userName);
  124.                     if (StringUtils.isNotEmpty(errorNum)){
  125.                         if (Objects.equals(errorNum,"3")){
  126.                             httpSession.setAttribute("code",null);
  127.                             redisClient.set(Constants.LOCK+userName,"true",120);
  128.                             res.setContentType(ContentType.APPLICATION_JSON.toString());
  129.                             res.getWriter().write(JSON.toJSONString(ResponseMessage.error(CommonEnums.CODE_305.code,CommonEnums.CODE_305.message+":120秒后解锁")));
  130.                         }else{
  131.                             httpSession.setAttribute("code",null);
  132.                             redisClient.set(Constants.ERROR_NUM+userName,String.valueOf(Integer.valueOf(errorNum)+1),120);
  133.                             customAuthenticationFailureHandler.onAuthenticationFailure(req,res,e);
  134.                         }
  135.                     }else{
  136.                         httpSession.setAttribute("code",null);
  137.                         redisClient.set(Constants.ERROR_NUM+userName,"1",120);
  138.                         customAuthenticationFailureHandler.onAuthenticationFailure(req,res,e);
  139.                     }
  140.                 }else{
  141.                     httpSession.setAttribute("code",null);
  142.                     customAuthenticationFailureHandler.onAuthenticationFailure(req,res,e);
  143.                 }
  144.             } catch (Exception e1) {
  145.                 throw new RuntimeException(e);
  146.             }
  147.             return null;
  148.         }
  149.     }
  150.  
  151.    // 用户成功登录后，这个方法会被调用，我们在这个方法里生成token
  152.     @Override
  153.     protected void successfulAuthentication(HttpServletRequest request,
  154.                                             HttpServletResponse response,
  155.                                             FilterChain chain,
  156.                                             Authentication auth) throws IOException, ServletException {
  157.         HttpSession httpSession = request.getSession();
  158.         httpSession.setAttribute("code",null);
  159.         redisClient.del(Constants.LOCK+auth.getName());
  160.         redisClient.del(Constants.ERROR_NUM+auth.getName());
  161.         String token = JwtProvider.addAuthentication(response, auth.getName());
  162.         UserDTO userDTO = userService.findByUserName(auth.getName());
  163.         JWTUserDTO userDetails = new JWTUserDTO(userDTO.getId(),userDTO.getUserName(),userDTO.getPassword(),
  164.                 userDTO.getUserNickName(),null,userDTO.getRoles());;
  165.         redisClient.set(Constants.JWT_USER+auth.getName(), JSONObject.toJSONString(userDetails));
  166.         response.setContentType(ContentType.APPLICATION_JSON.toString());
  167.         response.getWriter().write(JSON.toJSONString(ResponseMessage.success(CommonEnums.CODE_300.code,CommonEnums.CODE_300.message,token)));
  168.     }
  169.  
  170. }

9、rest接口：

（1） ：

  1. package com.demo.rest;
  2.  
  3. import com.demo.dto.ResponseMessage;
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RestController;
  9.  
  10. import javax.servlet.http.HttpServletRequest;
  11. import javax.servlet.http.HttpServletResponse;
  12. import javax.servlet.http.HttpSession;
  13. import java.util.Random;
  14.  
  15. @RestController
  16. @RequestMapping("/code")
  17. public class CodeController {
  18.  
  19.     private static Logger logger = LoggerFactory.getLogger(CodeController.class);
  20.  
  21.     /**
  22.      * 获取验证码
  23.      */
  24.     @GetMapping(value = "/getCode")
  25.     public ResponseMessage images(HttpServletRequest request, HttpServletResponse response) {
  26.  
  27.         try {
  28.             HttpSession httpSession = request.getSession();
  29.             Random r = new Random();
  30.             String code = String.valueOf(r.nextInt(100));
  31.             httpSession.setAttribute("code",code);
  32.             return ResponseMessage.success("验证码",code);
  33.         } catch (Exception e) {
  34.             logger.error("ValidateCodeController images ERROR MESSAGE={}", e.getMessage(), e);
  35.         }
  36.         return ResponseMessage.error("");
  37.     }
  38. }

（2）：

  1. package com.demo.rest;
  2.  
  3. import com.demo.constants.CommonEnums;
  4. import com.demo.constants.Constants;
  5. import com.demo.dto.AuthorityDTO;
  6. import com.demo.dto.JWTUserDTO;
  7. import com.demo.dto.ResponseMessage;
  8. import com.demo.dto.UserDTO;
  9. import com.demo.service.UserService;
  10. import com.demo.util.RedisClient;
  11. import org.apache.commons.lang.StringUtils;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.security.core.context.SecurityContextHolder;
  14. import org.springframework.web.bind.annotation.GetMapping;
  15. import org.springframework.web.bind.annotation.RequestMapping;
  16. import org.springframework.web.bind.annotation.RestController;
  17.  
  18. import java.util.List;
  19.  
  20. @RequestMapping("/user")
  21. @RestController
  22. public class UserController {
  23.  
  24.     @Autowired
  25.     private UserService userService;
  26.  
  27.     @Autowired
  28.     private RedisClient redisClient;
  29.  
  30.     /**
  31.      * 获取所有用户
  32.      * @return
  33.      */
  34.     @RequestMapping("/getAllUsers")
  35.     public ResponseMessage getAllUsers(){
  36.         List<UserDTO>  users = userService.getAllUsers();
  37.         return ResponseMessage.success(users);
  38.     }
  39.  
  40.     /**
  41.      * 获取权限
  42.      */
  43.     @RequestMapping("/getMyAuthorities")
  44.     public ResponseMessage  getMyAuthorities(){
  45.         JWTUserDTO jwtUser = (JWTUserDTO) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
  46.         Integer currentUserId = jwtUser.getId();
  47.         List<AuthorityDTO> authorityDTOS= userService.getAuthortiesByUserId(currentUserId);
  48.         return ResponseMessage.success(authorityDTOS);
  49.     }
  50.  
  51.     @GetMapping(value = "/logout")
  52.     public ResponseMessage logout(HttpServletRequest request) {
  53.         try{
  54.             JWTUserDTO jwtUser = (JWTUserDTO)SecurityContextHolder.getContext().getAuthentication().getPrincipal();
  55.             String userName = jwtUser.getUsername();
  56.             if (StringUtils.isEmpty(userName)){
  57.                 throw new RuntimeException(CommonEnums.CODE_303.message);
  58.             }
  59.             redisClient.del(Constants.TOKEN_JWT+userName);
  60.             request.logout();
  61.  
  62.         }catch (Exception e){
  63.  
  64.         }
  65.         return ResponseMessage.success(CommonEnums.CODE_200.code,CommonEnums.CODE_200.message);
  66.     }
  67. }
  68.

10、sercurity:

  1. package com.demo.sercurity;
  2.  
  3.  
  4. import com.demo.exception.CustomAuthenticationFailureHandler;
  5. import com.demo.exception.Http401AuthenticationEntryPoint;
  6. import com.demo.filter.JWTAuthenticationFilter;
  7. import com.demo.filter.JWTLoginFilter;
  8. import com.demo.service.CustomAuthenticationProvider;
  9. import com.demo.service.UserService;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.context.annotation.Configuration;
  12. import org.springframework.security.config.annotation.authentication.builders.AuthenticationManagerBuilder;
  13. import org.springframework.security.config.annotation.method.configuration.EnableGlobalMethodSecurity;
  14. import org.springframework.security.config.annotation.web.builders.HttpSecurity;
  15. import org.springframework.security.config.annotation.web.builders.WebSecurity;
  16. import org.springframework.security.config.annotation.web.configuration.EnableWebSecurity;
  17. import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
  18. import org.springframework.security.config.http.SessionCreationPolicy;
  19. import org.springframework.security.core.userdetails.UserDetailsService;
  20. import org.springframework.security.web.authentication.UsernamePasswordAuthenticationFilter;
  21.  
  22. /**
  23.  * SpringSecurity的配置
  24.  * 通过SpringSecurity的配置，将JWTLoginFilter，JWTAuthenticationFilter组合在一起
  25.  */
  26. @Configuration
  27. @EnableWebSecurity
  28. @EnableGlobalMethodSecurity(securedEnabled = true, jsr250Enabled = true, prePostEnabled = true)
  29. public class WebSecurityConfig extends WebSecurityConfigurerAdapter {
  30.  
  31.     /**白名单
  32.      * 需要放行的URL
  33.      */
  34.     private static final String[] AUTH_WHITELIST = {
  35.             "/v2/api-docs",
  36.             "/swagger-resources",
  37.             "/swagger-resources/**",
  38.             "/configuration/ui",
  39.             "/configuration/security",
  40.             "/swagger-ui.html",
  41.             "/static",
  42.             "/static/diagram-viewer",
  43.             "/static/**",
  44.             "/index.html",
  45.             "/code/**",  //验证码
  46.  
  47.     };
  48.  
  49.     @Autowired
  50.     private UserService userService;
  51.  
  52.     @Autowired
  53.     private CustomAuthenticationFailureHandler customAuthenticationFailureHandler;
  54.  
  55.  
  56.     // 设置 HTTP 验证规则
  57.     @Override
  58.     protected void configure(HttpSecurity httpSecurity) throws Exception {
  59.  
  60.         httpSecurity.cors().and().csrf().disable()
  61.                 .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS).and()
  62.                 .authorizeRequests()
  63.                 .anyRequest().authenticated()  // 所有请求需要身份认证
  64.                 .and()
  65.                 .exceptionHandling()
  66.                 .authenticationEntryPoint(
  67.                         new Http401AuthenticationEntryPoint())
  68.                 .and()
  69.                 .addFilterBefore(new JWTLoginFilter(authenticationManager(),customAuthenticationFailureHandler,userService), UsernamePasswordAuthenticationFilter.class)
  70.                 .addFilterBefore(new JWTAuthenticationFilter(authenticationManager(),userService), UsernamePasswordAuthenticationFilter.class);
  71.         //因为是spring整合了spring Security，本例加了session共享，每次检查原session的时候如果不存在的话，就会创建新的session，故需要手动设置
  72.         httpSecurity.sessionManagement().sessionCreationPolicy(SessionCreationPolicy.NEVER);
  73.  
  74.     }
  75.  
  76.     // 该方法是登录的时候会进入
  77.     @Override
  78.     public void configure(AuthenticationManagerBuilder auth) throws Exception {
  79.         // 使用自定义身份验证组件
  80.         auth.authenticationProvider(new CustomAuthenticationProvider(userService));
  81.     }
  82.  
  83.     @Override
  84.     public void configure(WebSecurity web) throws Exception {
  85.         web.ignoring().antMatchers(AUTH_WHITELIST);
  86.     }
  87.  
  88. }

11、 service:

  1. package com.demo.service;
  2.  
  3.  
  4. import com.demo.dto.JWTUserDTO;
  5. import com.demo.dto.UserDTO;
  6. import com.demo.util.AESUtils;
  7. import com.demo.util.MD5Util;
  8. import org.springframework.security.authentication.AuthenticationProvider;
  9. import org.springframework.security.authentication.BadCredentialsException;
  10. import org.springframework.security.authentication.UsernamePasswordAuthenticationToken;
  11. import org.springframework.security.core.Authentication;
  12. import org.springframework.security.core.AuthenticationException;
  13. import org.springframework.security.core.userdetails.UserDetails;
  14. import org.springframework.security.core.userdetails.UsernameNotFoundException;
  15.  
  16. import java.security.NoSuchAlgorithmException;
  17. import java.util.Objects;
  18.  
  19. /**
  20.  * 自定义身份认证验证组件
  21.  */
  22. public class CustomAuthenticationProvider implements AuthenticationProvider {
  23.     private UserService userService;
  24.  
  25.     public CustomAuthenticationProvider(
  26.                                         UserService userService
  27.                                         ){
  28.         this.userService = userService;
  29.     }
  30.  
  31.     @Override
  32.     public Authentication authenticate(Authentication authentication) throws AuthenticationException {
  33.         // 获取认证的用户名 & 密码
  34.         //前端带入的username
  35.         String username = authentication.getName();
  36.         //前端带入的加密password
  37.         String passwordRsa = authentication.getCredentials().toString();
  38.         //passwordRsa解密后的密码
  39.         String password = "";
  40.         String passwordMd5 = "";
  41.         //RSA解密
  42.         try {
  43.             password = AESUtils.decryptStr(passwordRsa,AESUtils.key);
  44.         } catch (Exception e) {
  45.             throw new UsernameNotFoundException("用户不存在");
  46.         }
  47.  
  48.         UserDTO userDO = userService.findByUserName(username);
  49.         if (userDO == null) {
  50.             throw new UsernameNotFoundException("用户不存在");
  51.         }
  52.  
  53.         //判断密码
  54.         try {
  55.             //md5加密
  56.             passwordMd5 = MD5Util.MD5(password);
  57.         } catch (NoSuchAlgorithmException e) {
  58.             throw new UsernameNotFoundException("用户不存在");
  59.         }
  60.         if (!Objects.equals(passwordMd5,userDO.getPassword())){
  61.             throw new BadCredentialsException("密码错误");
  62.         }
  63.  
  64.         UserDTO userDTO = userService.findByUserName(username);
  65.         JWTUserDTO userDetails = new JWTUserDTO(userDTO.getId(),userDTO.getUserName(),userDTO.getPassword(),
  66.                 userDTO.getUserNickName(),null,userDTO.getRoles());
  67.         // 这里设置权限和角色
  68.         Authentication auth = new UsernamePasswordAuthenticationToken(userDetails, null,userDetails.getAuthorities());
  69.         return auth;
  70.     }
  71.  
  72.     /**
  73.      * 是否可以提供输入类型的认证服务
  74.      * @param authentication
  75.      * @return
  76.      */
  77.     @Override
  78.     public boolean supports(Class<?> authentication) {
  79.         return authentication.equals(UsernamePasswordAuthenticationToken.class);
  80.     }
  81.  
  82. }

12、util:

(1):

  1. package com.demo.util;
  2.  
  3.  
  4. import javax.crypto.*;
  5. import javax.crypto.spec.IvParameterSpec;
  6. import javax.crypto.spec.SecretKeySpec;
  7. import java.io.UnsupportedEncodingException;
  8. import java.nio.charset.Charset;
  9. import java.security.InvalidAlgorithmParameterException;
  10. import java.security.InvalidKeyException;
  11. import java.security.NoSuchAlgorithmException;
  12.  
  13. public class AESUtils {
  14.  
  15.     private static String iv = "HGty&6%4ojyUyhgy";//偏移量字符串必须是16位 当模式是CBC的时候必须设置偏移量
  16.     private static String Algorithm = "AES";
  17.     private static String AlgorithmProvider = "AES/CBC/PKCS5Padding"; //算法/模式/补码方式
  18.     public final static String key="FUjs@17654HGJKKn";
  19.  
  20.     public static byte[] generatorKey() throws NoSuchAlgorithmException {
  21.         KeyGenerator keyGenerator = KeyGenerator.getInstance(Algorithm);
  22.         keyGenerator.init(256);//默认128，获得无政策权限后可为192或256
  23.         SecretKey secretKey = keyGenerator.generateKey();
  24.         return secretKey.getEncoded();
  25.     }
  26.  
  27.     public static IvParameterSpec getIv() throws UnsupportedEncodingException {
  28.         IvParameterSpec ivParameterSpec = new IvParameterSpec(iv.getBytes("utf-8"));
  29.         System.out.println("偏移量："+byteToHexString(ivParameterSpec.getIV()));
  30.         return ivParameterSpec;
  31.     }
  32.  
  33.     public static byte[] encrypt(String src, byte[] key) throws NoSuchAlgorithmException, NoSuchPaddingException,
  34.             InvalidKeyException, IllegalBlockSizeException, BadPaddingException, UnsupportedEncodingException, InvalidAlgorithmParameterException {
  35.         SecretKey secretKey = new SecretKeySpec(key, Algorithm);
  36.         IvParameterSpec ivParameterSpec = getIv();
  37.         Cipher cipher = Cipher.getInstance(AlgorithmProvider);
  38.         cipher.init(Cipher.ENCRYPT_MODE, secretKey, ivParameterSpec);
  39.         byte[] cipherBytes = cipher.doFinal(src.getBytes(Charset.forName("utf-8")));
  40.         return cipherBytes;
  41.     }
  42.  
  43.     public static byte[] decrypt(String src, byte[] key) throws Exception {
  44.         SecretKey secretKey = new SecretKeySpec(key, Algorithm);
  45.  
  46.         IvParameterSpec ivParameterSpec = getIv();
  47.         Cipher cipher = Cipher.getInstance(AlgorithmProvider);
  48.         cipher.init(Cipher.DECRYPT_MODE, secretKey, ivParameterSpec);
  49.         byte[] hexBytes = hexStringToBytes(src);
  50.         byte[] plainBytes = cipher.doFinal(hexBytes);
  51.         return plainBytes;
  52.     }
  53.  
  54.     /**
  55.      * 解密
  56.      * @param src
  57.      * @param keyStr
  58.      * @return
  59.      * @throws Exception
  60.      */
  61.     public static String decryptStr(String src, String keyStr) throws Exception {
  62.  
  63.         byte key[] = keyStr.getBytes("utf-8");
  64.         SecretKey secretKey = new SecretKeySpec(key, Algorithm);
  65.  
  66.         IvParameterSpec ivParameterSpec = getIv();
  67.         Cipher cipher = Cipher.getInstance(AlgorithmProvider);
  68.         cipher.init(Cipher.DECRYPT_MODE, secretKey, ivParameterSpec);
  69.         byte[] hexBytes = hexStringToBytes(src);
  70.         byte[] plainBytes = cipher.doFinal(hexBytes);
  71.         return new String(plainBytes,"UTF-8");
  72.     }
  73.  
  74.  
  75.     public static String encrypt(String src, String keyStr) throws NoSuchAlgorithmException, NoSuchPaddingException,
  76.             InvalidKeyException, IllegalBlockSizeException, BadPaddingException, UnsupportedEncodingException, InvalidAlgorithmParameterException {
  77.  
  78.         byte key[] = keyStr.getBytes("utf-8");
  79.         SecretKey secretKey = new SecretKeySpec(key, Algorithm);
  80.         IvParameterSpec ivParameterSpec = getIv();
  81.         Cipher cipher = Cipher.getInstance(AlgorithmProvider);
  82.         cipher.init(Cipher.ENCRYPT_MODE, secretKey, ivParameterSpec);
  83.         byte[] cipherBytes = cipher.doFinal(src.getBytes(Charset.forName("utf-8")));
  84.         return new String(cipherBytes,"UTF-8");
  85.     }
  86.  
  87.     public static void main(String args[]){
  88.         try {
  89.             String passwordMd5 = MD5Util.MD5("123456");
  90.             System.out.println("加密后密码："+passwordMd5);
  91.         } catch (Exception e) {
  92.             e.printStackTrace();
  93.         }
  94.     }
  95.     /**
  96.      * 将byte转换为16进制字符串
  97.      * @param src
  98.      * @return
  99.      */
  100.     public static String byteToHexString(byte[] src) {
  101.         StringBuilder sb = new StringBuilder();
  102.         for (int i = 0; i < src.length; i++) {
  103.             int v = src[i] & 0xff;
  104.             String hv = Integer.toHexString(v);
  105.             if (hv.length() < 2) {
  106.                 sb.append("0");
  107.             }
  108.             sb.append(hv);
  109.         }
  110.         return sb.toString();
  111.     }
  112.  
  113.     /**
  114.      * 将16进制字符串装换为byte数组
  115.      * @param hexString
  116.      * @return
  117.      */
  118.     public static byte[] hexStringToBytes(String hexString) {
  119.         hexString = hexString.toUpperCase();
  120.         int length = hexString.length() / 2;
  121.         char[] hexChars = hexString.toCharArray();
  122.         byte[] b = new byte[length];
  123.         for (int i = 0; i < length; i++) {
  124.             int pos = i * 2;
  125.             b[i] = (byte) (charToByte(hexChars[pos]) << 4 | (charToByte(hexChars[pos + 1]))& 0xff);
  126.         }
  127.         return b;
  128.     }
  129.  
  130.     private static byte charToByte(char c) {
  131.         return (byte) "0123456789ABCDEF".indexOf(c);
  132.     }
  133.  
  134.  
  135.      /*public static void main(String[] args) {
  136.         try {
  137.             // byte key[] = generatorKey();
  138.             System.out.println("FUjs@17654HGJKKn".length());
  139.             // 密钥必须是16的倍数
  140.             byte key[] = "FUjs@17654HGJKKn".getBytes("utf-8");//hexStringToBytes("0123456789ABCDEF");
  141.             String src = "usersrs=111111?sdfjsalkj=1mlkjklasjdfkls?sss=sdfsjlk1123123123?sdd=453456465432165765432221351567897654132";
  142.             System.out.println("密钥:"+byteToHexString(key));
  143.             System.out.println("原字符串:"+src);
  144.  
  145.             String enc = byteToHexString(encrypt(src, key));
  146.             System.out.println("加密："+enc);
  147.             System.out.println("解密："+decryptStr(enc, AESUtils.key));
  148.         } catch (InvalidKeyException e) {
  149.             e.printStackTrace();
  150.         } catch (NoSuchAlgorithmException e) {
  151.             e.printStackTrace();
  152.         } catch (NoSuchPaddingException e) {
  153.             e.printStackTrace();
  154.         } catch (IllegalBlockSizeException e) {
  155.             e.printStackTrace();
  156.         } catch (BadPaddingException e) {
  157.             e.printStackTrace();
  158.         } catch (UnsupportedEncodingException e) {
  159.             e.printStackTrace();
  160.         } catch (Exception e) {
  161.             e.printStackTrace();
  162.         }
  163.     }*/
  164.  
  165.  
  166. }

(2):

  1. package com.demo.util;
  2.  
  3. import org.apache.commons.codec.digest.DigestUtils;
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6.  
  7. import java.io.UnsupportedEncodingException;
  8. import java.security.MessageDigest;
  9. import java.security.NoSuchAlgorithmException;
  10. import java.util.*;
  11.  
  12. /**
  13.  * Md5算法加密
  14.  *
  15.  * @author <a href="mailTo:helen@ibw.cn">Helen</a>
  16.  * @time Mar 19, 2013
  17.  * @version 1.0
  18.  */
  19. public class MD5Util {
  20.  
  21.     private final static Logger logger = LoggerFactory.getLogger(MD5Util.class);
  22.  
  23.     private final static String APP_KEY="hYHN#1son@16faEV2";
  24.     private final static String CHARSET="UTF-8";
  25.     /**
  26.      * MD5加密算法
  27.      *
  28.      * @param s
  29.      * @return
  30.      */
  31.     public final static String MD5(String s) throws NoSuchAlgorithmException {
  32.         char hexDigits[] = { '0', '1', '2', '3', '4', '5', '6', '7', '8', '9',
  33.                 'A', 'B', 'C', 'D', 'E', 'F' };
  34.         byte[] btInput = s.getBytes();
  35.         // 获得MD5摘要算法的 MessageDigest 对象
  36.         MessageDigest mdInst;
  37.         mdInst = MessageDigest.getInstance("MD5");
  38.         // 使用指定的字节更新摘要
  39.         mdInst.update(btInput);
  40.         // 获得密文
  41.         byte[] md = mdInst.digest();
  42.         // 把密文转换成十六进制的字符串形式
  43.         int j = md.length;
  44.         char str[] = new char[j * 2];
  45.         int k = 0;
  46.         for (int i = 0; i < j; i++) {
  47.             byte byte0 = md[i];
  48.             str[k++] = hexDigits[byte0 >>> 4 & 0xf];
  49.             str[k++] = hexDigits[byte0 & 0xf];
  50.         }
  51.         return new String(str);
  52.     }
  53.  
  54.  
  55.     /**
  56.      * 编码转换
  57.      * @param content
  58.      * @param charset
  59.      * @return
  60.      * @throws UnsupportedEncodingException
  61.      */
  62.     private static byte[] getContentBytes(String content, String charset) {
  63.         if (charset == null || "".equals(charset)) {
  64.             return content.getBytes();
  65.         }
  66.         try {
  67.             return content.getBytes(charset);
  68.         } catch (UnsupportedEncodingException e) {
  69.             throw new RuntimeException("MD5签名过程中出现错误,指定的编码集不对,您目前指定的编码集是:" + charset);
  70.         }
  71.     }
  72.  
  73.     public static String sign(String prestr){
  74.         String mysign = DigestUtils.md5Hex(getContentBytes(prestr + APP_KEY, CHARSET));
  75.         return mysign;
  76.     }
  77.  
  78.     public static String signParams(Map<String,String> params){
  79.         try {
  80.             if (params != null && params.size()>0){
  81.                 List<Map.Entry<String, String>> list = new ArrayList(params.entrySet());
  82.                 Collections.sort(list, new Comparator<Map.Entry<String,String>>() {
  83.                     @Override
  84.                     public int compare(Map.Entry<String, String> o1, Map.Entry<String, String> o2) {
  85.                         return o1.getKey().compareTo(o2.getKey());
  86.                     }
  87.                 });
  88.                 StringBuffer sb = new StringBuffer();
  89.                 for (Map.Entry<String, String> ent:list) {
  90.                     sb.append(ent.getKey());
  91.                     sb.append(ent.getValue());
  92.                 }
  93.                 logger.info("原字符串：{}",sb.toString());
  94.                 return sign(sb.toString());
  95.             }
  96.         }catch (Exception e){
  97.  
  98.         }
  99.         return "";
  100.     }
  101.  
  102.     public static boolean isSign(HashMap<String,String> params,String sign){
  103.         try{
  104.             String newSign = signParams(params);
  105.             logger.info("原签名：{}",sign);
  106.             logger.info("新签名：{}",newSign);
  107.             if (Objects.equals(sign,newSign)){
  108.                 return true;
  109.             }
  110.         }catch (Exception e){
  111.  
  112.         }
  113.         return false;
  114.     }
  115.  
  116.  
  117.  
  118. }

(3):

  1. package com.demo.util;
  2.  
  3. import com.demo.constants.Constants;
  4. import com.demo.exception.TokenException;
  5. import com.demo.factory.ServiceFactory;
  6. import io.jsonwebtoken.*;
  7. import org.apache.commons.lang.StringUtils;
  8. import org.slf4j.Logger;
  9. import org.slf4j.LoggerFactory;
  10.  
  11. import javax.servlet.http.HttpServletRequest;
  12. import javax.servlet.http.HttpServletResponse;
  13. import java.util.Date;
  14.  
  15. /**
  16.  * token管理器
  17.  */
  18. public class JwtProvider {
  19.  
  20.     private static final Logger logger = LoggerFactory.getLogger(JwtProvider.class);
  21.     private static  RedisClient redisClient;
  22.  
  23.     static {
  24.         redisClient = ServiceFactory.getInstance().createRedisClient();
  25.     }
  26.  
  27.     /**
  28.      * 生成token并将token写入redis
  29.      * @param res
  30.      * @param username
  31.      * @return
  32.      */
  33.     public static String addAuthentication(HttpServletResponse res, String username){
  34.         String jwtStr = Jwts.builder()
  35.                 .setSubject(username)
  36.                 .setExpiration(new Date(System.currentTimeMillis() + Constants.EXPIRATIONTIME))
  37.                 .signWith(SignatureAlgorithm.HS512, Constants.SECRET)
  38.                 .compact();
  39.         String tokent = jwtStr;
  40.         res.addHeader(Constants.HEADER_STRING,tokent );
  41.         //每次重置token，实现单一点登录
  42.         redisClient.set(Constants.TOKEN_JWT+username,tokent);
  43.         return tokent;
  44.     }
  45.  
  46.     /**
  47.      * 从token中获取username
  48.      * @param req
  49.      * @return
  50.      */
  51.     public static String getAuthentication(HttpServletRequest req){
  52.         String token = req.getHeader(Constants.HEADER_STRING);
  53.         String username = null;
  54.         if(!StringUtils.isEmpty(token)){
  55.             try{
  56.                 // parse the jwt
  57.                 username = Jwts.parser()
  58.                         .setSigningKey(Constants.SECRET)
  59.                         .parseClaimsJws(token)
  60.                         .getBody()
  61.                         .getSubject();
  62.             }catch (ExpiredJwtException e) {
  63.                 logger.error("Token已过期: {} " + e);
  64.                 throw new TokenException("Token已过期");
  65.             } catch (UnsupportedJwtException e) {
  66.                 logger.error("Token格式错误: {} " + e);
  67.                 throw new TokenException("Token格式错误");
  68.             } catch (MalformedJwtException e) {
  69.                 logger.error("Token没有被正确构造: {} " + e);
  70.                 throw new TokenException("Token没有被正确构造");
  71.             } catch (SignatureException e) {
  72.                 logger.error("签名失败: {} " + e);
  73.                 throw new TokenException("签名失败");
  74.             } catch (IllegalArgumentException e) {
  75.                 logger.error("非法参数异常: {} " + e);
  76.                 throw new TokenException("非法参数异常");
  77.             }
  78.         }
  79.         return username;
  80.     }
  81. }

(4):

  1. package com.demo.util;
  2.  
  3. import com.fasterxml.jackson.databind.ObjectMapper;
  4. import org.slf4j.Logger;
  5. import org.slf4j.LoggerFactory;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.stereotype.Component;
  8. import redis.clients.jedis.Jedis;
  9. import redis.clients.jedis.JedisPool;
  10. import redis.clients.jedis.JedisPoolConfig;
  11.  
  12. import java.io.ByteArrayInputStream;
  13. import java.io.ByteArrayOutputStream;
  14. import java.io.ObjectInputStream;
  15. import java.io.ObjectOutputStream;
  16. import java.lang.reflect.Field;
  17. import java.util.*;
  18.  
  19. @Component
  20. public class RedisClient {
  21.  
  22.     private  final Logger logger = LoggerFactory.getLogger(RedisClient.class);
  23.  
  24.     private  final String SUCCESS_OK = "OK";
  25.     private  final Long SUCCESS_STATUS_LONG = 1L;
  26.  
  27.     // SET IF NOT EXIST，即当key不存在时，我们进行set操作；若key已经存在，则不做任何操作
  28.     private  final String SET_IF_NOT_EXIST = "NX";
  29.     // 给key加一个过期的设置，具体时间由第五个参数决定
  30.     private  final String SET_WITH_EXPIRE_TIME = "PX";
  31.  
  32.     private static JedisPool jedisPool;
  33.  
  34.     private static final String IP = "127.0.0.1"; // ip
  35.     private static final int PORT = 6379; // 端口
  36.     // private static final String AUTH=""; // 密码(原始默认是没有密码)
  37.     private static int MAX_ACTIVE = 1024; // 最大连接数
  38.     private static int MAX_IDLE = 200; // 设置最大空闲数
  39.     private static int MAX_WAIT = 10000; // 最大连接时间
  40.     private static int TIMEOUT = 10000; // 超时时间
  41.     private static boolean BORROW = true; // 在borrow一个事例时是否提前进行validate操作
  42.  
  43.      /**
  44.      * 初始化线程池
  45.      */
  46.     static {
  47.         JedisPoolConfig config = new JedisPoolConfig();
  48.         config.setMaxTotal(MAX_ACTIVE);
  49.         config.setMaxIdle(MAX_IDLE);
  50.         config.setMaxWaitMillis(MAX_WAIT);
  51.         config.setTestOnBorrow(BORROW);
  52.          jedisPool = new JedisPool(config, IP, PORT, TIMEOUT);
  53.     }
  54.  
  55.     public JedisPool getJedisPool(){
  56.         return jedisPool;
  57.     }
  58.  
  59.     /**
  60.      * 字符串set
  61.      *
  62.      * @param key
  63.      * @param value
  64.      * @return
  65.      */
  66.     public  boolean set(String key, String value) {
  67.         boolean ret = false;
  68.         Jedis jedis = null;
  69.         try {
  70.             jedis = jedisPool.getResource();
  71.             if (jedis == null) {
  72.                 return ret;
  73.             }
  74.             String status = jedis.set(key, value);
  75.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  76.                 ret = true;
  77.             }
  78.         } catch (Exception e) {
  79.             logger.error("redis set 出错", e);
  80.             jedisPool.returnBrokenResource(jedis);
  81.         } finally {
  82.             if (null != jedis) {
  83.                 jedisPool.returnResource(jedis);
  84.             }
  85.         }
  86.  
  87.         return ret;
  88.     }
  89.  
  90.  
  91.  
  92.     /**
  93.      * 字符串set
  94.      *
  95.      * @param key
  96.      * @param value
  97.      * @param seconds
  98.      *            单位秒，大于0
  99.      * @return
  100.      */
  101.     public  boolean set(String key, String value, int seconds) {
  102.         boolean ret = false;
  103.         Jedis jedis = null;
  104.         try {
  105.             jedis = jedisPool.getResource();
  106.             if (jedis == null) {
  107.                 return ret;
  108.             }
  109.             String status = jedis.setex(key, seconds, value);
  110.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  111.                 ret = true;
  112.             }
  113.         } catch (Exception e) {
  114.             logger.error("redis set 出错", e);
  115.             jedisPool.returnBrokenResource(jedis);
  116.         } finally {
  117.             if (null != jedis) {
  118.                 jedisPool.returnResource(jedis);
  119.             }
  120.         }
  121.         return ret;
  122.     }
  123.  
  124.     public  boolean set(byte[] key, int seconds, byte[] value) {
  125.         boolean ret = false;
  126.         Jedis jedis = null;
  127.         try {
  128.             jedis = jedisPool.getResource();
  129.             if (jedis == null) {
  130.                 return ret;
  131.             }
  132.             String status = jedis.setex(key, seconds, value);
  133.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  134.                 ret = true;
  135.             }
  136.         } catch (Exception e) {
  137.             logger.error("redis set 出错", e);
  138.             jedisPool.returnBrokenResource(jedis);
  139.         } finally {
  140.             if (null != jedis) {
  141.                 jedisPool.returnResource(jedis);
  142.             }
  143.         }
  144.         return ret;
  145.     }
  146.  
  147.     /**
  148.      * 是否存在key
  149.      *
  150.      * @param key
  151.      * @return
  152.      */
  153.     public  boolean isExists(String key) {
  154.         boolean ret = false;
  155.         Jedis jedis = null;
  156.         try {
  157.             jedis = jedisPool.getResource();
  158.             if (jedis == null) {
  159.                 return ret;
  160.             }
  161.             return jedis.exists(key);
  162.         } catch (Exception e) {
  163.             logger.error("redis isExists 出错", e);
  164.             jedisPool.returnBrokenResource(jedis);
  165.         } finally {
  166.             if (null != jedis) {
  167.                 jedisPool.returnResource(jedis);
  168.             }
  169.         }
  170.         return ret;
  171.     }
  172.  
  173.     /**
  174.      * 字符串 删除
  175.      *
  176.      * @param key
  177.      * @return
  178.      */
  179.     public  boolean del(byte[] key) {
  180.         boolean ret = false;
  181.         Jedis jedis = null;
  182.         try {
  183.             jedis = jedisPool.getResource();
  184.             if (jedis == null) {
  185.                 return ret;
  186.             }
  187.             Long status = jedis.del(key);
  188.             if (Objects.equals(SUCCESS_STATUS_LONG,status)) {
  189.                 ret = true;
  190.             }
  191.         } catch (Exception e) {
  192.             logger.error("redis del 出错", e);
  193.             jedisPool.returnBrokenResource(jedis);
  194.         } finally {
  195.             if (null != jedis) {
  196.                 jedisPool.returnResource(jedis);
  197.             }
  198.         }
  199.         return ret;
  200.     }
  201.  
  202.     public  boolean del(String key) {
  203.         boolean ret = false;
  204.         Jedis jedis = null;
  205.         try {
  206.             jedis = jedisPool.getResource();
  207.             if (jedis == null) {
  208.                 return ret;
  209.             }
  210.             Long status = jedis.del(key);
  211.             if (Objects.equals(SUCCESS_STATUS_LONG,status)) {
  212.                 ret = true;
  213.             }
  214.         } catch (Exception e) {
  215.             logger.error("redis del 出错", e);
  216.             jedisPool.returnBrokenResource(jedis);
  217.         } finally {
  218.             if (null != jedis) {
  219.                 jedisPool.returnResource(jedis);
  220.             }
  221.         }
  222.         return ret;
  223.     }
  224.  
  225.     /**
  226.      * 字符串获取
  227.      *
  228.      * @param key
  229.      * @return
  230.      */
  231.     public  String get(String key) {
  232.         String ret = null;
  233.         Jedis jedis = null;
  234.         try {
  235.             jedis = jedisPool.getResource();
  236.             if (jedis == null) {
  237.                 return ret;
  238.             }
  239.             ret = jedis.get(key);
  240.         } catch (Exception e) {
  241.             logger.error("redis get 出错", e);
  242.             jedisPool.returnBrokenResource(jedis);
  243.         } finally {
  244.             if (null != jedis) {
  245.                 jedisPool.returnResource(jedis);
  246.             }
  247.         }
  248.  
  249.         return ret;
  250.     }
  251.  
  252.     public Long ttl(String key){
  253.         Long ret = null;
  254.         Jedis jedis = null;
  255.         try {
  256.             jedis = jedisPool.getResource();
  257.             if (jedis == null) {
  258.                 return ret;
  259.             }
  260.             ret = jedis.ttl(key);
  261.         } catch (Exception e) {
  262.             logger.error("redis get 出错", e);
  263.             jedisPool.returnBrokenResource(jedis);
  264.         } finally {
  265.             if (null != jedis) {
  266.                 jedisPool.returnResource(jedis);
  267.             }
  268.         }
  269.         return ret;
  270.     }
  271.  
  272.     public  byte[] get(byte[] key) {
  273.         byte[] ret = null;
  274.         Jedis jedis = null;
  275.         try {
  276.             jedis = jedisPool.getResource();
  277.             if (jedis == null) {
  278.                 return ret;
  279.             }
  280.             ret = jedis.get(key);
  281.         } catch (Exception e) {
  282.             logger.error("redis get 出错", e);
  283.             jedisPool.returnBrokenResource(jedis);
  284.         } finally {
  285.             if (null != jedis) {
  286.                 jedisPool.returnResource(jedis);
  287.             }
  288.         }
  289.  
  290.         return ret;
  291.     }
  292.  
  293.     /**
  294.      * 获取分布式锁
  295.      *
  296.      * @param lockKey
  297.      *            key为锁
  298.      * @param requestId
  299.      *            加锁请求
  300.      * @param expireTime
  301.      *            key的过期时间
  302.      * @return
  303.      */
  304.     public  boolean getLock(String lockKey, String requestId, int expireTime) {
  305.         boolean ret = false;
  306.         Jedis jedis = null;
  307.         try {
  308.             jedis = jedisPool.getResource();
  309.             if (jedis == null) {
  310.                 return ret;
  311.             }
  312.             String status = jedis.set(lockKey, requestId, SET_IF_NOT_EXIST, SET_WITH_EXPIRE_TIME, expireTime);
  313.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  314.                 ret = true;
  315.             }
  316.         } catch (Exception e) {
  317.             logger.error("redis 获取分布式锁 出错", e);
  318.             jedisPool.returnBrokenResource(jedis);
  319.         } finally {
  320.             if (null != jedis) {
  321.                 jedisPool.returnResource(jedis);
  322.             }
  323.         }
  324.         return ret;
  325.     }
  326.  
  327.     /**
  328.      * 释放分布式锁
  329.      *
  330.      * @param lockKey
  331.      * @param requestId
  332.      */
  333.     public  boolean releaseLock(String lockKey, String requestId) {
  334.         boolean ret = false;
  335.         Jedis jedis = null;
  336.         try {
  337.             jedis = jedisPool.getResource();
  338.             if (jedis == null) {
  339.                 return ret;
  340.             }
  341. 			/*
  342. 			 * 其他请求误解锁问题 if(requestId.equals(jedis.get(lockKey))) { jedis.del(lockKey); }
  343. 			 */
  344.  
  345.             String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
  346.             Object status = jedis.eval(script, Collections.singletonList(lockKey),
  347.                     Collections.singletonList(requestId));
  348.             if (SUCCESS_STATUS_LONG.equals(status)) {
  349.                 ret = true;
  350.             }
  351.         } catch (Exception e) {
  352.             logger.error("redis 释放分布式锁 出错", e);
  353.             jedisPool.returnBrokenResource(jedis);
  354.         } finally {
  355.             if (null != jedis) {
  356.                 jedisPool.returnResource(jedis);
  357.             }
  358.         }
  359.         return ret;
  360.     }
  361.  
  362.     /**
  363.      * 序列化存入对象
  364.      *
  365.      * @param key
  366.      * @param obj
  367.      * @return
  368.      */
  369.     public  boolean set(byte[] key, Object obj) {
  370.         boolean ret = false;
  371.         Jedis jedis = null;
  372.         try {
  373.             jedis = jedisPool.getResource();
  374.             if (jedis == null) {
  375.                 return ret;
  376.             }
  377.             ByteArrayOutputStream baos = new ByteArrayOutputStream();
  378.             ObjectOutputStream oos = new ObjectOutputStream(baos);
  379.             oos.writeObject(obj);
  380.             String status = jedis.set(key, baos.toByteArray());
  381.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  382.                 ret = true;
  383.             }
  384.         } catch (Exception e) {
  385.             logger.error("redis set 出错", e);
  386.             jedisPool.returnBrokenResource(jedis);
  387.         } finally {
  388.             if (null != jedis) {
  389.                 jedisPool.returnResource(jedis);
  390.             }
  391.         }
  392.  
  393.         return ret;
  394.  
  395.     }
  396.  
  397.     /**
  398.      * 取序列化对象
  399.      *
  400.      * @param key
  401.      * @return
  402.      */
  403.     public  Object getObj(byte[] key) {
  404.         Object ret = null;
  405.         Jedis jedis = null;
  406.         try {
  407.             jedis = jedisPool.getResource();
  408.             if (jedis == null) {
  409.                 return ret;
  410.             }
  411.  
  412.             byte[] rets = jedis.get(key);
  413.             ByteArrayInputStream bais = new ByteArrayInputStream(rets);
  414.             ObjectInputStream ois = new ObjectInputStream(bais);
  415.             return ois.readObject();
  416.         } catch (Exception e) {
  417.             logger.error("redis get 出错", e);
  418.             jedisPool.returnBrokenResource(jedis);
  419.         } finally {
  420.             if (null != jedis) {
  421.                 jedisPool.returnResource(jedis);
  422.             }
  423.         }
  424.  
  425.         return ret;
  426.     }
  427.  
  428.     /**
  429.      * hash数据类型存储对象
  430.      *
  431.      * @param key
  432.      * @param obj
  433.      * @return
  434.      */
  435.     public  boolean setHm(String key, Object obj) {
  436.         boolean ret = false;
  437.         Jedis jedis = null;
  438.         try {
  439.             jedis = jedisPool.getResource();
  440.             if (jedis == null) {
  441.                 return ret;
  442.             }
  443.             Map<String, String> hash = objToMap(obj);
  444.             String status = jedis.hmset(key, hash);
  445.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  446.                 ret = true;
  447.             }
  448.         } catch (Exception e) {
  449.             logger.error("redis setHm 出错", e);
  450.             jedisPool.returnBrokenResource(jedis);
  451.         } finally {
  452.             if (null != jedis) {
  453.                 jedisPool.returnResource(jedis);
  454.             }
  455.         }
  456.  
  457.         return ret;
  458.     }
  459.  
  460.     /**
  461.      * 修改对象属性
  462.      *
  463.      * @param key
  464.      * @param field
  465.      * @param value
  466.      * @return
  467.      */
  468.     public  boolean setHm(String key, String field, String value) {
  469.         boolean ret = false;
  470.         Jedis jedis = null;
  471.         try {
  472.             jedis = jedisPool.getResource();
  473.             if (jedis == null) {
  474.                 return ret;
  475.             }
  476.  
  477.             Long status = jedis.hset(key, field, value);
  478.             if (0L == status) {
  479.                 ret = true;
  480.             }
  481.         } catch (Exception e) {
  482.             logger.error("redis setHm 出错", e);
  483.             jedisPool.returnBrokenResource(jedis);
  484.         } finally {
  485.             if (null != jedis) {
  486.                 jedisPool.returnResource(jedis);
  487.             }
  488.         }
  489.  
  490.         return ret;
  491.     }
  492.  
  493.     /**
  494.      * 根据fields 查询key对象属性列表
  495.      *
  496.      * @param key
  497.      * @param fields
  498.      * @return
  499.      */
  500.     public List<String> getHm(String key, String... fields) {
  501.         List<String> ret = null;
  502.         Jedis jedis = null;
  503.         try {
  504.             jedis = jedisPool.getResource();
  505.             if (jedis == null) {
  506.                 return null;
  507.             }
  508.             ret = jedis.hmget(key, fields);
  509.         } catch (Exception e) {
  510.             logger.error("redis getHm 出错", e);
  511.             jedisPool.returnBrokenResource(jedis);
  512.         } finally {
  513.             if (null != jedis) {
  514.                 jedisPool.returnResource(jedis);
  515.             }
  516.         }
  517.  
  518.         return ret;
  519.     }
  520.  
  521.     /**
  522.      * 根据field 查询key对象属性
  523.      *
  524.      * @param key
  525.      * @param
  526.      * @return
  527.      */
  528.     public  String getHm(String key, String field) {
  529.         String ret = null;
  530.         Jedis jedis = null;
  531.         try {
  532.             jedis = jedisPool.getResource();
  533.             if (jedis == null) {
  534.                 return null;
  535.             }
  536.  
  537.             ret = jedis.hget(key, field);
  538.  
  539.         } catch (Exception e) {
  540.             logger.error("redis getHm 出错", e);
  541.             jedisPool.returnBrokenResource(jedis);
  542.         } finally {
  543.             if (null != jedis) {
  544.                 jedisPool.returnResource(jedis);
  545.             }
  546.         }
  547.  
  548.         return ret;
  549.     }
  550.  
  551.  
  552.  
  553.     /**
  554.      * json格式存对象
  555.      * @param key
  556.      * @param obj
  557.      * @return
  558.      */
  559.     public  boolean setJson(String key,Object obj) {
  560.         boolean ret = false;
  561.         Jedis jedis = null;
  562.         try {
  563.             jedis = jedisPool.getResource();
  564.             if (jedis == null) {
  565.                 return ret;
  566.             }
  567.             ObjectMapper mapper = new ObjectMapper();
  568.             String status = jedis.set(key, mapper.writeValueAsString(obj));
  569.             if (SUCCESS_OK.equalsIgnoreCase(status)) {
  570.                 ret = true;
  571.             }
  572.         } catch (Exception e) {
  573.             logger.error("redis setJson 出错", e);
  574.             jedisPool.returnBrokenResource(jedis);
  575.         } finally {
  576.             if (null != jedis) {
  577.                 jedisPool.returnResource(jedis);
  578.             }
  579.         }
  580.  
  581.         return ret;
  582.     }
  583.  
  584.     /**
  585.      * json格式取对象
  586.      * @param key
  587.      * @param clazz
  588.      * @return
  589.      */
  590.     public  Object getJson(String key,Class clazz) {
  591.         Object ret = null;
  592.         Jedis jedis = null;
  593.         try {
  594.             jedis = jedisPool.getResource();
  595.             if (jedis == null) {
  596.                 return ret;
  597.             }
  598.             String str = jedis.get(key);
  599.             ObjectMapper mapper = new ObjectMapper();
  600.             ret = mapper.readValue(str, clazz);
  601.         } catch (Exception e) {
  602.             logger.error("redis getJson 出错", e);
  603.             jedisPool.returnBrokenResource(jedis);
  604.         } finally {
  605.             if (null != jedis) {
  606.                 jedisPool.returnResource(jedis);
  607.             }
  608.         }
  609.  
  610.         return ret;
  611.  
  612.     }
  613.  
  614.     private HashMap<String, String> objToMap(Object obj) {
  615.  
  616.         if(null == obj) {
  617.             return null;
  618.         }
  619.         HashMap<String, String> map = new HashMap<String, String>();
  620.         Field[] fields = obj.getClass().getDeclaredFields();
  621.         try {
  622.             for (int i = 0; i < fields.length; i++) {
  623.                 String varName = fields[i].getName();
  624.                 boolean accessFlag = fields[i].isAccessible();
  625.                 fields[i].setAccessible(true);
  626.  
  627.                 Object o = fields[i].get(obj);
  628.                 if (o != null) {
  629.                     map.put(varName, o.toString());
  630.                 }
  631.  
  632.                 fields[i].setAccessible(accessFlag);
  633.             }
  634.         } catch (Exception e) {
  635.  
  636.         }
  637.  
  638.         return map;
  639.     }
  640.  
  641.     /**
  642.      * 设置一个key的过期的秒数
  643.      *
  644.      * @param keyFormat
  645.      *            key标识
  646.      * @param seconds
  647.      *            过期的秒数
  648.      * @param keyValues
  649.      *            key变量
  650.      * @return 1表示设置成功， 0 表示设置失败或者无法被设置
  651.      */
  652.     public Long expire(String key, int seconds) {
  653.         Jedis jedis = null;
  654.         try {
  655.             jedis =jedisPool.getResource();
  656.             return jedis.expire(key, seconds);
  657.         } finally {
  658.             if (jedis != null) {
  659.                 jedis.close();
  660.             }
  661.         }
  662.     }
  663. }

12、启动类：

  1. package com.demo;
  2.  
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.context.annotation.ImportResource;
  6.  
  7. @SpringBootApplication
  8. @ImportResource("classpath:consumer.xml")
  9. public class RestStart {
  10.  
  11.     public static void main(String args[]){
  12.         SpringApplication.run(RestStart.class,args);
  13.     }
  14. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/article/detail/53879
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号