package com.test; import java.util.ArrayList; import java.util.List; import redis.clients.jedis.JedisPoolConfig; import redis.clients.jedis.JedisShardInfo; import redis.clients.jedis.ShardedJedis; import redis.clients.jedis.ShardedJedisPool; public class RedisShardPoolTest { static ShardedJedisPool pool; static{ JedisPoolConfig config =new JedisPoolConfig();//Jedis池配置 config.setMaxActive(500);//最大活动的对象个数 config.setMaxIdle(1000 * 60);//对象最大空闲时间 config.setMaxWait(1000 * 10);//获取对象时最大等待时间 config.setTestOnBorrow(true); String hostA = "192.168.0.100"; int portA = 6379; String hostB = "192.168.0.115"; int portB = 6379; List<JedisShardInfo> jdsInfoList =new ArrayList<JedisShardInfo>(2); JedisShardInfo infoA = new JedisShardInfo(hostA, portA); infoA.setPassword("admin"); JedisShardInfo infoB = new JedisShardInfo(hostB, portB); infoB.setPassword("admin"); jdsInfoList.add(infoA); jdsInfoList.add(infoB); pool =new ShardedJedisPool(config, jdsInfoList); } /** * @param args */ public static void main(String[] args) { for(int i=0; i<100; i++){ String key = generateKey(); ShardedJedis jds = null; try { jds = pool.getResource(); System.out.println(key+":"+jds.getShard(key).getClient().getHost()); System.out.println(jds.set(key,Math.random()+"")); } catch (Exception e) { e.printStackTrace(); } finally { pool.returnResource(jds); } } } private static int index = 1; public static String generateKey(){ return String.valueOf(Thread.currentThread().getId())+"_"+(index++); } }
相关推荐
Java Redis线程池ShardedJedisPool 使用方法,Java Jedis连接池的使用
jedis配置,使用了ShardedJedisPool 连接池。适合初学者了解原理。
使用实例 static ShardedJedisPool shareJedisPool; static List<JedisShardInfo> jdsInfoList =new ArrayList(); static{ JedisPoolConfig config =new JedisPoolConfig();//Jedis池配置 config.setMaxActive...
jedis客户端 /** * 非切片客户端链接 */ private Jedis jedis; /** * 非切片链接池 */ private JedisPool jedisPool; /** * 切片客户端链接 ... private ShardedJedisPool shardedJedisPool;
尝试使用连接池,包括单机的JedisPool,分布式的ShardedJedisPool,并进行相关操作。直接运行Infrastructure.java 2017/11/23 version 1.2 修改了jedis释放的逻辑,不能不管什么情况都一律使用returnResource()。...
包含redis源码,哨兵多节点分片连接池扩展实现代码,ShardedJedisPool分片连接池测试类实现,JedisSentinelPool哨兵连接池测试类实现,JedisPool连接池测试实现类,
针对电商分布式系统的基础架构实现 环境搭建 整体架构 Mysql集群 Redis集群 负载均衡针对不同的场景采用不同的...ShardedJedisPool 无法处理结点宕机问题,需要在结点异常时通过 zookeeper 获取最新的可访问结点列表
自己编写的基于jedis的客户端工具,最大亮点,支持多个redis数据源,启动后自动进行检测连接是否可用,同时还支持...支持切片客户端连接池:ShardedJedisPool 和 指定客户端连接池:JedisPool。轻量级,好用,不解释。