Redis에는 어떤 API가 있나요?-Redis-php.cn

Redis에는 어떤 API가 있나요?

1. Redis 클라이언트 소개

1.1 소개

Jedis 클라이언트는 Redis 공식 홈페이지에서 권장하는 Java 기반 클라이언트입니다. 라이브러리 파일은 다양한 API의 캡슐화 및 호출을 구현합니다.

Jedis 소스 코드 프로젝트 주소: https://github.com/xetorthio/jedis

1.2.

Redis 클라이언트를 사용하는 경우, 이 예에서는 Redis 2.8에 해당하는 버전을 선택하는 것이 가장 좋습니다. .19 클라이언트가 사용됩니다. jedis -2.6.3을 사용하려면 Maven 프로젝트에 다음 참조를 추가하세요.

<dependency>
         <groupId>redis.clients</groupId>
         <artifactId>jedis</artifactId>
         <version>2.6.3</version>
         <type>jar</type>
         <scope>compile</scope>
   </dependency>

로그인 후 복사

1.3. Notes

Redis 클라이언트에는 현재 Redis에 대한 좋은 버전 지원과 API 도킹을 기반으로 하는 공식 권장 Java 도킹 클라이언트로 Jedis를 사용합니다. 더 이상 사용되지 않는 인터페이스에서 사용합니다.

Redis는 현재 새 버전 전환 기간 중입니다. 버전 3.0은 아직 안정적이지 않습니다. 그러나 버전 3.0은 최신 클러스터 기능을 제공하므로 향후 안정 버전이 출시되면 3.0으로 업그레이드될 수 있습니다. 사용된 Jedis는 현재 버전의 API 3.0을 지원합니다.

2. Redis 클라이언트에 일반적으로 사용되는 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

로그인 후 복사

연결 풀 구성 인스턴스화 코드(또는 수행할 수도 있음) 스프링 주입을 통해 구성):

   /**
    * 获取化连接池配置
    * @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<String> sentinels = new HashSet<String>();
         //监听器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<JedisShardInfo> serverlist = new LinkedList<JedisShardInfo>();
         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);

로그인 후 복사

3. 샘플 코드

1. 간단한 문자열 추가

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

로그인 후 복사

2. 가격 및 시간별 정렬(가격 및 시간의 SortSet이 저장되어 있는 경우)

//레벨 2 정렬 작업 수행 ()

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

로그인 후 복사

3. 가격 및 시간 기준(가격 및 시간의 SortSet이 저장되어 있는 경우)

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

로그인 후 복사

4. JavaBeans를 해시 테이블에 저장

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

로그인 후 복사

5. 해시 테이블에서 JavaBeans 읽기

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

로그인 후 복사

6. hash

//list中的bean继承至RedisBean
List<T> 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<Object> list = ts.exec();
//释放资源
JedisUtil.getInstance().returnJedis(jd);

로그인 후 복사

9. Jedis 명명 규칙의 합성 KEY를 얻는 방법

//获取连接资源
   Jedis jedis = JedisUtil.getInstance().getJedis();
   //获取管道
Pipeline pipeline = jedis.pipelined();
//执行业务以及调用jedis提供的接口功能
…
jedis.hset(…);
…
//提交并释放管道
pipeline.syncAndReturnAll();
//释放资源
JedisUtil.getInstance().returnJedis(jedis);

로그인 후 복사

1. 값 연산용 명령

//获取类的唯一键值key,例如：User:1(User为class,1为uuid)其中user继承于Reidsbean
JedisUtilEx.getInstance().getBeanKey(user);
//另一种获取类的唯一键值key的方法
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls);
//获取bean对应的KEY(对应列的唯一键值key)
JedisUtilEx.getInstance().getBeanKey(String uuid,Class<T> cls,String... fileds);
//获取bean对应的KEY(集群key)
JedisUtilEx.getInstance().getBeanKey(Class<T> cls,String... fileds);

로그인 후 복사

2. 문자열 연산용 명령

 exists(key)：确认一个key是否存在
     del(key)：删除一个key
     type(key)：返回值的类型
     keys(pattern)：返回满足给定pattern的所有key
     randomkey：随机返回key空间的一个key
     rename(oldname, newname)：将key由oldname重命名为newname，若newname存在则删除newname表示的key
     dbsize：返回当前数据库中key的数目
     expire：设定一个key的活动时间（s）
     ttl：获得一个key的活动时间
     select(index)：按索引查询
     move(key, dbindex)：将当前数据库中的key转移到有dbindex索引的数据库
     flushdb：删除当前选择数据库中的所有key
     flushall：删除所有数据库中的所有key

로그인 후 복사

4. 집합 연산용 명령

  set(key, value)：给数据库中名称为key的string赋予值value
     get(key)：返回数据库中名称为key的string的value
     getset(key, value)：给名称为key的string赋予上一次的value
     mget(key1, key2,…, key N)：返回库中多个string（它们的名称为key1，key2…）的value
     setnx(key, value)：如果不存在名称为key的string，则向库中添加string，名称为key，值为value
     setex(key, time, value)：向库中添加string（名称为key，值为value）同时，设定过期时间time
     mset(key1, value1, key2, value2,…key N, value N)：同时给多个string赋值，名称为key i的string赋值value i
     msetnx(key1, value1, key2, value2,…key N, value N)：如果所有名称为key i的string都不存在，则向库中添加string，名称key i赋值为value i
     incr(key)：名称为key的string增1操作
     incrby(key, integer)：名称为key的string增加integer
     decr(key)：名称为key的string减1操作
     decrby(key, integer)：名称为key的string减少integer
     append(key, value)：名称为key的string的值附加value
     substr(key, start, end)：返回名称为key的string的value的子串

로그인 후 복사

5. 6. 해시 연산을 위한 명령

 rpush(key, value)：在名称为key的list尾添加一个值为value的元素
     lpush(key, value)：在名称为key的list头添加一个值为value的 元素
     llen(key)：返回名称为key的list的长度
     lrange(key, start, end)：返回名称为key的list中start至end之间的元素（下标从0开始，下同）
     ltrim(key, start, end)：截取名称为key的list，保留start至end之间的元素
     lindex(key, index)：返回名称为key的list中index位置的元素
     lset(key, index, value)：给名称为key的list中index位置的元素赋值为value
     lrem(key, count, value)：删除count个名称为key的list中值为value的元素。count为0，删除所有值为value的元素，count>0      从头至尾删除count个值为value的元素，count<0从尾到头删除|count|个值为value的元素。
     lpop(key)：返回并删除名称为key的list中的首元素
     rpop(key)：返回并删除名称为key的list中的尾元素
     blpop(key1, key2,… key N, timeout)：lpop 命令的block版本。即当timeout为0时，若遇到名称为key i的list不存在或该list为空，则命令结束。如果 timeout>0，则遇到上述情况时，等待timeout秒，如果问题没有解决，则对key i+1开始的list执行pop操作。
     brpop(key1, key2,… key N, timeout)：rpop的block版本。参考上一命令。
     rpoplpush(srckey, dstkey)：返回并删除名称为srckey的list的尾元素，并将该元素添加到名称为dstkey的list的头部

로그인 후 복사

5. Redis 명명 규칙

Redis의 모든 데이터는 키-값 쌍, 즉 모든 데이터는 키 값(Key)을 통해서만 관리할 수 있으므로

명명 규칙을 표준화하세요. jedis 클라이언트에는 특별한 명명 규칙 생성 기능이 포함되어 있습니다. 코드 참조 예제 코드:

6. 참조

API:

http://www.php.cn/dic/54.html

더 많은 기능을 보려면 이 문서를 참조하여

더 보기 Redis 관련 기술 기사를 보려면

Redis Tutorial 칼럼을 방문하여 알아보세요!

위 내용은 Redis에는 어떤 API가 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!