一个高并发买票的实例

2.一个高并发买票的实例：

马克-to-win：我们现在回到春节高并发买票的问题。我们假设有一百万个人买一百张票，其中买票程序一百万个线程同时运行。不用改变mysql的缺省事务隔离级别。任何人在买之前都用普通的select * from table来访问数据库获得目前的票数。假如现在是一百，之后大家一起点“下单”钮。这个钮所对应的程序可以这样：先select * from table for update，这样所有别人的select * from table for update这句话都会被挡住，这个时刻选出的数据库的票的存量是准确的。你可以加一个判断，比如如果存量大于1，我就买一张票。（有很多高并发程序，会在这里加一个乐观锁版本的判断，如果还是老版本就做更新。马克-to-win：原理和目的和我们的例子是一样的）注意这里加判断，虽然耗时，但至关重要，（这也是很多公司的通用做法）而且必须像这样独占排他挡住别人大张旗鼓的做。假如你不下决心独占排他的去做判断，当你真正更新的时候，也许数据已经被别人更改了。也许一秒前看存量是一百，一秒之后已经变成零了。不判断就直接更新的话，数据库票数也许会变成负数。完成判断之后就是更新数据库票数减一张，当然还需做一些其他的工作，比如订单表中需要增加一行记录是谁买的之类的，最后提交。之后队列中下一个事务就会被开始执行。这只是程序的一个总的思路，真正做项目还需考虑用户体验比如超时问题，（connection query有超时timeout异常）或用户等得不耐烦，主动关闭窗口。这时数据库服务器就会照顾下一个select * from table for update。马克-to-win：真正做项目时，我们可以选择用select * from t for update nowait （不等待行锁释放，提示锁冲突，不返回结果）或select * from t for update wait 5 （等待5秒，若行锁仍未释放，则提示锁冲突，不返回结果）给用户提供三个选择，可以死等，不等，或等5秒。同时告诉用户现在多少人在队列中你的前面（每有一个人发出请求，在ServletContext中就加1，完成就减1），大概多长时间可以到你，因为数据库完成一个用多长时间可以算出来。下面我们就给出一个并发买票的简单实现。（本例子我们还用上章的register数据库表，用age变量代表车票数，道理是一样的）

例 1.2.1

package com;
import java.sql.*;
public class ConcurBuy_MarkToWin {
    void concurBuy() {
        Connection con = null;
        Statement s = null;
        try {
            con = DatabaseConn.getConnection();
            s = con.createStatement();
            System.out.println("11111111"+Thread.currentThread().getName());
            } catch (Exception ex) {
                ex.printStackTrace();
            }
        } finally {
            try {
                s.close();
                con.close();
            } catch (SQLException e) {
                e.printStackTrace();
            }
            System.out.println("successfully in finally"+ con+Thread.currentThread().getName());
        }
    }
}
package com;
class MulThreMarkToWin extends Thread {
    public void run() {
    }
}
public class TestConcurBuy_MarkToWin {
    public static void main(String[] args) {
        Thread t1 = new MulThreMarkToWin();
        Thread t2 = new MulThreMarkToWin();
        t1.start();
        t2.start();

更多请看：https://blog.csdn.net/qq_44591615/article/details/109274985

一个高并发买票的实例相关推荐

【面试】如何设计一个高并发系统
一.为什么需要秒杀系统? 电商平台本质是在线上撮合买卖双方的购销需求,达成交易.虽然是线上交易,但也遵守朴素的经济学原理,供求关系决定了商品的经济活动.当供求平衡时,买方和卖方处于对等关系,双方相对稳 ...
如何设计一个高并发高可用的秒杀或抢券系统
一个大型网站应用一般都是从最初小规模网站甚至是单机应用发展而来的,为了让系统能够支持足够大的业务量,从前端到后端也采用了各种各样技术,前端静态资源压缩整合.使用CDN.分布式SOA架构.缓存.数据库加 ...
php小程序秒抢高并发,PHP 如何设计一个高并发高可用的秒杀或抢券系统
一个大型网站应用一般都是从最初小规模网站甚至是单机应用发展而来的,为了让系统能够支持足够大的业务量,从前端到后端也采用了各种各样技术,前端静态资源压缩整合.使用CDN.分布式SOA架构.缓存.数据库加 ...
【面试题】如何设计一个高并发的系统？
每个行业都一样,人才都是分层次的,从事技术行业的程序员们更是如此,按照技术能力分为三六九等. 每个层次的人出去面试,面试官考察的方向是不一样的. 刚入职场的小白,会问你很多基础性的知识,有过几年经验的 ...
mysql每秒支持多少并发_如何设计一个高并发系统？
面试题如何设计一个高并发系统? 面试官心理分析说实话,如果面试官问你这个题目,那么你必须要使出全身吃奶劲了.为啥?因为你没看到现在很多公司招聘的 JD 里都是说啥,有高并发就经验者优先. 如果你确 ...
一个springboot能支持多少并发_吃透这篇，你也能搭建出一个高并发和高性能的系统...
" 什么是高并发?高并发是互联网分布式系统架构的性能指标之一,它通常是指单位时间内系统能够同时处理的请求数,简单点说,就是 QPS(Queries Per Second). 那么我们在谈论高 ...
oom 如何避免高并发_【面试题】如何设计一个高并发系统？
面试题如何设计一个高并发系统? 原文链接:https://github.com/doocs/advanced-java/blob/master/docs/high-concurrency/high- ...
面试题：如何设计一个高并发系统？
面试官心理分析说实话,如果面试官问你这个题目,那么你必须要使出全身吃奶劲了.为啥?因为你没看到现在很多公司招聘的 JD 里都是说啥,有高并发就经验者优先. 如果你确实有真才实学,在互联网公司里干过高 ...
php ssc 源码_吃透这篇，你也能搭建出一个高并发和高性能的系统
什么是高并发?高并发是互联网分布式系统架构的性能指标之一,它通常是指单位时间内系统能够同时处理的请求数,简单点说,就是 QPS(Queries Per Second). 那么我们在谈论高并发的时候,究 ...

一个高并发买票的实例

一个高并发买票的实例相关推荐

最新文章

热门文章