redis的javaclientJedis简单封装

经过我们团队的一番讨论,终于决定使用redis来进行我们的业务缓存。redis会将数据缓存到内存中,执行效率会非常快。同一时候异步将数据写入到磁盘中。进行持久化。

且redis支持主从同步,支持分布式部署,支持N多数据结构,这对于我们有着莫大的吸引力。

參见:http://blog.csdn.net/yichenlian/article/details/27207383

我们团队讨论的焦点是在于redis的灾备恢复问题。

因为redis的持久化是异步的。总会有一点时间内存中数据和磁盘数据不同步的情况(当然能够设置成全然同步。那么用redis的意义就大打折扣了)。尽管没有找到尽善尽美的解决的方法。只是有一些网上的处理方式还是能够接受的。

參见:http://blog.csdn.net/xiangliangyu/article/details/8165644        随后我使用javaclientJedis对redis相关操作进行了一些系统的简单的封装。使用的是jedis的分布式连接池,这样方便于redis横向扩展,添加高可用性。封装思路:首先定义连接池类,封装连接池获取方式;对外为接口。接口定义的是redis常规操作,定义的方法基本与redis中一致,而且使用接口便于扩展;实现接口,我封装的实现类仅仅使用了分布式的方式(即ShardedJedis),也能够使用别的实现方式,能够自己扩展。

1.获取连接池:

简单配置JedisPoolConfig

JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
		jedisPoolConfig.setMaxTotal(maxTotal);//the max number of connection
		jedisPoolConfig.setMaxIdle(maxIdle);//the max number of free
		jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);//the longest time of waiting

设置JedisShardInfo(redis.clients.jedis.JedisShardInfo.JedisShardInfo(String
host, int port))

得到ShardedJedisPool(连接池):redis.clients.jedis.ShardedJedisPool.ShardedJedisPool(GenericObjectPoolConfig
poolConfig, List<JedisShardInfo> shards,Hashing
algo)

这样就得到了连接池。

2.定义接口,简单为上:

public interface JedisClientInterface {

	/**
	 * 写入一般的string类型的value
	 *
	 * @param key
	 * @param value
	 */
	void put(String key, String value);

	/**
	 * 读取String类型的value
	 *
	 * @param key
	 * @return
	 */
	String get(String key);
}

3.完毕实现类:

public class JedisClientShardImpl implements JedisClientInterface {
@Override
	public void put(String key, String value) {
		boolean flag = true;
		ShardedJedis shardedJedis = pool.getResource();
		try{
			if(shardedJedis!=null){
				shardedJedis.set(key, value);
			}
		}catch(Exception e){
			flag = false;
			e.printStackTrace();
		}finally{
			if (flag){
                           pool.returnResource(shardedJedis);
                        }else{
                           pool.returnBrokenResource(shardedJedis);
                        }
		}
	}

	@Override
	public String get(String key) {
		boolean flag = true;
		ShardedJedis shardedJedis = pool.getResource();
		try{
			if(shardedJedis!=null){
				return shardedJedis.get(key);
			}
		}catch(Exception e){
			flag = false;
			e.printStackTrace();
		}finally{
                        if (flag){
                           pool.returnResource(shardedJedis);
                        }else{
                           pool.returnBrokenResource(shardedJedis);
                        }
               }
               return null;
        }
}

至此,整个封装流程就走通了。

能够随意向下扩展了。

时间: 2024-08-04 14:10:27

redis的javaclientJedis简单封装的相关文章

redis的java客户端Jedis简单封装

经过我们团队的一番讨论,最终决定使用redis来进行我们的业务缓存.redis会将数据缓存到内存中,运行效率会很快.同时异步将数据写入到磁盘中,进行持久化. 且redis支持主从同步,支持分布式部署,支持N多数据结构,这对于我们有着莫大的吸引力. 参见:http://blog.csdn.net/yichenlian/article/details/27207383 我们团队讨论的焦点是在于redis的灾备恢复问题.由于redis的持久化是异步的,总会有一点时间内存中数据和磁盘数据不同步的情况(当

redis数据库操作的C++简单封装

用c++简单封装了redis的基本操作(hiredis) 接口包括:①链接和断开连接.②设置键值对(set).③查询键值对(get).④删除键值对(del).⑤将所有键显示出来 若任何一处发生错误,返回对应的错误状态码,同时可以调用getErrorMsg()查看错误信息 所有码包括: M_REDIS_OK = 0, //执行成功 M_CONNECT_FAIL = -1, //连接redis失败 M_CONTEXT_ERROR = -2, //RedisContext返回错误 M_REPLY_ER

Redis客户端连接方式Hiredis简单封装使用,连接池、屏蔽连接细节

工作需要对Hiredis进行了简单封装,实现功能: 1.API进行统一,对外只提供一个接口: 2.屏蔽上层应用对连接的细节处理: 3.底层采用队列的方式保持连接池,保存连接会话: 4.重连时采用时间戳进行控制,每隔一定时间(3s)重连一次,防止频繁重试造成的不必要浪费. 先看一下Hiredis的常用数据结构与API: //hiredis/hiredis.h /* Context for a connection to Redis */ typedef struct redisContext {

利用redis List队列简单实现秒杀 PHP代码实现

利用redis List队列简单实现秒杀 PHP代码实现 2018年05月28日 11:37:46 m_nanle_xiaobudiu 阅读数 35674更多 分类专栏: Redis 版权声明:本文为博主原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明. 本文链接:https://blog.csdn.net/m_nanle_xiaobudiu/article/details/80479666 一 生产者producer部分 ---------------------

JDBC简单封装

/** * JDBC简单封装 * 需要借助FastJsonUtil可以参考上一篇 * @author huangxincheng * */ public class BaseDao { private static String URL; private static String USERNAME; private static String PASSWORD; private static String DRIVER; private  Connection connection; priv

对系统网络请求进行简单封装

AGConnectionNet对系统网络请求进行简单封装,可便利的进行网络请求,并将数据解析与网络请求封装在同一方法下,使用更加便利(JSON 解析采用自身解析方法, XML 解析采用第三方 ReadXML 进行解析). 方法具体参数说明 初始化方法:/*** 类方法,实例化当前数据请求对象 (单例)** @return 当前请求对象*/+ (instancetype)shareRequestData; 仅进行请求数据方法/*** 请求数据 (session 请求)** @param URLSt

iOS sqlite 增删改查 简单封装(基于 FMDB)

/** *  对 sqlite 的使用进行简单封装,仅涉及简单的单表 增删改查 * *  基于 FMDB * *  操作基于 model ,数据库表字段与 model 属性一一对应,对 model 整体进行操作 * *  根据 model 对象自动建表,字段类型只支持 NSString , NSIteger , float * *  用到 runtime 运行时获取 model 属性 * */ 1 // 2 // AGDatabaseManager.h 3 // 4 // Created by

简单封装sqlite3 实现实体对象与关系型数据库的相关操作【IOS】

源码如下,只有一个类文件 // //  DBHelper.h // //  Created by Jason_Msbaby on 15/10/15. //  Copyright ? 2015年 张杰. All rights reserved. // /**  *  简单封装了对于sqlite的使用 没有加入对事务及其他复杂的特性     基于传入sql语句的方式进行执行     使用单例模式     根据model对象自动创建表 只支持 NSInter NSString float 数据类型的支

httpclient4.3简单封装

对httpclient4.3版本的一个简单封装,下面是代码 /**  * httputil工具类  *   * @author rex  */ public class HttpUtil {     private static CloseableHttpClient client;     private static BasicCookieStore cookieStore;     private static HttpGet get;     private static HttpPos