如何在高並發下，http請求返回絕對的當前請求是第幾個請求？-php教程-PHP中文網

如何在高並發下，http請求返回絕對的當前請求是第幾個請求？

WBOY

發布： 2016-08-18 09:16:21

原創

1096 人瀏覽過

例如，我第一次訪問請求返回json：
{"n": 1}

我第100次訪問請求返回json：
{"n": 100}

傳統的寫資料庫，再查資料庫返回，在並發大時好像不能保證，我該怎麼辦？這應該是最簡化了的問題了

回覆內容：

例如，我第一次訪問請求返回json：
{"n": 1}

我第100次訪問請求返回json：
{"n": 100}

傳統的寫資料庫，再查資料庫返回，在並發大時好像不能保證，我該怎麼辦？這應該是最簡化了的問題了

最簡單的方法就是建個自增id主鍵的mysql表，然後每來一次請求就插一條記錄，再讀出這條記錄，讀出的id就是你要的值。

接著就可以根據id值來輕鬆處理高並發的場景了，比如【秒殺】就可用id小於300且能被6整除的規則認為秒殺成功；【抽獎】可以用能被100整除（百分之一機率）作為中獎等等。

如果自己實作也無非就是單線程死循環處理socket請求維護一個全域變量，不如用現成的mysql方便可靠。

如果是java的話，一個全局的AtomicLong可以滿足你的需求吧，getAndIncrement原子操作，再加上volatile修飾，如果是其他語言，大同小異吧

使用redis中的setnx(id),單執行緒保證每次加1，而且還是記憶體資料庫，速度超快。

讀取操作：使用快取
寫入操作：使用佇列非同步寫入

純粹Java的話，可以把計數器物件做成單例，透過filter攔截所有請求計算器加1（需要同步）。不知道你說的資料庫是什麼意思，{n : 100},n是資料庫拿的？

其實你要做的是一個常駐內存的隊列,按請求先後做排隊處理.
單機上可以試試Linux內存文件系統(tmpfs)上/dev/shm讀寫SQLite.
讀文件不需要經過網絡,也不需要自行實現記憶體常駐,鎖,自增以及唯一約束.

<code><?php
header('Content-Type: text/plain; charset=utf-8');
// sudo mkdir -m 777 /dev/shm/app
$file = '/dev/shm/app/data.db3';
$ddl = "
BEGIN;
CREATE TABLE IF NOT EXISTS queue (
    id           INTEGER PRIMARY KEY AUTOINCREMENT,
    user_id      INTEGER
);
CREATE UNIQUE INDEX IF NOT EXISTS queue_user_id_idx ON queue(user_id);
COMMIT;
";
if(!file_exists($file)) {
    //多核下多进程并发时可能都会进入到这个判断分支,所以DDL中要用IF NOT EXISTS
    $db = new PDO('sqlite:'.$file);
    $db->exec($ddl); // pdo_sqlite 的 query 和 prepare 不支持一次执行多条SQL语句
} else {
    $db = new PDO('sqlite:'.$file);
}
$stmt = $db->prepare('INSERT INTO queue(user_id) VALUES(?)');
$stmt->execute(array(time())); //time()换成你的用户ID
echo $stmt->rowCount()."\n";   //查询中受影响(改动)的行数,插入失败时为0
echo $db->lastInsertId();      //插入的自增ID,插入失败时为0
// php -S 127.0.0.1:8080 -t /home/eechen/www >/dev/null 2>&1 &
// ab -c100 -n1000 http://127.0.0.1:8080/</code>

登入後複製

最簡單的是用redis的zset進行自增，效率高，簡單，單機的話也可以考慮使用atomiclong(宕機重啟後失效)