Redis学习笔记-事务

Posted 2020-07-28 左侧码工

package cn.com;

import java.util.List;

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

public class Redis_Transactions {

	public static Jedis redis = new Jedis("localhost", 6379);// 连接redis
	
	
	/**
	 * 基本事务用法
	 * 默认给user1,user2都初始化为1000
	 * 开启事务
	 * 给user:1:money 加一
	 * 给user:2:money 减一
	 * 执行事务
	 * */
	public static void base_trans() throws InterruptedException{
		redis.flushDB();//清除数据
		redis.set("money", "1000");
		redis.set("money1", "1000");
	    long start = System.currentTimeMillis(); 
	   
	    Transaction tx = redis.multi(); 
	    tx.incr("money");//给用户user:1 加一块钱
	    tx.decr("money1");//给用户user:1 减一块钱
	    List<Object> results = tx.exec(); 
	    long end = System.currentTimeMillis(); 
	    System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds"); 
	   
	    System.out.println(redis.get("money"));
	    System.out.println(redis.get("money1"));
	    redis.disconnect(); 
	}
	
	/**
	 * 用户事务
	 * 默认给user1,user2都初始化为1000
	 * 开启事务
	 * 给user:1:money 加一
	 * 给user:2:money 减一
	 * 我们user:2:money 的值是a 是无法执行减1 的操作 那是否还是照样执行
	 * 因为redis事务是比较简单的，像下面这种问题需要开发者自己控制，redis 事务是不做控制的
	 * */
	public static void user_trans() throws InterruptedException{
		redis.flushDB();//清除数据
		redis.set("user:1:money", "1000");
		redis.set("user:2:money", "a");
	    long start = System.currentTimeMillis(); 
	    Transaction tx = redis.multi(); 
	     
	    tx.incr("user:1:money");//给用户user:1 加一块钱
	    tx.decr("user:2:money");//给用户user:1 减一块钱
	   
	    List<Object> results = tx.exec(); 
	    long end = System.currentTimeMillis(); 
	    System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds"); 
	    
	    System.out.println(redis.get("user:1:money"));
	    System.out.println(redis.get("user:2:money"));
	    redis.disconnect(); 
	}
	
	/**
	 * 执行事务的过程其他客户端改变了其中的key值，解决数据一致性问题
	 * 通过watch 对key的监控来实现其他客户端修改数据后，事务取消
	 * 用法 首先用watch 开始对key的监控 在开启事务，顺序一定要先监控在执行事务
	 * */
	public static void changedata_trans() throws InterruptedException{
		redis.flushDB();//清除数据
		redis.set("user:1:money", "1000");
		redis.set("user:2:money", "1000");
	    long start = System.currentTimeMillis(); 
	    redis.watch("user:1:money");
	    Transaction tx = redis.multi(); 
	    tx.incr("user:1:money");//给用户user:1 加一块钱
	    tx.decr("user:2:money");//给用户user:1 减一块钱
	    changedata();//改变数据的方法
	    List<Object> results = tx.exec(); 
	   
	    long end = System.currentTimeMillis(); 
	    System.out.println("Transaction SET: " + ((end - start)/1000.0) + " seconds"); 
	    
	    System.out.println(redis.get("user:1:money"));
	    System.out.println(redis.get("user:2:money"));
	    redis.disconnect(); 
	}
	
	
	/**
	 * 模拟新开客户端对事务中监控的key对应的元素进行修改
	 * 
	 * **/
	public static void changedata(){
		  Jedis redis2 = new Jedis("localhost", 6379);// 连接redis
		  redis2.set("user:1:money", "8888");
	}
	
 
 
	public static void main(String [] args) throws InterruptedException{
		changedata_trans(); 
	
		
	}
}