万级TPS亿级流水-中台账户系统架构设计标签：高并发万级TPS亿级流水账户系统背景业务模型应用层设计数据层设计日切对账背景我们需要给所有前台业务提供统一的账户系统，用来支撑所有前台产品线的用户资产管理，统一提供支持大并发万级TPS、亿级流水、数据强一致、风控安全、日切对账、财务核算、审计等能力，在万级TPS下保证绝对的数据准确性和数据溯源能力。注：资金类系统只有合格和不合格，哪怕数据出现只有0.0
分类：
其他好文 时间：
2020-06-21 09:24:54
阅读次数：
48
前言 这是消息队列系列的开篇，简单介绍一些概念。 正文 我觉得使用消息队列主要有两点好处：1.通过异步处理提高系统性能（削峰、减少响应所需时间）;2.降低系统耦合性。 如上图，在不使用消息队列服务器的时候，用户的请求数据直接写入数据库，在高并发的情况下数据库压力剧增，使得响应速度变慢。 但是在使用消 ...
分类：
其他好文 时间：
2020-06-20 23:51:55
阅读次数：
60
Scrapy是一个常用的爬虫框架，可以提升爬虫的效率，从而更好的实现爬虫。Scrapy是一个为了抓取网页数据、提取结构性数据而编写的应用框架，该框架是封装的，包含request（异步调度和处理）、下载器（多线程的Downloader）、解析器（selector）和twisted（异步处理）等。 第一 ...
分类：
其他好文 时间：
2020-06-14 20:52:44
阅读次数：
70
1.背景RabbitMQ是一个由erlang开发的AMQP(Advanved Message Queue)的开源实现。 2.应用场景2.1异步处理场景说明：用户注册后，需要发注册邮件和注册短信,传统的做法有两种1.串行的方式;2.并行的方式(1)串行方式:将注册信息写入数据库后,发送注册邮件,再发送 ...
分类：
其他好文 时间：
2020-06-13 21:23:14
阅读次数：
50
背景 我们在需要保证代码在多个异步处理之后执行,我们通常会使用 Promise.all(promises: []).then(fun: function); Promise.all可以保证，promises数组中所有promise对象都达到resolve状态，才执行then回调 那么会出现的情况是， ...
分类：
其他好文 时间：
2020-06-13 13:16:16
阅读次数：
121
Serverless与图像处理 在前言部分说到，传统的图像处理方法，会比较占用资源，让服务器压力比较大，甚至会影响用户体验： 那么我们是否可以通过Serverless架构，实现一个异步处理流程？ 所谓的异步处理流程就是，用户直接上传图片到对象存储，直接将图片等资源进行持久化，然后通过对象存储相关的触 ...
分类：
其他好文 时间：
2020-06-08 11:02:27
阅读次数：
89
参考 http://www.ruanyifeng.com/blog/2015/05/async.html https://segmentfault.com/a/1190000007535316 await 只能出现在 async 函数中 async 函数返回的是一个 Promise 对象。 asyn ...
分类：
其他好文 时间：
2020-06-02 11:43:37
阅读次数：
72
在开发中，很多时候会异步处理一些业务需求，在不影响主业务的情况下，还需要做一些附加的耗时长的操作，可以在主代码中 开一个线程（主要有三种线程）： 1.new ARunnable类，实现Runnable接口，复写run方法： public class ARunnable implements Runn ...
分类：
编程语言 时间：
2020-05-31 11:28:19
阅读次数：
79
1：18 1.什么是高并发系统的消息队列？ 队列：对头+队列容器+对尾 消息队列（MessageQueue MQ）：有一个队列容器，生产者（入队列），消费者（出队列） 2.使用消息队列的场景（使用消息队列的原因）： 2.1 分布式场景 2.1.1 异步处理 多线程可以节省时间，但是会降低cpu吞吐量 ...
分类：
其他好文 时间：
2020-05-30 19:56:13
阅读次数：
59
前言 首先，大家先了解一下三者的概念究竟是什么？有哪些功能？工作原理？ 一、RabbitMQ 1.消息型中间件，用于不同应用之间的通信，基于amqp协议实现 2.功能：将一些无需要及时返回而且耗时的操作提取出来，进行解耦，利用异步处理，提高系统的吞吐量 3工作原理：A生产消息，发送给服务器的exch ...
分类：
数据库 时间：
2020-05-29 17:53:48
阅读次数：
71
