【转】大话程序猿眼里的高并发架构

原文&＃xff1a; http://blog.thankbabe.com/2016/09/14/high-concurrency-scheme/?from&＃61;sf

前言

高并发经常会发生在有大活跃用户量&＃xff0c;用户高聚集的业务场景中&＃xff0c;如&＃xff1a;秒杀活动&＃xff0c;定时领取红包等。
为了让业务可以流畅的运行并且给用户一个好的交互体验&＃xff0c;我们需要根据业务场景预估达到的并发量等因素&＃xff0c;来设计适合自己业务场景的高并发处理方案。

在电商相关产品开发的这些年&＃xff0c;我有幸的遇到了并发下的各种坑&＃xff0c;这一路摸爬滚打过来有着不少的血泪史&＃xff0c;这里进行的总结&＃xff0c;作为自己的归档记录&＃xff0c;同时分享给大家。

服务器架构

业务从发展的初期到逐渐成熟&＃xff0c;服务器架构也是从相对单一到集群&＃xff0c;再到分布式服务。 
一个可以支持高并发的服务少不了好的服务器架构&＃xff0c;需要有均衡负载&＃xff0c;数据库需要主从集群&＃xff0c;nosql缓存需要主从集群&＃xff0c;静态文件需要上传cdn&＃xff0c;这些都是能让业务程序流畅运行的强大后盾。

服务器这块多是需要运维人员来配合搭建&＃xff0c;具体我就不多说了&＃xff0c;点到为止。
大致需要用到的服务器架构如下&＃xff1a;

• 服务器
  • 均衡负载(如&＃xff1a;nginx&＃xff0c;阿里云SLB)
  • 资源监控
  • 分布式
• 数据库
  • 主从分离&＃xff0c;集群
  • DBA 表优化&＃xff0c;索引优化&＃xff0c;等
  • 分布式
• nosql
  • redis
    • 主从分离&＃xff0c;集群
  • mongodb
    • 主从分离&＃xff0c;集群
  • memcache
    • 主从分离&＃xff0c;集群
• cdn
  • html
  • css
  • js
  • image

并发测试

高并发相关的业务&＃xff0c;需要进行并发的测试&＃xff0c;通过大量的数据分析评估出整个架构可以支撑的并发量。

测试高并发可以使用第三方服务器或者自己测试服务器&＃xff0c;利用测试工具进行并发请求测试&＃xff0c;分析测试数据得到可以支撑并发数量的评估&＃xff0c;这个可以作为一个预警参考&＃xff0c;俗话说知己自彼百战不殆。

第三方服务:

• 阿里云性能测试

并发测试工具&＃xff1a;

• Apache JMeter
• Visual Studio性能负载测试
• Microsoft Web Application Stress Tool

实战方案

通用方案

日用户流量大&＃xff0c;但是比较分散&＃xff0c;偶尔会有用户高聚的情况&＃xff1b;

场景&＃xff1a; 用户签到&＃xff0c;用户中心&＃xff0c;用户订单&＃xff0c;等
服务器架构图&＃xff1a; 

说明&＃xff1a;

场景中的这些业务基本是用户进入APP后会操作到的&＃xff0c;除了活动日(618,双11&＃xff0c;等)&＃xff0c;这些业务的用户量都不会高聚集&＃xff0c;同时这些业务相关的表都是大数据表&＃xff0c;业务多是查询操作&＃xff0c;所以我们需要减少用户直接命中DB的查询&＃xff1b;优先查询缓存&＃xff0c;如果缓存不存在&＃xff0c;再进行DB查询&＃xff0c;将查询结果缓存起来。

更新用户相关缓存需要分布式存储&＃xff0c;比如使用用户ID进行hash分组&＃xff0c;把用户分布到不同的缓存中&＃xff0c;这样一个缓存集合的总量不会很大&＃xff0c;不会影响查询效率。

方案如&＃xff1a;

• 用户签到获取积分
  • 计算出用户分布的key,redis hash中查找用户今日签到信息
  • 如果查询到签到信息&＃xff0c;返回签到信息
  • 如果没有查询到&＃xff0c;DB查询今日是否签到过&＃xff0c;如果有签到过&＃xff0c;就把签到信息同步redis缓存。
  • 如果DB中也没有查询到今日的签到记录&＃xff0c;就进行签到逻辑&＃xff0c;操作DB添加今日签到记录&＃xff0c;添加签到积分(这整个DB操作是一个事务)
  • 缓存签到信息到redis&＃xff0c;返回签到信息
  • 注意这里会有并发情况下的逻辑问题&＃xff0c;如&＃xff1a;一天签到多次&＃xff0c;发放多次积分给用户。
  • 我的博文[大话程序猿眼里的高并发]有相关的处理方案。
• 用户订单
  • 这里我们只缓存用户第一页的订单信息&＃xff0c;一页40条数据&＃xff0c;用户一般也只会看第一页的订单数据
  • 用户访问订单列表&＃xff0c;如果是第一页读缓存&＃xff0c;如果不是读DB
  • 计算出用户分布的key,redis hash中查找用户订单信息
  • 如果查询到用户订单信息&＃xff0c;返回订单信息
  • 如果不存在就进行DB查询第一页的订单数据&＃xff0c;然后缓存redis&＃xff0c;返回订单信息
• 用户中心
  • 计算出用户分布的key,redis hash中查找用户订单信息
  • 如果查询到用户信息&＃xff0c;返回用户信息
  • 如果不存在进行用户DB查询&＃xff0c;然后缓存redis&＃xff0c;返回用户信息
• 其他业务
  • 上面例子多是针对用户存储缓存&＃xff0c;如果是公用的缓存数据需要注意一些问题&＃xff0c;如下
  • 注意公用的缓存数据需要考虑并发下的可能会导致大量命中DB查询&＃xff0c;可以使用管理后台更新缓存&＃xff0c;或者DB查询的锁住操作。
  • 我的博文[大话Redis进阶]对更新缓存问题和推荐方案的分享。

以上例子是一个相对简单的高并发架构&＃xff0c;并发量不是很高的情况可以很好的支撑&＃xff0c;但是随着业务的壮大&＃xff0c;用户并发量增加&＃xff0c;我们的架构也会进行不断的优化和演变&＃xff0c;比如对业务进行服务化&＃xff0c;每个服务有自己的并发架构&＃xff0c;自己的均衡服务器&＃xff0c;分布式数据库&＃xff0c;nosql主从集群&＃xff0c;如&＃xff1a;用户服务、订单服务&＃xff1b;

消息队列

秒杀、秒抢等活动业务&＃xff0c;用户在瞬间涌入产生高并发请求

场景&＃xff1a;定时领取红包&＃xff0c;等
服务器架构图&＃xff1a;

说明&＃xff1a;

场景中的定时领取是一个高并发的业务&＃xff0c;像秒杀活动用户会在到点的时间涌入&＃xff0c;DB瞬间就接受到一记暴击&＃xff0c;hold不住就会宕机&＃xff0c;然后影响整个业务&＃xff1b;

像这种不是只有查询的操作并且会有高并发的插入或者更新数据的业务&＃xff0c;前面提到的通用方案就无法支撑&＃xff0c;并发的时候都是直接命中DB&＃xff1b;

设计这块业务的时候就会使用消息队列的&＃xff0c;可以将参与用户的信息添加到消息队列中&＃xff0c;然后再写个多线程程序去消耗队列&＃xff0c;给队列中的用户发放红包&＃xff1b;

方案如&＃xff1a;

• 定时领取红包
  • 一般习惯使用 redis的 list
  • 当用户参与活动&＃xff0c;将用户参与信息push到队列中
  • 然后写个多线程程序去pop数据&＃xff0c;进行发放红包的业务
  • 这样可以支持高并发下的用户可以正常的参与活动&＃xff0c;并且避免数据库服务器宕机的危险

附加&＃xff1a; 
通过消息队列可以做很多的服务。 
如&＃xff1a;定时短信发送服务&＃xff0c;使用sset(sorted set)&＃xff0c;发送时间戳作为排序依据&＃xff0c;短信数据队列根据时间升序&＃xff0c;然后写个程序定时循环去读取sset队列中的第一条&＃xff0c;当前时间是否超过发送时间&＃xff0c;如果超过就进行短信发送。

一级缓存

高并发请求连接缓存服务器超出服务器能够接收的请求连接量&＃xff0c;部分用户出现建立连接超时无法读取到数据的问题&＃xff1b;

因此需要有个方案当高并发时候时候可以减少命中缓存服务器&＃xff1b;

这时候就出现了一级缓存的方案&＃xff0c;一级缓存就是使用站点服务器缓存去存储数据&＃xff0c;注意只存储部分请求量大的数据&＃xff0c;并且缓存的数据量要控制&＃xff0c;不能过分的使用站点服务器的内存而影响了站点应用程序的正常运行&＃xff0c;一级缓存需要设置秒单位的过期时间&＃xff0c;具体时间根据业务场景设定&＃xff0c;目的是当有高并发请求的时候可以让数据的获取命中到一级缓存&＃xff0c;而不用连接缓存nosql数据服务器&＃xff0c;减少nosql数据服务器的压力

比如APP首屏商品数据接口&＃xff0c;这些数据是公共的不会针对用户自定义&＃xff0c;而且这些数据不会频繁的更新&＃xff0c;像这种接口的请求量比较大就可以加入一级缓存&＃xff1b;

服务器架构图&＃xff1a;

合理的规范和使用nosql缓存数据库&＃xff0c;根据业务拆分缓存数据库的集群&＃xff0c;这样基本可以很好支持业务&＃xff0c;一级缓存毕竟是使用站点服务器缓存所以还是要善用。

静态化数据

高并发请求数据不变化的情况下如果可以不请求自己的服务器获取数据那就可以减少服务器的资源压力。

对于更新频繁度不高&＃xff0c;并且数据允许短时间内的延迟&＃xff0c;可以通过数据静态化成JSON&＃xff0c;XML,HTML等数据文件上传CDN&＃xff0c;在拉取数据的时候优先到CDN拉取&＃xff0c;如果没有获取到数据再从缓存&＃xff0c;数据库中获取&＃xff0c;当管理人员操作后台编辑数据再重新生成静态文件上传同步到CDN&＃xff0c;这样在高并发的时候可以使数据的获取命中在CDN服务器上。

CDN节点同步有一定的延迟性&＃xff0c;所以找一个靠谱的CDN服务器商也很重要

其他方案

• 对于更新频繁度不高的数据&＃xff0c;APP,PC浏览器&＃xff0c;可以缓存数据到本地&＃xff0c;然后每次请求接口的时候上传当前缓存数据的版本号&＃xff0c;服务端接收到版本号判断版本号与最新数据版本号是否一致&＃xff0c;如果不一样就进行最新数据的查询并返回最新数据和最新版本号&＃xff0c;如果一样就返回状态码告知数据已经是最新。减少服务器压力&＃xff1a;资源、带宽

未完待续…
有补充的留言给我哦