首页 \ 教程 \ redis

redis教程

redis集群与主从配置

redis 基础教程

redis 数据类型

Redis 高级教程

知识点

Redis

使用连接池操作redis

Oceanus连接池的相关配置

httpclient 使用连接池管理http请求对象

JDBC系列教程之十五：数据源和连接池

tomcat连接池和mysql数据库的中文乱码

项目中用连接池管理Connection,connection用完后还关闭吗？

httpclient 关闭连接池中无效连接

redis 集群环境搭建-redis集群管理

solrcloud分布式集群部署及索引操作实例

Redis Lua脚本操作

Redis 客户端连接、密码验证、连接数设置

MapReduce的一对多连接操作

redis安装-redis集群管理

redis 集群使用主从复制架构-redis集群管理

redis新增集群节点-redis集群管理

使用集群式的连接池操作redis

2019-03-19 21:34|来源: 网路

集群式连接池和普通的连接池主要的区别是：

1、普通连接池使用的是 JedisPool

2、集群式连接池使用的是 ShardedJedisPool

普通连接池的创建方式在上一节已经介绍过了，本次介绍集群式连接池的创建方式

// 定义集群信息

List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();

shards.add(new JedisShardInfo("127.0.0.1", 6379));

shards.add(new JedisShardInfo("127.0.0.1", 6380));

// 定义集群连接接

ShardedJedisPool shardedJedisPool = new ShardedJedisPool(poolConfig, shards);

示例：

package com._656463.redis;
 
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 ShardedJedisPoolDemo {
 
    public static void main(String[] args) {
        // 构建连接池配置对象
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        // 设置最大连接数
        poolConfig.setMaxTotal(50);
 
        // 定义集群信息
        List<JedisShardInfo> shards = new ArrayList<JedisShardInfo>();
        shards.add(new JedisShardInfo("127.0.0.1", 6379));
        shards.add(new JedisShardInfo("127.0.0.1", 6380));
 
        // 定义集群连接接
        ShardedJedisPool shardedJedisPool = new ShardedJedisPool(poolConfig,
                shards);
        ShardedJedis shardedJedis = null;
        try {
            // 从连接池中获取到jedis分片对象
            shardedJedis = shardedJedisPool.getResource();
 
            for (int i = 0; i < 100; i++) {
                shardedJedis.set("key" + i, "value" + i);
            }
 
            // 从redis中获取数据
            String value = shardedJedis.get("mytest");
            System.out.println(value);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            if (null != shardedJedis) {
                // 关闭，检测连接是否有效，有效则放回到连接池中，无效则重置状态
                shardedJedis.close();
            }
        }
 
        // 关闭连接池，正常使用的时候，不用关闭
        shardedJedisPool.close();
    }
}

本文参数网络