From a31dab3f22c4bc3fc9f7a2fa236c0b65f480346e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=9C=E7=9A=87?= Date: Wed, 4 Jul 2018 11:10:04 +0800 Subject: [PATCH] remove redis --- pom.xml | 6 -- .../tigon/mybatis/cache/RedisCache.java | 4 +- .../tigon/mybatis/cache/RedisCacheConfig.java | 6 +- tigon-redis/README.md | 1 - tigon-redis/pom.xml | 68 ------------------- .../chyxion/tigon/redis/pub/PubProducer.java | 19 ------ .../redis/pub/support/PubProducerSupport.java | 38 ----------- .../chyxion/tigon/redis/util/PubSubUtils.java | 20 ------ .../resources/spring/spring-summer-redis.xml | 37 ---------- .../com/flaginfo/echat/redis/TestDriver.java | 18 ----- .../flaginfo/echat/redis/test/TestPub.java | 33 --------- .../flaginfo/echat/redis/test/TestSub.java | 28 -------- .../src/test/resources/log4j.properties | 6 -- .../test/resources/spring/config.properties | 11 --- .../spring/spring-redis-sub-test.xml | 11 --- .../resources/spring/spring-redis-test.xml | 12 ---- .../shiro/UserIdKeyRedisSessionCache.java | 40 +++++------ 17 files changed, 27 insertions(+), 331 deletions(-) delete mode 100644 tigon-redis/README.md delete mode 100644 tigon-redis/pom.xml delete mode 100644 tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/PubProducer.java delete mode 100644 tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/support/PubProducerSupport.java delete mode 100644 tigon-redis/src/main/java/me/chyxion/tigon/redis/util/PubSubUtils.java delete mode 100644 tigon-redis/src/main/resources/spring/spring-summer-redis.xml delete mode 100644 tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/TestDriver.java delete mode 100644 tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestPub.java delete mode 100644 tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestSub.java delete mode 100644 tigon-redis/src/test/resources/log4j.properties delete mode 100644 tigon-redis/src/test/resources/spring/config.properties delete mode 100644 tigon-redis/src/test/resources/spring/spring-redis-sub-test.xml delete mode 100644 tigon-redis/src/test/resources/spring/spring-redis-test.xml diff --git a/pom.xml b/pom.xml index 6eb997f..857c732 100644 --- a/pom.xml +++ b/pom.xml @@ -38,7 +38,6 @@ tigon-model tigon-mybatis tigon-sequence - tigon-redis tigon-mybatis-cache-redis tigon-shiro-cache tigon-shiro-cache-redis @@ -74,11 +73,6 @@ tigon-web ${project.version} - - me.chyxion.tigon - tigon-redis - ${project.version} - me.chyxion.tigon tigon-mybatis-cache-redis diff --git a/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCache.java b/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCache.java index 18e975e..80a6290 100644 --- a/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCache.java +++ b/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCache.java @@ -18,8 +18,8 @@ import org.springframework.data.redis.core.HashOperations; @Slf4j public final class RedisCache implements Cache { private final String id; - private final RedisTemplate redisTpl; - private final HashOperations hashOp; + private final RedisTemplate redisTpl; + private final HashOperations hashOp; private final RedisCacheConfig config; /** diff --git a/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCacheConfig.java b/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCacheConfig.java index 108b413..535ee86 100644 --- a/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCacheConfig.java +++ b/tigon-mybatis-cache-redis/src/main/java/me/chyxion/tigon/mybatis/cache/RedisCacheConfig.java @@ -2,6 +2,7 @@ package me.chyxion.tigon.mybatis.cache; import javax.annotation.PostConstruct; import org.springframework.data.redis.core.RedisTemplate; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Autowired; /** @@ -13,7 +14,8 @@ import org.springframework.beans.factory.annotation.Autowired; */ public class RedisCacheConfig { @Autowired - private RedisTemplate redisTpl; + @Qualifier("redisTemplate") + private RedisTemplate redisTpl; private static RedisCacheConfig instance; @PostConstruct @@ -31,7 +33,7 @@ public class RedisCacheConfig { /** * @return the redisTpl */ - public RedisTemplate getRedisTpl() { + public RedisTemplate getRedisTpl() { return redisTpl; } } diff --git a/tigon-redis/README.md b/tigon-redis/README.md deleted file mode 100644 index 17f626b..0000000 --- a/tigon-redis/README.md +++ /dev/null @@ -1 +0,0 @@ -# tigon-redis diff --git a/tigon-redis/pom.xml b/tigon-redis/pom.xml deleted file mode 100644 index 6514fe3..0000000 --- a/tigon-redis/pom.xml +++ /dev/null @@ -1,68 +0,0 @@ - - - 4.0.0 - tigon-redis - jar - Tigon Redis - Tigon Redis - - - me.chyxion.tigon - tigon - 0.0.1-SNAPSHOT - ../ - - - - - org.apache.commons - commons-lang3 - 3.1 - - - org.springframework.data - spring-data-redis - - - redis.clients - jedis - 2.9.0 - - - - org.slf4j - jcl-over-slf4j - test - - - org.apache.logging.log4j - log4j-slf4j-impl - test - - - org.apache.logging.log4j - log4j-core - test - - - org.springframework - spring-context - ${spring.version} - test - - - org.springframework - spring-test - ${spring.version} - test - - - junit - junit - test - - - diff --git a/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/PubProducer.java b/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/PubProducer.java deleted file mode 100644 index 266f368..0000000 --- a/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/PubProducer.java +++ /dev/null @@ -1,19 +0,0 @@ -package me.chyxion.tigon.redis.pub; - -/** - * @version 0.0.1 - * @since 0.0.1 - * @author Shaun Chyxion
- * chyxion@163.com
- * Nov 7, 2015 5:32:36 PM - */ -public interface PubProducer { - String PUB_QUEUE_SUFFIX = "_QUEUE"; - String MESSAGE_CHANEL = "__PUBLICATION__"; - - /** - * @param topic topic - * @param message message - */ - void publish(String topic, Object message); -} diff --git a/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/support/PubProducerSupport.java b/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/support/PubProducerSupport.java deleted file mode 100644 index 479f30f..0000000 --- a/tigon-redis/src/main/java/me/chyxion/tigon/redis/pub/support/PubProducerSupport.java +++ /dev/null @@ -1,38 +0,0 @@ -package me.chyxion.tigon.redis.pub.support; - -import me.chyxion.tigon.redis.pub.PubProducer; -import me.chyxion.tigon.redis.util.PubSubUtils; -import org.springframework.data.redis.core.RedisTemplate; -import org.springframework.beans.factory.annotation.Autowired; - -/** - * @version 0.0.1 - * @since 0.0.1 - * @author Shaun Chyxion
- * chyxion@163.com
- * Nov 7, 2015 5:07:50 PM - */ -public class PubProducerSupport - implements PubProducer { - @Autowired - private RedisTemplate redisTpl; - @Autowired - private RedisTemplate strRedisTpl; - - /** - * {@inheritDoc} - */ - @Override - public void publish(final String topic, final Object message) { - if (message != null) { - if (message instanceof CharSequence) { - strRedisTpl.opsForList().rightPush(PubSubUtils.queueKey(topic), - String.valueOf(message)); - } - else { - redisTpl.opsForList().rightPush(PubSubUtils.queueKey(topic), message); - } - } - strRedisTpl.convertAndSend(MESSAGE_CHANEL, topic); - } -} diff --git a/tigon-redis/src/main/java/me/chyxion/tigon/redis/util/PubSubUtils.java b/tigon-redis/src/main/java/me/chyxion/tigon/redis/util/PubSubUtils.java deleted file mode 100644 index 81f3666..0000000 --- a/tigon-redis/src/main/java/me/chyxion/tigon/redis/util/PubSubUtils.java +++ /dev/null @@ -1,20 +0,0 @@ -package me.chyxion.tigon.redis.util; - -/** - * @author Shaun Chyxion
- * chyxion@163.com
- * Dec 24, 2017 10:54 AM - */ -public class PubSubUtils { - public static final String QUEUE_PREFIX = "__TIGON_REDIS_PUB__"; - public static final String MESSAGE_CHANEL = "__TIGON_REDIS_PUB__"; - - /** - * return topic queue - * @param topic topic - * @return topic queue - */ - public static String queueKey(final String topic) { - return QUEUE_PREFIX + ":" + topic; - } -} diff --git a/tigon-redis/src/main/resources/spring/spring-summer-redis.xml b/tigon-redis/src/main/resources/spring/spring-summer-redis.xml deleted file mode 100644 index b846181..0000000 --- a/tigon-redis/src/main/resources/spring/spring-summer-redis.xml +++ /dev/null @@ -1,37 +0,0 @@ - - - Tigon Redis - - - - - - - - - - - - - - - - - - - - - - - - - - diff --git a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/TestDriver.java b/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/TestDriver.java deleted file mode 100644 index c1bec82..0000000 --- a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/TestDriver.java +++ /dev/null @@ -1,18 +0,0 @@ -package cn.com.flaginfo.echat.redis; - -import org.junit.Test; - -/** - * @version 0.0.1 - * @since 0.0.1 - * @author chyxion
- * chyxion@163.com
- * Mar 14, 2015 3:03:57 PM - */ -public class TestDriver { - - @Test - public void testHash() { - // System.err.println(new AuthConfig().hashPassword("123", "456")); - } -} diff --git a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestPub.java b/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestPub.java deleted file mode 100644 index b01c89a..0000000 --- a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestPub.java +++ /dev/null @@ -1,33 +0,0 @@ -package cn.com.flaginfo.echat.redis.test; - -import java.util.Date; - -import me.chyxion.tigon.redis.pub.PubProducer; - -import org.junit.Test; -import org.junit.runner.RunWith; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -/** - * @version 0.0.1 - * @since 0.0.1 - * @author Shaun Chyxion
- * chyxion@163.com
- * Nov 9, 2015 9:08:17 AM - */ -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration({ - "classpath:spring/spring-echat-redis.xml", - "classpath:spring/spring-redis-test.xml", -}) -public class TestPub { - @Autowired - private PubProducer pp; - - @Test - public void testRun() { - pp.publish("MESSAGE", "Hello, Redis Pub!" + new Date()); - } -} diff --git a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestSub.java b/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestSub.java deleted file mode 100644 index e62036b..0000000 --- a/tigon-redis/src/test/java/cn/com/flaginfo/echat/redis/test/TestSub.java +++ /dev/null @@ -1,28 +0,0 @@ -package cn.com.flaginfo.echat.redis.test; - -import org.junit.Test; -import java.util.Scanner; -import org.junit.runner.RunWith; -import org.springframework.test.context.ContextConfiguration; -import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; - -/** - * @version 0.0.1 - * @since 0.0.1 - * @author Shaun Chyxion
- * chyxion@163.com
- * Nov 9, 2015 9:27:19 AM - */ -@RunWith(SpringJUnit4ClassRunner.class) -@ContextConfiguration({ - "classpath:spring/spring-echat-redis.xml", - "classpath:spring/spring-redis-test.xml", - "classpath:spring/spring-redis-sub-test.xml", -}) -public class TestSub { - - @Test - public void testRun() { - new Scanner(System.in).next(); - } -} diff --git a/tigon-redis/src/test/resources/log4j.properties b/tigon-redis/src/test/resources/log4j.properties deleted file mode 100644 index 9b2b66b..0000000 --- a/tigon-redis/src/test/resources/log4j.properties +++ /dev/null @@ -1,6 +0,0 @@ -log4j.rootLogger=debug, console - -log4j.appender.console=org.apache.log4j.ConsoleAppender -log4j.appender.console.layout=org.apache.log4j.PatternLayout -log4j.appender.console.Encoding=utf-8 -log4j.appender.console.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss,SSS} %-5p [%F:%L] %m%n diff --git a/tigon-redis/src/test/resources/spring/config.properties b/tigon-redis/src/test/resources/spring/config.properties deleted file mode 100644 index b34fa1e..0000000 --- a/tigon-redis/src/test/resources/spring/config.properties +++ /dev/null @@ -1,11 +0,0 @@ -# Config Dev - -# Redis -redis.host=127.0.0.1 -#redis.port=6379 -#redis.password=0211 -redis.port=6380 -redis.password=6ca2b1bf0fe311e5:Y24kfEiNJxQFc17D - -#redis.port=6382 -#redis.password=e1605352ed8511e4:F92dd46acd0fe11e4 \ No newline at end of file diff --git a/tigon-redis/src/test/resources/spring/spring-redis-sub-test.xml b/tigon-redis/src/test/resources/spring/spring-redis-sub-test.xml deleted file mode 100644 index aa91e91..0000000 --- a/tigon-redis/src/test/resources/spring/spring-redis-sub-test.xml +++ /dev/null @@ -1,11 +0,0 @@ - - - - diff --git a/tigon-redis/src/test/resources/spring/spring-redis-test.xml b/tigon-redis/src/test/resources/spring/spring-redis-test.xml deleted file mode 100644 index 502f0b0..0000000 --- a/tigon-redis/src/test/resources/spring/spring-redis-test.xml +++ /dev/null @@ -1,12 +0,0 @@ - - - - - diff --git a/tigon-shiro-cache-redis/src/main/java/me/chyxion/tigon/shiro/cache/shiro/UserIdKeyRedisSessionCache.java b/tigon-shiro-cache-redis/src/main/java/me/chyxion/tigon/shiro/cache/shiro/UserIdKeyRedisSessionCache.java index 171c51b..c0804ff 100644 --- a/tigon-shiro-cache-redis/src/main/java/me/chyxion/tigon/shiro/cache/shiro/UserIdKeyRedisSessionCache.java +++ b/tigon-shiro-cache-redis/src/main/java/me/chyxion/tigon/shiro/cache/shiro/UserIdKeyRedisSessionCache.java @@ -14,6 +14,7 @@ import org.apache.shiro.cache.CacheException; import me.chyxion.tigon.shiro.model.AuthUser; import me.chyxion.tigon.shiro.cache.SessionCache; import org.springframework.beans.factory.annotation.Value; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.beans.factory.annotation.Autowired; /** @@ -28,8 +29,9 @@ import org.springframework.beans.factory.annotation.Autowired; public class UserIdKeyRedisSessionCache implements SessionCache { @Autowired - protected RedisTemplate redisTpl; - @Value("${shiro.session.redis.prefix:AUTH_SESSION}") + @Qualifier("redisTemplate") + protected RedisTemplate redisTpl; + @Value("${tigon.shiro.session.redis.prefix:AUTH_SESSION}") protected String prefix; protected String userIdSessionPrefix; @@ -65,9 +67,9 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Session put(Serializable sessionId, Session session) { - log.info("Redis Session Cache Put [{}:{}:{}].", prefix, sessionId, session); + log.info("Redis session cache put [{}:{}:{}].", prefix, sessionId, session); valueOp().set(prefix + ":" + sessionId, - (Serializable) session, + session, session.getTimeout(), TimeUnit.MILLISECONDS); return session; @@ -78,10 +80,10 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Session remove(Serializable sessionId) { - log.info("Redis Session Cache Remove [{}].", sessionId); + log.info("Redis session cache remove [{}].", sessionId); Session session = get(sessionId); if (session != null) { - log.info("Redis Session Cache Remove [{}].", session); + log.info("Redis session cache remove [{}].", session); redisTpl.delete(prefix + ":" + sessionId); } return session; @@ -92,7 +94,7 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public void clear() throws CacheException { - log.warn("Redis Session Cache #clear Not Supported"); + log.warn("Redis session cache #clear not supported"); } /** @@ -109,7 +111,7 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Set keys() { - log.warn("Redis Session Cache #keys Not Supported"); + log.warn("Redis session cache #keys not supported"); return Collections.emptySet(); } @@ -118,7 +120,7 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Collection values() { - log.warn("Redis Session Cache #values Not Supported"); + log.warn("Redis session cache #values not supported"); return Collections.emptyList(); } @@ -127,15 +129,15 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Session findByUserId(final Serializable userId) { - log.debug("Find Session By User Id [{}].", userId); + log.debug("Find session by user id [{}].", userId); Serializable sessionId = hashOp().get(userIdSessionPrefix, userId); Session session = null; if (sessionId != null) { - log.debug("User [{}] Session Id [{}] Found.", userId, sessionId); + log.debug("User [{}] session id [{}] found.", userId, sessionId); session = get(sessionId); - log.info("User [{}] Session [{}] Found.", userId, session); + log.info("User [{}] session [{}] found.", userId, session); if (session == null) { - log.info("No User [{}] Session Found, Remove."); + log.info("No user [{}] session found, remove."); hashOp().delete(userIdSessionPrefix, userId); } } @@ -147,23 +149,23 @@ public class UserIdKeyRedisSessionCache implements SessionCache { */ @Override public Session putUserSession(Session session) { - log.info("Put User Session [{}].", session); + log.info("Put user session [{}].", session); AuthUser authUser = AuthUser.get(session); - Assert.state(authUser != null, "Auth User Not Found In Session"); + Assert.state(authUser != null, "Auth user not found in session"); final Serializable userId = authUser.getUserId(); - Assert.state(userId != null, "Session Auth User Id Could Not Be Null"); - log.info("Put User [{}] Session [{}].", userId, session); + Assert.state(userId != null, "Session auth user id could not be null"); + log.info("Put user [{}] session [{}].", userId, session); hashOp().put(userIdSessionPrefix, userId, session.getId()); return session; } // -- // private methods - protected HashOperations hashOp() { + protected HashOperations hashOp() { return redisTpl.opsForHash(); } - protected ValueOperations valueOp() { + protected ValueOperations valueOp() { return redisTpl.opsForValue(); } }