redis中使用java腳本實(shí)現(xiàn)分布式鎖
來(lái)源:易賢網(wǎng) 閱讀:980 次 日期:2015-04-14 14:17:30
溫馨提示:易賢網(wǎng)小編為您整理了“redis中使用java腳本實(shí)現(xiàn)分布式鎖”,方便廣大網(wǎng)友查閱!

redis被大量用在分布式的環(huán)境中,自然而然分布式環(huán)境下的鎖如何解決,立馬成為一個(gè)問(wèn)題。例如我們當(dāng)前的手游項(xiàng)目,服務(wù)器端是按業(yè)務(wù)模塊劃分服務(wù)器的,有應(yīng)用服,戰(zhàn)斗服等,但是這兩個(gè)vm都有可能同時(shí)改變玩家的屬性,這如果在同一個(gè)vm下面,就很容易加鎖,但如果在分布式環(huán)境下就沒(méi)那么容易了,當(dāng)然利用redis現(xiàn)有的功能也有解決辦法,比如redis的腳本。

redis在2.6以后的版本中增加了Lua腳本的功能,可以通過(guò)eval命令,直接在RedisServer環(huán)境中執(zhí)行Lua腳本,并且可以在Lua腳本中調(diào)用Redis命令。

使用腳本的好處:

1.減少網(wǎng)絡(luò)開(kāi)銷(xiāo):可以把一些要批量處理的功能,發(fā)在一個(gè)腳本里面執(zhí)行,減少客戶(hù)端和redis的交互次數(shù)

2.原子操作:這主要就是我們?cè)谶@邊主要利用的功能,在分布式環(huán)境下保證數(shù)據(jù)的原子性。

3.復(fù)用:客戶(hù)端發(fā)送的腳本會(huì)永久的存儲(chǔ)在redis中,這就意味著其他客戶(hù)端可以復(fù)用這一腳本而不需要使用代碼完成同樣的邏輯。

下面先看一段lua腳本:

代碼如下:

local food=redis.call('hget',KEYS[1],'food');

food=food+ARGV[1];

redis.call('hset',KEYS[1],'food',food);

local diamond=redis.call('hget',KEYS[1],'diamond');

diamond=diamond+ARGV[2];

redis.call('hset',KEYS[1],'diamond',diamond);

注:redis.call是我們?cè)谀_本中調(diào)用redis命令,KEYS和ARGV2個(gè)數(shù)組,分別是鍵和參數(shù),下標(biāo)都是從1開(kāi)始的,不是0。

這段腳本的功能是取出 KEYS指定的玩家food(糧草)和diamond(玉石),然后就行修改,最后保存在redis中,腳本的執(zhí)行,保證了整個(gè)操作的原子性。

下面我們用java代碼來(lái)看看具體的實(shí)現(xiàn)過(guò)程

代碼如下:

Jedis jedis = new Jedis("192.168.128.128", 6379);

// 1.初始玩家數(shù)據(jù)到redis中

GamePlayer player = new GamePlayer();

player.setId(1001);

player.setName("ksfzhaohui");

player.setFood(100);

player.setDiamond(100);

Map<String, String> beanMap = BeanUtil.warp(player);// 將對(duì)象轉(zhuǎn)換成map

String beanKey = getRedisBeanKey(player.getClass(), player.getId());

System.out.println("key:" + beanKey);

jedis.hmset(beanKey, beanMap);// 將玩家數(shù)據(jù)保存到redis中

首先模擬了一個(gè)玩家將玩家信息保存在redis中,這邊的Id隨便寫(xiě)了一個(gè),正常的情況下都是通過(guò)redis的命令incr生成一個(gè)id

結(jié)果:

名單

代碼如下:

String script = "local food=redis.call('hget',KEYS[1],'food');"

+ "food=food+ARGV[1];"

+ "redis.call('hset',KEYS[1],'food',food);"

+ "local diamond=redis.call('hget',KEYS[1],'diamond');"

+ "diamond=diamond+ARGV[2];"

+ "redis.call('hset',KEYS[1],'diamond',diamond);";

List<String> keys = new ArrayList<String>();

keys.add(beanKey);

List<String> args = new ArrayList<String>();

args.add("100");

args.add("100");

// 3.執(zhí)行腳本

jedis.eval(script, keys, args);

指定鍵和參考,執(zhí)行腳本,結(jié)果:

名單2

BeanUtil代碼:

代碼如下:

public class BeanUtil {

private static Logger logger = Logger.getLogger(BeanUtil.class);

private static final String CLASS = "class";

/**

* 將指定的對(duì)象數(shù)據(jù)封裝成map

*

* @param bean

* 對(duì)象數(shù)據(jù)

* @return

*/

@SuppressWarnings("all")

public static Map<String, String> warp(Object bean) {

Map<String, String> propertyMap = new HashMap<String, String>();

try {

PropertyDescriptor[] ps = Introspector.getBeanInfo(bean.getClass())

.getPropertyDescriptors();

for (PropertyDescriptor propertyDescriptor : ps) {

String propertyName = propertyDescriptor.getName();

if (propertyName != null && !propertyName.equals(CLASS)) {

Method getter = propertyDescriptor.getReadMethod();

if (getter != null) {

propertyMap.put(propertyName,

String.valueOf(getter.invoke(bean, null)));

}

}

}

} catch (Exception e) {

logger.error(e);

}

return propertyMap;

}

}

更多信息請(qǐng)查看IT技術(shù)專(zhuān)欄

更多信息請(qǐng)查看數(shù)據(jù)庫(kù)
易賢網(wǎng)手機(jī)網(wǎng)站地址:redis中使用java腳本實(shí)現(xiàn)分布式鎖
由于各方面情況的不斷調(diào)整與變化,易賢網(wǎng)提供的所有考試信息和咨詢(xún)回復(fù)僅供參考,敬請(qǐng)考生以權(quán)威部門(mén)公布的正式信息和咨詢(xún)?yōu)闇?zhǔn)!

2025國(guó)考·省考課程試聽(tīng)報(bào)名

  • 報(bào)班類(lèi)型
  • 姓名
  • 手機(jī)號(hào)
  • 驗(yàn)證碼
關(guān)于我們 | 聯(lián)系我們 | 人才招聘 | 網(wǎng)站聲明 | 網(wǎng)站幫助 | 非正式的簡(jiǎn)要咨詢(xún) | 簡(jiǎn)要咨詢(xún)須知 | 加入群交流 | 手機(jī)站點(diǎn) | 投訴建議
工業(yè)和信息化部備案號(hào):滇ICP備2023014141號(hào)-1 云南省教育廳備案號(hào):云教ICP備0901021 滇公網(wǎng)安備53010202001879號(hào) 人力資源服務(wù)許可證:(云)人服證字(2023)第0102001523號(hào)
云南網(wǎng)警備案專(zhuān)用圖標(biāo)
聯(lián)系電話(huà):0871-65099533/13759567129 獲取招聘考試信息及咨詢(xún)關(guān)注公眾號(hào):hfpxwx
咨詢(xún)QQ:526150442(9:00—18:00)版權(quán)所有:易賢網(wǎng)
云南網(wǎng)警報(bào)警專(zhuān)用圖標(biāo)