springBoot整合Redis（一、Jedis操作Redis）

在springboot环境下连接redis的方法有很多，首先最简单的就是直接通过jedis类来连接，jedis类就相当于是redis的客户端表示。

但是因为现在比较常用的是：StringRedisTemplate和RedisTemplate，所以jedis只做简单的介绍。

一、Jedis连接方式

        1) Jedis直接链接Redis服务器

        第一步：先引入Jedis的依赖：

<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>3.11.0</version>
</dependency>

        第二步  直接连接:

    public static void main(String[] args) {//连接本地的 Redis 服务Jedis jedis = new Jedis("localhost",6379);// 如果 Redis 服务设置了密码，需要用下面这行代码输入密码jedis.auth("123456");System.out.println("连接成功");//查看服务是否运行System.out.println("服务正在运行: "+jedis.ping());}

显示已经连接成功！

 2）通过连接池的方式获取 Jedis

        第一步仍然是引入依赖。

        第二步代码实现：

    public static void main(String[] args) {// 创建Jedis连接池配置对象JedisPoolConfig config = new JedisPoolConfig();// 最大连接数config.setMaxTotal(30);// 最大空闲连接数config.setMaxIdle(10);// 最小空闲连接数config.setMinIdle(5);// 最长等待毫秒数config.setMaxWaitMillis(3000);//        连接到 redis 服务器上JedisPool jedisPool = new JedisPool(new JedisPoolConfig(),"localhost", 6379, 10000, "123456");for (int i = 1; i <=31; i++) {Jedis jedis = jedisPool.getResource();System.out.println(jedis);
//            jedis.close();          // 将连接归还到连接池}jedisPool.close();          // 释放资源}

    需要先创建JedisPoolConfig 连接池配置对象来进行配置，然后再使用JedisPool 进行连接。

        3）使用工厂模式连接Redis 

        一般我们不会这个频繁的创建Redis连接，正常情况下会使用工厂模式进行创建，这样会方便很多。

        1）首先创建配置文件，将Jedis的各种配置信息，全都放到配置文件中设置        

redis:host: localhostport: 6379database: 1#连接超时时间timeout: 10password: 123456#最大连接数poolMaxTotal=: 10#最大空闲连接数poolMaxIdle: 5#最大等待连接数poolMaxWait: 3

         2）创建配置类：

@Component
@ConfigurationProperties(prefix = "redis")
@Data
public class RedisConfig {private String host;private int port;private int timeout;//秒private String password;private int poolMaxTotal;private int poolMaxIdle;private int  poolMaxWait;//秒private int database;
}
@Configuration
public class JedisPoolFactory {@AutowiredRedisConfig redisConfig;@Beanpublic JedisPool JedisPoolFactory(){System.out.println(redisConfig.toString());JedisPoolConfig poolConfig=new JedisPoolConfig();poolConfig.setMaxIdle(redisConfig.getPoolMaxIdle());poolConfig.setMaxTotal(redisConfig.getPoolMaxTotal());poolConfig.setMaxWaitMillis(redisConfig.getPoolMaxWait()*1000);JedisPool jp=new JedisPool(poolConfig,redisConfig.getHost(),redisConfig.getPort(),redisConfig.getTimeout()*1000,redisConfig.getPassword(),redisConfig.getDatabase());return jp;}
}

        3）像上面创建完配置类之后就可以直接使用Jedis了，示例如下：

@RestController
@RequestMapping("/redis")
public class RedisController {@AutowiredJedisPool jedisPool;@GetMapping("/demo")public void name(@RequestParam("name") String name){Jedis jedis = jedisPool.getResource();jedis.set("name", name);jedis.close();}
}

         这是最简单的使用示例。

 

        4） 哨兵模式连接Redis

        1.首先还是要创建配置文件跟配置类，只不过属性要稍微改一下

redis:sentinelHost: localhost1:26379,localhost2:localhost:26379masterName: mymaster
#  host: host
#  port: 6379database: 1#连接超时时间timeout: 30password: 123456#最大连接数poolMaxTotal=: 10#最大空闲连接数poolMaxIdle: 5#最大等待连接数poolMaxWait: 3

        配置类：

@Component
@ConfigurationProperties(prefix = "redis")
@Data
public class RedisConfig {private String  sentinelHost;private String masterName;
//    private int port;private int timeout;//秒private String password;private int poolMaxTotal;private int poolMaxIdle;private int  poolMaxWait;//秒private int database;}

        2.创建连接池：

@Configuration
public class JedisPoolFactory {@AutowiredRedisConfig redisConfig;@Beanpublic JedisSentinelPool JedisPoolFactory(){System.out.println(redisConfig.toString());JedisPoolConfig poolConfig=new JedisPoolConfig();poolConfig.setMaxIdle(redisConfig.getPoolMaxIdle());poolConfig.setMaxTotal(redisConfig.getPoolMaxTotal());poolConfig.setMaxWaitMillis(redisConfig.getPoolMaxWait()*1000);// 哨兵信息，注意填写哨兵的地址String[] host = redisConfig.getSentinelHost().split(",");Set<String> sentinels = new HashSet<>(Arrays.asList(host));// 创建连接池JedisSentinelPool jp = new JedisSentinelPool(redisConfig.getMasterName(),sentinels,poolConfig,2000, redisConfig.getPassword(),redisConfig.getDatabase());return jp;}
}

          4) 集群模式连接：

                都差不多，只简单说一下如何创建连接池：

public static void testCluster() {// 配置参数，根据服务器情况设置连接参数JedisPoolConfig config = new JedisPoolConfig();config.setMaxIdle(100);// 添加集群master地址Set<HostAndPort> jedisClusterSet = new HashSet<>();jedisClusterSet.add(new HostAndPort("192.168.242.128", 8201));jedisClusterSet.add(new HostAndPort("192.168.242.128", 8202));jedisClusterSet.add(new HostAndPort("192.168.242.128", 8203));// 连接集群JedisCluster jedisCluster = new JedisCluster(jedisClusterSet, config);// r如果带密码//JedisCluster jedisCluster  = new JedisCluster(jedisClusterSet,1000, 1000, 5, password, config);// 设置keyjedisCluster.set("okayjam", "www.okayjam.com");// 读取keySystem.out.println(jedisCluster.get("okayjam"));
}

二、Jedis的操作：

       1)Jedis对key的操作
            jedis.flushDB();// 清空数据jedis.echo("hello");// 判断key否存在jedis.exists("foo");// 如果数据库没有任何key，返回nil，否则返回数据库中一个随机的key。String randomKey = jedis.randomKey();System.out.println("randomKey: " + randomKey);// 设置60秒后该key过期jedis.expire("key", 60);// key有效毫秒数System.out.println(jedis.pttl("key"));// 移除key的过期时间jedis.persist("key");// 获取key的类型, "string", "list", "set". "none" none表示key不存在System.out.println("type: " + jedis.type("key"));// 导出key的值byte[] bytes = jedis.dump("key");System.out.println(new String(bytes));// 将key重命名jedis.renamenx("key", "keytest");System.out.println("key是否存在: " + jedis.exists("key"));// 判断是否存在System.out.println("keytest是否存在: " + jedis.exists("keytest"));// 判断是否存在// 查询匹配的key// KEYS       * 匹配数据库中所有 key 。// KEYS       h?llo 匹配 hello ， hallo 和 hxllo 等。// KEYS       h*llo 匹配 hllo 和 heeeeello 等。// KEYS       h[ae]llo 匹配 hello 和 hallo ，但不匹配 hillo 。// 特殊符号用 \ 隔开。Set<String> set = jedis.keys("k*");System.out.println(set);// 删除keyjedis.del("key");System.out.println(jedis.exists("key"));
        2) Jedis对字符串(String)的相关操作
        jedis.set("hello", "hello");// 使用append 向字符串后面添加jedis.append("hello", " world");System.out.println(jedis.get("hello"));// set覆盖字符串jedis.set("hello", "123");System.out.println(jedis.get("hello"));// 设置过期时间jedis.setex("hello2", 2, "world2");System.out.println(jedis.get("hello2"));// 一次添加多个key-value对jedis.mset("a", "1", "b", "2");// 获取a和b的valueList<String> valus = jedis.mget("a", "b");System.out.println(valus);// 批量删除jedis.del("a", "b");System.out.println(jedis.exists("a"));System.out.println(jedis.exists("b"));

        3)Jedis对链表(Lists)的操作
            String key = "mylist";jedis.del(key);// 队列添加元素jedis.rpush(key, "aaaa");jedis.rpush(key, "aaaa");jedis.rpush(key, "bbbb");jedis.rpush(key, "cccc");jedis.rpush(key, "cccc");// 队列长度System.out.println("lenth: " + jedis.llen(key));// 打印队列，从索引0开始，到倒数第1个（全部元素）System.out.println("all elements: " + jedis.lrange(key, 0, -1));// 索引为1的元素System.out.println("index of 1: " + jedis.lindex(key, 1));// 设置队列里面一个元素的值，当index超出范围时会返回一个error。jedis.lset(key, 1, "aa22");System.out.println("index of 1: " + jedis.lindex(key, 1));// 从队列的右边入队一个元素jedis.rpush(key, "-2", "-1");// 先-2，后-1入队列System.out.println("all elements: " + jedis.lrange(key, 0, -1));// 从队列的左边入队一个或多个元素jedis.lpush(key, "second element", "first element");// 先second// element，后first// elementF入队列System.out.println("all elements: " + jedis.lrange(key, 0, -1));// 从队列的右边出队一个元素System.out.println(jedis.rpop(key));// 从队列的左边出队一个元素System.out.println(jedis.lpop(key));System.out.println("all elements: " + jedis.lrange(key, 0, -1));// count > 0: 从头往尾移除值为 value 的元素，count为移除的个数。// count < 0: 从尾往头移除值为 value 的元素，count为移除的个数。// count = 0: 移除所有值为 value 的元素。jedis.lrem(key, 1, "cccc");System.out.println("all elements: " + jedis.lrange(key, 0, -1));// 即最右边的那个元素也会被包含在内。 如果start比list的尾部下标大的时候，会返回一个空列表。// 如果stop比list的实际尾部大的时候，Redis会当它是最后一个元素的下标。System.out.println(jedis.lrange(key, 0, 2));System.out.println("all elements: " + jedis.lrange(key, 0, -1));// 删除区间以外的元素System.out.println(jedis.ltrim(key, 0, 2));System.out.println("all elements: " + jedis.lrange(key, 0, -1));
        4)Jedis对集合(Sets)的操作
            // 清空数据System.out.println(jedis.flushDB());String key = "myset";String key2 = "myset2";// 集合添加元素jedis.sadd(key, "aaa", "bbb", "ccc");jedis.sadd(key2, "bbb", "ccc", "ddd");// 获取集合里面的元素数量System.out.println(jedis.scard(key));// 获得两个集合的交集，并存储在一个关键的结果集jedis.sinterstore("destination", key, key2);System.out.println(jedis.smembers("destination"));// 获得两个集合的并集，并存储在一个关键的结果集jedis.sunionstore("destination", key, key2);System.out.println(jedis.smembers("destination"));// key集合中，key2集合没有的元素，并存储在一个关键的结果集jedis.sdiffstore("destination", key, key2);System.out.println(jedis.smembers("destination"));// 确定某个元素是一个集合的成员System.out.println(jedis.sismember(key, "aaa"));// 从key集合里面随机获取一个元素System.out.println(jedis.srandmember(key));// aaa从key移动到key2集合jedis.smove(key, key2, "aaa");System.out.println(jedis.smembers(key));System.out.println(jedis.smembers(key2));// 删除并获取一个集合里面的元素System.out.println(jedis.spop(key));// 从集合里删除一个或多个元素jedis.srem(key2, "ccc", "ddd");System.out.println(jedis.smembers(key2));
        5)Jedis对有序集合(Sorted Sets)的操作 
            // 清空数据System.out.println(jedis.flushDB());String key = "mysortset";Map<String, Double> scoreMembers = new HashMap<String, Double>();scoreMembers.put("aaa", 1001.0);scoreMembers.put("bbb", 1002.0);scoreMembers.put("ccc", 1003.0);// 添加数据jedis.zadd(key, 1004.0, "ddd");jedis.zadd(key, scoreMembers);// 获取一个排序的集合中的成员数量System.out.println(jedis.zcard(key));// 返回的成员在指定范围内的有序集合，以0表示有序集第一个成员，以1表示有序集第二个成员，以此类推。// 负数下标，以-1表示最后一个成员，-2表示倒数第二个成员Set<String> coll = jedis.zrange(key, 0, -1);System.out.println(coll);// 返回的成员在指定范围内的逆序集合coll = jedis.zrevrange(key, 0, -1);System.out.println(coll);// 元素下标System.out.println(jedis.zscore(key, "bbb"));// 删除元素System.out.println(jedis.zrem(key, "aaa"));System.out.println(jedis.zrange(key, 0, -1));// 给定值范围内的成员数System.out.println(jedis.zcount(key, 1002.0, 1003.0));
        6)Jedis对哈希(Hashs)的操作
            // 清空数据System.out.println(jedis.flushDB());String key = "myhash";Map<String, String> hash = new HashMap<String, String>();hash.put("aaa", "11");hash.put("bbb", "22");hash.put("ccc", "33");// 添加数据jedis.hmset(key, hash);jedis.hset(key, "ddd", "44");// 获取hash的所有元素(key值)System.out.println(jedis.hkeys(key));// 获取hash中所有的key对应的value值System.out.println(jedis.hvals(key));// 获取hash里所有元素的数量System.out.println(jedis.hlen(key));// 获取hash中全部的域和值,以Map<String, String> 的形式返回Map<String, String> elements = jedis.hgetAll(key);System.out.println(elements);// 判断给定key值是否存在于哈希集中System.out.println(jedis.hexists(key, "bbb"));// 获取hash里面指定字段对应的值System.out.println(jedis.hmget(key, "aaa", "bbb"));// 获取指定的值System.out.println(jedis.hget(key, "aaa"));// 删除指定的值System.out.println(jedis.hdel(key, "aaa"));System.out.println(jedis.hgetAll(key));// 为key中的域 field 的值加上增量 incrementSystem.out.println(jedis.hincrBy(key, "bbb", 100));System.out.println(jedis.hgetAll(key));

三、Jedis操作封装类

        一般不直接从Jedis连接池中获取实例然后进行操作，一般会写好一个封装类，然后使用封装类进行操作，简单提供几个示例：
        

        1) 示例一

        例如平时常用的redis操作的get、set、exists、incr、decr方法，序列化的beanToString和stringToBean方法，用到的是import com.alibaba.fastjson.JSON;

@Service
public class RedisService {@AutowiredJedisPool jedisPool;/*** 获取单个对象* @param prefix* @param key* @param clazz* @param <T>* @return*/public <T> T get(KeyPrefix prefix,String key,Class<T> clazz){Jedis jedis =null;try {jedis = jedisPool.getResource();//生成真正的keyString realKey =prefix.getPrefix()+key;String str = jedis.get(realKey);T t=stringToBean(str,clazz);return t;}finally {returnToPool(jedis);}}/*** 设置对象* @param prefix* @param key* @param value* @param <T>* @return*/public <T> boolean set(KeyPrefix prefix,String key,T value){Jedis jedis =null;try {jedis = jedisPool.getResource();String str=beanToString(value);if (str==null||str.length()<=0)return false;//生成真正的keyString realKey =prefix.getPrefix()+key;int seconds=prefix.expireSeconds();if (seconds<=0){jedis.set(realKey,str);} else {jedis.setex(realKey,seconds,str);}jedis.set(realKey, str);return true;}finally {returnToPool(jedis);}}/*** 判断是否存在* @param prefix* @param key* @param <T>* @return*/public <T> boolean exists(KeyPrefix prefix,String key){Jedis jedis =null;try {jedis = jedisPool.getResource();//生成真正的keyString realKey =prefix.getPrefix()+key;return jedis.exists(realKey);}finally {returnToPool(jedis);}}/*** 增加值* @param prefix* @param key* @param <T>* @return*/public <T> Long incr(KeyPrefix prefix,String key){Jedis jedis =null;try {jedis = jedisPool.getResource();//生成真正的keyString realKey =prefix.getPrefix()+key;return jedis.incr(realKey);}finally {returnToPool(jedis);}}/*** 减少值* @param prefix* @param key* @param <T>* @return*/public <T> Long decr(KeyPrefix prefix,String key){Jedis jedis =null;try {jedis = jedisPool.getResource();//生成真正的keyString realKey =prefix.getPrefix()+key;return jedis.decr(realKey);}finally {returnToPool(jedis);}}private <T> String beanToString(T value) {if (value==null)return null;Class<?> aClass = value.getClass();if (aClass==int.class||aClass==Integer.class){return ""+value;}else if (aClass==String.class){return (String) value;}else if (aClass==long.class||aClass==Long.class){return ""+value;}else {return JSON.toJSONString(value);}}private <T> T stringToBean(String str,Class<T> aClass) {if (str==null||str.length()<=0||aClass==null)return null;if (aClass==int.class||aClass==Integer.class){return (T)Integer.valueOf(str);}else if (aClass==String.class){return (T)str;}else if (aClass==long.class||aClass==Long.class){return (T)Long.valueOf(str);}else {return JSON.toJavaObject(JSON.parseObject(str),aClass);}}private void returnToPool(Jedis jedis) {if (jedis!=null){jedis.close();}}}

        

        2) 示例二：
/*** 基于jedis的redis操作工具类* @author jyf* @time 2019/8/3 22:30*/
public final class RedisUtils {/*除了该工具类提供的方法外，还可以在外面调用getJedis()方法，获取到jedis实例后，调用它原生的api来操作*//*** 获取jedis对象，并选择redis库。jedis默认是0号库，可传入1-16之间的数选择库存放数据* 原则上使用一个redis库存放数据，通过特定的key的命令规则来区分不同的数据就行了。** @param index redis库号。使用可变参数的目的就是该参数可传可不传。* @return 返回jedis对象*/public static Jedis getJedis(int... index) {Jedis jedis = MyJedisPoolConfig.getJedisPool().getResource();if (index != null && index.length > 0) {if (index[0] > 0 && index[0] <= 16){jedis.select(index[0]);}}return jedis;}/*########################  key的操作  ################################*//*** 根据pattern返回当前库中的key** @param pattern* @return*/public static Set<String> keys(String pattern) {Jedis jedis = null;Set<String> keys = null;try {jedis = getJedis();keys = jedis.keys(pattern);}finally {if (jedis != null){jedis.close();}}return keys;}/*** 删除一个或多个key** @param key 一个或多个key*/public static Long del(String... key) {Jedis jedis = null;Long delNum = 0L;try {jedis = getJedis();delNum =jedis.del(key);}finally {if (jedis != null){jedis.close();}}return delNum;}/*** 批量删除* @param keyList 要删除的key的集合*/public static void mdel(List<String> keyList){Jedis jedis = getJedis();//获取pipelinePipeline pipeline = jedis.pipelined();for (String key : keyList) {pipeline.del(key);}//执行结果同步，这样才能保证结果的正确性。实际上不执行该方法也执行了上面的命令，但是结果确不一定完全正确。//注意pipeline.sync();//关闭连接jedis.close();}/*** 判断某个key是否还存在** @param key key* @return*/public static Boolean exists(String key) {Jedis jedis = null;Boolean flag = false;try {jedis = getJedis();flag = jedis.exists(key);}finally {if (jedis != null){jedis.close();}}return flag;}/*** 设置某个key的过期时间，单位秒** @param key key* @param seconds 过期时间秒*/public static void expire(String key, int seconds) {Jedis jedis = null;try {jedis = getJedis();jedis.expire(key, seconds);}finally {if (jedis != null){jedis.close();}}}/*** 查看某个key还有几秒过期，-1表示永不过期 ，-2表示已过期** @param key key* @return*/public static Long timeToLive(String key) {Jedis jedis = null;Long ttl;try {jedis = getJedis();ttl = jedis.ttl(key);}finally {if (jedis != null){jedis.close();}}return ttl;}/*** 查看某个key对应的value的类型** @param key* @return*/public static String type(String key) {Jedis jedis = null;String type = null;try {jedis = getJedis();type = jedis.type(key);}finally {if (jedis != null){jedis.close();}}return type;}/*########################  string(字符串)的操作  ####################*//*** 获取某个key的value，类型要对，只能value是string的才能获取** @param key* @return*/public static String get(String key) {Jedis jedis = null;String value = null;try {jedis = getJedis();value = jedis.get(key);}finally {if (jedis != null){jedis.close();}}return value;}/*** 设置某个key的value** @param key* @param value*/public static void set(String key, String value) {Jedis jedis = null;try {jedis = getJedis();jedis.set(key, value);}finally {if (jedis != null){jedis.close();}}}/*** 字符串后追加内容** @param key key* @param appendContent 要追加的内容*/public static void append(String key, String appendContent) {Jedis jedis = null;try {jedis = getJedis();jedis.append(key, appendContent);}finally {if (jedis != null){jedis.close();}}}/*** 返回key的value的长度** @param key* @return*/public static Long strlen(String key) {Jedis jedis = null;Long strLen = 0L;try {jedis = getJedis();strLen = jedis.strlen(key);}finally {if (jedis != null){jedis.close();}}return strLen;}/*** value 加1 必* 须是字符型数字* @param key* @return 增加后的值*/public static Long incr(String key) {Jedis jedis = null;Long incrResult = 0L;try {jedis = getJedis();incrResult = jedis.incr(key);}finally {if (jedis != null){jedis.close();}}return incrResult;}/*** value 减1   必须是字符型数字** @param key* @return*/public static Long decr(String key) {Jedis jedis = null;Long decrResult = 0L;try {jedis = getJedis();decrResult = jedis.decr(key);}finally {if (jedis != null){jedis.close();}}return decrResult;}/*** value 加increment** @param key key* @param increment 加几* @return*/public static Long incrby(String key, int increment) {Jedis jedis = null;Long incrByResult = 0L;try {jedis = getJedis();incrByResult = jedis.incrBy(key, increment);}finally {if (jedis != null){jedis.close();}}return incrByResult;}/*** value 减increment** @param key* @param increment* @return*/public static Long decrby(String key, int increment) {Jedis jedis = null;Long decrByResult = 0L;try {jedis = getJedis();decrByResult = jedis.decrBy(key, increment);}finally {if (jedis != null){jedis.close();}}return decrByResult;}/*** 给某个key设置过期时间和value，成功返回OK** @param key key* @param seconds 过期时间秒* @param value 设置的值* @return*/public static String setex(String key, int seconds, String value) {Jedis jedis = null;String result = null;try {jedis = getJedis();result = jedis.setex(key, seconds, value);}finally {if (jedis != null){jedis.close();}}return result;}/*########################  list(列表)的操作  #######################*///lpush rpush lpop rpop lrange lindex llen lset/*** 从左边向列表中添加值** @param key key* @param str 要添加的值*/public static void lpush(String key, String str) {Jedis jedis = null;try {jedis = getJedis();jedis.lpush(key, str);}finally {if (jedis != null){jedis.close();}}}/*** 从右边向列表中添加值** @param key key* @param str 要添加的值*/public static void rpush(String key, String str) {Jedis jedis = null;try {jedis = getJedis();jedis.rpush(key, str);}finally {if (jedis != null){jedis.close();}}}/*** 从左边取出一个列表中的值** @param key* @return*/public static String lpop(String key) {Jedis jedis = null;String lpop = null;try {jedis = getJedis();lpop = jedis.lpop(key);}finally {if (jedis != null){jedis.close();}}return lpop;}/*** 从右边取出一个列表中的值** @param key* @return*/public static String rpop(String key) {Jedis jedis = null;String rpop = null;try {jedis = getJedis();rpop = jedis.rpop(key);}finally {if (jedis != null){jedis.close();}}return rpop;}/*** 取出列表中指定范围内的值，0 到 -1 表示全部** @param key* @param startIndex* @param endIndex* @return*/public static List<String> lrange(String key, int startIndex, int endIndex) {Jedis jedis = null;List<String> result = null;try {jedis = getJedis();result = jedis.lrange(key, startIndex, endIndex);}finally {if (jedis != null){jedis.close();}}return result;}/*** 返回某列表指定索引位置的值** @param key 列表key* @param index 索引位置* @return*/public static String lindex(String key, int index) {Jedis jedis = null;String lindex = null;try {jedis = getJedis();lindex = jedis.lindex(key, index);}finally {if (jedis != null){jedis.close();}}return lindex;}/*** 返回某列表的长度** @param key* @return*/public static Long llen(String key) {Jedis jedis = null;Long llen = 0L;try {jedis = getJedis();llen = jedis.llen(key);}finally {if (jedis != null){jedis.close();}}return llen;}/*** 给某列表指定位置设置为指定的值** @param key* @param index* @param str*/public static void lset(String key, Long index, String str) {Jedis jedis = null;try {jedis = getJedis();jedis.lset(key, index, str);}finally {if (jedis != null){jedis.close();}}}/*** 对列表进行剪裁，保留指定闭区间的元素(索引位置也会重排)* @param key 列表key* @param startIndex 开始索引位置* @param endIndex 结束索引位置*/public static void ltrim(String key,Integer startIndex,Integer endIndex){Jedis jedis = null;try {jedis = getJedis();jedis.ltrim(key, startIndex, endIndex);}finally {if (jedis != null){jedis.close();}}}/*** 从列表的左边阻塞弹出一个元素* @param key 列表的key* @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞* @return*/public static List<String> blpop(String key,Integer timeout){Jedis jedis = null;List<String> valueList = null;try {jedis = getJedis();valueList = jedis.blpop(timeout, key);}finally {if (jedis != null){jedis.close();}}return valueList;}/*** 从列表的右边阻塞弹出一个元素* @param key 列表的key* @param timeout 阻塞超时时间，0表示若没有元素就永久阻塞* @return*/public static List<String> brpop(String key,Integer timeout){Jedis jedis = null;List<String> valueList = null;try {jedis = getJedis();valueList = jedis.brpop(timeout, key);}finally {if (jedis != null){jedis.close();}}return valueList;}/*########################  hash(哈希表)的操作  #######################*///hset hget hmset hmget hgetall hdel hkeys hvals hexists hincrby/*** 给某个hash表设置一个键值对** @param key* @param field* @param value*/public static void hset(String key, String field, String value) {Jedis jedis = null;try {jedis = getJedis();jedis.hset(key, field, value);}finally {if (jedis != null){jedis.close();}}}/*** 取出某个hash表中某个field对应的value** @param key key* @param field field* @return*/public static String hget(String key, String field) {Jedis jedis = null;String hget = null;try {jedis = getJedis();hget = jedis.hget(key, field);}finally {if (jedis != null){jedis.close();}}return hget;}/*** 某个hash表设置一个或多个键值对** @param key* @param kvMap*/public static void hmset(String key, Map<String, String> kvMap) {Jedis jedis = null;try {jedis = getJedis();jedis.hmset(key, kvMap);}finally {if (jedis != null){jedis.close();}}}/*** 取出某个hash表中任意多个key对应的value的集合** @param key* @param fields* @return*/public static List<String> hmget(String key, String... fields) {Jedis jedis = null;List<String> hmget = null;try {jedis = getJedis();hmget = jedis.hmget(key, fields);}finally {if (jedis != null){jedis.close();}}return hmget;}/*** 取出某个hash表中所有的键值对** @param key* @return*/public static Map<String, String> hgetall(String key) {Jedis jedis = null;Map<String, String> kvMap = null;try {jedis = getJedis();kvMap = jedis.hgetAll(key);}finally {if (jedis != null){jedis.close();}}return kvMap;}/*** 判断某个hash表中的某个key是否存在** @param key* @param field* @return*/public static Boolean hexists(String key, String field) {Jedis jedis = null;Boolean exists = null;try {jedis = getJedis();exists = jedis.hexists(key, field);}finally {if (jedis != null){jedis.close();}}return exists;}/*** 返回某个hash表中所有的key** @param key* @return*/public static Set<String> hkeys(String key) {Jedis jedis = null;Set<String> keys = null;try {jedis = getJedis();keys = jedis.hkeys(key);}finally {if (jedis != null){jedis.close();}}return keys;}/*** 返回某个hash表中所有的value** @param key* @return*/public static List<String> hvals(String key) {Jedis jedis = null;List<String> hvals = null;try {jedis = getJedis();hvals = jedis.hvals(key);}finally {if (jedis != null){jedis.close();}}return hvals;}/*** 删除某个hash表中的一个或多个键值对** @param key* @param fields*/public static void hdel(String key, String... fields) {Jedis jedis = null;try {jedis = getJedis();jedis.hdel(key, fields);}finally {if (jedis != null){jedis.close();}}}/*** 给某个hash表中的某个field的value增加多少** @param key       hash表的key* @param field     表中的某个field* @param increment 增加多少* @return*/public static Long hincrby(String key, String field, Long increment) {Jedis jedis = null;Long result = null;try {jedis = getJedis();result = jedis.hincrBy(key, field, increment);}finally {if (jedis != null){jedis.close();}}return result;}/*########################  set(集合)的操作  ###########################*//*** 往set集合中添加一个或多个元素* @param key key* @param members 要添加的元素* @return 添加成功的元素个数*/public static Long sadd(String key,String... members){Jedis jedis = null;Long num = 0L;try {jedis = getJedis();num = jedis.sadd(key, members);}finally {if (jedis != null){jedis.close();}}return num;}/*** 返回set集合中的所有元素，顺序与加入时的顺序一致* @param key key* @return*/public static Set<String> smembers(String key){Jedis jedis = null;Set<String> members = null;try {jedis = getJedis();members = jedis.smembers(key);}finally {if (jedis != null){jedis.close();}}return members;}/*** 判断集合中是否存在某个元素* @param key key* @param member 某个元素* @return true存在，false不存在*/public static Boolean sismember(String key,String member){Jedis jedis = null;Boolean isMember = false;try {jedis = getJedis();isMember = jedis.sismember(key, member);}finally {if (jedis != null){jedis.close();}}return isMember;}/*** 返回set集合的长度* @param key key* @return*/public static Long scard(String key){Jedis jedis = null;Long len = 0L;try {jedis = getJedis();len = jedis.scard(key);}finally {if (jedis != null){jedis.close();}}return len;}/*** 删除set集合中指定的一个或多个元素* @param key* @param members 要删除的元素* @return 删除成功的元素个数*/public static Long srem(String key,String... members){Jedis jedis = null;Long num = 0L;try {jedis = getJedis();num = jedis.srem(key,members);}finally {if (jedis != null){jedis.close();}}return num;}/*** 将key1中的元素key1Member移动到key2中* @param key1 来源集合key* @param key2 目的地集合key* @param key1Member key1中的元素* @return 1成功，0失败*/public static Long smove(String key1,String key2,String key1Member){Jedis jedis = null;Long num = 0L;try {jedis = getJedis();num = jedis.smove(key1,key2,key1Member);}finally {if (jedis != null){jedis.close();}}return num;}/*** 随机查询返回集合中的指定个数的元素（若count为负数，返回的元素可能会重复）* @param key key* @param count 要查询返回的元素个数* @return 元素list集合*/public static List<String> srandmember(String key,int count){Jedis jedis = null;List<String> members = null;try {jedis = getJedis();members = jedis.srandmember(key,count);}finally {if (jedis != null){jedis.close();}}return members;}/*** 从set集合中随机弹出指定个数个元素* @param key key* @param count 要弹出的个数* @return 随机弹出的元素*/public static Set<String> spop(String key,int count){Jedis jedis = null;Set<String> members = null;try {jedis = getJedis();members = jedis.spop(key,count);}finally {if (jedis != null){jedis.close();}}return members;}/*** 求交集，返回多个set集合相交的部分* @param setKeys 多个set集合的key* @return 相交的元素集合*/public static Set<String> sinter(String... setKeys){Jedis jedis = null;Set<String> members = null;try {jedis = getJedis();members = jedis.sinter(setKeys);}finally {if (jedis != null){jedis.close();}}return members;}/*** 求并集，求几个set集合的并集（因为set中不会有重复的元素，合并后的集合也不会有重复的元素）* @param setKeys 多个set的key* @return 合并后的集合*/public static Set<String> sunion(String... setKeys){Jedis jedis = null;Set<String> members = null;try {jedis = getJedis();members = jedis.sunion(setKeys);}finally {if (jedis != null){jedis.close();}}return members;}/*** 求差集，求几个集合之间的差集* @param setKeys 多个set的key* @return 差集*/public static Set<String> sdiff(String... setKeys){Jedis jedis = null;Set<String> members = null;try {jedis = getJedis();members = jedis.sdiff(setKeys);}finally {if (jedis != null){jedis.close();}}return members;}/*########################  zset(有序集合)的操作  #######################*//*** 添加一个元素到zset* @param key key* @param score 元素的分数* @param member 元素* @return 成功添加的元素个数*/public static Long zadd(String key,double score, String member){Jedis jedis = null;Long num = null;try {jedis = getJedis();num = jedis.zadd(key,score,member);}finally {if (jedis != null){jedis.close();}}return num;}
}

        简单举两个例子，可以仿照这个自己进行封装。

四、Jedis事务操作

#开启jedis事务

Transaction multi=jedis.multi();

#添加数据到redis中

multi.set("ka", "va");

#jedis事务提交

multi.exec();

#jedis事务回滚

multi.discard();

	Jedis jedis=new Jedis("127.0.0.1",6379);Transaction multi=jedis.multi();//开启redis事务try {//设置数据multi.set("ka", "va");multi.set("kb", "vb");int num=1/0;multi.set("kc", "vc");} catch (Exception e) {//multi.discard();e.printStackTrace();}//redis事务提交multi.exec();		
以上代码的结果是：redis成功保存ka,kb,不会保存kc。Jedis jedis=new Jedis("127.0.0.1",6379);
//开启事务Transaction multi=jedis.multi();try {multi.set("ka", "va");multi.set("kb", "vb");int num=1/0;	multi.set("kc", "vc");} catch (Exception e) {//redis事务回滚multi.discard();e.printStackTrace();}//redis事务回滚multi.exec();	以上代码的结果是：redis不会保存ka,kb,kc.

 

五、Jedis 使用发布与订阅

整个过程可以分为以下几个步骤：

  • 创建Redis连接；
  • 创建订阅者；
  • 创建发布者；
  • 发布消息；
  • 接收消息。

1.使用jedis的publish(String channel, String message)方法向通道发布消息；

2.使用jedis的subscribe(JedisPubSub jedisPubSub, String... channels)方法订阅通道；

3.jedisPubSub参数使用自定义类继承JedisPubSub类，重写onMessage(String channel, String message)方法即可处理接收的消息；

4.JedisPubSub类的方法可以按照需求重写：

public abstract class JedisPubSub {private int subscribedChannels = 0;private volatile Client client;public JedisPubSub() {}public void onMessage(String channel, String message) {}public void onPMessage(String pattern, String channel, String message) {}public void onSubscribe(String channel, int subscribedChannels) {}public void onUnsubscribe(String channel, int subscribedChannels) {}public void onPUnsubscribe(String pattern, int subscribedChannels) {}public void onPSubscribe(String pattern, int subscribedChannels) {}public void onPong(String pattern) {}
}

demo:

JedisPool jedisPool = new JedisPool(new JedisPoolConfig(), "192.168.100.155", 6379, 3000, "KFQ2xc3iozsa", 0);new Thread(new Runnable() {@Overridepublic void run() {while (true) {Jedis jedis = jedisPool.getResource();try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("发布消息");jedis.publish("ch", "hello");//发布消息jedis.close();}}}).start();MyPubSub mypubsub = new MyPubSub();new Thread(new Runnable() {@Overridepublic void run() {Jedis jedis = jedisPool.getResource();jedis.subscribe(mypubsub, "ch");//订阅消息jedis.close();}}).start();try {Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}mypubsub.unsubscribe();// 取消所有订阅}static class MyPubSub extends JedisPubSub {@Overridepublic void onSubscribe(String channel, int subscribedChannels) {System.out.println("订阅了：" + channel);super.onSubscribe(channel, subscribedChannels);}@Overridepublic void onMessage(String channel, String message) {System.out.println("收到通道" + channel + "消息：" + message);super.onMessage(channel, message);}@Overridepublic void onUnsubscribe(String channel, int subscribedChannels) {System.out.println("取消订阅：" + channel);super.onUnsubscribe(channel, subscribedChannels);}}

Redis总结（五）redis发布订阅模式 - 知乎 (zhihu.com)

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/2809458.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

强化学习（GPS）

强化学习（GPS）

GPS——Guided Policy Search引导策略搜索 基于模型的强化学习算法 GPS目前被作为基础算法广泛应用于各种强化学习任务中&#xff0c;其出发点在于纯粹的策略梯度方法在更新参数时不会用到环境模型因而属于一种无模型强化学习算法。由于没有利用任何环境的内在属性&#xff0…
阅读更多...
在线网络代理转发NPClient

在线网络代理转发NPClient

NPClient操作方式&#xff1a; 用浏览器打开网站http://101.35.247.87:9000/ 点击注册 输入注册的用户名和密码&#xff0c;就会进入如下界面&#xff1a; 点击登录 输入用户名和密码后进入如下界面&#xff1a; 点击下载代理客户端&#xff0c;下载时要稍微等一下&#xff0c…
阅读更多...
【hashmap】【将排序之后的字符串作为哈希表的键】【获取 HashMap 中所有值的集合】Leetcode 49 字母异位词分组

【hashmap】【将排序之后的字符串作为哈希表的键】【获取 HashMap 中所有值的集合】Leetcode 49 字母异位词分组

【hashmap】【将排序之后的字符串作为哈希表的键】【获取 HashMap 中所有值的集合】Leetcode 49 字母异位词分组 解法1 将排序之后的字符串作为哈希表的键解法2 在解法一的基础上加入了getOrDefault ---------------&#x1f388;&#x1f388;题目链接&#x1f388;&#x1f3…
阅读更多...
K—近邻算法实际应用案例

K—近邻算法实际应用案例

K—近邻算法实际应用案例 1. 案例1&#xff1a;鸢尾花种类预测1.1 数据集获取和属性介绍1.1.1 scikit-learn中的数据集介绍1.1.2 sklearn数据集返回值介绍 1.2 数据可视化介绍&#xff08;查看数据分布&#xff09;1.3 数据集的划分1.4 特征工程1.4.1 归一化1.4.2 标准化 1.5 鸢…
阅读更多...
09 呼吸灯

09 呼吸灯

呼吸灯简介 呼吸灯实际展示的效果就是一个 LED 灯的亮度由亮到暗&#xff0c;再由暗到亮的变化过程&#xff0c;并且该过程是循环往复的&#xff0c;像呼吸一样那么有节奏。 呼吸灯通常是采用 PWM(Pulse Width Modulation&#xff0c;即脉冲宽度调制) 的方式实现&#xff0c;在…
阅读更多...
zabbix监控业务数据

zabbix监控业务数据

前言 监控系统除了监控os和数据库性能相关的指标外&#xff0c;业务数据也是重点监控的对象。 一线驻场的运维同学应该深有体会&#xff0c;每天需要向甲方或者公司反馈现场的数据情况&#xff0c;正常情况下一天巡检两次&#xff0c;早上上班后和下午下班前各一次。监控项目…
阅读更多...
Vue3 路由配置 + 路由跳转 + 路由传参（动态路由传参 + 普通路由传参）

Vue3 路由配置 + 路由跳转 + 路由传参（动态路由传参 + 普通路由传参）

Vue Router&#xff1a; Vue.js 的官方路由。它与 Vue.js 核心深度集成&#xff0c;让用 Vue.js 构建单页应用变得轻而易举。 效果 一、介绍 1、官方文档&#xff1a;https://router.vuejs.org/zh/introduction.html 介绍 | Vue RouterVue.js 的官方路由https://router.vuejs.…
阅读更多...
MATLAB练习题：违背直觉的三门问题（非常有趣的一道题目）

MATLAB练习题：违背直觉的三门问题（非常有趣的一道题目）

​讲解视频&#xff1a;可以在bilibili搜索《MATLAB教程新手入门篇——数学建模清风主讲》。​ MATLAB教程新手入门篇&#xff08;数学建模清风主讲&#xff0c;适合零基础同学观看&#xff09;_哔哩哔哩_bilibili 三门问题&#xff08;Monty Hall problem&#xff09;又称蒙提…
阅读更多...
nginx之状态页 日志分割 自定义图表 证书

nginx之状态页 日志分割 自定义图表 证书

5.1 网页的状态页 基于nginx 模块 ngx_http_stub_status_module 实现&#xff0c;在编译安装nginx的时候需要添加编译参数 --with-http_stub_status_module&#xff0c;否则配置完成之后监测会是提示语法错误注意: 状态页显示的是整个服务器的状态,而非虚拟主机的状态 server{…
阅读更多...
Nvidia Jetson Orin NX配置环境

Nvidia Jetson Orin NX配置环境

Nvidia Jetson Orin NX配置环境配置环境 一、安装jetson5.1.2二、安装jtop三、配置CUDA和cuDNN四、安装Pytorch 先导片&#xff1a;Jetson采用arm64架构 一、安装jetson5.1.2 安装好jetson自带cuda、cudnn和tensorRT 官方文档 更换源 sudo vi /etc/apt/sources.list.d/nvidia…
阅读更多...
LeetCode 第一题: 两数之和

LeetCode 第一题: 两数之和

文章目录 第一题: 两数之和题目描述示例 解题思路Go语言实现 - 一遍哈希表法C实现算法分析 排序和双指针法Go语言实现 - 排序和双指针法C算法分析 暴力法Go语言实现 - 暴力法C算法分析 二分搜索法Go语言实现 - 二分搜索法C算法分析 第一题: 两数之和 ‍ 题目描述 给定一个整…
阅读更多...
组态软件在物联网中的应用

组态软件在物联网中的应用

随着物联网的快速发展&#xff0c;组态软件在物联网中的应用也越来越广泛。组态软件是一种用于创建和管理物联网系统的可视化工具&#xff0c;它能够将传感器、设备和网络连接起来&#xff0c;实现数据的采集、分析和可视化。本文将探讨组态软件在物联网中的应用&#xff0c;并…
阅读更多...
如何利用EXCEL批量插入图片

如何利用EXCEL批量插入图片

目录 1.excel打开目标表格&#xff1b; 2.点开视图-宏-录制宏&#xff0c;可以改宏的名字或者选择默认&#xff1b; 3.然后点开视图-宏-查看宏 4.点编辑进去 5.修改代码&#xff1a; &#xff08;1&#xff09;打开之后会显示有一堆代码 &#xff08;2&#xff09;将这个…
阅读更多...
【前端】nginx 反向代理，实现跨域问题

【前端】nginx 反向代理，实现跨域问题

前面讲跨域的问题&#xff0c;这篇 C# webapi 文章里面已经说过了。在上述文章中是属于从服务器端去允许访问的策略去解决跨域问题。而这里是从客户端的角度利用反向代理的方法去解决跨域问题。 反向代理&#xff1a;其原理就是将请求都接收到一个中间件&#xff08;中间地址&a…
阅读更多...
基于springboot+vue的音乐网站(前后端分离)

基于springboot+vue的音乐网站(前后端分离)

博主主页&#xff1a;猫头鹰源码 博主简介&#xff1a;Java领域优质创作者、CSDN博客专家、阿里云专家博主、公司架构师、全网粉丝5万、专注Java技术领域和毕业设计项目实战&#xff0c;欢迎高校老师\讲师\同行交流合作 ​主要内容&#xff1a;毕业设计(Javaweb项目|小程序|Pyt…
阅读更多...
YOLOv8改进 | Conv篇 | 全新的SOATA轻量化下采样操作ADown（参数量下降百分之二十，附手撕结构图）

YOLOv8改进 | Conv篇 | 全新的SOATA轻量化下采样操作ADown（参数量下降百分之二十，附手撕结构图）

一、本文介绍 本文给大家带来的改进机制是利用2024/02/21号最新发布的YOLOv9其中提出的ADown模块来改进我们的Conv模块，其中YOLOv9针对于这个模块并没有介绍，只是在其项目文件中用到了，我将其整理出来用于我们的YOLOv8的项目，经过实验我发现该卷积模块（作为下采样模块）…
阅读更多...
EasyRecovery2024个人免费版本电脑手机数据恢复软件下载

EasyRecovery2024个人免费版本电脑手机数据恢复软件下载

EasyRecovery是一款功能强大的数据恢复软件&#xff0c;能够帮助用户恢复丢失、删除、格式化或损坏的数据。无论是由于误操作、病毒攻击、硬盘故障还是其他原因导致的数据丢失&#xff0c;EasyRecovery都能提供有效的解决方案。 该软件支持从各种存储介质恢复数据&#xff0c;…
阅读更多...
霍金《时间简史》（A Brief History of Time）学习笔记（第五章）（下）

霍金《时间简史》（A Brief History of Time）学习笔记（第五章）（下）

Chapter 5: Elementary Particles and the Forces of Nature Second Half (P81-90)
阅读更多...
进程等待进程程序替换

进程等待进程程序替换

在之前的进程状态一文中我们初步了解到了僵尸进程&#xff0c;我们都知道僵尸进程是一个已经运行完毕但然仍占用内存资源的进程&#xff0c;它的存在会浪费系统资源&#xff0c;我们必须想方设法将僵尸进程清理掉。 先来想一下为什么会存在僵尸进程&#xff0c;一个进程的回收…
阅读更多...
pytest如何在类的方法之间共享变量？

pytest如何在类的方法之间共享变量？

在pytest中&#xff0c;setup_class是一个特殊的方法&#xff0c;它用于在类级别的测试开始之前设置一些初始化的状态。这个方法会在类中的任何测试方法执行之前只运行一次。 当你在setup_class中使用self来修改类属性时&#xff0c;你实际上是在修改类的一个实例属性。在Pyth…
阅读更多...
最新文章

Copyright @ 2022~2023