标签：err node jedis redis配置 nis 地址 客户 指定 value
一、背景
上篇文章我们介绍了如何在centos7下面进行安装单机版redis以及redis集群。这篇文章，我们来聊一聊如何使用java客户端来进行操作redis。我们知道redis的java客户端有很多,如：jedis、redission等。这篇文章着重介绍我们平常使用最多的redis的java客户端jedis。
二、通过单元测试来小试牛刀
1.首先在maven的pom.xml中引入jedis-client的依赖
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.7.2</version>
</dependency>
2.使用junit进行单元测试
package com.hafiz.redis.test; import java.util.HashSet; import java.util.Set; import org.junit.Test; import redis.clients.jedis.HostAndPort; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisCluster; import redis.clients.jedis.JedisPool; public class JedisTest { @Test public void testJedisSingle() { // 创建一个jedis连接 Jedis client = new Jedis("192.168.25.153", 6379); client.set("name", "zhangsan"); String name = client.get("name"); System.out.println(name); // 关闭连接 client.close(); } @Test public void testJedisPoolSingle() { // 创建一个连接池对象，系统中应该是单例的 JedisPool pool = new JedisPool("192.168.25.153", 6379); // 从连接池中获取一个连接 Jedis client = pool.getResource(); client.set("age", "100"); String name = client.get("name"); String age = client.get("age"); System.out.println(name); System.out.println(age); // jedis必须关闭连接 client.close(); // 关闭连接池 pool.close(); } @Test public void testJedisCluster() { // 创建一个jedisCluster对象的节点集合 Set<HostAndPort> nodes = new HashSet<>(); // 在nodes中指定每个节点的地址 nodes.add(new HostAndPort("192.168.25.153", 7001)); nodes.add(new HostAndPort("192.168.25.153", 7002)); nodes.add(new HostAndPort("192.168.25.153", 7003)); nodes.add(new HostAndPort("192.168.25.153", 7004)); nodes.add(new HostAndPort("192.168.25.153", 7005)); nodes.add(new HostAndPort("192.168.25.153", 7006)); // 创建一个jedisCluster对象，该对象在系统中应该是单例的 JedisCluster cluster = new JedisCluster(nodes); cluster.set("id", "100"); cluster.set("value", "Hello Jedis"); System.out.println(cluster.get("id")); System.out.println(cluster.get("value")); // 系统关闭时，关闭集群 cluster.close(); } }
三、在项目中，使用Spring集成Redis
1.redis.properties文件如下：
#Redis stand-alone config redis.single.host=192.168.25.153 redis.single.port=6379 #Redis cluster config redis.cluster.node1.host=192.168.25.153 redis.cluster.node1.port=7001 redis.cluster.node2.host=192.168.25.153 redis.cluster.node2.port=7002 redis.cluster.node3.host=192.168.25.153 redis.cluster.node3.port=7003 redis.cluster.node4.host=192.168.25.153 redis.cluster.node4.port=7004 redis.cluster.node5.host=192.168.25.153 redis.cluster.node5.port=7005 redis.cluster.node6.host=192.168.25.153 redis.cluster.node6.port=7006
2.spring-redis配置文件如下：
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"> <!-- Redis stand-alone config --> <bean id = "jedisPool" class = "redis.clients.jedis.JedisPool"> <constructor-arg name="host" value="${redis.single.host}"/> <constructor-arg name="port" value="${redis.single.port}"/> </bean> <bean id = "singleJedisClient" class = "com.taotao.rest.component.impl.SingleJedisClient"/> <!-- Redis cluster config --> <!-- <bean id="jedisCluster" class="redis.clients.jedis.JedisCluster"> <constructor-arg name="nodes"> <set> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node1.host}"/> <constructor-arg name="port" value="${redis.cluster.node1.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node2.host}"/> <constructor-arg name="port" value="${redis.cluster.node2.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node3.host}"/> <constructor-arg name="port" value="${redis.cluster.node3.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node4.host}"/> <constructor-arg name="port" value="${redis.cluster.node4.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node5.host}"/> <constructor-arg name="port" value="${redis.cluster.node5.port}"/> </bean> <bean class="redis.clients.jedis.HostAndPort"> <constructor-arg name="host" value="${redis.cluster.node6.host}"/> <constructor-arg name="port" value="${redis.cluster.node6.port}"/> </bean> </set> </constructor-arg> </bean> <bean id="clusterJedisClient" class="com.hafiz.rest.component.impl.ClusterJedisClient"/> --> </beans>
默认放开的是单机版配置，如需使用集群版请注释上面单机版配置，并打开下面集群版配置。
3.接着我们编写一个JedisClient接口类
package com.hafiz.component; public interface JedisClient { String set(String key, String value); String get(String key); Long del(String key); Long hset(String key, String item, String value); String hget(String key, String item); Long hdel(String key, String... item); Long incr(String key); Long decr(String key); Long expire(String key, int seconds); Long ttl(String key); }
4.然后我们给出单机版的实现类：SingleJedisClient.java
package com.hafiz.component.impl; import org.springframework.beans.factory.annotation.Autowired; import com.taotao.rest.component.JedisClient; import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; /** * Redis单机客户端工具类 * @author Administrator */ public class SingleJedisClient implements JedisClient { @Autowired private JedisPool jedisPool; @Override public String set(String key, String value) { Jedis client = jedisPool.getResource(); String result = client.set(key, value); client.close(); return result; } @Override public String get(String key) { Jedis client = jedisPool.getResource(); String result = client.get(key); client.close(); return result; } @Override public Long del(String key) { Jedis client = jedisPool.getResource(); Long result = client.del(key); client.close(); return result; } @Override public Long hset(String key, String item, String value) { Jedis client = jedisPool.getResource(); Long result = client.hset(key, item, value); client.close(); return result; } @Override public String hget(String key, String item) { Jedis client = jedisPool.getResource(); String result = client.hget(key, item); client.close(); return result; } @Override public Long hdel(String key, String... item) { Jedis client = jedisPool.getResource(); Long result = client.hdel(key, item); client.close(); return result; } @Override public Long incr(String key) { Jedis client = jedisPool.getResource(); Long result = client.incr(key); client.close(); return result; } @Override public Long decr(String key) { Jedis client = jedisPool.getResource(); Long result = client.decr(key); client.close(); return result; } @Override public Long expire(String key, int seconds) { Jedis client = jedisPool.getResource(); Long result = client.expire(key, seconds); client.close(); return result; } @Override public Long ttl(String key) { Jedis client = jedisPool.getResource(); Long result = client.ttl(key); client.close(); return result; } }
5.我们再提供集群版的实现类:ClusterJedisClient.java
package com.hafiz.component.impl; import org.springframework.beans.factory.annotation.Autowired; import com.taotao.rest.component.JedisClient; import redis.clients.jedis.JedisCluster; /** * Redis集群客户端工具类 * @author Administrator */ public class ClusterJedisClient implements JedisClient { @Autowired private JedisCluster jedisCluster; @Override public String set(String key, String value) { return jedisCluster.set(key, value); } @Override public String get(String key) { return jedisCluster.get(key); } @Override public Long del(String key) { return jedisCluster.del(key); } @Override public Long hset(String key, String item, String value) { return jedisCluster.hset(key, item, value); } @Override public String hget(String key, String item) { return jedisCluster.hget(key, item); } @Override public Long hdel(String key, String... item) { return jedisCluster.hdel(key, item); } @Override public Long incr(String key) { return jedisCluster.incr(key); } @Override public Long decr(String key) { return jedisCluster.decr(key); } @Override public Long expire(String key, int seconds) { return jedisCluster.expire(key, seconds); } @Override public Long ttl(String key) { return jedisCluster.ttl(key); } }
6.spring集成redis单元测试
package com.taotao.rest.test; import org.junit.Test; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.taotao.rest.component.JedisClient; public class SpringJedisTest { @Test public void testJedisClientSpring() throws Exception { //创建一个spring容器 ApplicationContext applicationContext = new ClassPathXmlApplicationContext("classpath:spring/applicationContext-*.xml"); //从容器中获得JedisClient对象 JedisClient jedisClient = applicationContext.getBean(JedisClient.class); //jedisClient操作redis jedisClient.set("cliet1", "1000"); String string = jedisClient.get("cliet1"); System.out.println(string); } }
四、总结
通过本文我们对jedis的使用有了进一步的了解，知道了如何使用spring对redis进行集成，也对jedisClient做了单机以及集群的实现。很有成就感，未来走向架构师的路还有很远，继续努力吧！
标签：err node jedis redis配置 nis 地址 客户 指定 value
原文地址：http://www.cnblogs.com/hafiz/p/7143400.html
