package redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Pipeline;
public class Shiwu {
private static Jedis jedis = new Jedis("192.168.10.250", 6379);
public static void main(String[] args) {
jedis.watch("age");
Pipeline pipeline = jedis.pipelined();
pipeline.multi();
pipeline.set("age", "10");
pipeline.incr("age");
pipeline.incr("age");
pipeline.incr("age");
pipeline.incr("age");
pipeline.exec();
}
}
事务确保命令全部成功或者全部失败，pipeline确保命令一起发送，但是是不是全都完成就不知道了。
package redis;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;
public class Shiwu {
private static Jedis jedis = new Jedis("192.168.10.250", 6379);
public static void main(String[] args) {
jedis.watch("age");
Transaction tx = jedis.multi();
tx.set("age", "10");
tx.incr("age");
tx.incr("age");
tx.incr("age");
tx.incr("age");
tx.exec();
}
}
