guozhaoran / spikesystem Goto Github PK

View Code? Open in Web Editor NEW

2.7K 2.7K 736.0 42 KB

一个秒杀系统的例子分析

Go 100.00%

spikesystem's People

Stargazers

Watchers

Forkers

wang92w zhuyu hustshawn hanks110 ak12jee githublibobo jacklibobo 52im kawhiwei 18268323036 jiasong18 spencerxie algernoonliu wwsdsy njzhuzhiwei yuxin02 bugphp jions7ihj chinassx shangmacun will2love wming3 rubincarter swzhaogang fypinglearnningzone mysileng 18306873504 xyyzzzz huzhengping william-zzw carrot369 asangus atree989 heyecheng iquanhe hyl2048 junbai2018 mango77881 ckmro-labs apple006 pengzw chaunsin songw2016 zhoudaqing wupfhub mbyase novahe wqk151 rulerlwx luxlaughing easy16 blackspadejack fangxinmiao winsomexjs scottleef yansdouble piggona yxdsuper fikofan 3013218061 chhq mixyoung gavinhwa gaomingjie ericyang521 lqj701 pengxiaozi ajiana everonce smartdriver001 yl463539765 jackyzheng123 coderxingzhang linqing0201 jiang-xs sniperdong zhangkg chenzpcloud skyformat99 gyyixr zhanghanlin98 tchigher qpzkobe zhangzsan lihjchina corba33 kavir0 merz9b wclwksn heshen xuyongmin michael-xhc jianglinlong suetming martindelophy hhy5277 panxuechao guofff githubcy adward-liu

spikesystem's Issues

远程扣库存能保证数据一致性吗？

代码都看了，当某台服务器挂了，上面的余票怎么重新分配到剩余服务器上，最关键的地方没写。

请问用的什么作图工具

想推荐你这个项目

大佬你好，我是Go语言中文网（https://studygolang.com ）站长，看到你这个项目，很赞，我想分享给更多的 Go 语言爱好者。特向你申请授权我发布到网站和对应的公众号等渠道。因为会大量引用README中的内容，期待您的回复！谢谢！

本地hash方案

感觉最后可以加一步，当余票很少时，也许把用户id本地hash，少于多少（比如还有10张票，QPS1w，用hash值少于多少卡掉99%的请求，使qps就100（为余票个数*10）就行）的直接返空，直接显示售罄了，这样让大部分本地库存不用再去请求redis远程减库存。

对Redis的压力也很大吧？

如果分库server的库存减和总redis库存减的操作是原子操作这个是前提的话，8点放票，此时库存都是足够的，瞬间所有的分仓库都会去请求Redis。100W并发请求，就可能有绝大多数的请求同样也会去Redis。这个问题如何解决。单单去增加redis服务器的并发能力吗？

readme 中lua脚本判断条件写反了

readme里lua脚本
if(ticket_sold_nums > ticket_total_nums) then
return redis.call('HINCRBY', ticket_key, ticket_sold_key, 1)
end

应该是
ticket_total_nums > ticket_sold_nums
代码里是对的

chan使用是否合理？

使用chan使得所有的请求在单实例中串行处理，是否会降低吞吐？
我理解本地库存最主要的目的，应该是当本地库存不足时，不去请求redis。保证本地库存源子操作这种需求源子操作或者用lock就可以解决，不必让所有请求的串行处理吧。
而且go chan底层也是基于lock实现的，通过benchmark chan 没体现出任何优势。
如果理解错误点还望指正。

有几点疑问

1、如何临时追加库存
2、扣费成功后，发送mq失败怎么处理？
3、mq可能存在丢消息的情况；
4、redis数据可能存在丢失，如何处理？

老黑?????

是否漏了第一张图

lua脚本

lua 脚本 >= 情况下会超卖一个，所以改成>

优化

if localSpike.LocalDeductionStock() && remoteSpike.RemoteDeductionStock(redisConn) {
		util.RespJson(w, 1,  "抢票成功", nil)
		LogMsg = LogMsg + "result:1,localSales:" + strconv.FormatInt(localSpike.LocalSalesVolume, 10)
	} else {
		util.RespJson(w, -1, "已售罄", nil)
		LogMsg = LogMsg + "result:0,localSales:" + strconv.FormatInt(localSpike.LocalSalesVolume, 10)
	}

失败应该回滚本地的一个记录

if localSpike.LocalDeductionStock() && remoteSpike.RemoteDeductionStock(redisConn) {
		util.RespJson(w, 1,  "抢票成功", nil)
		LogMsg = LogMsg + "result:1,localSales:" + strconv.FormatInt(localSpike.LocalSalesVolume, 10)
	} else {
		util.RespJson(w, -1, "已售罄", nil)
		spike.LocalSalesVolume = spike.LocalSalesVolume - 1   
		LogMsg = LogMsg + "result:0,localSales:" + strconv.FormatInt(localSpike.LocalSalesVolume, 10)
	}

库存量分配到本地机器机制或时机是怎样的

把库存分配到本地机器的机制是怎样的，在什么时机或以什么方式进行，怎样保证数据的一致性，如果一台机器分配时没有成功，这台机器没有了库存，落在此机器上的请求会不会买不到票？

操作消息队列的时机

对最后一张图不是很理解这个消息队列的操作时机

guozhaoran / spikesystem Goto Github PK

spikesystem's People

Stargazers

Watchers

Forkers

spikesystem's Issues

Recommend Projects

Recommend Topics

Recommend Org