redis应用于缓存 -凯发k8国际

zw7534313

浏览: 1231611 次
性别:
来自: 北京

博主相关

博客

微博

相册

文章分类

社区版块

( 0)
( 21)
( 1)

存档分类

2023-12 ( 11)
2023-08 ( 10)
2022-08 ( 1)

redis应用于缓存

博客分类：

redis

redis

import redis.clients.jedis.jedis;
public class redisjava {
private static string host = "192.168.1.101";

public static void main(string[] args) {
//isserverrunning();

// set(); //1.保存放键/值对

// setsiglelist(); //2.保存list

// getredisserverallkeys(); //3.获取所有的key

// setsinglemap(); //4.保存map

//setobject(); //5.保存序列化的对象

setobjectwithtimeout(); //6.保存序列化的对象并设置超时时间

//setjson(); //
}

private static void isserverrunning(){
//连接本地的 redis 服务
      jedis jedis = new jedis(host);
      system.out.println("connection to server sucessfully");
      //查看服务是否运行
      system.out.println("server is running: " jedis.ping());
}

static void set(){
//连接本地的 redis 服务
      jedis jedis = new jedis(host);
      system.out.println("connection to server sucessfully");
      //设置 redis 字符串数据
      jedis.set("w3ckey", "redis tutorial");
     // 获取存储的数据并输出
     system.out.println("stored string in redis:: " jedis.get("w3ckey"));
}

static void setsiglelist(){
//连接本地的 redis 服务
      jedis jedis = new jedis(host);
      system.out.println("connection to server sucessfully");
      //存储数据到列表中
      jedis.lpush("tutorial-list", "redis");
      jedis.lpush("tutorial-list", "mongodb");
      jedis.lpush("tutorial-list", "mysql");

      jedis.lpush("tutorial-list", "mysql2");
      jedis.lpush("tutorial-list", "mysql3");
      jedis.lpush("tutorial-list", "mysql4");
      jedis.lpush("tutorial-list", "mysql5");
     // 获取存储的数据并输出
     list list = jedis.lrange("tutorial-list", 0 ,2);
     for(int i=0; i        system.out.println("stored string in redis:: " list.get(i));
     }

     system.out.println();
     list = jedis.lrange("tutorial-list", 1, 2);
     for(int i=0; i        system.out.println("stored string in redis:: " list.get(i));
     }

     string val = jedis.lpop("tutorial-list"); //移除list.get(0)并返回值
     system.out.println("list.get(0): " val);

     for(int i=0; i        system.out.println("stored string in redis:: " list.get(i));
}
}

static void getredisserverallkeys(){
//连接本地的 redis 服务
      jedis jedis = new jedis(host);
      system.out.println("connection to server sucessfully");

     // 获取数据并输出
     set list = jedis.keys("*");
     string key = null;
     for(iterator it = list.iterator(); it.hasnext();) {
       key = (string)it.next();
       system.out.println("list of stored keys:: " key);
     }
}

static void setsinglemap(){
jedis jedis = new jedis(host);
map map = new hashmap();
map.put("name", "fujianchao");
map.put("password", "123");
map.put("age", "12");
// 存入一个map
jedis.hmset("user", map);
// map key的个数
system.out.println("map的key的个数" jedis.hlen("user"));
// map key
system.out.println("map的key" jedis.hkeys("user"));
// map value
system.out.println("map的value" jedis.hvals("user"));
// (string key, string... fields)返回值是一个list
list list = jedis.hmget("user", "age", "name");
system.out.println("redis中key的各个 fields值："
jedis.hmget("user", "age", "name") list.size());
// 删除map中的某一个键的值 password
// 当然 (key, fields) 也可以是多个fields
jedis.hdel("user", "age");
system.out.println("删除后map的key" jedis.hkeys("user"));

jedis.hset("user", "num", "100");
system.out.println("新增后map的key" jedis.hkeys("user"));
}

static void setobject(){
jedis jedis = new jedis(host);

user user = new user();
user.setname("张三");
user.setid(1000);

jedis.set("user1".getbytes(), serializationutil.serialize(user));

byte[] val = jedis.get("user1".getbytes());
user u1 = (user)serializationutil.deserialize(val);
system.out.println(u1.getname());
}

//redis缓存
static void setobjectwithtimeout(){
jedis jedis = new jedis(host);

user user = new user();
user.setname("张三");
user.setid(1000);

jedis.set("user1".getbytes(), serializationutil.serialize(user));
int timeout=2;
jedis.expire("user1".getbytes(), timeout); //2秒过期

byte[] val = jedis.get("user1".getbytes());
user u1 = (user)serializationutil.deserialize(val);
system.out.println(u1.getname());

try {
thread.currentthread().sleep(3000); //阻塞3秒
} catch (interruptedexception e) {
e.printstacktrace();
}
val = jedis.get("user1".getbytes());
// u1 = (user)serializationutil.deserialize(val);
system.out.println(val); //超时值为空
}

}

public class serializationutil {
    /**
     * 序列化
     *
     * @param object
     * @return
     */
    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;
    }

    /**
     * 反序列化
     *
     * @param bytes
     * @return
     */
    public static object deserialize(byte[] bytes) {
        bytearrayinputstream bais = null;
        try {
            bais = new bytearrayinputstream(bytes);
            objectinputstream ois = new objectinputstream(bais);
            return ois.readobject();
        } catch (exception e) {

        }
        return null;
    }

}

分享到：

2020-04-28 17:06
浏览 357
评论(0)
分类:编程语言

发表评论

您还没有登录,请您登录后再发表评论