文档章节

Redis事务

秋风醉了
 秋风醉了
发布于 2016/04/14 13:43
字数 1025
阅读 62
收藏 1
点赞 1
评论 0

Redis事务

redis事务简述

MULTI,EXEC,DISCARD,WATCH 四个命令是 redis 事务的四个基础命令。其中:

  • MULTI,告诉 redis 服务器开启一个事务。注意,只是开启,而不是执行

  • EXEC,告诉 redis 开始执行事务

  • DISCARD,告诉 redis 取消事务

  • WATCH,监视某一个键值对,它的作用是在事务执行之前如果监视的键值被修改,事务会被取消。

在介绍 redis 事务之前,先来展开 redis 命令队列的内部实现。


redis命令队列

redis 允许一个客户端不间断执行多条命令:发送 MULTI 后,用户键入多条命令;再发送 EXEC 即可不间断执行之前输入的多条命令。

➜  redis_7000 redis-cli -p 7000
127.0.0.1:7000> multi
OK
127.0.0.1:7000> set email helloworld
QUEUED
127.0.0.1:7000> set count 10
QUEUED
127.0.0.1:7000> incrby count 2
QUEUED
127.0.0.1:7000> exec
1) OK
2) OK
3) (integer) 12
127.0.0.1:7000>

由上面给出的 redis 客户端操作,来看看 redis 服务器的状态变化:



redis事务不可回滚

下面示例操作,

127.0.0.1:7000> multi
OK
127.0.0.1:7000> set counter 15
QUEUED
127.0.0.1:7000> incrby counter hello
QUEUED
127.0.0.1:7000> incrby counter 2
QUEUED
127.0.0.1:7000> exec
1) OK
2) (error) ERR value is not an integer or out of range
3) (integer) 17
127.0.0.1:7000> get counter
"17"

当执行exec时,会顺序的执行命令队列中的命令,其中一条命令incrby counter hello是错误的,但不会影响命令队列中其他命令的执行。从上面命令执行结果就可以看出,当incrby counter hello命令执行失败后,并没有影响下一条命令的执行,而是成功的自增了2,最后得到counter的结果是17,正确自增后的结果。


redis事务具有隔离性

开启两个redis客户端,当其中一个客户端进入事务状态后,不影响另一个客户端进入事务状态。


Redis WATCH命令

WATCH命令的实现

在每个代表数据库的 redis.h/redisDb 结构类型中, 都保存了一个 watched_keys 字典, 字典的键是这个数据库被监视的键, 而字典的值则是一个链表, 链表中保存了所有监视这个键的客户端。

比如说,以下字典就展示了一个 watched_keys 字典的例子:

其中, 键 key1 正在被 client2 、 client5 和 client1 三个客户端监视, 其他一些键也分别被其他别的客户端监视着。

WATCH 命令的作用, 就是将当前客户端和要监视的键在 watched_keys 中进行关联。

举个例子, 如果当前客户端为 client10086 , 那么当客户端执行 WATCH key1 key2 时, 前面展示的 watched_keys 将被修改成这个样子:

通过 watched_keys 字典, 如果程序想检查某个键是否被监视, 那么它只要检查字典中是否存在这个键即可; 如果程序要获取监视某个键的所有客户端, 那么只要取出键的值(一个链表), 然后对链表进行遍历即可。


WATCH命令的使用示例

客户端A如下操作,

127.0.0.1:7000> watch counter
OK
127.0.0.1:7000> multi
OK
127.0.0.1:7000> set counter 19
QUEUED
127.0.0.1:7000> incrby counter 2

接下来在客户端B修改counter的值,

127.0.0.1:7000> set counter 18
OK

最后客户端A执行exec命令,是命令队列执行,最后看结果,

127.0.0.1:7000> exec
(nil)
127.0.0.1:7000> get counter
"18"

最后返回结果为nil,说明该redis事务就没有执行,正是因为watch的作用,检测到counter的值发生了变化,导致整个事务被取消。


Jedis实现事务

如下示例代码,

package com.usoft.jedis.sample;

import org.junit.Before;
import org.junit.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.Transaction;

import java.util.List;

/**
 * Created by xinxingegeya on 16/4/14.
 */
public class JedisTrxTest {

    /**
     * jedis连接池
     */
    public JedisPool jedisPool;

    @Before
    public void before() {
        JedisPoolConfig config = new JedisPoolConfig();
        config.setMaxTotal(10);
        config.setMaxIdle(5);
        config.setMaxWaitMillis(5000);
        config.setTestOnBorrow(true);
        jedisPool = new JedisPool(config, "127.0.0.1", 7000);
    }

    @Test
    public void test() {
        Jedis jedis = jedisPool.getResource();
        /**
         * watch监视一个key
         * 当该key对应的值被其他客户端修改后,该事务被取消
         */
        jedis.watch("counter");
        long start = System.currentTimeMillis();
        Transaction tx = jedis.multi();
        tx.set("counter", "10");
        tx.incrBy("counter", 10);
        List<Object> results = tx.exec();
        long end = System.currentTimeMillis();
        for (Object result : results) {
            System.out.println(result);
        }
        System.out.println("Transaction SET: " + ((end - start) / 1000.0) + " seconds");
    }

}

============END============

© 著作权归作者所有

共有 人打赏支持
秋风醉了
粉丝 222
博文 581
码字总数 411013
作品 0
东城
程序员

暂无相关文章

Mahout推荐算法API详解

前言 用Mahout来构建推荐系统,是一件既简单又困难的事情。简单是因为Mahout完整地封装了“协同过滤”算法,并实现了并行化,提供非常简单的API接口;困难是因为我们不了解算法细节,很难去根...

xiaomin0322 ⋅ 24分钟前 ⋅ 0

WampServer默认web服务器根目录位置

安装WampServer之后的web服务器根目录默认位置在WampServer安装目录下的www:

临江仙卜算子 ⋅ 25分钟前 ⋅ 0

Redux的一些手法记录

Redux Redux的基本概念见另一篇文。 这里记录一下Redux在项目中的实际操作的手法。 actions 首先定义action.js,actions的type,可以另起一个action-type.js文件。 action-type.js用来存...

LinearLaw ⋅ 26分钟前 ⋅ 0

android 手势检测(左右滑动、上下滑动)

GestureDetector类可以让我们快速的处理手势事件,如点击,滑动等。 使用GestureDetector分三步: 1. 定义GestureDetector类 2. 初始化手势类,同时设置手势监听 3. 将touch事件交给gesture...

王先森oO ⋅ 41分钟前 ⋅ 0

java 方法的执行时间监控 设置超时(Future 接口)

java 方法的执行时间监控 设置超时(Future 接口) import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor......

青峰Jun19er ⋅ 45分钟前 ⋅ 0

一名开源小白的Apache成长自述

今天收到了来自Apache Vote我成为Serviceomb项目Committer的邮件,代表自己的贡献得到了充分的肯定;除了感谢团队的给力支持,我更希望将自己的成长经历——如何践行Apache Way的心得介绍给大...

微服务框架 ⋅ 47分钟前 ⋅ 0

vim介绍、颜色显示和移动光标、一般模式下复制、剪切和粘贴

1.vim 是 vi 的升级版 vim 是带有颜色显示的 mini安装的系统,一般都不带有vim [root@aminglinux-128 ~]# yum install -y vim-enhanced已加载插件:fastestmirror, langpacksLoading mir...

oschina130111 ⋅ 48分钟前 ⋅ 0

Deepin 操作系统四面楚歌

作为国内做的最好的 Linux 发行版,源自 Debian sid 的 Deepin 目前正面临重重困境,新版本不断延期,开发人员离职,bug 长期得不到修复,和 Debian/Ubuntu 的兼容性问题也面临越来越严重的挑...

六库科技 ⋅ 48分钟前 ⋅ 0

MyBatis之动态sql

我们需要知道的是,使用mybatis重点是对sql的灵活解析和处理。在原先的UserMappser.xml中,我们这样查询表中满足条件的记录 : 123 <select id="findUserList" parameterType="userQuery...

瑟青豆 ⋅ 48分钟前 ⋅ 0

这届俄罗斯世界杯的冷门那么多怎么办?

最纯粹的世界杯,最神奇的大冷门。 德国0比1被墨西哥摩擦了。 日本历史性的赢了哥伦比亚。 C罗也挑平了西班牙。 梅西被冰岛狮吼吼愣神了。 就连11次进世界杯4强的巴西也被瑞士逼平了。 天台已...

开源中国众包平台 ⋅ 49分钟前 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部