Redis的java客户端Jedis配备与使用
Redis的java客户端Jedis配置与使用使用jedis java客户端[java]public?static?void?main(String[]?args)?{?
Redis的java客户端Jedis配置与使用
使用jedis java客户端[java]
public?static?void?main(String[]?args)?{??????Jedis?jedis?=?new?Jedis("147.151.240.234",6379);??????jedis.set("foo",?"bar");??????String?value?=?jedis.get("foo");??????System.out.println(value);??}?
?
二：spring中配置：
首先，在项目中引入jeids的jar包。??Xml代码
- <!--?java?readis客户端?-->????
- <dependency>????
- ????<groupId>redis.clients</groupId>????
- ????<artifactId>jedis</artifactId>????
- ????<version>2.0.0</version>????
- </dependency>???
其次，在spring配置文件中添加配置（也可以直接new出这些对象，一样的）
<bean id="jedisPoolConfig" value="50" /> <property name="maxIdle" value="10" /> <property name="maxWait" value="1000" /> <property name="testOnBorrow" value="true"/> </bean> <bean id="jedis.shardInfo" value="这里填你的reids服务器ip" /> <constructor-arg index="1" value="6379" /> </bean> <bean id="shardedJedisPool" ref="jedisPoolConfig" /> <constructor-arg index="1"> <list> <ref bean="jedis.shardInfo" /> </list> </constructor-arg> </bean>
? 最后，调用的时候Java代码- ShardedJedis?jedis?=??shardedJedisPool.getResource();????
- ???jedis.get(key);?//从redis服务器获取值????
- ???jedis.set(key,?value);?//将值保存到redis服务器????
?
jedis pool的问题
在使用jedis pool时遇到了这个问题：It seems like server has closed the connection
原因分析：
1.redis server 关闭了此客户端的连接:server端设置了maxidletime(默认是5分钟），服务端会不断循环检测clinet的最后一次通信时间（lastinteraction），如果大于maxidletime，则关闭连接，并回收相关资源。client在向该连接中写数据后就会由于server端已经关闭而出现 broken pipe的问题。
2.pool的设置错误:
<bean id="jedisPoolConfig" value="20" /> <property name="maxIdle" value="10" /> <property name="maxWait" value="1000" /> </bean><!-- jedis shard信息配置 --> <bean id="jedis.shardInfo" value="*.*.*.*" /> <constructor-arg index="1" value="6379" /> </bean> <!-- jedis shard pool配置 --> <bean id="shardedJedisPool" ref="jedisPoolConfig" /> <constructor-arg index="1"> <list> <ref bean="jedis.shardInfo" /> </list> </constructor-arg> </bean> <bean id="jedisCommands" factory-bean="shardedJedisPool" factory-method="getResource" />
?上面的这种配法在spring初始化时获取一次实例化jedisCommands，而后每次的redis的调用时并未从pool中获取
解决方案：
设置
<!-- POOL配置 --> <bean id="jedisPoolConfig" value="20" /> <property name="maxIdle" value="10" /> <property name="maxWait" value="1000" /> <property name="testOnBorrow" value="true"/> </bean> <!-- jedis shard信息配置 --> <bean id="jedis.shardInfo" value="*.*.*.*" /> <constructor-arg index="1" value="6379" /> </bean> <!-- jedis shard pool配置 --> <bean id="shardedJedisPool" ref="jedisPoolConfig" /> <constructor-arg index="1"> <list> <ref bean="jedis.shardInfo" /> </list> </constructor-arg> </bean>
?
?
最近初次尝试使用redis，java客户端采用的jedis，写了几个简单的类满足基本的服务器配置，以及客户端对象的使用等。
客户端对象的创建[java]
package?jediscache.common;????import?redis.clients.jedis.Jedis;??import?redis.clients.jedis.JedisPool;??import?redis.clients.jedis.JedisPoolConfig;??import?redis.clients.jedis.Protocol;????public?class?JedisFactory?{????????????private?JedisPoolConfig?jedisPoolConfig;????????????private?JedisPool?jedisPool;????????public?JedisFactory(JedisPoolConfig?jedisPoolConfig)?{??????????super();??????????this.jedisPoolConfig?=?jedisPoolConfig;??????}????????????public?Jedis?getJedisInstance(String?host)?{??????????return?getJedisPool(host,?Protocol.DEFAULT_PORT).getResource();??????}????????????public?Jedis?getJedisInstance(String?host,?int?port)?{??????????return?getJedisPool(host,?port).getResource();??????}????????????public?JedisPool?getJedisPool(String?host)?{??????????return?getJedisPool(host,?Protocol.DEFAULT_PORT);??????}????????public?JedisPool?getJedisPool(String?host,?int?port)?{??????????if?(jedisPool?==?null)?{??????????????jedisPool?=?new?JedisPool(jedisPoolConfig,?host,?port);??????????}??????????return?jedisPool;??????}????????????/**??????*?配合使用getJedisInstance方法后将jedis对象释放回连接池中??????*???????*?@param?jedis?使用完毕的Jedis对象??????*?@return?true?释放成功；否则返回false??????*/??????public?boolean?release(Jedis?jedis)?{??????????if?(jedisPool?!=?null?&&?jedis?!=?null)?{??????????????jedisPool.returnResource(jedis);??????????????return?true;??????????}??????????return?false;??????}????}???
使用客户端对象[java]
public?void?testLpush()?{??????JedisFactory?factory?=?new?JedisFactory(new?JedisPoolConfig());??????Jedis?jedis?=?factory.getJedisInstance("localhost");????????????try?{??????????String?word?=?"word";??????????jedis.lpush(word,?"first");??????????jedis.lpush(word,?"second");??????????jedis.lpush(word,?"three");??????????System.out.println("word?:?"?+?jedis.lrange(word,?0,?-1));??????}?finally?{??????????factory.release(jedis);??????}??}??
?
