您的位置:首页 > 数据库 > Redis

Java使用Jedis操作Redis

2017-01-10 22:43 351 查看
package com.zhuyang.redis.command;

import redis.clients.jedis.Jedis;

public class Utils {
public static Jedis getJedis (){
return new Jedis("localhost");
}
}


package com.zhuyang.redis.command;

import java.util.HashMap;
import java.util.Map;

import redis.clients.jedis.Jedis;

public class RedisHash {

/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
Jedis jedis = Utils.getJedis();
Map map =new HashMap();
map.put("name", "java");
map.put("author", "zhuyang");
map.put("price", "500");
jedis.hmset("book", map);
String fileds []= new String[]{"name","price"};
System.out.println(jedis.hmget("book",fileds));
System.out.println(jedis.hgetAll("book"));
}

}


package com.zhuyang.redis.command;

import java.util.List;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPubSub;

public class RedisJavaList {

/**
* @param args
*/
public static void main(String[] args) {
Jedis jedis = Utils.getJedis();
for (int i = 0; i < 3; i++) {
jedis.lpush("list", "l" + i);
}
for (int i = 3; i < 6; i++) {
jedis.rpush("list", "l" + i);
}

List<String> list = jedis.lrange("list", 0, jedis.llen("list"));
for (String l : list) {
System.out.println(l);
}

jedis.del("list");

}

}


package com.zhuyang.redis.command;

public class RedisJavaString {
public static void main(String[] args) {

System.out.println(Utils.getJedis().ping());
Utils.getJedis().set("key_java", "value");
System.out.println(Utils.getJedis().get("key_java"));
}
}


package com.zhuyang.redis.command;

import java.util.List;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;

public class RedisPipeline {
public static void main(String[] args) {
Jedis jedis = Utils.getJedis();

long start = System.currentTimeMillis();
for (int i = 0; i < 10000; i++) {
jedis.set("key" + i+1, "key" + i+1);
}
long end = System.currentTimeMillis();
System.out.println("spend time without pipe" + ((end - start) / 1000.0)
+ " seconds");

Pipeline pipe = jedis.pipelined();
start = System.currentTimeMillis();
for (int i = 0; i < 10000; i++) {
pipe.set("key" + i+1, "key" + i+1);
}
List<Object> results = pipe.syncAndReturnAll();
end = System.currentTimeMillis();
System.out.println("Pipelined SET: " + ((end - start) / 1000.0)
+ " seconds");
jedis.disconnect();
}
}


package com.zhuyang.redis.command;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;

public class RedisTxn {
public static void main(String[] args) {
Jedis jedis = Utils.getJedis();
jedis.watch("key6");
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
Transaction txn = jedis.multi();
txn.set("key6", "key777");
System.out.println(txn.exec());
}
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: