add jwt demo

README.md

@@ -20,7 +20,7 @@
  - 注册中心：consul/zookeeper
  - RPC：motan/dubbo
  - RPC治理：motan-manager
- - 安全框架：shiro
+ - 安全框架：shiro/jwt [jwt多设备token demo](./jboot-b2c/README.md)
  - 缓存框架：ehcache/redis
  - 容错隔离：hystrix
  - 调用监控：hystrix-dashboard
@@ -34,8 +34,8 @@
  - jboot-admin-parent：父模块，主要管理依赖
  - jboot-admin-base：框架相关代码
  - jboot-admin：后台管理客户端模块
- - jboot-wechat：微信公众号客户端模块
- - jboot-b2c：b2c客户端模块
+ - jboot-wechat：微信公众号客户端模块，客户端demo
+ - jboot-b2c：b2c客户端模块，客户的demo
  - jboot-admin-service：系统服务端模块，包含api、entity、provider三个子模块
  - jboot-admin-service-api：系统服务api模块，定义服务端与客户端api标准
  - jboot-admin-service-entity：系统服务实体模块，定义服务所需model、dto、服务状态类
@@ -44,11 +44,13 @@
  - jboot-b2c-service-api：B2C服务api模块，定义服务端与客户端api标准
  - jboot-b2c-service-entity：B2C服务实体模块，定义服务所需model、dto、服务状态类
  - jboot-b2c-service-provider：B2C服务实现模块，针对api的实现
+ 
 ### 重要更新
 
     1、2018-01-18： 添加微信公众号模块jboot-wechat，微信公众号demo
     2、2018-01-23： 添加B2C服务端模块jboot-b2c-service，b2c商品管理demo
     3、2018-01-25： 添加B2C客户端模块，初始化上传，作为商城秒杀demo模块
+    4、2018-02-01： B2C客户端添加 JWT 前后分离验证 demo 
  
 ### 项目使用
 

jboot-admin-base/src/main/java/io/jboot/admin/base/common/CacheKey.java

@@ -36,4 +36,7 @@ public class CacheKey {
 	
 	/** 验证码 缓存 */
 	public static final String CACHE_CAPTCHAR_SESSION = "captchar-cache";
+
+	/** jwt_token */
+	public static final String CACHE_JWT_TOKEN = "jwt_token";
 }

jboot-admin-base/src/main/java/io/jboot/admin/base/plugin/jwt/JwtToken.java

@@ -0,0 +1,41 @@
+package io.jboot.admin.base.plugin.jwt;
+
+import java.io.Serializable;
+
+/**
+ * JwtToken
+ * @author Rlax
+ *
+ */
+public class JwtToken implements Serializable {
+
+    public JwtToken() {
+
+    }
+
+    public JwtToken(String userId, String version) {
+        this.userId = userId;
+        this.version = version;
+    }
+
+    /** 用户id */
+    private String userId;
+    /** 版本号 */
+    private String version;
+
+    public String getUserId() {
+        return userId;
+    }
+
+    public void setUserId(String userId) {
+        this.userId = userId;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+}

jboot-b2c/README.md

@@ -0,0 +1,3 @@
+### JWT 多设备token支持
+
+![jwt](./doc/img/jwt.png)

jboot-b2c/src/main/java/io/jboot/b2c/controller/MainController.java

@@ -0,0 +1,67 @@
+package io.jboot.b2c.controller;
+
+import com.jfinal.aop.Before;
+import com.jfinal.kit.Ret;
+import io.jboot.Jboot;
+import io.jboot.admin.base.common.CacheKey;
+import io.jboot.admin.base.common.RestResult;
+import io.jboot.admin.base.exception.BusinessException;
+import io.jboot.admin.base.interceptor.NotNullPara;
+import io.jboot.admin.base.plugin.jwt.JwtToken;
+import io.jboot.admin.base.web.base.BaseController;
+import io.jboot.b2c.support.JwtTokenInterceptor;
+import io.jboot.web.controller.annotation.RequestMapping;
+
+
+/**
+ * 主控制器
+ * @author Rlax
+ *
+ */
+@RequestMapping("/")
+public class MainController extends BaseController {
+
+    @Before(JwtTokenInterceptor.class)
+    public void index() {
+        renderJson(RestResult.buildSuccess(Ret.create("userId", getJwtPara("userId")).set("version", getJwtPara("version"))));
+    }
+
+    /**
+     * 调转登录页面
+     */
+    public void login() {
+
+    }
+
+    /**
+     * 登录 基于 jwt
+     */
+    @NotNullPara({"loginName", "pwd"})
+    public void postLogin(String loginName, String pwd) {
+
+        // 实际项目这里应该调用service
+        if ("user1".equals(loginName) && "123123".equals(pwd)) {
+            // 此处1 为用户id，实际项目中，使用服务查询id
+            JwtToken jwtToken =  Jboot.me().getCache().get(CacheKey.CACHE_JWT_TOKEN, String.valueOf(1L));
+            if (jwtToken == null) {
+                // 新创建 jwt token，此处为 demo
+                jwtToken = new JwtToken(String.valueOf(1L), String.valueOf(System.currentTimeMillis()));
+                // token 缓存 默认 2小时
+                Jboot.me().getCache().put(CacheKey.CACHE_JWT_TOKEN, jwtToken.getUserId(), jwtToken, 2 * 60 * 60);
+            }
+
+            setJwtAttr("userId", jwtToken.getUserId());
+            setJwtAttr("version", jwtToken.getVersion());
+        } else {
+            throw new BusinessException("用户名密码错误");
+        }
+
+        renderJson(RestResult.buildSuccess("登录成功"));
+    }
+
+    @Before(JwtTokenInterceptor.class)
+    public void logout() {
+        Jboot.me().getCache().remove(CacheKey.CACHE_JWT_TOKEN, getJwtPara("userId"));
+        renderJson(RestResult.buildSuccess("退出成功"));
+    }
+}

jboot-b2c/src/main/java/io/jboot/b2c/support/JwtTokenInterceptor.java

@@ -0,0 +1,49 @@
+package io.jboot.b2c.support;
+
+import com.jfinal.aop.Interceptor;
+import com.jfinal.aop.Invocation;
+import io.jboot.Jboot;
+import io.jboot.admin.base.common.CacheKey;
+import io.jboot.admin.base.exception.BusinessException;
+import io.jboot.admin.base.plugin.jwt.JwtToken;
+import io.jboot.utils.StringUtils;
+import io.jboot.web.controller.JbootController;
+
+/**
+ * jwt 拦截器
+ * @author Rlax
+ *
+ */
+public class JwtTokenInterceptor implements Interceptor {
+
+    @Override
+    public void intercept(Invocation inv) {
+
+        if (inv.getController() instanceof JbootController) {
+            JbootController c = (JbootController) inv.getController();
+            String userId = c.getJwtPara("userId");
+            String version = c.getJwtPara("version");
+
+            if (StringUtils.isBlank(userId) || StringUtils.isBlank(version) ) {
+                throw new BusinessException("not auth");
+            }
+
+            // 此处1L 为测试，实际会从服务获取
+            if (!"1".equals(userId)) {
+                throw new BusinessException("not auth");
+            }
+
+            JwtToken jwtToken =  Jboot.me().getCache().get(CacheKey.CACHE_JWT_TOKEN, userId);
+            if (jwtToken == null) {
+                throw new BusinessException("not auth");
+            }
+
+            if (!jwtToken.getVersion().equals(version)) {
+                throw new BusinessException("not auth");
+            }
+        }
+
+        inv.invoke();
+    }
+
+}

jboot-b2c/src/main/resources/jboot.properties

@@ -100,3 +100,10 @@ jboot.mq.redis.password=123456
 jboot.mq.redis.channel=message-channel
 jboot.mq.redis.database=0
 #---------------------------------------------------------------------------------#
+
+#---------------------------------------------------------------------------------#
+jboot.web.jwt.httpHeaderName=Jwt
+jboot.web.jwt.secret=wtSB6bFrfJWLBmfhtyJbpF1L17F7XrGX
+# 60 * 60 * 24 * 7 * 1000
+jboot.web.jwt.validityPeriod=604800000
+#---------------------------------------------------------------------------------#