1:什么是Token?:三部分组成:头+有效负载+签名
1.1 JWT创建中的一些方法讲解:
public static String createTokenWithClaim(User user){Map<String,Object> map = new HashMap<>();map.put("typ","JWT");map.put("alg","HS256");Algorithm algorithm = Algorithm.HMAC256(TOKEN_SECRET);
Date nowDate = new Date();Date expireDate = new Date(System.currentTimeMillis() + EXPIRE_TIME); String token = JWT.create().withHeader(map).withClaim("loginName",user.getRead_username()) .withClaim("deptName","技术部") .withClaim("loginPass",user.getRead_userpass()) .withIssuer("SERVICE") .withSubject("this is test token") .withAudience("APP") .withIssuedAt(nowDate) .withExpiresAt(expireDate).sign(algorithm); return token;}
1.2: JWT解密中的一些方法讲解:
public static void verifyToken(String token){Algorithm algorithm = Algorithm.HMAC256(TOKEN_SECRET);JWTVerifier verifier = JWT.require(algorithm)
.build();DecodedJWT jwt = verifier.verify(token);String subject = jwt.getSubject();List<String> audience = jwt.getAudience();Map<String, Claim> claims = jwt.getClaims();for (Map.Entry<String, Claim> entry : claims.entrySet()){String key = entry.getKey();Claim claim = entry.getValue();String value = claim.asString();System.out.println("key:"+key+" value:"+claim.asString());}}}
2:Springboot+JWT+Redis实现登陆登出功能
2.1:首先我们在pom引入redis:
<!-- JWT --><dependency><groupId>com.auth0</groupId><artifactId>java-jwt</artifactId><version>3.4.0</version></dependency><!-- Redis依赖 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId><!-- 1.5的版本默认采用的连接池技术是jedis 2.0以上版本默认连接池是lettuce, 在这里采用jedis,所以需要排除lettuce的jar --><exclusions><exclusion><groupId>redis.clients</groupId><artifactId>jedis</artifactId></exclusion><exclusion><groupId>io.lettuce</groupId><artifactId>lettuce-core</artifactId></exclusion></exclusions></dependency><!-- 添加jedis客户端 --><dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>2.9.0</version></dependency><!--spring2.0集成redis所需common-pool2--><!-- 必须加上,jedis依赖此 --><!-- spring boot 2.0 的操作手册有标注 大家可以去看看 地址是:https://docs.spring.io/spring-boot/docs/2.0.3.RELEASE/reference/htmlsingle/--><dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId><version>RELEASE</version></dependency>
2.2:在application.yml中配置:
redis:# Redis服务器地址host: 127.0.0.1# Redis数据库索引(默认为0)database: 0# Redis服务器连接端口port: 6379password:#连接超时时间(毫秒)timeout: 3600
2.3:基础的BaseRedisConfig配置类,序列化:
package com.example.common;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.cache.interceptor.KeyGenerator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;import java.lang.reflect.Method;
import java.time.Duration;@Configuration
@EnableCaching
public class BaseRedisConfig {@Beanpublic KeyGenerator keyGenerator() {return new KeyGenerator() {@Overridepublic Object generate(Object target, Method method, Object... params) {StringBuilder sb = new StringBuilder();sb.append(target.getClass().getName());sb.append(method.getName());for (Object obj : params) {sb.append(obj.toString());}return sb.toString();}};}@Beanpublic RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(redisConnectionFactory);Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}@Beanpublic CacheManager cacheManager(RedisConnectionFactory factory) {RedisSerializer<String> redisSerializer = new StringRedisSerializer();Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper om = new ObjectMapper();om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(om);RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig().entryTtl(Duration.ofSeconds(600)).serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer)).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer)).disableCachingNullValues();RedisCacheManager cacheManager = RedisCacheManager.builder(factory).cacheDefaults(config).build();return cacheManager;}
}
2.4:对redis中的redisTemplate封装:(接口和实现类)

package com.example.service;
import org.springframework.data.domain.Sort;
import org.springframework.data.geo.Distance;
import org.springframework.data.geo.GeoResults;
import org.springframework.data.geo.Point;
import org.springframework.data.redis.connection.RedisGeoCommands;import java.util.List;
import java.util.Map;
import java.util.Set;
public interface RedisService {void set(String key, Object value, long time);void set(String key, Object value);Object get(String key);Boolean del(String key);Long del(List<String> keys);Boolean expire(String key, long time);Long getExpire(String key);Boolean hasKey(String key);Long incr(String key, long delta);Long decr(String key, long delta);Object hGet(String key, String hashKey);Boolean hSet(String key, String hashKey, Object value, long time);void hSet(String key, String hashKey, Object value);Map<Object, Object> hGetAll(String key);Boolean hSetAll(String key, Map<String, Object> map, long time);void hSetAll(String key, Map<String, ?> map);void hDel(String key, Object... hashKey);Boolean hHasKey(String key, String hashKey);Long hIncr(String key, String hashKey, Long delta);Long hDecr(String key, String hashKey, Long delta);Set<Object> sMembers(String key);Long sAdd(String key, Object... values);Long sAdd(String key, long time, Object... values);Boolean sIsMember(String key, Object value);Long sSize(String key);Long sRemove(String key, Object... values);List<Object> lRange(String key, long start, long end);Long lSize(String key);Object lIndex(String key, long index);Long lPush(String key, Object value);Long lPush(String key, Object value, long time);Long lPushAll(String key, Object... values);Long lPushAll(String key, Long time, Object... values);Long lRemove(String key, long count, Object value);Boolean bitAdd(String key, int offset, boolean b);Boolean bitGet(String key, int offset);Long bitCount(String key);List<Long> bitField(String key, int limit, int offset);byte[] bitGetAll(String key);Long geoAdd(String key, Double x, Double y, String name);List<Point> geoGetPointList(String key, Object... place);Distance geoCalculationDistance(String key, String placeOne, String placeTow);GeoResults<RedisGeoCommands.GeoLocation<Object>> geoNearByPlace(String key, String place, Distance distance, long limit, Sort.Direction sort);List<String> geoGetHash(String key, String... place);
}
2.5:RedisServiceImpl
package com.example.service.impl;
import com.example.service.RedisService;
import org.springframework.data.domain.Sort;
import org.springframework.data.geo.Distance;
import org.springframework.data.geo.GeoResults;
import org.springframework.data.geo.Point;
import org.springframework.data.redis.connection.BitFieldSubCommands;
import org.springframework.data.redis.connection.RedisGeoCommands;
import org.springframework.data.redis.core.RedisCallback;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
@Service
public class RedisServiceImpl implements RedisService {@Resourceprivate RedisTemplate<String, Object> redisTemplate;@Overridepublic void set(String key, Object value, long time) {redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);}@Overridepublic void set(String key, Object value) {redisTemplate.opsForValue().set(key, value);}@Overridepublic Object get(String key) {return redisTemplate.opsForValue().get(key);}@Overridepublic Boolean del(String key) {return redisTemplate.delete(key);}@Overridepublic Long del(List<String> keys) {return redisTemplate.delete(keys);}@Overridepublic Boolean expire(String key, long time) {return redisTemplate.expire(key, time, TimeUnit.SECONDS);}@Overridepublic Long getExpire(String key) {return redisTemplate.getExpire(key, TimeUnit.SECONDS);}@Overridepublic Boolean hasKey(String key) {return redisTemplate.hasKey(key);}@Overridepublic Long incr(String key, long delta) {return redisTemplate.opsForValue().increment(key, delta);}@Overridepublic Long decr(String key, long delta) {return redisTemplate.opsForValue().increment(key, -delta);}@Overridepublic Object hGet(String key, String hashKey) {return redisTemplate.opsForHash().get(key, hashKey);}@Overridepublic Boolean hSet(String key, String hashKey, Object value, long time) {redisTemplate.opsForHash().put(key, hashKey, value);return expire(key, time);}@Overridepublic void hSet(String key, String hashKey, Object value) {redisTemplate.opsForHash().put(key, hashKey, value);}@Overridepublic Map<Object, Object> hGetAll(String key) {return redisTemplate.opsForHash().entries(key);}@Overridepublic Boolean hSetAll(String key, Map<String, Object> map, long time) {redisTemplate.opsForHash().putAll(key, map);return expire(key, time);}@Overridepublic void hSetAll(String key, Map<String, ?> map) {redisTemplate.opsForHash().putAll(key, map);}@Overridepublic void hDel(String key, Object... hashKey) {redisTemplate.opsForHash().delete(key, hashKey);}@Overridepublic Boolean hHasKey(String key, String hashKey) {return redisTemplate.opsForHash().hasKey(key, hashKey);}@Overridepublic Long hIncr(String key, String hashKey, Long delta) {return redisTemplate.opsForHash().increment(key, hashKey, delta);}@Overridepublic Long hDecr(String key, String hashKey, Long delta) {return redisTemplate.opsForHash().increment(key, hashKey, -delta);}@Overridepublic Set<Object> sMembers(String key) {return redisTemplate.opsForSet().members(key);}@Overridepublic Long sAdd(String key, Object... values) {return redisTemplate.opsForSet().add(key, values);}@Overridepublic Long sAdd(String key, long time, Object... values) {Long count = redisTemplate.opsForSet().add(key, values);expire(key, time);return count;}@Overridepublic Boolean sIsMember(String key, Object value) {return redisTemplate.opsForSet().isMember(key, value);}@Overridepublic Long sSize(String key) {return redisTemplate.opsForSet().size(key);}@Overridepublic Long sRemove(String key, Object... values) {return redisTemplate.opsForSet().remove(key, values);}@Overridepublic List<Object> lRange(String key, long start, long end) {return redisTemplate.opsForList().range(key, start, end);}@Overridepublic Long lSize(String key) {return redisTemplate.opsForList().size(key);}@Overridepublic Object lIndex(String key, long index) {return redisTemplate.opsForList().index(key, index);}@Overridepublic Long lPush(String key, Object value) {return redisTemplate.opsForList().rightPush(key, value);}@Overridepublic Long lPush(String key, Object value, long time) {Long index = redisTemplate.opsForList().rightPush(key, value);expire(key, time);return index;}@Overridepublic Long lPushAll(String key, Object... values) {return redisTemplate.opsForList().rightPushAll(key, values);}@Overridepublic Long lPushAll(String key, Long time, Object... values) {Long count = redisTemplate.opsForList().rightPushAll(key, values);expire(key, time);return count;}@Overridepublic Long lRemove(String key, long count, Object value) {return redisTemplate.opsForList().remove(key, count, value);}@Overridepublic Boolean bitAdd(String key, int offset, boolean b) {return redisTemplate.opsForValue().setBit(key, offset, b);}@Overridepublic Boolean bitGet(String key, int offset) {return redisTemplate.opsForValue().getBit(key, offset);}@Overridepublic Long bitCount(String key) {return redisTemplate.execute((RedisCallback<Long>) con -> con.bitCount(key.getBytes()));}@Overridepublic List<Long> bitField(String key, int limit, int offset) {return redisTemplate.execute((RedisCallback<List<Long>>) con ->con.bitField(key.getBytes(),BitFieldSubCommands.create().get(BitFieldSubCommands.BitFieldType.unsigned(limit)).valueAt(offset)));}@Overridepublic byte[] bitGetAll(String key) {return redisTemplate.execute((RedisCallback<byte[]>) con -> con.get(key.getBytes()));}@Overridepublic Long geoAdd(String key, Double x, Double y, String name) {return redisTemplate.opsForGeo().add(key, new Point(x, y), name);}@Overridepublic List<Point> geoGetPointList(String key, Object... place) {return redisTemplate.opsForGeo().position(key, place);}@Overridepublic Distance geoCalculationDistance(String key, String placeOne, String placeTow) {return redisTemplate.opsForGeo().distance(key, placeOne, placeTow, RedisGeoCommands.DistanceUnit.KILOMETERS);}@Overridepublic GeoResults<RedisGeoCommands.GeoLocation<Object>> geoNearByPlace(String key, String place, Distance distance, long limit, Sort.Direction sort) {RedisGeoCommands.GeoRadiusCommandArgs args = RedisGeoCommands.GeoRadiusCommandArgs.newGeoRadiusArgs().includeDistance().includeCoordinates();if (Sort.Direction.ASC == sort) {args.sortAscending();} else {args.sortDescending();}args.limit(limit);return redisTemplate.opsForGeo().radius(key, place, distance, args);}@Overridepublic List<String> geoGetHash(String key, String... place) {return redisTemplate.opsForGeo().hash(key, place);}}
2.6:登录接口填写:
@PostMapping("/login")public Result<User> login(@RequestBody User user) {User res = userService.login(user);if (redisService.get(user.getUsername())==null){String token = JWT.create().withAudience(res.getUsername()).sign(Algorithm.HMAC256(res.getPassword()));res.setToken(token);logService.log(user.getUsername(), StrUtil.format("用户 {} 登录系统", user.getUsername()));redisService.set(res.getUsername(),token,1800);return Result.success(res);}else {return Result.error("500","你已在其他设备登陆");}}
2.7:登出接口填写:
@DeleteMappingpublic Result<?> loginOut(HttpServletRequest request){String token = request.getHeader("token");String username = JWT.decode(token).getAudience().get(0);redisService.del(username);return Result.success("退出成功");}
2.8:拦截器:

package com.example.common;import cn.hutool.core.util.StrUtil;
import com.auth0.jwt.JWT;
import com.auth0.jwt.JWTVerifier;
import com.auth0.jwt.algorithms.Algorithm;
import com.auth0.jwt.exceptions.JWTDecodeException;
import com.auth0.jwt.exceptions.JWTVerificationException;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.example.entity.User;
import com.example.exception.CustomException;
import com.example.service.RedisService;
import com.example.service.UserService;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.HandlerInterceptor;import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
public class AuthInterceptor implements HandlerInterceptor {@Resourceprivate UserService userService;@Resourceprivate RedisService redisService;@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {String token = request.getHeader("token");if (StrUtil.isBlank(token)) {throw new CustomException("401", "未获取到token, 请重新登录");}String username;try {username = JWT.decode(token).getAudience().get(0);} catch (JWTDecodeException j) {throw new CustomException("401", "权限验证失败, 请重新登录");}if (redisService.get(username)==null){throw new CustomException("401", "token已过期");}if (redisService.get(username).equals(token)){User user = userService.getOne(Wrappers.<User>lambdaQuery().eq(User::getUsername, username));if (user == null) {throw new CustomException("401", "用户不存在, 请重新登录");}JWTVerifier jwtVerifier = JWT.require(Algorithm.HMAC256(user.getPassword())).build();try {jwtVerifier.verify(token);} catch (JWTVerificationException e) {throw new CustomException("401", "token不合法, 请重新登录");}return true;}throw new CustomException("401", "token不一致");}}