关于java:每天千万级订单的生成数据库系统如何设计订单系统架构如何设计

10次阅读

共计 13315 个字符,预计需要花费 34 分钟才能阅读完成。

  • 理解随订单量的晋升,数据库系统经验了哪些变动,这些变动带来哪些痛点
  • 分库分表环境下,订单的 id 生成有哪些方法
  • 雪花算法的原理及实现
  • 领取环境下,对订单零碎的架构设计带来哪些影响

1. 架构体系深刻分析

1.1 演进与背景

随着数据量的增长,个别 db 的架构,经验如下演进:

1)单库主从

  • 业务申请并发量大到一定量级后,繁多主库无奈接受,将读写剥离,从库诞生。
  • 挑战:开发层框架反对,多数据源,数据读从提早问题。

2)单库双主多从架构

  • 实战较少,多为灾备而生,双主单写,灾备切换

3)分区表

数据库层面做数据分区策略,对开发层通明。

实用场景:

  • 适宜订单场景,最初局部有热点数据,其余都是历史订单(不沉闷)
  • 分区表的数据更容易保护,能够间接针对分区做删除、优化、查看、修复、备份等操作
  • 反对多硬件设施,不同分区扩散到不同设施,如硬盘
  • 优化查问,只应用必要的分区来进步查问效率,波及 sum()和 count()聚合查问时,也能够实现分区并发再汇总。

局限性:

  • 数量下限,一个表最多只能有 1024 个分区(mysql5.6 之后反对 8192 个分区)
  • 分区表达式类型受限,多为整数或日期。
  • 如果表中有主键或惟一索引,那么分区键必须是主键或惟一索引
  • 分区表中无奈应用外键束缚

4)横向分表

  • mysql 单表性能超过千万级别会导致性能重大降落,横向,切成多张表。
  • 挑战:分表策略,量级估算,分多少表?查问问题,扩容问题

5)多库

  • 超大量级的单库,备份,主从同步臃肿不堪,
  • 即便拆了表,单服务器仍然扛不住,io 成为瓶颈。裁减物理节点,就必须分库
  • 挑战:多数据源写,开发框架反对。数据散发难度进一步回升。

1.2 痛点

  • 支流架构个别分库分表都会波及,谋求性能的同时,带来各种痛点
  • 分库分表并不是一门翻新技术,它只是因为数据体系结构的限度而做的无奈之举
  • 机器配置无奈有限回升,老本飙升,无可奈何衍生的计划

1.2.1 连贯

1)jdbc 直连

开发层面保护,最原始的,sql 拼接

简略粗犷,sql 代码写死,扩容会变得极其蹩脚。

String year = getYear();

String sql = "select * from order_"+year+"where xxxx";

2)中间件:一般来讲,两种伎俩

​ DBproxy,对 DB 层面,针对机器做代理,个别须要 LVS/F5 等伎俩来实现流量的负载平衡,跨机房可能须要 DNS 散发,常见组件:

组件 公司 性能
Atlas 360 读写拆散、动态分表
Meituan Atlas 美团 读写拆散、单库分表,目前曾经在原厂逐渐下架。
Cobar 阿里(B2B) Proxy 的模式位于前台利用和理论数据库之间,凋谢 MySQL 通信协议,开源版中只反对 MySQL,不反对读写拆散。
MyCAT 阿里 基于 Cobar,是一个实现了 MySQL 协定的服务器,能够把它看作是一个数据库代理
Heisenberg 百度 热重启配置、可程度扩容、恪守 MySQL 原生协定、无语言限度。
Kingshard Kingshard 由 Go 开发高性能 MySQL Proxy 我的项目,在满足根本的读写拆散的性能上,Kingshard 的性能是直连 MySQL 性能的 80% 以上。
Vitess 谷歌、Youtube Rpc 形式,集群基于 ZooKeeper 治理
DRDS 阿里 专一于解决单机关系型数据库扩展性问题。

JDBC Proxy,从 jdbc 连贯层面下手,须要对不同的语言编写 Driver

组件 公司 性能
TDDL 阿里淘宝 动静数据源、读写拆散、分库分表,很久没更新了
Zebra 美团点评 动静数据源、读写拆散、分库分表、CAT 监控,接入简单、限度多。
MTDDL 美团点评 动静数据源、读写拆散、分布式主键生成、分库分表、连接池、SQL 监控

3)sharding-jdbc:


​ 轻量级 Java 框架,在 Java 的 JDBC 层提供的额定服务。以 jar 包模式应用客户端直连数据库,无需额定部署和依赖,可了解为增强版的 JDBC 驱动,齐全兼容 JDBC 和各种 ORM 框架。

  • ORM 框架,JPA, Hibernate, Mybatis, Spring JDBC,甚至间接应用 JDBC。
  • 连接池,DBCP, C3P0, BoneCP, Druid, HikariCP。
  • 数据库,MySQL,Oracle,SQLServer 和 PostgreSQL。

1.2.2 数据

1)分库分表课题:

  • 分表维度矛盾(用户,工夫)
  • 查问复杂度回升(买家,卖家)
  • 数据聚合运算难度减少(数据统计)

2)亿级数据扩容课题:

  • 扩容变得复杂(影响数据分片)

3)本课题:

  • 多库多表怎么保障生成的订单号惟一

2. 分布式订单生成策略

  • springboot 下,基于 sharding-jdbc 的框架简介。
  • 分表下的订单表案例介绍,userid 维度(分库雷同)
  • 启动与调试,按 userid 验证数据落库,再查问
  • 重点:分布式 id 的生成策略

2.1 自增

2.1.1 问题背景

1)业务代码

    @GetMapping("/incadd")
    public Incorder add(int userid){Incorder incorder = new Incorder();
        incorder.setUserid(userid);
        mapper.insert(incorder);
        return incorder;
    }

2)运行后果

3)剖析

  • 单表下自增性能不会造成数据错乱,数据库本身个性保障了主键的平安
  • 会泄露 id 法则,数据隔离做不好的话,不法分子可能会循环撞库窃取订单数据
  • 自增是表维度,一旦拆表,多个自增,有序性被突破

2.1.2 起始点分段

1)计划

设置表 2 的起始点,再来跑试试……

# 用以下 sql,或者客户端工具设置:ALTER TABLE incorder_1 AUTO_INCREMENT=10;

2)优缺点

  • 简略容易,数据库层面设置,代码是不须要动的
  • 边界的切分人为保护,操作简单,触发器主动保护能够实现但在高并发下不举荐

2.1.3 分段步长自增

1)计划

-- 查看
show session variables like 'auto_inc%';
show global  variables  like 'auto_inc%';

-- 设定自增步长
set session auto_increment_increment=2;
-- 设置起始值
set session auto_increment_offset=1;

-- 全局的
set global auto_increment_increment=2;
set global auto_increment_offset=1;

3)问题

  • 影响范畴不可控,要么 session 每次设置,遗记会出乱子。要么全局设置,影响全库所有表
  • 论断:不可取!!!

2.1.4 Sequence 个性

仅限于 oracle 和 sqlserver,支流 mysql 不反对

-- 创立一个 sequence:create sequence sequence_name as int minvalue 1 maxvalue 1000000000 start with 1 increment by 1 no cache;

-- sequence 的应用:sequence_name.nextval 

sequence_name.currval

-- 在表中应用 sequence:insert into incorder_0 values(sequence_name.nextval,userid);

2.2 业务规定

2.2.1 计划思维

不必自增,自定义 id,加上业务属性,从业务细分角度对并发性降维。例如淘宝,在订单号中退出用户 id。

加上用户 id 后,并发性维度升高到单个用户,每个用户的下单速度变的可控。

工夫戳 +userid,业务角度,一个失常用户不可能 1 毫秒内下两个单子,即使有阐明是刻意刷单,应该被前端限流。

2.2.2. 实现

    @GetMapping("/busiadd")
    public Strorder busiadd(int userid){Strorder order = new Strorder();
        order.setId(System.currentTimeMillis()+"-"+userid);
        order.setUserid(userid);
        strorderMapper.save(order);
        return order;
    }

2.3 集中式调配

2.3.1 MaxId 表

1)通过一张 max 表集中调配

CREATE TABLE `maxid` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT,
  `name` varchar(50) DEFAULT NULL,
  `nextid` bigint(20) DEFAULT NULL,
  PRIMARY KEY (`id`)
);

insert into maxid(name,nextid) values ('orders',1000);

2)创立函数

DROP FUNCTION getid;

-- 创立函数
CREATE FUNCTION getid(table_name VARCHAR(50))
RETURNS BIGINT(20)
BEGIN
  -- 定义变量
  DECLARE id BIGINT(20);
  -- 给定义的变量赋值 
    update maxid set nextid=nextid+1 where name = table_name;
    SELECT nextid INTO id FROM maxid WHERE name = table_name;
  -- 返回函数处理结果
  RETURN id;
END 

3)StrorderMapper 调整 id 策略,借助 mybatis 的 SelectKey 生成 id,留神 Before=true

    @Insert({"insert into strorder (id,userid)",
            "values (#{id},#{userid,jdbcType=INTEGER})"
    })
    @SelectKey(statement="SELECT getid('orders') from dual", 
               keyProperty="id", before=true, resultType=String.class)
    int getIdSave(Strorder record);
/**
 * maxid 表验证
 */
@GetMapping("/maxId")
public Strorder maxId(int userid){Strorder order = new Strorder();
    order.setUserid(userid);
    strorderMapper.getIdSave(order);
    return order;
}

4)启动验证分表的 id 状况,maxid 表的记录状况。

5)优缺点

  • 不须要借助任何中间件,数据库外部解决
  • 表性能问题感人,下单业务如果事务过长,会造成锁期待

2.3.2 分布式缓存

通过 redis 的 inc 原子属性来实现

1)配置 redis 服务器

# Redis 服务器地址
spring.redis.host=127.0.0.1
# Redis 服务器连贯端口
spring.redis.port=6379

2)应用 redis 主键

@GetMapping("/redisId")
public Strorder redisId(int userid){Strorder order = new Strorder();
    order.setId(template.opsForValue().increment("next_order_id").toString());
    order.setUserid(userid);
    strorderMapper.save(order);
    return order;
}

3)优缺点

  • 须要额定的中间件 redis
  • 与 db 相比不够直观,不不便查看以后增长的 id 值,须要额定连贯 redis 服务器读取
  • 性能不是问题,redis 失去业界验证和认可
  • 对 redis 集群的可靠性要求很高,禁止呈现故障,否则全副入库被阻断
  • 数据一致性须要留神,只管 redis 有长久策略,down 机复原时须要确认和以后库中最大 id 的一致性

2.4 uuid

2.4.1 代码生成

1)业务代码

@GetMapping("/uuid")
public Strorder uuid(int userid){Strorder order = new Strorder();
    order.setId(UUID.randomUUID().toString());
    order.setUserid(userid);
    strorderMapper.save(order);
    return order;
}

2)启动,数据库验证 save 后果

2.4.2 优缺点

  • 最简略的计划,数据迁徙不便
  • 毛病也是非常明显的,太过简短,十分的不敌对,可读性极差
  • 须要应用字符串存储,占用大量存储空间
  • 在建设索引和基于索引进行查问时性能不如数字

2.5 雪花算法

2.5.1 概论

​ UUID 能保障保障时空惟一,然而过长且是字符,雪花算法由 Twitter 创造,是一串数字。

​ Snowflake 是一种约定,它把工夫戳、工作组 ID、工作机器 ID、自增序列号组合在一起,生成一个 64bits 的整数 ID,可能应用 (2^41)/(1000606024365) = 69.7 年,每台机器每毫秒实践最多生成 2^12 个 ID

1 bit:固定为 0

二进制里第一个 bit 如果是 1,示意正数,然而咱们生成的 id 都是负数,所以第一个 bit 对立都是 0。

41 bit:工夫戳,单位毫秒

41 bit 能够示意的数字多达 2^41 – 1,也就是能够标识 2 ^ 41 – 1 个毫秒值。

留神!这个工夫不是相对工夫戳,而是相对值,所以须要定义一个零碎开始上线的起始工夫

10 bit:哪台机器产生的

代表的是这个服务最多能够部署在 2^10 台机器上,也就是 1024 台机器。

官网定义,前 5 个 bit 代表机房 id,后 5 个 bit 代表机器 id。

这 10 位是机器维度,能够依据公司的理论状况自在定制。

12 bit:自增序列

同 1 毫秒内,同一机器,能够产生 2 ^ 12 – 1 = 4096 个不同的 id。

优缺点:

  • 不依赖第三方介质例如 Redis、数据库,本地程序生成分布式自增 ID
  • 只能保障在工作组中的机器生成的 ID 惟一,不同组下可能会反复
  • 工夫回拨后,生成的 ID 就会反复,所以须要放弃工夫是网络同步的。

2.5.2 实现

1)本人用 java 代码实现

工具类:

package com.itheima.sharding.config;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component
public class Snowflake {/** 序列的掩码,12 个 1,也就是(0B111111111111=0xFFF=4095) */
    private static final long SEQUENCE_MASK = 0xFFF;

    /** 零碎起始工夫,这里取 2020-01-01 **/
    private long startTimeStamp = 1577836800000L;

    /** 上次生成 ID 的工夫截 */
    private long lastTimestamp = -1L;

    /** 工作机器 ID(0~31) */
    private long workerId;

    /** 数据中心 ID(0~31) */
    private long datacenterId;

    /** 毫秒内序列(0~4095) */
    private long sequence = 0L;


    /**
     * @param datacenterId 数据中心 ID (0~31)
     * @param workerId     工作机器 ID (0~31)
     */
    public Snowflake(@Value("${snowflake.datacenterId}") long datacenterId, @Value("${snowflake.workerId}") long workerId) {if (workerId > 31 || workerId < 0) {throw new IllegalArgumentException("workId 必须在 0 -31 之间,以后 ="+workerId);
        }
        if (datacenterId > 31 || datacenterId < 0) {throw new IllegalArgumentException("datacenterId 必须在 0 -31 之间,以后 ="+datacenterId);
        }

        this.workerId = workerId;
        this.datacenterId = datacenterId;
    }

    /**
     * 加锁,线程平安
     * @return long 类型的 ID
     */
    public synchronized long nextId() {long timestamp = currentTime();

        // 如果以后工夫小于上一次 ID 生成的工夫戳,阐明零碎时钟回退过这个时候该当抛出异样
        if (timestamp < lastTimestamp) {throw new RuntimeException("时钟回退!时间差 ="+(lastTimestamp - timestamp));
        }

        // 同一毫秒内,序列减少
        if (lastTimestamp == timestamp) {
            // 超出阈值。思考下为什么这么运算?sequence = (sequence + 1) & SEQUENCE_MASK;
            // 毫秒内序列溢出
            if (sequence == 0) {
                // 自旋期待下一毫秒
                while ((timestamp= currentTime()) <= lastTimestamp);
            }
        } else {
            // 曾经进入下一毫秒,从 0 开始计数
            sequence = 0L;
        }

        // 赋值为新的工夫戳
        lastTimestamp = timestamp;

        // 移位拼接
        long id = ((timestamp - startTimeStamp) << 22)
                | (datacenterId << 17)
                | (workerId << 12)
                | sequence;

        System.out.println("new id ="+id);
        System.out.println("bit id ="+toBit(id));

        return id;
    }


    /**
     * 返回以后工夫,以毫秒为单位
     */
    protected long currentTime() {return System.currentTimeMillis();
    }

    /**
     * 转成二进制展现
     */
    public static String toBit(long id){String bit = StringUtils.leftPad(Long.toBinaryString(id), 64, "0");
        return bit.substring(0,1) +
                "-" +
                bit.substring(1,42) +
                "-" +
                bit.substring(42,52)+
                "-" +
                bit.substring(52,64);
    }

    public static void main(String[] args) {Snowflake idWorker = new Snowflake(1, 1);

        for (int i = 0; i < 10; i++) {long id = idWorker.nextId();
            System.out.println(id);
            System.out.println(toBit(id));
        }

    }


}

springboot 启动参数,指定机器编号:

snowflake.datacenterId=1
snowflake.workerId=1

业务局部:

/**
 * 自定义雪花算法
 */
@GetMapping("/myflake")
public Strorder myflake(int userid){Strorder order = new Strorder();
    order.setId(String.valueOf(snowflake.nextId()));
    order.setUserid(userid);
    strorderMapper.save(order);
    return order;
}
  • 代码启动生成,剖析位数
  • 更改机器 id,剖析位数

2)借助 sharding 配置

配置信息,非常简单

spring.shardingsphere.sharding.tables.strorder.key-generator.column=id
spring.shardingsphere.sharding.tables.strorder.key-generator.type=SNOWFLAKE
spring.shardingsphere.sharding.tables.strorder.key-generator.props.worker.id=3

Mapper 代码

@Insert({"insert into strorder (userid)",
        "values (#{userid,jdbcType=INTEGER})"
})
@SelectKey(statement="SELECT max(id) from strorder where userid=#{userid,jdbcType=INTEGER}", keyProperty="id", before=false, resultType=String.class)
int shardingIdSave(Strorder record);

业务代码

/**
 * sharding 的雪花算法
 */
@GetMapping("/shardingFlake")
public Strorder shardingFlake(int userid){Strorder order = new Strorder();
    order.setUserid(userid);
    strorderMapper.shardingIdSave(order);
    System.out.println(Snowflake.toBit(Long.valueOf(order.getId())));
    return order;
}

后果剖析

  • 生成的 id 号由 sharding-jdbc 主动增加到 maper 的 sql 中
  • 机器编号为 3,所以打印的 bit 中机器为 00011,批改为其余机器,测试后果

sharding 源码剖析:

package org.apache.shardingsphere.core.strategy.keygen;

import com.google.common.base.Preconditions;
import java.util.Calendar;
import java.util.Properties;
import lombok.Generated;
import org.apache.shardingsphere.spi.keygen.ShardingKeyGenerator;

public final class SnowflakeShardingKeyGenerator implements ShardingKeyGenerator {
    public static final long EPOCH;
    private static final long SEQUENCE_BITS = 12L;
    private static final long WORKER_ID_BITS = 10L;
    private static final long SEQUENCE_MASK = 4095L;
    private static final long WORKER_ID_LEFT_SHIFT_BITS = 12L;
    private static final long TIMESTAMP_LEFT_SHIFT_BITS = 22L;
    private static final long WORKER_ID_MAX_VALUE = 1024L;
    private static final long WORKER_ID = 0L;
    private static final int DEFAULT_VIBRATION_VALUE = 1;
    private static final int MAX_TOLERATE_TIME_DIFFERENCE_MILLISECONDS = 10;
    private static TimeService timeService = new TimeService();
    private Properties properties = new Properties();
    private int sequenceOffset = -1;
    private long sequence;
    private long lastMilliseconds;

    public SnowflakeShardingKeyGenerator() {}

    public String getType() {return "SNOWFLAKE";}

    public synchronized Comparable<?> generateKey() {long currentMilliseconds = timeService.getCurrentMillis();
        if (this.waitTolerateTimeDifferenceIfNeed(currentMilliseconds)) {currentMilliseconds = timeService.getCurrentMillis();
        }

        if (this.lastMilliseconds == currentMilliseconds) {if (0L == (this.sequence = this.sequence + 1L & 4095L)) {currentMilliseconds = this.waitUntilNextTime(currentMilliseconds);
            }
        } else {this.vibrateSequenceOffset();
            this.sequence = (long)this.sequenceOffset;
        }

        this.lastMilliseconds = currentMilliseconds;
        return currentMilliseconds - EPOCH << 22 | this.getWorkerId() << 12 | this.sequence;}

    //...

    // 获取机器编号
    private long getWorkerId() {long result = Long.valueOf(this.properties.getProperty("worker.id", String.valueOf(0L)));
        Preconditions.checkArgument(result >= 0L && result < 1024L);
        return result;
    }



    //...
    

    // 序列下限,等待下一毫秒
    private long waitUntilNextTime(long lastTime) {
        long result;
        for(result = timeService.getCurrentMillis(); 
            result <= lastTime; 
            result = timeService.getCurrentMillis()) {;}

        return result;
    }



    static {Calendar calendar = Calendar.getInstance();
        calendar.set(2016, 10, 1);
        calendar.set(11, 0);
        calendar.set(12, 0);
        calendar.set(13, 0);
        calendar.set(14, 0);
        EPOCH = calendar.getTimeInMillis();}
}

3)时钟回退问题

对于 snowflake 算法的缺点(时钟回拨问题),sharding-jdbc 没有给出解决方案

2.5.3 第三方实现

1)百度 UidGenerator

https://github.com/baidu/uid-…

  • 位数不太一样,1-28-22-13
  • 须要 mysql 数据库建表,来主动配置工作节点
  • 反对 spring 配置与集成
  • 反对 bit 位自定义,及 bit 调配相干倡议

2)美团 Leaf-snowflake

https://tech.meituan.com/2017…

  • 位数沿用 snowflake 计划的 bit 位设计
  • 应用 Zookeeper 长久程序节点的个性主动对 snowflake 节点配置 wokerID
  • 解决了时钟回退问题
  • 线上可靠性验证,美团的金融、领取交易、餐饮、外卖、酒店游览、猫眼电影等泛滥业务

3. 领取场景下的订单(拓展)

3.1 领取政策

1)领取牌照是干啥的?

​ 实践上,没有领取牌照,电商只能做自营。

​ 但凡波及 B 端用户在平台开展业务,就会波及资金流动问题。他人的钱通过平台领取转手,就须要通过批准。这个批准所取得的资格就是领取牌照。

2)217 号文的下达

​ 次要给出了无证经营领取业务的次要认定规范:采取平台对接或“大商户”模式,即客户资金先划转至网络平台账户,再由网络平台结算给该平台二级商户,均属于无证经营领取业务。

3)“一清”与“二清”是什么:

​ 一清公司的领取不须要领取牌照,然而也不做资金结算,而是交给银联来结算。

​ 二清公司则是没有领取牌照却做着资金结算工作。

​ 简略来说就是平台接不接触到钱的问题。

4)为什么这么做?二清的危险在哪里

​ 买家的钱应该给卖家才对,当初给到平台再由平台转交。

​ 那么平台无受权无牌照的状况下,跑了怎么办?

5)那么对订单零碎的影响在哪里?

(订单零碎整改案例)

如果你所在公司波及二清不合规问题。那么订单零碎要留神。一般来说,银行接口要求以下操作:

  • 商户入驻,确立平台方,商户方的虚构子账户。买方也就是支付方不须要入驻
  • 领取下单时条目带分成(个别两种形式,比例和金额)
  • 确认收货后,平台调银行订单结算接口实现交易

3.2 条目折扣

1)流动折扣比例折算到条目

回顾满减流动问题。满 99 减 9,那么设计订单条目表时,要带有理论折扣价,而比例放在订单上

订单表记录:


条目表记录:


平账:

30×0.9090 + 40×0.9090 +(50*0.909+1.92)= 111

3.3 退货换货

1)退货设计:

退货要生成退货单,关联旧订单 id,条目也关联旧条目 id,而原始订单不做任何改变。

调取银行时,调接口,对应的条目退货即可,资金会由银行原路返回。

留神赠品返还和理论退款金额问题。

2)换货设计:

换货也要生成退货单,关联新旧两条订单 id,条目关联旧条目 id,用来记录要拿哪些条目换。

同时生成新的订单,示意要换成的新商品。订单类型标注为换货单

换货时的价格折算问题:多退少补。如果多好办,抵扣后,残余条目走银行退货接口

补的时候比拟麻烦。这就波及到上面的领取单。

3.4 分期领取

领取单的设计:

惯例状况下,一笔订单一笔领取单,领取单上挂订单号,金额 = 订单应酬金额

如果是下面的补单,领取金额就须要作为差价记录理论领取金额,条目标记为换货差价

波及分期领取,对应多笔领取单,造成虚构条目标注领取内容。

3.5 订单状态与接口关系

下单 → 新建,不须要调银行接口

领取 → 领取胜利,调银行领取接口,只是领取胜利,没有分成

确认收货 → 结算,调银行结算接口,银行会进行清理操作

3.6 超时订单勾销


依据库存设计对订单有不同的解决策略:

下单减库存的,要留神超时勾销,大订单量及分库分表条件下,扫表计划不可取,应该设计为提早生产

领取减库存的,不须要额定解决。

3.7 对账单与结算单

在“二清”政策下,对账流程变成两步,类比旧的领取,对应单子也会变成两种

领取胜利的:进入领取对账

确认收货的:进入结算对账

4. 零碎级可用性保障(拓展)

4.1 数据一致性

1)订单周边服务:

下订单过程,业务极其简单,不只是订单号的生成插入,除了订单零碎,还可能波及库存零碎,促销零碎,领取零碎,结算零碎,积分零碎,同时可能有上游的订单统计核心。

2)双向接口:

调用须要返回值的交互,比方调促销零碎,获取促销信息。

多为强依赖的关联,应用分布式框架,基于框架层面的重试机制,接口幂等设计,保障数据的最终一致性。

3)单向接口:

属于告诉类调用,不须要返回值。如下单后告诉给上游的订单统计核心,或大屏展现

能够采纳扔音讯队列,基于音讯队列层面做高可用与调优。对订单零碎来说,只须要保障投放时的音讯确认即可。上游生产端是生产方须要关注的事件。

4)反复数据问题:

个别的重复性数据,只有做到幂等设计,不会产生。

多见于领取环节。即一条订单对应了多条领取单。

策略:人工确认,接口退单,对账保底。

4.2 数据库高可用

1)日常备份

冷备:文件级备份,疾速且残缺。读写操作均不可进行,须要停机。作为劫难时复原到某个工夫点

热备:读写操作均可执行,作为备用库待命,down 机时及时顶上去。

2)机房灾备

同一服务下,日志文件与数据文件分盘放

跨机房,双主单写,事务日志校验,灾备切换。

4.3 利用级爱护

1)限流,避免刷单

nginx,lua+redis,sentinel

2)异步排队,秒杀音讯队列排队,异步生产

秒杀申请到来后进入 mq,后端下单服务异步生产,前台轮询查问排队状态。

3)周边服务降级

如积分,评估,某些统计,爬虫,举荐服务降级,提早解决。

本文由传智教育博学谷 – 狂野架构师教研团队公布
如果本文对您有帮忙,欢送关注和点赞;如果您有任何倡议也可留言评论或私信,您的反对是我保持创作的能源
转载请注明出处!

正文完
 0