用Java搭建一套访问redis的API

1. 创建一个RedisClient类

package com.jason.study.redis.jedisPool;import org.apache.log4j.Logger;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;import java.util.List;
import java.util.Map;
import java.util.Set;/*** @author denglinjie*/
public class RedisClient {private final static Logger log = Logger.getLogger(RedisClient.class);private String serverIP;private int port;private JedisPool pool = null;private int timeout;private String auth;public RedisClient(String serverIP, int port, int timeout, String auth){JedisPoolConfig config = new JedisPoolConfig();this.serverIP = serverIP;this.port = port;this.timeout = timeout;this.auth = auth;if("".equals(auth))auth = null;pool = new JedisPool(config,serverIP, port,timeout,auth);}public void rPush(String key ,String value){Jedis jedis = null;try {jedis =  pool.getResource();if(jedis == null){if(!isAlive()){return ;}  }jedis.rpush(key, value);}catch(Exception e){if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);}finally{if(jedis != null)pool.returnResource(jedis);}}public void lPush(String key ,String value){Jedis jedis = null;try {jedis =  pool.getResource();if(jedis == null){if(!isAlive()){return ;}  }jedis.lpush(key, value);}catch(Exception e){if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);}finally{if(jedis != null)pool.returnResource(jedis);}}public long lRem(String key,String value){Jedis jedis = null;try {jedis =  pool.getResource();if(jedis == null){if(!isAlive()){return 0l ;}}return jedis.lrem(key, 0,value);}catch(Exception e){if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);}finally{if(jedis != null)pool.returnResource(jedis);}return 0l;}public List<String> lRange(String key,long start,long end){Jedis jedis = null;try {jedis =  pool.getResource();if(jedis == null){if(!isAlive()){return null ;}   }return jedis.lrange(key, start, end);}catch(Exception e){if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);}finally{if(jedis != null)pool.returnResource(jedis);}return null;}public void zAdd(String key, double score, String value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return;}jedis.zadd(key, score, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}}public Double zincrby(String key, double score, String value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0d;}return jedis.zincrby(key, score, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zAdd error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0d;}public long zRemByScore(String key, double score) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.zremrangeByScore(key, score, score);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zRemByScore error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public Set<String> zRange(String key, int start, int end) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.zrange(key, start, end);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zRange error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Long zrank(String key, String member) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0l;}return jedis.zrevrank(key, member);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zRange error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0l;}public Set<String> zrevrange(String key, int start, int end) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.zrevrange(key, start, end);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zRange error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Long zreRank(String key, String member) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return -1L;}Long result= jedis.zrevrank(key, member);pool.returnResource(jedis);return result;} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zreRank error , ip =" + serverIP + " , port = " + port, e);} finally {}return -1L;}public long zLen(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.zcard(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zLen error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public Double zscore(String key, String value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return (double) 0;}return jedis.zscore(key, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zscore error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return (double) 0L;}public Long zcount(String key, Double min, Double max) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.zcount(key, min, max);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zcount error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public long sAdd(String key, String member) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.sadd(key, member);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient sAdd error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public String get(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.get(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient sAdd error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public long sRem(String key, String member) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.srem(key, member);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient sRem error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public boolean sIsMember(String key, String member) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return false;}return jedis.sismember(key, member);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient sIsMember error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return false;}public Long strIncr(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.incr(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strIncr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Long incrBy(String key, long num) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}Long result = jedis.incrBy(key, num);pool.returnResource(jedis);return result;} catch (Exception e) {if (jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient incrBy error , ip =" + serverIP + " , port = " + port, e);}return null;}public Long strdecrBy(String key, long num) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.decrBy(key, num);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecrBy error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Long strdecr(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.decr(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public boolean isAlive(){boolean isConnected = false;Jedis jedis = null;try{jedis = pool.getResource();if(jedis == null){return false;}isConnected = jedis.isConnected();}catch(Exception e){if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient isAlive error , ip =" + serverIP + " , port = " + port, e);}finally{if(jedis != null)pool.returnResource(jedis);}return isConnected;}public String set(String key, String value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.set(key, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Set<String> smembers(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.smembers(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public long llen(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0l;}return jedis.llen(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0l;}public long del(String... keys) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.del(keys);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient del error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public Set<String> keys(String pattern) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.keys(pattern);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient keys error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public boolean exists(String pattern) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return false;}return jedis.exists(pattern);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient keys error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return false;}public Long expire(String key, int ttl) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.expire(key, ttl);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient expire error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public String srandomMember(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.srandmember(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient srandomemember error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public List<String> srandomMember(String key, int size) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}List<String> list = jedis.srandmember(key, size);if (jedis != null)pool.returnResource(jedis);return list;} catch (Exception e) {if (jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient srandomemember error , ip =" + serverIP + " , port = " + port, e);}return null;}public String hmset(String key, Map<String, String> value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hmset(key, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public List<String> hmget(String key, String... fields) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hmget(key, fields);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Set<String> hkeys(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hkeys(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public Map<String, String> hgetAll(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hgetAll(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient strdecr error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public long zrem(String key, String[] members) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.zrem(key, members);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zrem error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public Set<String> zrangeByScore(String key, double min, double max) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.zrangeByScore(key, min, max);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient zrangeByScore error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public long srem(String key, String[] members) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.srem(key, members);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient sRem members error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public long hset(String key, String field, String value) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0;}return jedis.hset(key, field, value);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient hset error , ip =" + serverIP + " , port = "+ port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0;}public String hget(String key, String field) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hget(key, field);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient hget error , ip =" + serverIP + " , port = "+ port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public List<String> hvals(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return null;}return jedis.hvals(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient hvals error , ip =" + serverIP + " , port = "+ port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return null;}public long hlen(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.hlen(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient hlen error , ip =" + serverIP + " , port = "+ port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public long hdel(String key, String[] fields) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.hdel(key, fields);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient hdel error , ip =" + serverIP + " , port = "+ port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}public Long ttl(String key) {Jedis jedis = null;try {jedis = pool.getResource();if (jedis == null) {return 0L;}return jedis.ttl(key);} catch (Exception e) {if(jedis != null)pool.returnBrokenResource(jedis);log.error("RedisClient ttl error , ip =" + serverIP + " , port = " + port, e);} finally {if (jedis != null)pool.returnResource(jedis);}return 0L;}
}

2. 创建一个获取RedistClient的工厂类

package com.jason.study.redis.jedisPool;/*** Created by denglinjie on 2016/8/19.*/
public class JedisFactory {public static RedisClient getRedisClient() {String ip = "10.10.10.10";int port = 10006;int timeout = 3000;String auth = "123456";return new RedisClient(ip, port, timeout, auth);}
}

3. 测试类

package com.jason.study.redis.jedisPool;import org.junit.Test;/*** Created by denglinjie on 2016/8/19.*/
public class TestJedisPool {@Testpublic void testPool() {RedisClient redisClient = JedisFactory.getRedisClient();System.out.println(redisClient.hget("key", "field"));System.out.println(redisClient.exists("key"));}
}

用Java搭建一套访问redis的API相关推荐

基于 Node.js 爬虫的数据 API，搭建一套属于自己的 API 数据
SpliderApi https://github.com/ecitlm/Spl... 基于nodejs 的爬虫 API接口项目,包括前端开发日报.知乎日报.前端top框架排行.妹纸福利.搞笑视频/ ...
基于springboot+bootstrap+mysql+redis搭建一套完整的权限架构【八】【完善整个项目】
上一章我们已经完成了菜单模块的开发工作,那么到了本章我们将完成我们角色管理模块的开发工作,在本章开始一个全新的模块进行开发的时候我们需要遵守一定的命名和开发规范如下: 1.我们的Controller的 ...
java token redis生成算法_如何访问 Redis 中的海量数据，服务才不会挂掉？
来源:www.toutiao.com/i6697540366528152077 一.前言有时候我们需要知道线上的Redis的使用情况,尤其需要知道一些前缀的key值,让我们怎么去查看呢?并且通常情况 ...
centos 7下的redis 环境搭建以及C语言使用hiredis访问redis
系统 CentOS7 Redis 官网下载 https://redis.io/download 1.下载解压 [root@TestServer-DFJR programs]# /usr/loca ...
手把手0基础项目实战（一）——教你搭建一套可自动化构建的微服务框架(SpringBoot+Dubbo+Docker+Jenkins)...
本文你将学到什么? 本文将以原理+实战的方式,首先对"微服务"相关的概念进行知识点扫盲,然后开始手把手教你搭建这一整套的微服务系统. 项目完整源码下载 https://github ...
idea ssm框架搭建详细步骤_搭建一套纯净版的SSM框架，随时CV使用它不香吗？
之前的时候写过一篇文章,因为各种原因,需要搭建一套ssm框架,上次的时候就是搭建了一套框架,但是其中相应的代码实现并没有添加进去,今天咱就完整起来,搭建一个测试代码,当然大家不需要非要用我的,再网上有 ...
手把手0基础项目实战（一）——教你搭建一套可自动化构建的微服务框架(SpringBoot+Dubbo+Docker+Jenkins)......
手把手0基础项目实战(一)--教你搭建一套可自动化构建的微服务框架(SpringBoot+Dubbo+Docker+Jenkins)... 原文: 手把手0基础项目实战(一)--教你搭建一套可自动化构 ...
0基础教你搭建一套可自动化构建的微服务框架(SpringBoot+Dubbo+Docker+Jenkins)
2019独角兽企业重金招聘Python工程师标准>>> 本文你将学到什么? 本文将以原理+实战的方式,首先对"微服务"相关的概念进行知识点扫盲,然后开始手把手教你 ...
阿里高级微服务架构师亲手教你搭建一套可自动化构建的微服务框架
这套微服务框架能干啥? 这套系统搭建完之后,那可就厉害了: 微服务架构你的整个应用程序将会被拆分成一个个功能独立的子系统,独立运行,系统与系统之间通过RPC接口通信.这样这些系统之间的耦合度大大降低 ...

用Java搭建一套访问redis的API

用Java搭建一套访问redis的API相关推荐

最新文章

热门文章