您好,登錄后才能下訂單哦!
本篇文章給大家分享的是有關redis的最大并發量是多少,小編覺得挺實用的,因此分享給大家學習,希望大家閱讀完這篇文章后可以有所收獲,話不多說,跟著小編一起來看看吧。
redis中的并發問題
使用redis作為緩存已經很久了,redis是以單進程的形式運行的,命令是一個接著一個執行的,一直以為不會存在并發的問題,直到今天看到相關的資料,才恍然大悟。
具體問題實例
有個鍵,假設名稱為myNum,里面保存的是阿拉伯數字,假設現在值為1,存在多個連接對myNum進行操作的情況,這個時候就會有并發的問題。假設有兩個連接linkA和linkB,這兩個連接都執行下面的操作,取出myNum的值,+1,然后再存回去,看看下面的交互:
linkA get myNum => 1linkB get myNum => 1linkA set muNum => 2linkB set myNum => 2
執行完操作之后,結果可能是2,這和我們預期的3不一致。
再看一個具體的例子:
<?phprequire "vendor/autoload.php";$client = new Predis\Client([ 'scheme' => 'tcp', 'host' => '127.0.0.1', 'port' => 6379,]);for ($i = 0; $i < 1000; $i++) { $num = intval($client->get("name")); $num = $num + 1; $client->setex("name", $num, 10080); usleep(10000);}
設置name初始值為0,然后同時用兩個終端執行上面的程序,最后name的值可能不是2000,而是一個<2000的值,這也就證明了我們上面的并發問題的存在,這個該怎么解決呢?
redis中的事務
redis中也是有事務的,不過這個事務沒有mysql中的完善,只保證了一致性和隔離性,不滿足原子性和持久性。
redis事務使用multi、exec命令
原子性,redis會將事務中的所有命令執行一遍,哪怕是中間有執行失敗也不會回滾。kill信號、宿主機宕機等導致事務執行失敗,redis也不會進行重試或者回滾。
持久性,redis事務的持久性依賴于redis所使用的持久化模式,遺憾的是各種持久化模式也都不是持久化的。
隔離性,redis是單進程,開啟事務之后,會執行完當前連接的所有命令直到遇到exec命令,才處理其他連接的命令。
一致性,看了文檔,覺得挺扯的,但是貌似說的沒有問題。
redis中的事務不支持原子性,所以解決不了上面的問題。
當然了redis還有一個watch命令,這個命令可以解決這個問題,看下面的例子,對一個鍵執行watch,然后執行事務,由于watch的存在,他會監測鍵a,當a被修該之后,后面的事務就會執行失敗,這就確保了多個連接同時來了,都監測著a,只有一個能執行成功,其他都返回失敗。
127.0.0.1:6379> set a 1OK127.0.0.1:6379> watch aOK127.0.0.1:6379> multi OK127.0.0.1:6379> incr aQUEUED127.0.0.1:6379> exec1) (integer) 2 127.0.0.1:6379> get a"2"
失敗時候的例子,從最后可以看出,test的值被其他連接修改了:
127.0.0.1:6379> set test 1OK127.0.0.1:6379> watch testOK127.0.0.1:6379> multiOK127.0.0.1:6379> incrby test 11QUEUED127.0.0.1:6379> exec(nil) 127.0.0.1:6379> get test"100"
問題如何解決
redis中命令是滿足原子性的,因此在值為阿拉伯數字的時候,我可以將get和set命令修改為incr或者incrby來解決這個問題,下面的代碼開啟兩個終端同時執行,得到的結果是滿足我們預期的2000。
<?phprequire "vendor/autoload.php";$client = new Predis\Client([ 'scheme' => 'tcp', 'host' => '127.0.0.1', 'port' => 6379,]);for ($i = 0; $i < 1000; $i++) { $client->incr("name"); $client->expire("name", 10800); usleep(10000);}
確實可行,效果還不錯,這里寫了個例子
<?phprequire "vendor/autoload.php";$client = new Predis\Client([ 'scheme' => 'tcp', 'host' => '127.0.0.1', 'port' => 6379,]);class RedisLock{ public $objRedis = null; public $timeout = 3; /** * @desc 設置redis實例 * * @param obj object | redis實例 */ public function __construct($obj) { $this->objRedis = $obj; } /** * @desc 獲取鎖鍵名 */ public function getLockCacheKey($key) { return "lock_{$key}"; } /** * @desc 獲取鎖 * * @param key string | 要上鎖的鍵名 * @param timeout int | 上鎖時間 */ public function getLock($key, $timeout = NULL) { $timeout = $timeout ? $timeout : $this->timeout; $lockCacheKey = $this->getLockCacheKey($key); $expireAt = time() + $timeout; $isGet = (bool)$this->objRedis->setnx($lockCacheKey, $expireAt); if ($isGet) { return $expireAt; } while (1) { usleep(10); $time = time(); $oldExpire = $this->objRedis->get($lockCacheKey); if ($oldExpire >= $time) { continue; } $newExpire = $time + $timeout; $expireAt = $this->objRedis->getset($lockCacheKey, $newExpire); if ($oldExpire != $expireAt) { continue; } $isGet = $newExpire; break; } return $isGet; } /** * @desc 釋放鎖 * * @param key string | 加鎖的字段 * @param newExpire int | 加鎖的截止時間 * * @return bool | 是否釋放成功 */ public function releaseLock($key, $newExpire) { $lockCacheKey = $this->getLockCacheKey($key); if ($newExpire >= time()) { return $this->objRedis->del($lockCacheKey); } return true; } }$start_time = microtime(true);$lock = new RedisLock($client);$key = "name";for ($i = 0; $i < 10000; $i++) { $newExpire = $lock->getLock($key); $num = $client->get($key); $num++; $client->set($key, $num); $lock->releaseLock($key, $newExpire);}$end_time = microtime(true);echo "花費時間 : ". ($end_time - $start_time) . "\n";
執行shell php setnx.php & php setnx.php&,最后會得到結果:
$ 花費時間 : 4.3004920482635 [2] + 72356 done php setnx.php# root @ ritoyan-virtual-pc in ~/PHP/redis-high-concurrency [20:23:41] $ 花費時間 : 4.4319710731506 [1] + 72355 done php setnx.php
同樣循環1w次,去掉usleep,使用incr直接進行增加,耗時在2s左右。
而獲取所得時候取消usleep,時間不但沒減少,反而增加了,這個usleep的設置要合理,免得進程做無用的循環
總結
簡單的總結下,其實redis本事是不會存在并發問題的,因為他是單進程的,再多的command都是one by one執行的。我們使用的時候,可能會出現并發問題,比如get和set這一對。
更多相關資訊:
以上就是redis的最大并發量是多少,小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。