欢迎访问昆山宝鼎软件有限公司网站! 设为首页 | 网站地图 | XML | RSS订阅 | 宝鼎邮箱 | 后台管理


新闻资讯

MENU

软件开发知识

other) // select count(id) from Bids wh 昆山软件开发 ere item_id

点击: 次  来源:宝鼎软件 时间:2017-06-02

原文出处: 搜不狐

后续增补:这篇文章已经好久了,当初的设想是单机编程,每台处事器得到本身可以或许卖出几多产物,用户被随机分派到每台呆板长举办处理惩罚。

一、题目

1, 这是一个秒杀系统,软件开发,即大量用户抢有限的商品,先到先得

2, 用户并发会见流量很是大, 需要漫衍式的呆板集群处理惩罚请求

3, 系统实现利用Java

二、模块设计

1, 用户请求分发模块:利用Nginx或Apache将用户的请求分发到差异的呆板上。

2, 用户请求预处理惩罚模块:判定商品是不是尚有剩余来抉择是不是要处理惩罚该请求。

3, 用户请求处理惩罚模块:把通过预处理惩罚的请求封装成事务提交给数据库,并返回是否乐成。

4, 数据库接口模块:该模块是数据库的独一接口,认真与数据库交互,提供RPC接供词查询是否秒杀竣事、剩余数量等信息。

第一部门就不多说了,设置HTTP处事器即可,这里主要谈谈后头的模块。

用户请求预处理惩罚模块

颠末HTTP处事器的分发后,单个处事器的负载相对低了一些,但总量依然大概很大,假如靠山商品已经被秒杀完毕,那么直接给厥后的请求返回秒杀失败即可,不必再进一步发送事务了,示例代码可以如下所示:

package seckill;
import org.apache.http.HttpRequest;
/**
 * 预处理惩罚阶段,把不须要的请求直接驳回,须要的请求添加到行列中进入下一阶段.
 */
public class PreProcessor {
    // 商品是否尚有剩余
    private static boolean reminds = true;
    private static void forbidden() {
        // Do something.
    }
    public static boolean checkReminds() {
        if (reminds) {
            // 长途检测是否尚有剩余,该RPC接口应由数据库处事器提供,不必完全严格查抄.
            if (!RPC.checkReminds()) {
                reminds = false;
            }
        }
        return reminds;
    }
    /**
     * 每一个HTTP请求都要颠末该预处理惩罚.
     */
    public static void preProcess(HttpRequest request) {
        if (checkReminds()) {
            // 一个并发的行列
            RequestQueue.queue.add(request);
        } else {
            // 假如已经没有商品了,则直接驳回请求即可.
            forbidden();
        }
    }
}

并刊行列的选择

Java的并发包提供了三个常用的并刊行列实现,别离是:ConcurrentLinkedQueue 、 LinkedBlockingQueue 和 ArrayBlockingQueue。

ArrayBlockingQueue是初始容量牢靠的阻塞行列,我们可以用来作为数据库模块乐成竞拍的行列,好比有10个商品,那么我们就设定一个10巨细的数组行列。

ConcurrentLinkedQueue利用的是CAS原语无锁行列实现,是一个异部行列,入队的速度很快,劳务派遣管理系统,出队举办了加锁,机能稍慢。

LinkedBlockingQueue也是阻塞的行列,入队和出队都用了加锁,当队空的时候线程会临时阻塞。

由于我们的系统入队需求要远大于出队需求,一般不会呈现队空的环境,所以我们可以选择ConcurrentLinkedQueue来作为我们的请求行列实现:

package seckill;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import org.apache.http.HttpRequest;
public class RequestQueue {
    public static ConcurrentLinkedQueue<HttpRequest> queue =
            new ConcurrentLinkedQueue<HttpRequest>();
}

用户请求模块

package seckill;
import org.apache.http.HttpRequest;
public class Processor {
    /**
     * 发送秒杀事务到数据库行列.
     */
    public static void kill(BidInfo info) {
        DB.bids.add(info);
    }
    public static void process() {
        BidInfo info = new BidInfo(RequestQueue.queue.poll());
        if (info != null) {
            kill(info);
        }
    }
}
class BidInfo {
    BidInfo(HttpRequest request) {
        // Do something.
    }
}

数据库模块

数据库主要是利用一个ArrayBlockingQueue来暂存有大概乐成的用户请求。

package seckill;
import java.util.concurrent.ArrayBlockingQueue;
/**
 * DB应该是数据库的独一接口.
 */
public class DB {
    public static int count = 10;
    public static ArrayBlockingQueue<BidInfo> bids = new ArrayBlockingQueue<BidInfo>(10);
    public static boolean checkReminds() {
        // TODO
        return true;
    }
    // 单线程操纵
    public static void bid() {
        BidInfo info = bids.poll();
        while (count-- > 0) {
            // insert into table Bids values(item_id, user_id, bid_date, other)
            // select count(id) from Bids where item_id = ?
            // 假如数据库商品数量约莫总数,则符号秒杀已完成,配置符号位reminds = false.
            info = bids.poll();
        }
    }
}

三、后续