接入视频直播

admin

2021-09-24 f788607ff771a47bc60d6a86e00b3433c40f3d2c

 src/main/java/com/yeshi/buwan/util/RedisManager.java

@@ -9,6 +9,7 @@
import com.google.gson.Gson;
import com.yeshi.buwan.vo.video.VideoListResultVO;

import org.yeshi.utils.SerializeUtil;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.params.SetParams;
@@ -94,7 +95,7 @@
    }


    public void increase(String key,int s) {
    public void increase(String key, int s) {
        Jedis jedis = getJedis();
        try {
            jedis.incr(key);
@@ -129,6 +130,10 @@
        removeKey(key);
    }

    public void remove(String key) {
        removeKey(key);
    }

    /**
     * 保存视频数据
     *
@@ -137,7 +142,7 @@
     */
    public void saveVideoList(String key, VideoListResultVO videoData) {
        Gson gson = new Gson();
        cacheCommonString(key, gson.toJson(videoData), 60 * 60 * 24);
        cacheCommonString(key, gson.toJson(videoData), 60 * 60 * 8);
    }

    /**
@@ -208,4 +213,53 @@
            return true;
    }


    /**
     * 从redis缓存中查询，反序列化
     *
     * @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();
        }
    }

    /**
     * 将数据库中查询到的数据放入redis
     *
     * @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();
        }
    }

}