最近博主在看redis的時(shí)候發(fā)現(xiàn)了兩種redis使用方式，與之前redis作為緩存不同，利用的是redis可設(shè)置key的有效時(shí)間和redis的BRPOP命令。

分布式鎖

由于目前一些編程語(yǔ)言，如PHP等，不能在內(nèi)存中使用鎖，或者如Java這樣的，需要一下更為簡(jiǎn)單的鎖校驗(yàn)的時(shí)候，redis分布式鎖的使用就足夠滿(mǎn)足了。

redis的分布式鎖其實(shí)就是基于setnx方法和redis對(duì)key可設(shè)置有效時(shí)間的功能來(lái)實(shí)現(xiàn)的?；居梅ū容^簡(jiǎn)單。

public boolean tryLock(String lock,long expireTime){
  String expire = String.valueOf(System.currentTimeMillis() + expireTime + 1);
  Long result = jedis.setNx(lock,expire);
  if(result == 1L){
    jedis.expire(lock, expireTime);
    return true;
  }
  //判斷超時(shí)key可能未刪掉
  String currentValue = jedis.get(lock);
  if(Long.parseLong(currentValue) < System.currentTimeMillis()){
    jedis.set(lock, expire);
    jedis.expire(lock, expireTime);
    return true;
  }
  return false;
}
//expire是key的值，這里是為了防止運(yùn)行超時(shí)鎖被其他線(xiàn)程拿走之后誤刪鎖
public unlock(String lock,String expire){
  String value = jedis.get(lock);
  if(value != null && value != expire && Long.parseLong(value) > System.currentTimeMillis())
    jedis.del(lock);
}  

這里就是我根據(jù)redis的機(jī)制寫(xiě)的加鎖和解鎖方法?，F(xiàn)在redis不推薦使用setNx了，而是直接使用set命令set(lock, expire,"NX", expireTime,"EX"),可以直接包括了setNx和expire的作用。

消息隊(duì)列

消息隊(duì)列主要應(yīng)用在網(wǎng)絡(luò)服務(wù)中異步任務(wù)的實(shí)現(xiàn)，redis可以充當(dāng)消息隊(duì)列實(shí)現(xiàn)生產(chǎn)者/消費(fèi)者模型和訂閱/發(fā)布模型。

生產(chǎn)者/消費(fèi)者模型

生產(chǎn)者/消費(fèi)者模型需要存在生產(chǎn)者和消費(fèi)者兩方，而在redis中隊(duì)列的存儲(chǔ)和獲取可以作為消息隊(duì)列被生產(chǎn)者和消費(fèi)者使用，這里就不用Java代碼寫(xiě)了，使用redis命令來(lái)說(shuō)明。

 其實(shí)redis在其中做的還是緩存的作用，LPUSH queue task，將task放到queue隊(duì)列里面，這里稍微偏題一句，其實(shí)redis有l(wèi)push和rpush，意思就是從左邊插入隊(duì)列和從右邊插入隊(duì)列。這就是生產(chǎn)者的部分，將任務(wù)插入到指定隊(duì)列中。

 消費(fèi)者的部分有點(diǎn)相似，就是使用BRPOP queue 10，當(dāng)然這里的BRPOP也有對(duì)應(yīng)的BLPOP，由于隊(duì)列是按順序取任務(wù)的，所以這邊做的是左邊插入，右邊取出。這里需要注意的是，redis有BRPOP和RPOP，之所以用BRPOP的原因是這個(gè)有一個(gè)等待，就是命令中的10，這是一個(gè)等待時(shí)間，以秒為單位，意思是如果隊(duì)列中是空的，那么我先不返回，我等待10秒，如果期間有新的任務(wù)插入，那么我就取新的任務(wù)返回，還是沒(méi)有的話(huà)，返回空。

 另外BRPOP還支持優(yōu)先級(jí)，就是BRPOP queue:1 queue:2 queue:3 10，這個(gè)意思是順序獲取，如果queue:1沒(méi)有取到任務(wù)，到queue:2去取，依次往后。

訂閱/發(fā)布模型

訂閱/發(fā)布模型簡(jiǎn)單來(lái)說(shuō)就是由發(fā)布者向所有訂閱者發(fā)送任務(wù)，任何訂閱者都可以獲取任務(wù)，這里redis的實(shí)現(xiàn)就是使用訂閱命令。

 發(fā)布者可以使用publish channel task來(lái)發(fā)布相關(guān)的任務(wù)，而訂閱者則是使用subscribe channel，這是一個(gè)監(jiān)聽(tīng)命令，redis會(huì)一直監(jiān)聽(tīng)這個(gè)channel，如果發(fā)布者發(fā)布新的任務(wù)，監(jiān)聽(tīng)命令會(huì)返回任務(wù)，直到訂閱者主動(dòng)退出監(jiān)聽(tīng)。但是redis也為這個(gè)設(shè)置超時(shí)，保證監(jiān)聽(tīng)的有效性，默認(rèn)如果60s內(nèi)沒(méi)收到消息就異常退出，當(dāng)然這個(gè)可配置。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

最新評(píng)論