发表于: 2017-09-13 22:47:11
1 794
禅道:http://task.ptteng.com/zentao/project-task-302.html
已经延期
今天完成的事情:
1.完成了基础的redis连接
package com.task.redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
/**
* Created by gjf on 2017/09/04.
*/
public final class RedisUtil {
//Redis服务器IP
private static String ADDR = "localhost";
//Redis端口号
private static int PORT = 6379;
//可用连接实例的最大数目,默认值为8;
//如果赋值为-1,则表示不限制;如果pool已经分配了maxActive个jedis实例,则此时pool的状态为exhausted(耗尽)。
//没用上,尴尬,config没这个set方法
private static int MAX_ACTIVE = 1024;
//控制一个pool最多有多少个状态为idle(空闲的)的jedis实例,默认值也是8。
private static int MAX_IDLE = 200;
//等待可用连接的最大时间,单位毫秒,默认值为-1,表示永不超时。如果超过等待时间,则直接抛出JedisConnectionException;
private static int MAX_WAIT = 10000;
private static int TIMEOUT = 10000;
//在borrow一个jedis实例时,是否提前进行validate操作;如果为true,则得到的jedis实例均是可用的;
private static boolean TEST_ON_BORROW = true;
private static JedisPool jedisPool = null;
/**
* 初始化Redis连接池
*/
static {
try {
JedisPoolConfig config = new JedisPoolConfig();
config.setMaxIdle(MAX_IDLE);
config.setMaxWaitMillis(MAX_WAIT);
config.setTestOnBorrow(TEST_ON_BORROW);
jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT);
}catch (Exception e){
e.printStackTrace();
}
}
/**
* 获取Jedis实例
* @return
*/
public synchronized static Jedis getJedis(){
try{
if(jedisPool != null){
Jedis resource =jedisPool.getResource();
return resource;
}else {
return null;
}
}catch (Exception e){
e.printStackTrace();
return null;
}
}
/**
* 释放Jedis资源
* @param jedis
*/
public static void close(final Jedis jedis){
if(jedis != null){
jedis.close();
}
}
}
另一个序列化的类:
public static byte[] serialize(Object object) {
ObjectOutputStream oos = null;
ByteArrayOutputStream baos = null;
try {
// 序列化
baos = new ByteArrayOutputStream();
oos = new ObjectOutputStream(baos);
oos.writeObject(object);
byte[] bytes = baos.toByteArray();
return bytes;
} catch (Exception e) {
}
return null;
}
public static Object unserialize( byte[] bytes) {
ByteArrayInputStream bais = null;
try {
// 反序列化
bais = new ByteArrayInputStream(bytes);
ObjectInputStream ois = new ObjectInputStream(bais);
return ois.readObject();
} catch (Exception e) {
}
return null;
}
然后在service是这样的
@Cacheable("ha")
public List<User1> selectUsers() {
Jedis jedis=new Jedis("127.0.0.1",6379);
if(jedis.get("cache_d")==null) {
List user1 = user1Mapper.selectUsers();
jedis.set("cache_d".getBytes(), SerializeUtil. serialize(user1));
System.out.println("这是数据库");
return user1;
}else{
System.out.println("这是缓存");
byte[] value = jedis.get("cache_d".getBytes());
return (List)SerializeUtil. unserialize(value);
}
简单写一下,@Cacheable
在方法上加上@Cacheable注解,这个方法的返回值将具有缓存特性。
@Cacheable注解可以用在方法或者类级别。当他应用于方法级别的时候,就是如上所说的缓存返回值了。当应用在类级别的时候,这个类的所有方法的返回值都将被缓存。
@Cacheable注解有三个参数,value,key,condition。
value是存在什么地方,key就是取时候用的key condition是存的条件。
2.看老大直播
3.晚上搞spring redis
spring redis
我把该引入的宝引入了,配置文件也赔了,然后尝试运行的时候报错。想着重新找一下例子,发现删除了redis的部分也报错
不知道是哪个xml出错了,这上面也没说啊,明天重新搞一下,找了一个新的例子。
https://www.zhihu.com/question/40707647
家里网也太差今天,一直用的流量。
明天的计划:
继续尝试spring redsi整合
评论