发表于: 2017-09-13 22:47:11

1 795


禅道: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整合



返回列表 返回列表
评论

    分享到