Java Redis线程池ShardedJedisPool 使用方法,Java Jedis连接池的使用

Java 2016-08-22 16:45:00 6530

Jedis  Redis  提供的以 Java  API 方式操作 Redis  方式。下面来介绍一下 Redis   Jedis  的连接池使用方式。

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 RedisShardPoolDemo {
    
    final 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 = "123.0.0.1";
        int portA = 6379;
        String hostB = "123.0.0.2";
        int portB = 6379;
        List jdsInfoList =new ArrayList(2);
        JedisShardInfo infoA = new JedisShardInfo(hostA, portA);
        infoA.setPassword("pswd");
        JedisShardInfo infoB = new JedisShardInfo(hostB, portB);
        infoB.setPassword("pswd");
        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++);
    }
}

版权所属:SO JSON在线解析

原文地址:https://www.sojson.com/blog/106.html

转载时必须以链接形式注明原始出处及本声明。

本文主题:

如果本文对你有帮助,那么请你赞助我,让我更有激情的写下去,帮助更多的人。

关于作者
Java是一种简单的,面向对象的,分布式的,解释型的,健壮安全的,结构中立的,可移植的,性能优异、多线程的动态语言。本人发布一些简单的资料和Demo!
相关文章
Java Redis线程ShardedJedisPool 使用方法Java Jedis连接池使用
Java 解析JSON,JSON-LIB jar包下载和使用
Java客户端JedisRedis的的八种调用方式(事务、管道、分布式)介绍及测试
Redis教程,Redis集群搭建与Spring-data-redis使用(介绍篇)
Redis教程,Redis集群搭建与Spring-data-redis使用(Spring-data-redis使用篇)
Java 获取时间戳的方法大全,以及速度比较
Redis教程,Redis集群搭建与Spring-data-redis使用(集群搭建篇)
Shiro教程(八)Shiro Freemarker标签的使用
SpringMVC + Freemarker 模版的使用
JavaScript function 类型的使用说明
最新文章
Springboot 集成Aliyun MQ消息队列,Aliyun 消息队列配置及代码实现 13
SpringBoot 集成Spring-data-redis,redis对象序列化存储 18
天气API,全国天气 JSON API接口,可以获取十五天的天气预报 57
Springboot + Freemarker 集成配置 112
DNS查询, DNS测速检查接口,DNS测速接口 24
Mysql 并发插入、存在不插入,存在更新操作 44
SOJSON 阿里云活动达到67人,最终获得5年的1核2GB的ECS服务器使用权益 39
Java 完美解析.plist & 生成plist ,Android 解析.plist 36
Java SHA1的几种实现方式,Java SHA1 签名 58
Mac下Charles-proxy 抓包工具,iPhone 抓包演示 20
最热文章
Elasticsearch教程(四) elasticsearch head 插件安装和使用 117319
Elasticsearch教程(六) elasticsearch Client创建 75920
Elasticsearch教程(八) elasticsearch delete 删除数据(Java) 72387
Elasticsearch教程(二),IK分词器安装 70275
免费天气API,全国天气 JSON API接口,可以获取五天的天气预报 64788
Elasticsearch教程(一),全程直播(小白级别) 57931
Elasticsearch教程(五) elasticsearch Mapping的创建 55847
Elasticsearch教程(三),IK分词器安装 (极速版) 55149
Elasticsearch教程(七) elasticsearch Insert 插入数据(Java) 50459
Elasticsearch权威指南-中文.pdf,Elasticsearch 中文文档下载 43367
支付扫码

所有赞助/开支都讲公开明细,用于网站维护:赞助名单查看

正在加载... ...