NoSQL之Redis（五）--- Redis测试以及其与spring的集成

概述

本文是紧接着上文安装好单机版的redis和rediscluster的之后需要去验证是否安装成功，以及如何和Spring集成到一起。

Jedis

Jedis是是Redis官方推荐的Java客户端开发包，用于处理redis服务上的缓存数据。笔者用的是Jedis-2.7.2.jar

Redis安装测试

接着这上文，我们先简单的写一个测试类，测试一下单机版的redis是否已经可用

[java] view plain copy

print ?

@Test
public void testJedisSingle() {
// 创建一个jedis的对象。
Jedisjedis= newJedis("192.168.21.225", 6379);
// 调用jedis对象的方法，方法名称和redis的命令一致。
jedis.set("key1", "jedis test");
Stringstring= jedis.get("key1");
System.out.println(string);
// 关闭jedis。每次用完之后都应该关闭jedis
jedis.close();
}

测试结果入下：

在实际的运用过程中，我们基本上不会这样每连接一次redis就去创建一个Jedis对象，而是会在程序加载的时候直接创建一个连接池。测试方法如下

[java] view plain copy

print ?

/**
* 使用连接池
*/
@Test
public void testJedisPool() {
// 创建jedis连接池
JedisPoolpool= newJedisPool("192.168.21.225", 6379);
// 从连接池中获得Jedis对象
Jedisjedis= pool.getResource();
Stringstring= jedis.get("key1");
System.out.println(string);
// 关闭jedis对象
jedis.close();
pool.close();
}

运行结果入下：

测试完单机版之后，我们接下来看看如何使用Jedis操作redis集群（本文使用的是伪集群）

[java] view plain copy

print ?

@Test
public void testJedisCluster() {
HashSet<HostAndPort>nodes= newHashSet<>();
nodes.add(new HostAndPort("192.168.21.225",7001));
nodes.add(new HostAndPort("192.168.21.225",7002));
nodes.add(new HostAndPort("192.168.21.225",7003));
nodes.add(new HostAndPort("192.168.21.225",7004));
nodes.add(new HostAndPort("192.168.21.225",7005));
nodes.add(new HostAndPort("192.168.21.225",7006));
JedisClustercluster= newJedisCluster(nodes);
cluster.set("key1", "1000");
Stringstring= cluster.get("key1");
System.out.println(string);
cluster.close();
}

测试结果入下：

通过上面的测试一方面我们知道了如何简单的去操作redis，另一方面也验证在之前介绍的redis的按照是没有问题的。

与Spring的集成

下面我们看看在spring的配置文件中如何配置redis的参数和Jedis相关的东西。

连接池配置

首先我们看看redis连接池的配置

[html] view plain copy

print ?

<bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">
<property name="maxTotal" value="30" />
<property name="maxIdle" value="10" />
<property name="numTestsPerEvictionRun" value="1024" />
<property name="timeBetweenEvictionRunsMillis" value="30000" />
<property name="minEvictableIdleTimeMillis" value="1800000" />
<property name="softMinEvictableIdleTimeMillis" value="10000" />
<property name="maxWaitMillis" value="1500" />
<property name="testOnBorrow" value="true" />
<property name="testWhileIdle" value="true" />
<property name="blockWhenExhausted" value="false" />
</bean>

单机配置

[html] view plain copy

print ?

<bean id="redisClient" class="redis.clients.jedis.JedisPool">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="6379"></constructor-arg>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
<bean id="jedisClient" class="com.taotao.rest.dao.impl.JedisClientSingle" />
</bean>

集群配置

[html] view plain copy

print ?

<bean id="redisClient" class="redis.clients.jedis.JedisCluster">
<constructor-arg name="nodes">
<set>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7001"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7002"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7003"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7004"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7005"></constructor-arg>
</bean>
<bean class="redis.clients.jedis.HostAndPort">
<constructor-arg name="host" value="192.168.21.225"></constructor-arg>
<constructor-arg name="port" value="7006"></constructor-arg>
</bean>
</set>
</constructor-arg>
<constructor-arg name="poolConfig" ref="jedisPoolConfig"></constructor-arg>
</bean>
<bean id="jedisClientCluster"class="com.taotao.rest.dao.impl.JedisClientCluster"></bean>

工具类

为了方便笔者直接调用Jedis去操作redis，所以笔者写了一个JedisClient工具类，如下

[java] view plain copy

print ?

public interfaceJedisClient {
Stringget(String key);
Stringset(String key,String value);
Stringhget(String hkey,String key);
long hset(String hkey, String key, String value);
long incr(String key);
long expire(String key, int second);
long ttl(String key);
long del(String key);
long hdel(String hkey, String key);
}

由于对单机和集群的redis操作时不一样的，所以实现工具类的时候单机和集群的实现方式是不一样的。

单机实现

[java] view plain copy

print ?

public classJedisClientSingle implements JedisClient{
@Autowired
private JedisPool jedisPool;
@Override
public String get(String key) {
Jedisjedis= jedisPool.getResource();
Stringstring= jedis.get(key);
jedis.close();
return string;
}
@Override
public String set(String key, String value) {
Jedisjedis= jedisPool.getResource();
Stringstring= jedis.set(key, value);
jedis.close();
return string;
}
@Override
public String hget(String hkey, String key) {
Jedisjedis= jedisPool.getResource();
Stringstring= jedis.hget(hkey, key);
jedis.close();
return string;
}
@Override
public long hset(String hkey, String key, String value) {
Jedisjedis= jedisPool.getResource();
Longresult= jedis.hset(hkey, key, value);
jedis.close();
return result;
}
@Override
public long incr(String key) {
Jedisjedis= jedisPool.getResource();
Longresult= jedis.incr(key);
jedis.close();
return result;
}
@Override
public long expire(String key, int second) {
Jedisjedis= jedisPool.getResource();
Longresult= jedis.expire(key, second);
jedis.close();
return result;
}
@Override
public long ttl(String key) {
Jedisjedis= jedisPool.getResource();
Longresult= jedis.ttl(key);
jedis.close();
return result;
}
@Override
public long del(String key) {
Jedis jedis = jedisPool.getResource();
Longresult= jedis.del(key);
jedis.close();
return result;
}
@Override
public long hdel(String hkey, String key) {
Jedisjedis= jedisPool.getResource();
Longresult= jedis.hdel(hkey, key);
jedis.close();
return result;
}
}

集群实现

[java] view plain copy

print ?

public classJedisClientCluster implements JedisClient {
@Autowired
private JedisCluster jedisCluster;
@Override
public String get(String key) {
return jedisCluster.get(key);
}
@Override
public String set(String key, String value) {
return jedisCluster.set(key, value);
}
@Override
public String hget(String hkey, String key) {
return jedisCluster.hget(hkey, key);
}
@Override
public long hset(String hkey, String key, String value) {
return jedisCluster.hset(hkey, key, value);
}
@Override
public long incr(String key) {
return jedisCluster.incr(key);
}
@Override
public long expire(String key, int second) {
return jedisCluster.expire(key, second);
}
@Override
public long ttl(String key) {
return jedisCluster.ttl(key);
}
@Override
public long del(String key) {
return jedisCluster.del(key);
}
@Override
public long hdel(String hkey, String key) {
return jedisCluster.hdel(hkey, key);
}
}

测试

下面是测试配置以及工具类的方法

单机测试

[java] view plain copy

print ?

@Test
public void testSpringJedisSingle(){
ApplicationContextapplicationContext = newClassPathXmlApplicationContext(
"classpath:spring/applicationContext-*.xml");
JedisPoolpool= (JedisPool) applicationContext.getBean("redisClient");
Jedisjedis= pool.getResource();
Stringstring= jedis.get("key1");
System.out.println(string);
jedis.close();
pool.close();
}

集群测试

[html] view plain copy

print ?

@Test
public voidtestSpringJedisCluster() {
ApplicationContextapplicationContext = newClassPathXmlApplicationContext(
"classpath:spring/applicationContext-*.xml");
JedisClusterjedisCluster= (JedisCluster) applicationContext
.getBean("redisClient");
Stringstring= jedisCluster.get("key1");
System.out.println(string);
jedisCluster.close();
}

总结

至此，本文的的写作目的——测试集群，以及redis配置与Spring集成就达到了。其实在笔者在写本文的时候，一方面是对之前项目中redis运用的优化，另一方面在实际的其实本文在实现JedisClient的时候，所有的方法中在笔者的项目中是添加有日志的。至于为什么添加日志本文就不介绍了。

时间： 2024-11-20 09:31:05

NoSQL之Redis（五）--- Redis测试以及其与spring的集成的相关文章

Linux系统安装NoSQL（MongoDB和Redis）步骤及问题解决办法

原文出自[听云技术博客]:http://blog.tingyun.com/web/article/detail/1229 如下是我工作中的记录,介绍的是linux系统下NoSQL:MongoDB和Redis的安装过程和遇到的问题以及解决办法: 需要的朋友可以按照如下步骤进行安装,可以快速安装MongoDB和Redis,希望可以帮助大家:)! 一.MongoDB 1.MongoDB安装 (1)将安装包mongodb-linux-i686-3.0.2.tgz拷贝到要安装的服务器中这里我用的rz命令

Linux系统安装NoSQL（MongoDB和Redis）步骤及问题解决办法(总结篇)_Linux

如下是我工作中的记录,介绍的是linux系统下NoSQL:MongoDB和Redis的安装过程和遇到的问题以及解决办法: 需要的朋友可以按照如下步骤进行安装,可以快速安装MongoDB和Redis,希望可以帮助大家:)! 一.MongoDB 1.MongoDB安装 (1)将安装包mongodb-linux-i686-3.0.2.tgz拷贝到要安装的服务器中这里我用的rz命令,如果不支持需要安装yum -y install lrzsz (2)解压安装程序 tar xzvf mongodb-lin

linux中php安装redis扩展模块并测试

以Linux为例,首先下载php扩展模块,地址ps://github.com/nicolasff/phpredis">https://github.com/nicolasff/phpredis,下载完成后首先进行解压操作tar zxvf phpredis.tar.gz cd phpredis-master/ /usr/local/webserver/php/bin/phpize ./configure --with-php-config=/usr/local/webserver/php/b

Linux之redis配置文件redis.conf中英文对比说明

# Redis示例配置文件 # 注意单位问题:当需要设置内存大小的时候,可以使用类似1k.5GB.4M这样的常见格式: # # 1k => 1000 bytes # 1kb => 1024 bytes # 1m => 1000000 bytes # 1mb => 1024*1024 bytes # 1g => 1000000000 bytes # 1gb => 1024*1024*1024 bytes # # 单位是大小写不敏感的,所以1GB 1Gb 1gB的写法都是完

只安装redis的redis自动安装脚本

Redis自动安装部署本文总共分为4个部分: redis自动安装脚本目录结构说明: redis自动安装脚本内容: redis的操作系统服务脚本说明: 本文引用的资料链接地址. 说明:本文未涉及redis内存分配器部分的内容. 第一部分 Redis自动安装脚本目录结构说明: # ls 查看当前目录包含以下3个文件 -- install_redis.sh # redis自动安装脚本 -- redis-2.8.9.tar.gz # redis安装包(需make,make te

Redis 缓存 + Spring 的集成示例

SpringSession和Redis实现Session跨域 http://www.ithao123.cn/content-11111681.html tomcat中创建session很耗服务器内存原生session与session in redis对比下面是从stackoverflow上找到的一些观点: Using something like Redis for storing sessions is a great way to get more performance out of

Redis 缓存 + Spring 的集成示例(转)

<整合 spring 4(包括mvc.context.orm) + mybatis 3 示例>一文简要介绍了最新版本的 Spring MVC.IOC.MyBatis ORM 三者的整合以及声明式事务处理.现在我们需要把缓存也整合进来,缓存我们选用的是 Redis,本文将在该文示例基础上介绍 Redis 缓存 + Spring 的集成.关于 Redis 服务器的搭建请参考博客<Redhat5.8 环境下编译安装 Redis 并将其注册为系统服务>. 1. 依赖包安装 pom.xml

【Redis】Redis在实际项目中的应用

前言 Redis作为内存型的数据库,比mysql的速度快很多,所以经常会被用作缓存等,下面列举一下我在实际项目中的的使用. Code 缓存 string 采用string的存储结构对字符串进行存储常用的命令为 //存储缓存 SET key "value" //获取数据 GET key //增加超时时间(TTL),30s后缓存失效 SET key "value" 30 如果 key 已经持有其他值, SET 就覆写旧值,无视类型. 对于某个原本带有生存时间(TTL)

【Redis】Redis介绍与Redis3在Window下的安装

转载请注明出处http://blog.csdn.net/qq_26525215 本文源自[大学之旅_谙忆的博客] 前言其实在今天之前我都不知道Redis是什么东西.至于为什么知道了这个东西而且又要去学Redis. 因为需要学习Apache Shiro权限控制-里面用到了Redis所以就先把Redis学完再继续学习Shiro~ Redis介绍 Redis 是完全开源免费的遵守BSD协议是一个高性能的key-value数据库. Redis 与其他 key - value 缓存产品有以下三个特点 R