`
konin
  • 浏览: 10211 次
  • 性别: Icon_minigender_1
  • 来自: 武汉
社区版块
存档分类
最新评论

Redis实战之Redis + Jedis(转自CSDN)

redis 
阅读更多

 

用Memcached，对于缓存对象大小有要求，单个对象不得大于1MB，且不支持复杂的数据类型，譬如SET

等。基于这些限制，有必要考虑Redis！

相关链接：

Redis实战

Redis实战之Redis + Jedis

Redis实战之征服 Redis + Jedis + Spring （一）

Redis实战之征服 Redis + Jedis + Spring （二）

Redis实战之征服 Redis + Jedis + Spring （三）

 

言归正传，目前Redis大概有3中基于Java语言的Client：
?Jredis
?Jedis
?Redis4J

这里只说Jedis，因为它是官方提供的唯一Redis Client For Java Provider！

 

一、简单使用Jedis

需要Jedis就从Maven获取吧！
Maven Pom.xml

 

 

Xml代码 
<dependency> 
    <groupId>redis.clients</groupId> 
    <artifactId>jedis</artifactId> 
    <version>2.1.0</version> 
    <type>jar</type> 
    <scope>compile</scope> 
</dependency> 

 

 

[xml] view plain copy
<dependency> 
    <groupId>redis.clients</groupId> 
    <artifactId>jedis</artifactId> 
    <version>2.1.0</version> 
    <type>jar</type> 
    <scope>compile</scope> 
</dependency> 

 


 

 

 

如果只是简单使用Jedis，以下这么几行代码足够：

 

 

Java代码 
Jedis jedis = new Jedis("10.11.20.140"); 
String keys = "name"; 
 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, "snowolf"); 
// 取数据 
String value = jedis.get(keys); 
 
System.out.println(value); 

 

 

[java] view plain copy
Jedis jedis = new Jedis("10.11.20.140"); 
String keys = "name"; 
 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, "snowolf"); 
// 取数据 
String value = jedis.get(keys); 
 
System.out.println(value); 

 


 

 

二、池化使用Jedis

Jedis使用commons-pool完成池化实现。

先做个配置文件：

 

Properties代码 
#最大分配的对象数 
redis.pool.maxActive=1024 
#最大能够保持idel状态的对象数 
redis.pool.maxIdle=200 
#当池内没有返回对象时，最大等待时间 
redis.pool.maxWait=1000 
#当调用borrow Object方法时，是否进行有效性检查 
redis.pool.testOnBorrow=true 
#当调用return Object方法时，是否进行有效性检查 
redis.pool.testOnReturn=true 
#IP 
redis.ip=10.11.20.140 
#Port 
redis.port=6379 

 


 

 

 在静态代码段中完成初始化：

 

 

Java代码 
private static JedisPool pool; 
static { 
    ResourceBundle bundle = ResourceBundle.getBundle("redis"); 
    if (bundle == null) { 
        throw new IllegalArgumentException( 
                "[redis.properties] is not found!"); 
    } 
    JedisPoolConfig config = new JedisPoolConfig(); 
    config.setMaxActive(Integer.valueOf(bundle 
            .getString("redis.pool.maxActive"))); 
    config.setMaxIdle(Integer.valueOf(bundle 
            .getString("redis.pool.maxIdle"))); 
    config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait"))); 
    config.setTestOnBorrow(Boolean.valueOf(bundle 
            .getString("redis.pool.testOnBorrow"))); 
    config.setTestOnReturn(Boolean.valueOf(bundle 
            .getString("redis.pool.testOnReturn"))); 
    pool = new JedisPool(config, bundle.getString("redis.ip"), 
            Integer.valueOf(bundle.getString("redis.port"))); 
} 

 

 

[java] view plain copy
private static JedisPool pool; 
static { 
    ResourceBundle bundle = ResourceBundle.getBundle("redis"); 
    if (bundle == null) { 
        throw new IllegalArgumentException( 
                "[redis.properties] is not found!"); 
    } 
    JedisPoolConfig config = new JedisPoolConfig(); 
    config.setMaxActive(Integer.valueOf(bundle 
            .getString("redis.pool.maxActive"))); 
    config.setMaxIdle(Integer.valueOf(bundle 
            .getString("redis.pool.maxIdle"))); 
    config.setMaxWait(Long.valueOf(bundle.getString("redis.pool.maxWait"))); 
    config.setTestOnBorrow(Boolean.valueOf(bundle 
            .getString("redis.pool.testOnBorrow"))); 
    config.setTestOnReturn(Boolean.valueOf(bundle 
            .getString("redis.pool.testOnReturn"))); 
    pool = new JedisPool(config, bundle.getString("redis.ip"), 
            Integer.valueOf(bundle.getString("redis.port"))); 
} 

 


 

 然后，修改前面那段jedis操作Redis

 

Java代码 
// 从池中获取一个Jedis对象 
Jedis jedis = pool.getResource(); 
String keys = "name"; 
 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, "snowolf"); 
// 取数据 
String value = jedis.get(keys); 
 
System.out.println(value); 
 
// 释放对象池 
pool.returnResource(jedis); 

 

 

[java] view plain copy
// 从池中获取一个Jedis对象 
Jedis jedis = pool.getResource(); 
String keys = "name"; 
 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, "snowolf"); 
// 取数据 
String value = jedis.get(keys); 
 
System.out.println(value); 
 
// 释放对象池 
pool.returnResource(jedis); 

 


 

 改为从对象池中，获取Jedis实例：

 

 

Java代码 
// 从池中获取一个Jedis对象 
Jedis jedis = pool.getResource(); 

 

 

[java] view plain copy
// 从池中获取一个Jedis对象 
Jedis jedis = pool.getResource(); 

 


 

 

 

 切记，最后使用后，释放Jedis对象：

 

 

Java代码 
// 释放对象池 
pool.returnResource(jedis); 

 

 

[java] view plain copy
// 释放对象池 
pool.returnResource(jedis); 

 


 

 

 

三、一致性哈希

 

Memcached完全基于分布式集群，而Redis是Master-Slave，如果想把Reids，做成集群模式，无外乎多做几套Master-Slave，每套Master-Slave完成各自的容灾处理，通过Client工具，完成一致性哈希。

PS:Memcached是在Server端完成Sharding，Redis只能依靠各个Client做Sharding。可能会在Redis 3.0系列支持Server端Sharding。

 

保留前面的JedisPoolConfig，新增两个Redis的IP（redis1.ip，redis2.ip），完成两个JedisShardInfo实例，并将其丢进List中：

 

 

Java代码 
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); 

 

 

[java] view plain copy
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); 

 


 

 初始化ShardedJedisPool代替JedisPool：

 

 

Java代码 
ShardedJedisPool pool = new ShardedJedisPool(config, list); 

 

 

[java] view plain copy
1.ShardedJedisPool pool = new ShardedJedisPool(config, list); 

 


 

 改由ShardedJedis，获取Jedis对象：

 

 

Java代码 
// 从池中获取一个Jedis对象 
ShardedJedis jedis = pool.getResource(); 
String keys = "name"; 
String value = "snowolf"; 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, value); 
// 取数据 
String v = jedis.get(keys); 
 
System.out.println(v); 
 
// 释放对象池 
pool.returnResource(jedis); 

 

 

[java] view plain copy
// 从池中获取一个Jedis对象 
ShardedJedis jedis = pool.getResource(); 
String keys = "name"; 
String value = "snowolf"; 
// 删数据 
jedis.del(keys); 
// 存数据 
jedis.set(keys, value); 
// 取数据 
String v = jedis.get(keys); 
 
System.out.println(v); 
 
// 释放对象池 
pool.returnResource(jedis); 

 


 

 

 

 

四、Spring封装参考

 Ok，完成上述代码足够完成简单任务，如果有必要，可以用Spring封装初始化：

 

 

Xml代码 
<context:property-placeholder location="classpath:redis.properties" /> 
<bean 
    id="jedisPoolConfig" 
    class="redis.clients.jedis.JedisPoolConfig" 
> 
    <property 
        name="maxActive" 
        value="${redis.pool.maxActive}" /> 
    <property 
        name="maxIdle" 
        value="${redis.pool.maxIdle}" /> 
    <property 
        name="maxWait" 
        value="${redis.pool.maxWait}" /> 
    <property 
        name="testOnBorrow" 
        value="${redis.pool.testOnBorrow}" /> 
</bean> 
<bean 
    id="shardedJedisPool" 
    class="redis.clients.jedis.ShardedJedisPool" 
> 
    <constructor-arg 
        index="0" 
        ref="jedisPoolConfig" /> 
    <constructor-arg index="1"> 
        <list> 
            <bean class="redis.clients.jedis.JedisShardInfo"> 
                <constructor-arg 
                    index="0" 
                    value="${redis1.ip}" /> 
                <constructor-arg 
                    index="1" 
                    value="${redis.port}" 
                    type="int" /> 
            </bean> 
            <bean class="redis.clients.jedis.JedisShardInfo"> 
                <constructor-arg 
                    index="0" 
                    value="${redis2.ip}" /> 
                <constructor-arg 
                    index="1" 
                    value="${redis.port}" 
                    type="int" /> 
            </bean> 
        </list> 
    </constructor-arg> 
</bean> 

 

 

[xml] view plain copy
<context:property-placeholder location="classpath:redis.properties" /> 
<bean 
    id="jedisPoolConfig" 
    class="redis.clients.jedis.JedisPoolConfig" 
> 
    <property 
        name="maxActive" 
        value="${redis.pool.maxActive}" /> 
    <property 
        name="maxIdle" 
        value="${redis.pool.maxIdle}" /> 
    <property 
        name="maxWait" 
        value="${redis.pool.maxWait}" /> 
    <property 
        name="testOnBorrow" 
        value="${redis.pool.testOnBorrow}" /> 
</bean> 
<bean 
    id="shardedJedisPool" 
    class="redis.clients.jedis.ShardedJedisPool" 
> 
    <constructor-arg 
        index="0" 
        ref="jedisPoolConfig" /> 
    <constructor-arg index="1"> 
        <list> 
            <bean class="redis.clients.jedis.JedisShardInfo"> 
                <constructor-arg 
                    index="0" 
                    value="${redis1.ip}" /> 
                <constructor-arg 
                    index="1" 
                    value="${redis.port}" 
                    type="int" /> 
            </bean> 
            <bean class="redis.clients.jedis.JedisShardInfo"> 
                <constructor-arg 
                    index="0" 
                    value="${redis2.ip}" /> 
                <constructor-arg 
                    index="1" 
                    value="${redis.port}" 
                    type="int" /> 
            </bean> 
        </list> 
    </constructor-arg> 
</bean> 

 


 

 代码可以更简洁一些：

 

 

Java代码 
private ApplicationContext app; 
private ShardedJedisPool pool; 
 
@Before 
public void before() throws Exception { 
    app = new ClassPathXmlApplicationContext("applicationContext.xml"); 
    pool = (ShardedJedisPool) app.getBean("shardedJedisPool"); 
} 
 
@Test 
public void test() { 
 
    // 从池中获取一个Jedis对象 
    ShardedJedis jedis = pool.getResource(); 
    String keys = "name"; 
    String value = "snowolf"; 
    // 删数据 
    jedis.del(keys); 
    // 存数据 
    jedis.set(keys, value); 
    // 取数据 
    String v = jedis.get(keys); 
 
    System.out.println(v); 
 
    // 释放对象池 
    pool.returnResource(jedis); 
 
    assertEquals(value, v); 
} 

 

 

[java] view plain copy
private ApplicationContext app; 
private ShardedJedisPool pool; 
 
@Before 
public void before() throws Exception { 
    app = new ClassPathXmlApplicationContext("applicationContext.xml"); 
    pool = (ShardedJedisPool) app.getBean("shardedJedisPool"); 
} 
 
@Test 
public void test() { 
 
    // 从池中获取一个Jedis对象 
    ShardedJedis jedis = pool.getResource(); 
    String keys = "name"; 
    String value = "snowolf"; 
    // 删数据 
    jedis.del(keys); 
    // 存数据 
    jedis.set(keys, value); 
    // 取数据 
    String v = jedis.get(keys); 
 
    System.out.println(v); 
 
    // 释放对象池 
    pool.returnResource(jedis); 
 
    assertEquals(value, v); 
} 

 

 

原文出处：

http://blog.csdn.net/it_man/article/details/9730605

分享到：
| 带bom的utf转gbk
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    redis3.2.1+jedis2.8.0+jedis.api.rar一站下载

    Jedis是Java语言开发的Redis客户端，提供了丰富的API来操作Redis服务器，便于Java开发者在项目中集成Redis。 Redis 3.2.1是Redis的一个稳定版本，相比于早期版本，它引入了一些新的特性和改进。其中，重要的更新...

    redis安装脚本+jedis.jar.zip

    Redis是一款高性能的键值数据库，...3. **高级功能**：Jedis还支持事务（Transactions）、发布订阅（Pub/Sub）、有序集合（Sorted Sets）、哈希表（Hashes）等多种Redis功能，具体可参考Jedis官方文档或[CSDN上的教程]...

    redis实现分布式锁(java/jedis)

    redis实现分布式锁(java/jedis),其中包含工具方法以及使用demo 本资源是利用java的jedis实现 redis实现分布式锁(java/jedis),其中包含工具方法以及使用demo 本资源是利用java的jedis实现

    jedis-2.9.0 最新版Redis客户端CSDN下载

    Jedis是Java语言中使用最广泛的Redis客户端库，它提供了丰富的API来操作Redis服务器。在这个"jedis-2.9.0"的最新版本中，我们包含了三个重要的文件： 1. `jedis-2.9.0.jar`：这是Jedis的二进制发行版，包含了所有...

    redis的哨兵加集群安装文档

    哨兵模式是Redis提供的高可用解决方案之一，主要负责监控Redis实例的状态、在主节点发生故障时进行故障转移操作（自动将宕机主服务器的数据转移到新的主服务器上）、协助客户端重新配置连接信息等任务。通过哨兵模式...

    spring+mybatis+redis

    在spring+spring mvc+mybatis模式下，使用的最多的就是jedis，但是spring boot整合了redis后，依然可以使用jedis，但是同时也提供了一个RedisTemplate和StringRedisTemplate，RedisTemplate使用的序列化类是默认...

    redisjava例子

    在Java开发中，Jedis是连接Redis的最常用的客户端库，它提供了丰富的API来操作Redis的各种数据结构。在这个“redisjava例子”中，我们将探讨如何在Java应用中使用Jedis进行Redis的集成。 首先，我们要了解如何引入...

    (重新整理版)redis的java客户端jedis 管理类代码 支持主从复制的自动选择和自动恢复,读/写分离

    * redis主从架构的jedis客户端管理类,大概1000多行代码左右 * 1 支持主从复制key/value,pop/push,pub/sub,读/写分离等功能的灾难失败自动选择和恢复 * 2 可以选择读写分离功能,主写从读,默认不启用,都使用主服务...

    tomcat8+redis

    描述中的链接指向了一个CSDN博客文章，虽然具体内容无法直接引用，但我们可以推测它可能提供了关于配置和使用Tomcat 8与Redis集成的步骤和实践细节。通常，这样的集成是为了提升Web应用的性能，通过将频繁访问的数据...

    java操作redis工具类与配置文件，详细版

    jedis = new Jedis(prop.getProperty("redis.host"), Integer.parseInt(prop.getProperty("redis.port")), Integer.parseInt(prop.getProperty("redis.timeout"))); if (!prop.getProperty("redis.password")....

    redis实现实例

    在本实例中，我们将探讨如何使用Redis实现一个简单的应用，包括安装Redis、配置Java客户端Jedis以及处理连接超时问题。 首先，Redis的安装是整个过程的基础。在描述中提到的是Redis 3.0.2版本，这是一个稳定且广泛...

    redis客户端

    RedisClient是Redis客户端的GUI工具，使用Java swt和jedis编写，可以方便开发者浏览Redis数据库。该软件支持简体中文，非常适合国内用户使用，不需要汉化就可以直接使用。RedisClient将redis数据以资源管理器的界面...

    redis开发和运维

    在客户端方面，书中对Java客户端Jedis和Python客户端redis-py的使用方法进行了详细的说明，包括客户端管理、异常处理和案例分析，让开发者可以更有效地在应用程序中嵌入Redis。 持久化是数据库管理中的一个核心概念...

    java redis 各类型操作实例

    首先，为了在Java项目中使用Redis，我们需要引入Jedis库，这是一个流行的Java Redis客户端。在Maven项目的`pom.xml`文件中添加以下依赖： ```xml &lt;groupId&gt;redis.clients &lt;artifactId&gt;jedis &lt;version&gt;3.7.0 ``...

    redis安装及使用

    Redis客户端提供了两种主要方式来操作Redis服务器：命令行客户端和Java客户端（Jedis）。 ##### 命令行客户端： ```bash [root@zhangchaoyang bin]# ./redis-cli -h 127.0.0.1 -p 6379 127.0.0.1:6379&gt; set ...

    Redis-2.0.2下载地址及在windows下的安装使用教程

    Redis-2.0.2 的下载源有两个，可以从 GitHub 上的 MSOpenTech/redis 仓库获取，或者在中国软件下载网（csdn.net）上找到。下载完成后，将压缩文件解压至你选择的目录，例如 D:\redis-2.0.2。 2. **了解 Redis 文件...

    SpringBoot项目SSM+Redis整合

    使用`Jedis`或`Lettuce`客户端库可以方便地与Redis交互。启动Redis服务器后，SpringBoot可以通过配置文件（如`application.yml`或`application.properties`）设置连接参数，实现与Redis的连接。 **Thymeleaf** 是一...

    Windows Redis

    2. **连接Redis**: 创建Jedis实例，如`new Jedis("localhost", 6379)`。 3. **执行命令**: 使用Jedis对象提供的方法执行Redis命令，例如`set(key, value)`、`get(key)`等。 4. **关闭连接**: 操作完毕后记得关闭...

    redis demo

    本地连接redis的demo，可以是指对应key的过期时间 ，

Magicbox
Global site tag (gtag.js) - Google Analytics