From 74196bcc835d9b76cdd1bc3d85b0dfbe0191fc00 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 31 十二月 2020 19:23:43 +0800
Subject: [PATCH] 活动信息缓存

---
 service-lucky/src/main/java/com/ks/lucky/manager/RedisManager.java |  136 ++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 126 insertions(+), 10 deletions(-)

diff --git a/service-lucky/src/main/java/com/ks/lucky/manager/RedisManager.java b/service-lucky/src/main/java/com/ks/lucky/manager/RedisManager.java
index f41e20b..b4eaf70 100644
--- a/service-lucky/src/main/java/com/ks/lucky/manager/RedisManager.java
+++ b/service-lucky/src/main/java/com/ks/lucky/manager/RedisManager.java
@@ -1,28 +1,144 @@
 package com.ks.lucky.manager;
 
-import com.ks.lib.common.util.RedisUtil;
-import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.stereotype.Component;
+import org.yeshi.utils.SerializeUtil;
+import redis.clients.jedis.Jedis;
+import redis.clients.jedis.JedisPool;
+import redis.clients.jedis.params.SetParams;
 
 import javax.annotation.Resource;
+import java.util.Set;
 
 @Component
 public class RedisManager {
     @Resource
-    private RedisTemplate<String, Object> redisTemplate;
+    private JedisPool jedisPool;
 
-    private RedisUtil redisUtil = null;
+    public Jedis getJedis() {
+        Jedis jedis = jedisPool.getResource();
+        return jedis;
+    }
 
-    //娉ㄥ叆Redis鐩戝惉
-    public void setRedisUtil() {
-        if (redisUtil == null) {
-            redisUtil = new RedisUtil(redisTemplate);
+    private void setString(String key, String value, int seconds) {
+        Jedis jedis = getJedis();
+        try {
+            jedis.setex(key, seconds, value);
+        } finally {
+            jedis.close();
+        }
+    }
+
+    /**
+     * 缂撳瓨瀛楃涓�
+     *
+     * @param key
+     * @param value
+     */
+    private void setString(String key, String value) {
+        Jedis jedis = getJedis();
+        try {
+            jedis.set(key, value);
+        } finally {
+            jedis.close();
+        }
+
+    }
+
+
+    public void remove(String... keys) {
+        Jedis jedis = getJedis();
+        try {
+            jedis.del(keys);
+        } finally {
+            jedis.close();
+        }
+    }
+
+    public void removePrefix(String... keys) {
+        Jedis jedis = getJedis();
+        try {
+            for (String key : keys) {
+                Set<String> sets = jedis.keys(key + "*");
+                if (sets != null) {
+                    for (String k : sets) {
+                        jedis.del(k);
+                    }
+                }
+            }
+        } finally {
+            jedis.close();
+        }
+    }
+
+    private String getString(String key) {
+        Jedis jedis = getJedis();
+        try {
+            return jedis.get(key);
+        } finally {
+            jedis.close();
         }
     }
 
 
-    public void get() {
-        redisUtil.get("");
+    public String getCommonString(String key) {
+        return getString(key);
     }
 
+    public void cacheCommonString(String key, String value, int seconds) {
+        setString(key, value, seconds);
+    }
+
+    public void cacheCommonString(String key, String value) {
+        setString(key, value);
+    }
+
+    /**
+     * 浠巖edis缂撳瓨涓煡璇紝鍙嶅簭鍒楀寲
+     *
+     * @param redisKey
+     * @return
+     */
+    public Object getDataFromRedis(String redisKey) {
+        //鏌ヨ
+        Jedis jedis = jedisPool.getResource();
+        try {
+            byte[] result = jedis.get(redisKey.getBytes());
+
+            //濡傛灉鏌ヨ娌℃湁涓虹┖
+            if (null == result) {
+                return null;
+            }
+
+            //鏌ヨ鍒颁簡锛屽弽搴忓垪鍖�
+            return SerializeUtil.unSerialize(result);
+        } finally {
+            jedis.close();
+        }
+    }
+
+    /**
+     * 灏嗘暟鎹簱涓煡璇㈠埌鐨勬暟鎹斁鍏edis
+     *
+     * @param redisKey
+     * @param obj
+     */
+    public void setDataToRedis(String redisKey, Object obj, Integer seconds) {
+
+        //搴忓垪鍖�
+        byte[] bytes = SerializeUtil.serialize(obj);
+
+        SetParams params = null;
+        if (seconds != null) {
+            params = new SetParams().nx().ex(seconds);
+        }
+        //瀛樺叆redis
+        Jedis jedis = jedisPool.getResource();
+        try {
+            jedis.set(redisKey.getBytes(), bytes, params);
+        } finally {
+            jedis.close();
+        }
+    }
+
+
 }

--
Gitblit v1.8.0