您现在的位置是:首页 > 正文

Redis系列-JAVA与redis整合-JedisPool的使用

2024-01-30 19:46:49阅读 2

JedisPoolAPI


package com.jedis;

import java.util.LinkedList;
import java.util.List;
import java.util.ResourceBundle;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;
import redis.clients.jedis.ShardedJedis;
import redis.clients.jedis.ShardedJedisPool;

/**
 * jedis池使用
 * @author 
 * 
 */
public class MyJedisPool {
	
	//jedis池
	private static JedisPool pool; 
	//shardedJedis池
	private static ShardedJedisPool shardPool;
	//静态代码初始化池配置
	static { 
		//加载redis配置文件
	    ResourceBundle bundle = ResourceBundle.getBundle("redis");  
	    if (bundle == null) {  
	        throw new IllegalArgumentException("[redis.properties] is not found!");  
	    } 
	    //创建jedis池配置实例
	    JedisPoolConfig config = new JedisPoolConfig(); 
	    
	    int maxActivity = Integer.valueOf(bundle.getString("redis.pool.maxActive"));
	    int maxIdle = Integer.valueOf(bundle.getString("redis.pool.maxIdle"));
	    long maxWait = Long.valueOf(bundle.getString("redis.pool.maxWait"));
	    boolean testOnBorrow = Boolean.valueOf(bundle.getString("redis.pool.testOnBorrow"));
	    boolean onreturn = Boolean.valueOf(bundle.getString("redis.pool.testOnReturn"));
	    //设置池配置项值
	    config.setMaxActive(maxActivity);  
	    config.setMaxIdle(maxIdle);  
	    config.setMaxWait(maxWait);  
	    config.setTestOnBorrow(testOnBorrow);  
	    config.setTestOnReturn(onreturn);  
	    
	    //根据配置实例化jedis池
	    pool = new JedisPool(config, bundle.getString("redis.ip"), 
	    		Integer.valueOf(bundle.getString("redis.port")));
	    
	    //创建多个redis共享服务
	    JedisShardInfo jedisShardInfo1 = new JedisShardInfo(  
                bundle.getString("redis1.ip"), Integer.valueOf(bundle.getString("redis.port")));  
	    
	    JedisShardInfo jedisShardInfo2 = new JedisShardInfo(  
                bundle.getString("redis2.ip"), Integer.valueOf(bundle.getString("redis.port"))); 
  
	    List<JedisShardInfo> list = new LinkedList<JedisShardInfo>();  
	    list.add(jedisShardInfo1);  
	    list.add(jedisShardInfo2);
	    
	    //根据配置文件,创建shared池实例
	    shardPool = new ShardedJedisPool(config, list);
	}
	
	/**
	 * 测试jedis池方法
	 */
	public static void test1(){
		//从jedis池中获取一个jedis实例
		Jedis jedis = pool.getResource();
				
		//获取jedis实例后可以对redis服务进行一系列的操作
		jedis.set("name", "jack");
		System.out.println(jedis.get("name"));
		jedis.del("name");
		System.out.println(jedis.exists("name"));
		
		//释放对象池,即获取jedis实例使用后要将对象还回去
		pool.returnResource(jedis);		
	}
	
	/**
	 * 测试shardedJedis池方法
	 */
	public static void test2(){
		//从shard池中获取shardJedis实例
		ShardedJedis shardJedis = shardPool.getResource();
		
		//向redis服务插入两个key-value对象
		shardJedis.set("aaa", "jackson_aaa");
		System.out.println(shardJedis.get("aaa"));
		shardJedis.set("zzz", "jackson_zzz");
		System.out.println(shardJedis.get("zzz"));
		
		//释放资源
		shardPool.returnResource(shardJedis);
	}
	
	public static void main(String[] args) {
		//test1();//执行test1方法
		test2();//执行test2方法
	}
	
}


配置文件

########jedis##pool#############
#IP#redis1 server host# 
redis.ip=192.168.1.234

redis1.ip=192.168.1.234
#IP#redis2 server host# 
redis2.ip=192.168.1.235
#Port#redis server port#
redis.port=6379

redis.pool.maxActive=1024
redis.pool.maxIdle=200
redis.pool.maxWait=1000
redis.pool.testOnBorrow=true
redis.pool.testOnReturn=true


相关文章推荐

http://m.oschina.net/blog/101027

http://buerkai.iteye.com/blog/1626508

网站文章

  • Java集合

    【代码】Java集合。

    2024-01-30 19:46:41
  • Redis系列——第四章 Redis发布订阅模式

    Redis系列——第四章 Redis发布订阅模式

    Redis系列 Redis系列——第一章 Redis配置文件 Redis系列——第二章 Redis数据类型以及基本使用 Redis系列——第三章 Redis开启事务并实现乐观锁 Redis系列——第四章 Redis发布订阅模式 Redis系列——第五章 Redis持久化策略RDB与AOF Redis系列——第六章 Redis主从同步 Redis系列——第七章 Redis开启哨兵模式 ...

    2024-01-30 19:46:13
  • 数字化研发项目方案(下)

    数字化研发项目方案(下)

    IETP的主要功能包括通用的人机交互界面,方便用户快速定位、浏览所需内容的导航树,提供电子技术手册图文对照浏览功能,支持语音、视频、虚拟仿真等其他多媒体格式,对于故障隔离等具有决策树支持的工作,可以通...

    2024-01-30 19:45:57
  • linux nss升级,Linux系统升级

    首先查看当前版本信息# uname -aLinux localhost.localdomain3.10.0-123.el7.x86_64 #1 SMP Mon Jun 30 12:09:22 UTC ...

    2024-01-30 19:45:30
  • UniApp开发安卓以及H5实现页面级权限管理,避免用户浏览器直接输入url访问页面 最新发布

    UniApp开发安卓以及H5实现页面级权限管理,避免用户浏览器直接输入url访问页面 最新发布

    uni-app如何像vue-router中的beforeEach一样实现跳转拦截功能呢?为此uniapp官方提供了专门的API方法。

    2024-01-30 19:45:22
  • Mac M1安装Homebrew记录

    Mac M1安装Homebrew记录

    由于我是从老的MacBook Pro迁移到M1的,所以老的Homebrew版本在M1 ARM上已经不可用了。

    2024-01-30 19:45:15
  • C#无边框窗体移动代码

    #region 窗体移动 private Point mouseOff;//鼠标移动位置变量 private bool leftFlag;//标签是否为左键 ...

    2024-01-30 19:44:44
  • 基于G.1070的视频质量无参考打分集成回顾

    一、前言摆在面前的一个问题:视频会议在大规模使用后,如何评估、如何监控线上视频质量?视频质量的评估方法通常有有参考评估、无参考评估、半参考评估。其中:有参考评估需要原始视频和经过损伤的有损视频,通常原始视频不易获取,并且评估耗时较多;无参考评估仅需要有损视频即可进行,但结果与主观打分的符合度相对有参考要差一些,但好在耗时不多;半参考评估比较鸡肋,虽然不需要原始视频,但需要原始视频的部...

    2024-01-30 19:44:31
  • jquery validate 动态添加自定义校验规则

    需求:再已有验证(也是基于validate插件,验证功能写在表单中,不是用js代码,如:required写在input中)基础上如何自定义,并动态绑定到指定元素上,并通过$("#formid").va...

    2024-01-30 19:44:24
  • webgl - 3- 绘制三角形(上)

    webgl - 3- 绘制三角形(上)

    三角形是一个最简单,稳定的面,webgl中的三维模型都是由三角形面组成的。本章节目标:1.理解多点绘图原理2.可以绘制三角形,并将其组合成多边形。知识点:换缓冲区对象点,线,面图像第一章webgl的绘...

    2024-01-30 19:43:54