Redis的事务处理

Redis的事务操作

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set djk fdjs
QUEUED
127.0.0.1:6379> set djklg djgl
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> exec
(error) ERR EXEC without MULTI

127.0.0.1:6379> watch hello
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set hello ffff
QUEUED
127.0.0.1:6379> set name zll
QUEUED
127.0.0.1:6379> exec
(nil)

Jedis实例

public class JedisTransaction {
private Jedis jedis;
@Before
public void beforeJedis(){
jedis = JedisConnection.jedisConnection();
}
@Test
public void testTransaction(){
//事务一旦执行，客户端发来的请求都不能打断。
//开启一个事务
Transaction transaction = jedis.multi();
transaction.set("hello", "world!");
transaction.mset("hashset_keys","nnnn");
transaction.lpush("list_key","hhhh");
transaction.lpush("list_key","xxx");
transaction.exec();
System.out.println("=="+jedis.keys("*"));
}
@Test
public void testWatch(){
jedis.watch("name");
Transaction transaction = jedis.multi();
transaction.set("hello", "world!");
//此时用客户端，对name进行修改操作。
transaction.mset("name","tttt");
transaction.lpush("age","444");
System.out.println(transaction.exec());
}
@Test
public void testDiscard(){
Transaction transaction = jedis.multi();
transaction.set("hello", "world!");
//取消事务
System.out.println(transaction.discard());
}
}