首頁  >  文章  >  後端開發  >  如何在高並發下,http請求返回絕對的當前請求是第幾個請求?

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

WBOY
WBOY原創
2016-08-18 09:16:211053瀏覽

例如,我第一次訪問請求返回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(宕機重啟後失效)

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn