添加shiro 会话管理

HelloWorld521 · HelloWorld521 · commit bd4e27f3af8c · 2019-04-01T14:06:50.000+08:00
diff --git a/springboot-shiro/readme.md b/springboot-shiro/readme.md
@@ -0,0 +1,18 @@
+# springboot + shiro 
+## 介绍
+springboot + shiro + mybatis-plus 集成项目， 使用 mybatis-plus 生成 entity 和 dao 代码，集成 shiro 的权限控制
+
+## 需要知识
+
+* springboot
+* java多线程和网络编程
+
+## 源码
+见本项目
+
+
+## 收获
+Please feel free to contact us with any questions you may have.
+
+## 参考
+https://mrbird.cc/tags/Shiro/
diff --git a/springboot-shiro/src/main/java/com/springboot/demo/common/auth/ShiroConfig.java b/springboot-shiro/src/main/java/com/springboot/demo/common/auth/ShiroConfig.java
@@ -4,19 +4,25 @@
 import lombok.extern.slf4j.Slf4j;
 import org.apache.shiro.codec.Base64;
 import org.apache.shiro.mgt.SecurityManager;
+import org.apache.shiro.session.SessionListener;
+import org.apache.shiro.session.mgt.SessionManager;
 import org.apache.shiro.spring.LifecycleBeanPostProcessor;
 import org.apache.shiro.spring.security.interceptor.AuthorizationAttributeSourceAdvisor;
 import org.apache.shiro.spring.web.ShiroFilterFactoryBean;
 import org.apache.shiro.web.mgt.CookieRememberMeManager;
 import org.apache.shiro.web.mgt.DefaultWebSecurityManager;
 import org.apache.shiro.web.servlet.SimpleCookie;
+import org.apache.shiro.web.session.mgt.DefaultWebSessionManager;
 import org.crazycake.shiro.RedisCacheManager;
 import org.crazycake.shiro.RedisManager;
+import org.crazycake.shiro.RedisSessionDAO;
 import org.springframework.aop.framework.autoproxy.DefaultAdvisorAutoProxyCreator;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.DependsOn;
 
+import java.util.ArrayList;
+import java.util.Collection;
 import java.util.LinkedHashMap;
 
 /**
@@ -77,6 +83,8 @@ public SecurityManager securityManager() {
         securityManager.setRememberMeManager(rememberMeManager());
         // 加载 redisManager
         securityManager.setCacheManager(cacheManager());
+        // 加载 SessionManager
+        securityManager.setSessionManager(sessionManager());
         return securityManager;
     }
 
@@ -182,4 +190,21 @@ public ShiroDialect shiroDialect() {
         return new ShiroDialect();
     }
 
+    @Bean
+    public RedisSessionDAO sessionDAO() {
+        RedisSessionDAO redisSessionDAO = new RedisSessionDAO();
+        redisSessionDAO.setRedisManager(redisManager());
+        return redisSessionDAO;
+    }
+
+    @Bean
+    public SessionManager sessionManager() {
+        DefaultWebSessionManager sessionManager = new DefaultWebSessionManager();
+        Collection<SessionListener> listeners = new ArrayList<SessionListener>();
+        listeners.add(new ShiroSessionListener());
+        sessionManager.setSessionListeners(listeners);
+        sessionManager.setSessionDAO(sessionDAO());
+        return sessionManager;
+    }
+
 }
diff --git a/springboot-shiro/src/main/resources/templates/index.html b/springboot-shiro/src/main/resources/templates/index.html
@@ -14,6 +14,7 @@
         <a shiro:hasPermission="user:add" th:href="@{/user/add}">新增用户</a>
         <a shiro:hasPermission="user:delete" th:href="@{/user/delete}">删除用户</a>
     </div>
-<a th:href="@{/logout}">注销</a>
+    <a shiro:hasRole="管理员" th:href="@{/online/index}">在线用户管理</a>
+    <a th:href="@{/logout}">注销</a>
 </body>
 </html>
diff --git a/tomcatServer3.0/src/com/hjy/server/Server.java b/tomcatServer3.0/src/com/hjy/server/Server.java
@@ -37,7 +37,7 @@ public void init(){
 			e.printStackTrace();
 		}
 	}
-	public void recive(){
+	public void receive(){
 		try {
 			Socket client = server.accept();
 			ServerThread thread = new ServerThread(client);
@@ -60,7 +60,7 @@ public static void main(String[] args) {
 		//创建服务器
 		server2.init();
 		while(true){
-			server2.recive();
+			server2.receive();
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -37,7 +37,7 @@ public void init(){`
`37`	`37`	`e.printStackTrace();`
`38`	`38`	`}`
`39`	`39`	`}`
`40`		`- public void recive(){`
	`40`	`+ public void receive(){`
`41`	`41`	`try {`
`42`	`42`	`Socket client = server.accept();`
`43`	`43`	`ServerThread thread = new ServerThread(client);`
`@@ -60,7 +60,7 @@ public static void main(String[] args) {`
`60`	`60`	`//创建服务器`
`61`	`61`	`server2.init();`
`62`	`62`	`while(true){`
`63`		`- server2.recive();`
	`63`	`+ server2.receive();`
`64`	`64`	`}`
`65`	`65`	`}`
`66`	`66`