redis有哪些api-乐山大橙子建站

新闻中心

这里有您想知道的互联网营销解决方案

redis有哪些api

这篇文章将为大家详细讲解有关redis有哪些api，小编觉得挺实用的，因此分享给大家做个参考，希望大家阅读完这篇文章后可以有所收获。

公司主营业务：网站制作、成都做网站、移动网站开发等业务。帮助企业客户真正实现互联网宣传，提高企业的竞争能力。创新互联是一支青春激扬、勤奋敬业、活力青春激扬、勤奋敬业、活力澎湃、和谐高效的团队。公司秉承以“开放、自由、严谨、自律”为核心的企业文化，感谢他们对我们的高要求，感谢他们从不同领域给我们带来的挑战，让我们激情的团队有机会用头脑与智慧不断的给客户带来惊喜。创新互联推出樊城免费做网站回馈大家。

一、Redis Client介绍

1.1、简介

Jedis Client是Redis官网推荐的一个面向java客户端，库文件实现了对各类API进行封装调用。

Jedis源码工程地址：https://github.com/xetorthio/jedis

1.2、使用

Redis Client最好选用与服务端对应的版本，本例中使用Redis 2.8.19客户端使用jedis -2.6.3，Maven工程添加如下引用即可。


         redis.clients
         jedis
         2.6.3
         jar
         compile

1.3、注意事项

Redis Client拥有众多对接版本，本项目目前使用Jedis为官方推荐Java对接客户端，是基于其对Redis良好的版本支持和API对接，另外编码中尽量避免使用废弃接口。

Redis目前正在新版过渡期，3.0版本暂未稳定，但是由于3.0版本提供了最新的集群功能，可能在日后稳定版发布以后升级到3.0，目前使用的Jedis支持3.0的目前版本API。

二、Redis Client常用API

2.1、环境要求

语言：Java

JDK：1.7

Redis : 2.8.19（稳定版）

2.2、系统使用

2.2.1、建立连接

普通连接

Jedis jedis = new Jedis("localhost");
       jedis.set("foo", "bar");
       String value = jedis.get("foo");
       System.out.println(value);

设置连接池配置

该方法用于得到redis连接池连接使用的连接池配置，该连接池配置也可以通过spring注入的方式来进行相对应的配置，连接池采用的是平时比较常用的org.apache.commons.pool2.impl.GenericObjectPoolConfig来进行的连接池管理

配置文件如下

#redis服务器ip #   
    redis.ip=172.30.5.117 
   
    #redis服务器端口号# 
    redis.port=6379 
     
    ###jedis##pool##config### 
    #jedis的最大分配对象# 
    jedis.pool.maxActive=1024 
   
    #jedis最大保存idel状态对象数 # 
    jedis.pool.maxIdle=200 
   
    #jedis池没有对象返回时，最大等待时间 # 
    jedis.pool.maxWait=1000 
   
    #jedis调用borrowObject方法时，是否进行有效检查# 
    jedis.pool.testOnBorrow=true 
   
    #jedis调用returnObject方法时，是否进行有效检查 # 
    jedis.pool.testOnReturn=true

连接池配置实例化代码（也可通过spring注入进行配置）：

   /**
    * 获取化连接池配置
    * @return JedisPoolConfig
    * */
   private JedisPoolConfig getPoolConfig(){
      if(config == null){
         config = new JedisPoolConfig();
         //最大连接数
config.setMaxTotal(Integer.valueOf(getResourceBundle().getString("redis.pool.maxTotal")));
         //最大空闲连接数
config.setMaxIdle(Integer.valueOf(getResourceBundle().getString("redis.pool.maxIdle")));
         //获取连接时的最大等待毫秒数(如果设置为阻塞时BlockWhenExhausted),如果超时就抛异常, 小于零:阻塞不确定的时间,  默认-1
config.setMaxWaitMillis(Long.valueOf(getResourceBundle().getString("redis.pool.maxWaitMillis")));
         //在获取连接的时候检查有效性, 默认false
config.setTestOnBorrow(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnBorrow")));
         //在获取返回结果的时候检查有效性, 默认false
config.setTestOnReturn(Boolean.valueOf(getResourceBundle().getString("redis.pool.testOnReturn")));
      }
      return config;
   }

普通连接池连接

  这里展示的是普通的连接池方式链接redis的方案，跟普通的数据库连接池的操作方式类似；
/**
        * 初始化JedisPool
        * */
   private void initJedisPool(){
      if(pool == null){
         //获取服务器IP地址
         String ipStr = getResourceBundle().getString("redis.ip");
         //获取服务器端口
         int portStr = Integer.valueOf(getResourceBundle()
.getString("redis.port"));
         //初始化连接池
         pool = new JedisPool(getPoolConfig(), ipStr,portStr);
      }
   }

Sentinel连接池连接

该连接池用于应对Redis的Sentinel的主从切换机制，能够正确在服务器宕机导致服务器切换时得到正确的服务器连接，当服务器采用该部署策略的时候推荐使用该连接池进行操作；

 private void initJedisSentinelPool(){
      if(sentinelpool == null){
         //监听器列表
         Set sentinels = new HashSet();
         //监听器1
         sentinels.add(new HostAndPort("192.168.50.236",
26379).toString());
         //监听器2
         sentinels.add(new HostAndPort("192.168.50.237",
26379).toString());
//实际使用的时候在properties里配置即可：redis.sentinel.hostandports
=192.168.50.236:26379,192.168.50.237:26379
getResourceBundle().getString("redis.sentinel.hostandports")
//mastername是服务器上的master的名字，在master服务器的sentinel.conf中配置:
                     //[sentinel monitor server-1M  192.168.50.236 6379 2]
                     //中间的server-1M即为这里的masterName
         String masterName = getResourceBundle()
.getString("redis.sentinel.masterName");
         //初始化连接池
         sentinelpool = new JedisSentinelPool(masterName,
sentinels, getPoolConfig());
      }
   }

ShardedJedisPool连接池分片连接

   /**
        * 初始化ShardedJedisPool
        * Redis在容灾处理方面可以通过服务器端配置Master-Slave模式来实现。
        * 而在分布式集群方面目前只能通过客户端工具来实现一致性哈希分布存储，即key分片存储。
        * Redis可能会在3.0版本支持服务器端的分布存储
        * */
   private void initShardedJedisPool() {
      if (shardPool == null) {
         // 创建多个redis共享服务
         String redis1Ip = getResourceBundle().getString("redis1.ip");
         int redis1Port = Integer.valueOf(bundle.getString("redis.port"));
         JedisShardInfo jedisShardInfo1 = new JedisShardInfo(redis1Ip, redis1Port);
         String redis2Ip = getResourceBundle().getString("redis2.ip");
         int redis2Port = Integer.valueOf(bundle.getString("redis.port"));
         JedisShardInfo jedisShardInfo2 = new JedisShardInfo(redis2Ip, redis2Port);
 
         List serverlist = new LinkedList();
         serverlist.add(jedisShardInfo1);
         serverlist.add(jedisShardInfo2);
         // 初始化连接池
         shardPool = new ShardedJedisPool(getPoolConfig(),serverlist);
      }
   }

读写删除操作

// 从池中获取一个Jedis对象
      Jedis jedis = sentinelpool.getSentinelpoolResource();
      String keys = "name";
   // 删除key-value对象，如果key不存在则忽略此操作
      jedis.del(keys);
   // 存数据
      jedis.set(keys, "snowolf");
// 判断key是否存在，不存在返回false存在返回true
      jedis.exists(keys);
   // 取数据
      String value = jedis.get(keys);
   // 释放对象池（3.0将抛弃该方法）
      sentinelpool.returnSentinelpoolResource(jedis);

三、示例代码

1. String的简单追加

// 从池中获取一个Jedis对象
   JedisUtil.getInstance().STRINGS.append(key, value);

2. 价格时间排序（前提是已经存储了价格，时间的SortSet）

//执行2级排序操作（）

String stPriceSet = “stPriceSet”;//stPriceSet价格的sortset列表名
String stTimeSet = “stTimeSet”; // stTimeSet时间的sortset列表名
   Set sumSet = JedisUtilEx.getInstance()
.getSortSetByPirceUpAndTimeDown(stPriceSet, stTimeSet);
//排序以后可以重复获取上次排序结果(缓存时间10分钟)
Set sumSet = JedisUtilEx.getInstance()
getLastPirceUpAndTimeDownSet();

3. 价格时间排序（前提是已经存储了价格，时间的SortSet）

//执行2级排序操作
String stPriceSet = “stPriceSet”;//stPriceSet价格的sortset列表名
String stTimeSet = “stTimeSet”; // stTimeSet时间的sortset列表名
   Set sumSet = JedisUtilEx.getInstance()
. getSortSetByPirceDownAndTimeDown (stPriceSet, stTimeSet);
   //排序以后可以重复获取上次排序结果(缓存时间10分钟)
Set sumSet = JedisUtilEx.getInstance()
getLastPirceDownAndTimeDownSet ();

4. 保存JavaBean到hash表中

// bean继承至RedisBean
JedisUtilEx.getInstance().setBeanToHash(bean);

5. 从hash表中读取JavaBean

//uuid为业务制定的唯一标识符规则（相当于主键）
String uuid = “1”; //该ID是我们提前就知道的
//T继承至RedisBean;
JedisUtilEx.getInstance().getBeanFromHash (uuid,Class cls);

6. 将JavaBean列表装入hash中

//list中的bean继承至RedisBean
List beanList = …;
JedisUtilEx.getInstance().setBeanListToHash(beanList);
//异步版本的存储列表到hash
JedisUtilEx.getInstance().setBeanListToHashSyn(beanList);

7. 普通的操作流程示例

//获取jedis引用
Jedis jedis = JedisUtil.getInstance().getJedis();
//执行业务以及调用jedis提供的接口功能
…
jedis.hset(…);
…
//执行完成以后务必释放资源
JedisUtil.getInstance().returnJedis(jedis);
//若以后不会使用JEDIS，需要关闭所有链接池
   RedisConnetcion.destroyAllPools();

8. 事务执行流程

//获取连接资源
   Jedis jd = JedisUtil.getInstance().getJedis();
//开启事务
Transaction ts = jd.multi();
//执行业务以及调用jedis提供的接口功能
…
jedis.hset(…);
…
//执行事务
   List

新闻中心

其他资讯