redis+mysql+quartz 一种红包发送功能的实现

概要：

这篇文章主要是对半年前开发的红包模块进行整理，把其中主要的设计思想以及具体的实现方案进行介绍，如有设计以及实现上的缺陷，或是存在漏洞，请大家批评指正！

红包功能大家都很熟悉了，那在这里就简单的对红包功能进行描述...

功能描述：红包业务主要的功能包括四部分，分别是红包发送，红包接收，红包回收，以及红包记录查询。

1）红包发送：发送者账户->红包中间层

2）红包接收：红包中间层->接收者账户

3）红包回收：红包中间层中若存在红包留存超过24小时，则将其回收，红包中间层->发送者账户

功能描述大体了解之后，那接下来就是实现方案了...

首先给出设计流程，这部分将依次对红包发送、红包接收、红包回收的流程进行分析...

1. 设计流程

首先是红包发送功能，以群红包为例，其流程图如下所示：

图1 红包发送流程图

首先，采用基于高斯分布的方法，将金额100随机的分配成8份，然后将这8份数据存入到redis缓存队列(list)中，同时将队列的过期时间设置成24h；考虑到在抢红包的时候会出现重复抢的问题，那在这里采用的去除重复的方案是在redis缓存中维护一个已分配集合（set），集合里面存储的是已经接收过红包的用户ID；另外，在大量的用户同时抢红包的 情况，出于优化方面的考虑，为了起到一定的限流作用，同时减少对数据库的访问压力（考虑这种情况：一个时间段内，大量的用户在抢红包，在红包已经分配完的时刻之后 到来的请求，会给数据库带来一定的访问压力），那做法是在redis缓存中维护一个红包已分配完的标记（key-value）,有0（为分配完）/1（已分配完）两种状态，从而起到一定的限流作用。

继缓存层面之后，接下来是数据库层面，那在MySQL中的红包发送表（account_coin_records_user_coin_package_send）中生成一条记录，同时呢在把上面经高斯分布方法得到的8份金额插入到红包分配表（account_coin_records_user_coin_package_assign）中，初始化分配标记为0（未分配），至此，红包发送的整个流程完成。

然后是红包接收功能，其流程图如下所示：

图2 红包接收流程图

红包接收者发起请求（请求中包含红包ID、请求人的用户ID）去抢红包，首先需要一系列的验证，这个验证操作要同时基于redis缓存以及MySQL数据库中的数据进行 验证，主要是验证红包ID对应的红包是否存在、红包是否已经分配完了、红包是否已经过期了、红包接收者是否重复接收红包等。如果验证通过，那么这个用户是允许接收到红包的，接下来就是账户同步（红包中间层->用户账户，事务处理），若数据库操作成功，则红包接收成功，否则失败，至此，红包接收整体流程完成。

最后就是红包回收功能，其流程图如下所示：

图3 红包回收流程图

红包回收是采用定时调度策略发起的，时间间隔为5min不间断的轮询访问MySQL数据库，查询是否有待回收的红包（红包在红包中间层留存已经超过24h，且红包 未 分配完），若有需要回收的红包，这个时候基于效率方面的考虑，采用多线程方案来进行回收操作，每个红包对于一个线程，策略是：一个线程，一个请求，一个事务（这 个 方案只适用于待回收的红包个数不是很多的情况）。（注意：若需要回收的红包很多，若不断的申请线程，可能造成内存溢出问题，这时候具体问题具体分析，可以考虑生产者-消费者模式）；分布式架构，远程调用，接下来处理红包回收的服务器接收到红包回收请求后，进行账户同步以及红包状态标记（标记为已回收），若数据库事务出现异常，那么事务回滚，此时，这个红包没有回收成功，只能等待下一个5min后再次被回收。

到这里，流程基本介绍完了，那接下来介绍一下数据模型...

2. 数据模型

数据库用的是MySQL。将红包记录进行持久化存储，用于查询红包分配记录以及后期的历史记录查询。红包分配的数据模型如下图所示：

图4 红包分配数据模型

图4中展示了部分的比较重要的数据信息，表之间的关联是靠红包ID建立起来的，红包记录以及状态标记图中已经标识出来了，就不一一介绍了。

在数据库层面，接收红包功能存在高并发问题，那接下来就简单介绍下是如何处理并发的...

3. 并发处理

是如何处理高并发问题的呢？

分析：

首先，由于红包的金额存放在redis缓存队列中，由于redis是单线程的，那么在获取红包的阶段不存在并发问题...

然后，下一步是MySQL数据库一系列的update操作，存在高并发问题...

最后，是记录保存，insert操作，也不存在并发问题...

数据库中update操作，主要应用乐观锁和X锁两种方式来保证数据一致性的。

4. 并发测试

在一段时间的并发测试中，测试通过，不会出现数据不一致问题，红包回收功能也能正常进行。

目前在并发方面，至少支持同一时刻并发量为3000的抢红包操作不会出现问题。

总结，由于能力以及技术有限，目前的方案基本适用用户量不是很大的应用场景，后期随着用户量的增大，会进一步的进行优化...

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

赞 (0)

相关推荐

  • PHP使用redis实现统计缓存mysql压力的方法

    本文实例讲述了PHP使用redis实现统计缓存mysql压力的方法.分享给大家供大家参考,具体如下: <?php header("Content-Type:text/html;charset=utf-8"); include 'lib/mysql.class.php'; $mysql_obj = mysql::getConn(); //redis $redis = new Redis(); $redis->pconnect('127.0.0.1', 6379); if(is

  • PHP的Laravel框架结合MySQL与Redis数据库的使用部署

    相对于熟读官方文档,更重要的是要把框架环境搭起来. 零.环境介绍 操作系统:centOS 数据库: mysql 5.6 (阿里云RDS) PHP 5.4.4 (>=5.4即可) Laravel 5.0 一.安装LNMP 在安装Laravel之前,需要把Linux + Nginx + Mysql + Php的环境搭建好.具体的搭建步骤这里就不再详述了. P.S. Linux阿里云已经自带了,本文使用的是centOS 6.5 64位的ECS 关于Nginx和Apache的选择看自己喜好,本文使用的是

  • 从MySQL到Redis的简单数据库迁移方法

    从mysql搬一个大表到redis中,你会发现在提取.转换或是载入一行数据时,速度慢的让你难以忍受.这里我就要告诉一个让你解脱的小技巧.使用"管道输出"的方式把mysql命令行产生的内容直接传递给redis-cli,以绕过"中间件"的方式使两者在进行数据操作时达到最佳速度. 一个约八百万行数据的mysql表,原本导入到redis中需要90分钟,使用这个方法后,只需要两分钟.不管你信不信,反正我是信了. Mysql到Redis的数据协议 redis-cli命令行工具有

  • python连接MySQL、MongoDB、Redis、memcache等数据库的方法

    用Python写脚本也有一段时间了,经常操作数据库(MySQL),现在就整理下对各类数据库的操作,如后面有新的参数会补进来,慢慢完善. 一,python 操作 MySQL:详情见:[apt-get install python-mysqldb] 复制代码 代码如下: #!/bin/env python# -*- encoding: utf-8 -*-#-------------------------------------------------------------------------

  • CentOS 安装 PHP5.5+Redis+XDebug+Nginx+MySQL全纪录

    启动ssh服务 service sshd start yum -y update 查看centos版本 centos 5 执行: 复制代码 代码如下: rpm -Uvh http://mirror.webtatic.com/yum/el5/latest.rpm centos 6 执行: 复制代码 代码如下: rpm -Uvh http://mirror.webtatic.com/yum/el6/latest.rpm yum安装php 复制代码 代码如下: yum install php55w 

  • redis+mysql+quartz 一种红包发送功能的实现

    redis+mysql+quartz 一种红包发送功能的实现

    概要: 这篇文章主要是对半年前开发的红包模块进行整理,把其中主要的设计思想以及具体的实现方案进行介绍,如有设计以及实现上的缺陷,或是存在漏洞,请大家批评指正! 红包功能大家都很熟悉了,那在这里就简单的对红包功能进行描述... 功能描述:红包业务主要的功能包括四部分,分别是红包发送,红包接收,红包回收,以及红包记录查询. 1)红包发送:发送者账户->红包中间层 2)红包接收:红包中间层->接收者账户 3)红包回收:红包中间层中若存在红包留存超过24小时,则将其回收,红包中间层->发送者账户

  • Python实现的查询mysql数据库并通过邮件发送信息功能

    本文实例讲述了Python实现的查询mysql数据库并通过邮件发送信息功能.分享给大家供大家参考,具体如下: 这里使用Python查询mysql数据库,并通过邮件发送宕机信息. Python代码如下: #-*- coding: UTF-8 -*- #!/usr/bin/env python ''''' author:qlzhong Created on 2015-6-29 征途宕机日志统计汇总 ''' import MySQLdb import time import datetime impo

  • 通过redis的脚本lua如何实现抢红包功能

    redis 脚本介绍 Redis从2.6版本开始,通过内嵌支持Lua环境 好处 减少网络开销.可以将多个请求通过脚本的形式一次发送,减少网络延迟 原子操作.redis将整个脚本当作一个整体去执行,中间不会被其他命令插入,无需担心脚本执行过程中会出现竞态条件 复用.客户端发送的脚本会永久保存在redis中,可以复用这一脚本 数据库表设计 简单两张表,一个红包表,一个红包领取记录表 CREATE TABLE `t_red_envelope` ( `id` bigint(20) NOT NULL AU

  • 使用PHP+Redis实现延迟任务,实现自动取消订单功能

    简单定时任务解决方案:使用redis的keyspace notifications(键失效后通知事件) 需要注意此功能是在redis 2.8版本以后推出的,因此你服务器上的reids最少要是2.8版本以上: (A)业务场景: 1.当一个业务触发以后需要启动一个定时任务,在指定时间内再去执行一个任务(如自动取消订单,自动完成订单等功能) 2.redis的keyspace notifications 会在key失效后发送一个事件,监听此事件的的客户端就可以收到通知 (B)服务准备: 1.修改reid

  • Laravel5.0+框架邮件发送功能实现方法图文与实例详解

    本文实例讲述了Laravel5.0+框架邮件发送功能实现方法.分享给大家供大家参考,具体如下: I. 背景 近期在接触传说中最优雅的 PHP 框架--Laravel,学习了一下邮件发送功能,在此分享一下 测试环境:Laravel 5.2.45,Laravel 5.5 使用协议:SMTP 邮件传输协议 对于 ThinkPHP 框架框架的邮件发送可参考文章 ThinkPHP 框架下邮件发送功能 II. 功能开发过程 此处以 网易(163.com)邮箱为例. 一.前期准备 (1).首先对 SMTP 的

  • 深入Lumisoft.NET组件与.NET API实现邮件发送功能的对比分析

    深入Lumisoft.NET组件与.NET API实现邮件发送功能的对比分析

    我在另一篇文章<深入Lumisoft.NET实现邮件发送功能的方法详解>有大致对这个Lumisoft.NET组件的使用进行了介绍,当然Lumisoft.NET组件除了提供邮件发送功能外,还提供了邮件接收等功能的处理(包括基于POP3协议和IMAP协议),而.NET则除了提供SMTP协议功能外,则没有提供POP3协议处理的相关类库,因此收取邮件这需要自己进行封装(需要也可以参考codeproject.com上的相关文章). 1..NET的邮件发送功能实现.NET本身封装了一个SmtpClient

  • Android实现带附件的邮件发送功能

    Android实现带附件的邮件发送功能

    本文实例讲解了基于基于JMail实现Android邮件发送功能,分享给大家供大家参考,具体内容如下 在android上发送邮件方式: 第一种:借助GMail APP客户端,缺点是必须使用GMail帐号,有一点是比较方便,不需要写很多代码,但是不是很灵活. 第二种:基于JMail实现,可以很灵活的自己设置各种属性,不需要GMail帐号 在第二种方式的实现之前,看一下JMail对EMail结构的划分: 基于SMTP协议发送EMail,所以客户端必须要知道SMTP的主机. 腾讯邮件的SMTP主机为:s

  • Android仿微信、录制音频并发送功能

    Android仿微信、录制音频并发送功能

    MyRecorder(仿微信,录制音频并发送功能) ①布局实现(activity_main.xml) 布局采用线性布局,上面使用的一个ListView,下面使用的是一个自定义的Button(会在下面进行介绍) <?xml version="1.0" encoding="utf-8"?> <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"

  • Redis实现多人多聊天室功能

    Redis实现多人多聊天室功能

    本文为大家分享了Redis支持多人多聊天室功能的设计代码,供大家参考,具体内容如下 设计原理 左边的一个数据域,代表两个聊天室,聊天室id分别是827,729 在聊天室827里,有2个人,分别是jason22,jeff24他们分别已经阅读过聊天室内的id为5和6的消息 右边的一个数据域,代表了用户在不同的聊天室,jason22参与了827与729聊天室,在这两个聊天室里,他分别阅读到了id为5和id为10的消息 另外827聊天室内id为5的消息与729聊天室内id为5的消息不一样. 同时还有三个

  • 深入Lumisoft.NET实现邮件发送功能的方法详解

    深入Lumisoft.NET实现邮件发送功能的方法详解

    在前面的一些文章中,有介绍过DotNet内置SMTP类的邮件发送功能,附件.嵌入图片的模式都有介绍,本文继续介绍Lumisoft.NET这个非常优秀的开源组件,用该组件来设计开发邮件工具,将变得更加方便,功能更加强大.网上很多文章基本介绍如何使用该组件来收取邮件较多,较少介绍使用该组件做邮件发送功能的.本文主要探寻使用该组件实现邮件的发送功能,邮件发送有两种方式,一种是不用发件人即可发送邮件,一种是使用发件人账户密码和SMTP服务器来实现邮件发送的,本文分别对这两种方式进行介绍. 组件下载地址:

随机推荐