首页 > 代码库 > jedis入门一
jedis入门一
一.下载Jedis的依赖包jedis-2.1.0.jar，然后将其添加到classpath下面。
1. 定义连接：Redis暂时不要设置登录密码
Jedis jedis = new Jedis("192.168.142.12");2. 进行键值存储：
jedis.set("country", "China");3. 获取value值：
String country = jedis.get("country");4. 删除key：
jedis.del("country");
二、使用连接池：
1. 添加依赖包commons-pool.jar，注意不要选择高版本，以免不必要的错误。
2. 配置属性文件：redis.properties
redis.host=192.168.142.12 #Redis服务器地址redis.port=6379 #服务端口redis.timeout=3000 #超时时间：单位msredis.password=nick123 #授权密码redis.pool.maxActive=200 #最大连接数：能够同时建立的“最大链接个数”
redis.pool.maxIdle=20 #最大空闲数：空闲链接数大于maxIdle时，将进行回收
redis.pool.minIdle=5 #最小空闲数：低于minIdle时，将创建新的链接
redis.pool.maxWait=3000 #最大等待时间：单位ms
redis.pool.testOnBorrow=true #使用连接时，检测连接是否成功
redis.pool.testOnReturn=true #返回连接时，检测连接是否成功
3. 加载属性文件：redis.properties
ResourceBundle bundle = ResourceBundle.getBundle("redis");4. 创建配置对象：
JedisPoolConfig config = new JedisPoolConfig();String host = bundle.getString("redis.host");...config.setMaxActive(Integer.valueOf(bundle.getString("redis.pool.maxActive")));...config.setTestOnBorrow(Boolean.valueOf(bundle.getString("redis.pool.testOnBorrow")));...5. 创建Jedis连接池：
JedisPool pool = new JedisPool(config, host, port, timeout, password); [三]. 使用方式：
1. 从连接池获取Jedis对象：
Jedis jedis = pool.getResource();
2. 基本操作：
jedis.set("province", "shannxi");String province = jedis.get("province");jedis.del("province");3. 将Jedis对象归还给连接池：
pool.returnResource(jedis);三、jedis与spring整合
[一]. 搭建环境：
1. 在之前版本的基础之上，添加如下的依赖：
spring.jar
commons-logging.jar
log4j-1.2.15.jar
同时添加日志配置文件：log4j.properties到classpath下面。
2. 配置Spring文件：applicationContext.xml
注意：连接池jedisPool的配置，这里使用了构造方式注入，这是和Jedis的API一致的；
在注入port时，需要使用使用type = "int"指定注入的参数类型，否则出现异常。
1 <beans xmlns="http://www.springframework.org/schema/beans" 2 xmlns:context="http://www.springframework.org/schema/context" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd 5 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd"> 6 7 <!-- 加载redis配置文件 --> 8 <context:property-placeholder location="classpath:redis.properties"/> 9 10 <!-- redis连接池的配置 -->11 <bean id="jedisPoolConfig" class="redis.clients.jedis.JedisPoolConfig">12 <property name="maxActive" value="${redis.pool.maxActive}"/>13 <property name="maxIdle" value="${redis.pool.maxIdle}"/>14 <property name="minIdle" value="${redis.pool.minIdle}"/>15 <property name="maxWait" value="${redis.pool.maxWait}"/>16 <property name="testOnBorrow" value="${redis.pool.testOnBorrow}"/>17 <property name="testOnReturn" value="${redis.pool.testOnReturn}"/>18 </bean>19 20 <!-- redis的连接池pool，不是必选项：timeout/password -->21 <bean id = "jedisPool" class="redis.clients.jedis.JedisPool">22 <constructor-arg index="0" ref="jedisPoolConfig"/>23 <constructor-arg index="1" value="${redis.host}"/>24 <constructor-arg index="2" value="${redis.port}" type="int"/>25 <constructor-arg index="3" value="${redis.timeout}" type="int"/>26 <constructor-arg index="4" value="${redis.password}"/>27 </bean>28 29 </beans>
[二]. 从SPring容器中获取JedisPool：
1 ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");2 JedisPool pool = (JedisPool) context.getBean("jedisPool");3 Jedis jedis = pool.getResource();4 ...5 pool.returnResource(jedis);
[三]. 缓存JavaBean：
上一篇文章中，已经有了对Jedis使用的基本说明。
当然很多时候我们都希望Redis能够对JavaBean进行缓存，这需要借助于JDK提供的序列化技术。
1. 要求缓存实体实现了序列化Serializable接口：这里以Userinfo为例。
2. 序列化工具类：Jedis对序列化的支持，是提供了字节数组byte[]作为参数；
为此编写SerializingUtil工具类负责byte[]和JavaBean之间的相互转换。该方法的API如下所示：
1 public static byte[] serialize(Object source); 2 public static Object deserialize(byte[] source);
/** * 功能简述: 序列化工具类，负责byte[]和Object之间的相互转换. * @author Nick Xu * @version 1.0 */public class SerializingUtil { private static Log logger = LogFactory.getLog(SerializingUtil.class); /** * 功能简述: 对实体Bean进行序列化操作. * @param source 待转换的实体 * @return 转换之后的字节数组 * @throws Exception */ public static byte[] serialize(Object source) { ByteArrayOutputStream byteOut = null; ObjectOutputStream ObjOut = null; try { byteOut = new ByteArrayOutputStream(); ObjOut = new ObjectOutputStream(byteOut); ObjOut.writeObject(source); ObjOut.flush(); } catch (IOException e) { logger.error(source.getClass().getName() + " serialized error !", e); } finally { try { if (null != ObjOut) { ObjOut.close(); } } catch (IOException e) { ObjOut = null; } } return byteOut.toByteArray(); } /** * 功能简述: 将字节数组反序列化为实体Bean. * @param source 需要进行反序列化的字节数组 * @return 反序列化后的实体Bean * @throws Exception */ public static Object deserialize(byte[] source) { ObjectInputStream ObjIn = null; Object retVal = null; try { ByteArrayInputStream byteIn = new ByteArrayInputStream(source); ObjIn = new ObjectInputStream(byteIn); retVal = ObjIn.readObject(); } catch (Exception e) { logger.error("deserialized error !", e); } finally { try { if(null != ObjIn) { ObjIn.close(); } } catch (IOException e) { ObjIn = null; } } return retVal; }}
3. 对JavaBean的存储和获取：
定义实体：借助于Timestamp类，获取ms值。
1 Userinfo actual = new Userinfo(140520, "Nick Xu", 2 new Date(Timestamp.valueOf("1990-11-11 00:00:00").getTime()));
使用Jedis操作：key、value都需要转成byte[]字节数组。
Java代码
1 String key = "user.userid." + actual.getUserId(); 2 jedis.set(key.getBytes(), SerializingUtil.serialize(actual)); 3 Userinfo expected = (Userinfo) SerializingUtil.deserialize(jedis.get(key.getBytes()));
对象的比较：需要覆写equals和hashCode方法。
Java代码
1 assertEquals(expected, actual); 请参考：http://hello-nick-xu.iteye.com/blog/2077090
jedis入门一
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。