redis被大量用在分布式的環(huán)境中，自然而然分布式環(huán)境下的鎖如何解決，立馬成為一個問題。例如我們當(dāng)前的手游項(xiàng)目，服務(wù)器端是按業(yè)務(wù)模塊劃分服務(wù)器的，有應(yīng)用服，戰(zhàn)斗服等，但是這兩個vm都有可能同時改變玩家的屬性，這如果在同一個vm下面，就很容易加鎖，但如果在分布式環(huán)境下就沒那么容易了，當(dāng)然利用redis現(xiàn)有的功能也有解決辦法，比如redis的腳本。
redis在2.6以后的版本中增加了Lua腳本的功能，可以通過eval命令，直接在RedisServer環(huán)境中執(zhí)行Lua腳本，并且可以在Lua腳本中調(diào)用Redis命令。
使用腳本的好處:
1.減少網(wǎng)絡(luò)開銷：可以把一些要批量處理的功能，發(fā)在一個腳本里面執(zhí)行，減少客戶端和redis的交互次數(shù)
2.原子操作:這主要就是我們在這邊主要利用的功能，在分布式環(huán)境下保證數(shù)據(jù)的原子性。
3.復(fù)用:客戶端發(fā)送的腳本會永久的存儲在redis中，這就意味著其他客戶端可以復(fù)用這一腳本而不需要使用代碼完成同樣的邏輯。
下面先看一段lua腳本:
復(fù)制代碼 代碼如下:
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是我們在腳本中調(diào)用redis命令，KEYS和ARGV2個數(shù)組，分別是鍵和參數(shù)，下標(biāo)都是從1開始的，不是0。
這段腳本的功能是取出 KEYS指定的玩家food(糧草)和diamond(玉石)，然后就行修改，最后保存在redis中，腳本的執(zhí)行，保證了整個操作的原子性。
下面我們用java代碼來看看具體的實(shí)現(xiàn)過程
復(fù)制代碼 代碼如下:
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);
MapString, String> beanMap = BeanUtil.warp(player);// 將對象轉(zhuǎn)換成map
String beanKey = getRedisBeanKey(player.getClass(), player.getId());
System.out.println("key:" + beanKey);
jedis.hmset(beanKey, beanMap);// 將玩家數(shù)據(jù)保存到redis中
首先模擬了一個玩家將玩家信息保存在redis中，這邊的Id隨便寫了一個，正常的情況下都是通過redis的命令incr生成一個id
結(jié)果:
復(fù)制代碼 代碼如下:
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);";
ListString> keys = new ArrayListString>();
keys.add(beanKey);
ListString> args = new ArrayListString>();
args.add("100");
args.add("100");
// 3.執(zhí)行腳本
jedis.eval(script, keys, args);
指定鍵和參考，執(zhí)行腳本,結(jié)果:
BeanUtil代碼:
復(fù)制代碼 代碼如下:
public class BeanUtil {
private static Logger logger = Logger.getLogger(BeanUtil.class);
private static final String CLASS = "class";
/**
* 將指定的對象數(shù)據(jù)封裝成map
*
* @param bean
* 對象數(shù)據(jù)
* @return
*/
@SuppressWarnings("all")
public static MapString, String> warp(Object bean) {
MapString, String> propertyMap = new HashMapString, 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;
}
}
您可能感興趣的文章:- Redis實(shí)現(xiàn)分布式鎖的幾種方法總結(jié)
- 基于Redis實(shí)現(xiàn)分布式鎖以及任務(wù)隊(duì)列
- Redis分布式鎖的實(shí)現(xiàn)方式(redis面試題)
- Redis分布式鎖實(shí)現(xiàn)方式及超時問題解決
- Redis上實(shí)現(xiàn)分布式鎖以提高性能的方案研究
- redis實(shí)現(xiàn)分布式的方法總結(jié)
- Redis分布式非公平鎖的使用
