SpringBoot怎么通過redisTemplate調(diào)用lua腳本并打印調(diào)試信息到redislog

這篇文章給大家分享的是有關(guān)SpringBoot怎么通過redisTemplate調(diào)用lua腳本并打印調(diào)試信息到redis log的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個(gè)參考，一起跟隨小編過來看看吧。

創(chuàng)新互聯(lián)公司專注于企業(yè)全網(wǎng)整合營銷推廣、網(wǎng)站重做改版、龍安網(wǎng)站定制設(shè)計(jì)、自適應(yīng)品牌網(wǎng)站建設(shè)、H5頁面制作、電子商務(wù)商城網(wǎng)站建設(shè)、集團(tuán)公司官網(wǎng)建設(shè)、外貿(mào)網(wǎng)站建設(shè)、高端網(wǎng)站制作、響應(yīng)式網(wǎng)頁設(shè)計(jì)等建站業(yè)務(wù)，價(jià)格優(yōu)惠性價(jià)比高，為龍安等各大城市提供網(wǎng)站開發(fā)制作服務(wù)。

springboot是什么

springboot一種全新的編程規(guī)范，其設(shè)計(jì)目的是用來簡化新Spring應(yīng)用的初始搭建以及開發(fā)過程，SpringBoot也是一個(gè)服務(wù)于框架的框架，服務(wù)范圍是簡化配置文件。

第一次寫Lua腳本，并通過springboot的redisTemplate調(diào)用腳本，進(jìn)行腳本與應(yīng)用的交互。不熟悉真的折騰了好久，現(xiàn)在總結(jié)一下學(xué)習(xí)過程：

第一次寫完lua時(shí)，想到的就是如何在應(yīng)用調(diào)用腳本的時(shí)候，去調(diào)試腳本。在網(wǎng)上海搜了一把，能找到的有點(diǎn)相關(guān)的寥寥無幾。

有一種方法是通過執(zhí)行redis命令，調(diào)用redis客戶端，加載lua腳本，然后出現(xiàn)基于命令行調(diào)試的交互界面，輸入調(diào)試命令去調(diào)試腳本。如下：

在終端輸入命令：redis-cli.exe --ldb --eval LimitLoadTimes.lua 1 mykey , myargv

--ldb:redis-cli.exe進(jìn)行命令調(diào)試的必要參數(shù)

--eval:告訴redis客戶端去加載Lua腳本，后面跟著的就是 lua腳本的路徑（我是直接放在redis目錄下），

1：傳給Lua腳本的key的數(shù)量，我測試的時(shí)候是1

--mykey:自己傳的一個(gè)key值,和前面的數(shù)量1對應(yīng)

--myargv:自己傳的除key外的參數(shù)，可以是多個(gè)

注，命令中的逗號(hào)不能忽略，并且前后要有一個(gè)空格

回車，如上圖，本來以為可以進(jìn)入調(diào)試，結(jié)果等了半天，一直沒有出現(xiàn)交互的命令行界面，找了好久，還是沒找到辦法，結(jié)果只好先暫停（如果有大神遇到這種情況，跪求解~~）。換一種調(diào)試方式，把調(diào)試信息打在redis日志上。

下面是我自己調(diào)用腳本時(shí)，打印調(diào)試信息的方式，如果有更好的方式，請不吝賜教。

1、選擇redisTemplate序列化方式

首先，創(chuàng)建一個(gè)redisTemplate,具體代碼就不說了，這個(gè)比較簡單。要注意的是，需要設(shè)置redisTemplate的序列化方式，springBoot默認(rèn)是基于java jdk的序列化。通過這種序列化后的參數(shù)傳到Lua腳本是，是無法正常打印到redis日志的，會(huì)出現(xiàn)亂碼，而且參數(shù)如果傳的是一個(gè)Map或List的話，不方便解析。并且這種序列化占用的字節(jié)比較大。所以改成JSON序列化，用FastJson實(shí)現(xiàn)。

下面貼上redis序列化代碼：

public class FastJsonRedisSerializer<T> implements RedisSerializer<T> {
 public static final Charset DEFAULT_CHARSET = Charset.forName("UTF-8");
 private Class<T> clazz;
 public FastJsonRedisSerializer(Class<T> clazz){
  super();
  this.clazz = clazz;
 }
 @Override
 public byte[] serialize(T t) throws SerializationException {
  return ofNullable(t)
    .map(r -> JSON.toJSONString(r, SerializerFeature.WriteClassName).getBytes(DEFAULT_CHARSET))
    .orElseGet(() -> new byte[0]);
 }
 @Override
 public T deserialize(byte[] bytes) throws SerializationException {
  return Optional.ofNullable(bytes)
    .map(t -> JSON.parseObject(new String(t, DEFAULT_CHARSET), clazz))
    .orElseGet(() -> null);
 }
}

2、應(yīng)用端加載腳本，并設(shè)置傳遞參數(shù)

在springboot中，是用 DefaultRedisScript 類來加載腳本的，并設(shè)置相應(yīng)的數(shù)據(jù)類型來接收lua腳本返回的數(shù)據(jù)，這個(gè)泛型類在使用時(shí)設(shè)置泛型是什么類型，腳本返回的結(jié)果就是用什么類型接收。注意，該類只接收4種類型的返回類型，之前沒注意，還納悶為什么出錯(cuò)，看源碼才曉得，截圖，如下：

在lua腳本中，有兩個(gè)全局的變量，是用來接收redis應(yīng)用端傳遞的鍵值和其它參數(shù)的，分別為KEYS、ARGV。

在應(yīng)用端傳遞給KEYS時(shí)是一個(gè)數(shù)組列表，在lua腳本中通過索引方式獲取數(shù)組內(nèi)的值。

在應(yīng)用端，傳遞給ARGV的參數(shù)比較靈活，可以是多個(gè)獨(dú)立的參數(shù)，但對應(yīng)到Lua腳本中是，統(tǒng)一用ARGV這個(gè)數(shù)組接收，獲取方式也是通過數(shù)組下標(biāo)獲取。

下面貼上應(yīng)用端的測試代碼：

@Service("luaScriptService")
public class LuaScriptServiceImpl implements LuaScriptService{
 @Autowired
 private RedisTemplate<String,Object> redisTemplate1;
 private DefaultRedisScript<List> getRedisScript;
 @PostConstruct
 public void init(){
  getRedisScript = new DefaultRedisScript<List>();
  getRedisScript.setResultType(List.class);
  getRedisScript.setScriptSource(new ResourceScriptSource(new ClassPathResource("luascript/LimitLoadTimes.lua")));
 }
 @Override
 public void redisAddScriptExec(){
  /**
   * List設(shè)置lua的KEYS
   */
  List<String> keyList = new ArrayList();
  keyList.add("count");
  keyList.add("rate.limiting:127.0.0.1");
  /**
   * 用Mpa設(shè)置Lua的ARGV[1]
   */
  Map<String,Object> argvMap = new HashMap<String,Object>();
  argvMap.put("expire",10000);
  argvMap.put("times",10);
  /**
   * 調(diào)用腳本并執(zhí)行
   */
  List result = redisTemplate1.execute(getRedisScript,keyList, argvMap);
  System.out.println(result);
 }
}

代碼中發(fā)送了兩個(gè)key,還有一個(gè)map包裝的argv,傳遞到Lua腳本中時(shí)，KEYS和ARGV接收到的是對象字符串，所以得用lua的庫做相關(guān)的解碼，我們發(fā)送的時(shí)候是用json序列化的，用Lua的庫cjson可以轉(zhuǎn)成json對象。下面貼上Lua腳本代碼：

--獲取KEY
local key1 = KEYS[1]
local key2 = KEYS[2]
-- 獲取ARGV[1],這里對應(yīng)到應(yīng)用端是一個(gè)List<Map>.
-- 注意，這里接收到是的字符串，所以需要用csjon庫解碼成table類型
local receive_arg_json = cjson.decode(ARGV[1])
--返回的變量
local result = {}
--打印日志到reids
--注意，這里的打印日志級(jí)別，需要和redis.conf配置文件中的日志設(shè)置級(jí)別一致才行
redis.log(redis.LOG_DEBUG,key1)
redis.log(redis.LOG_DEBUG,key2)
redis.log(redis.LOG_DEBUG, ARGV[1],#ARGV[1])
--獲取ARGV內(nèi)的參數(shù)并打印
local expire = receive_arg_json.expire
local times = receive_arg_json.times
redis.log(redis.LOG_DEBUG,tostring(times))
redis.log(redis.LOG_DEBUG,tostring(expire))
--往redis設(shè)置值
redis.call("set",key1,times)
redis.call("incr",key2)
redis.call("expire",key2,expire)
--用一個(gè)臨時(shí)變量來存放json,json是要放入要返回的數(shù)組中的
local jsonRedisTemp={}
jsonRedisTemp[key1] = redis.call("get",key1)
jsonRedisTemp[key2] = redis.call("get", key2)
jsonRedisTemp["ttl"] = redis.call("ttl",key2)
redis.log(redis.LOG_DEBUG, cjson.encode(jsonRedisTemp))
result[1] = cjson.encode(jsonRedisTemp) --springboot redistemplate接收的是List,如果返回的數(shù)組內(nèi)容是json對象,需要將json對象轉(zhuǎn)成字符串,客戶端才能接收
result[2] = ARGV[1] --將源參數(shù)內(nèi)容一起返回
redis.log(redis.LOG_DEBUG,cjson.encode(result)) --打印返回的數(shù)組結(jié)果，這里返回需要以字符返回
return result

3、設(shè)置日志級(jí)別

代碼中，redis.log()函數(shù)向運(yùn)日志中輸出信息，這里要注意一下，函數(shù)里面設(shè)置的日志級(jí)別要和redis.conf配置文件中設(shè)置的日志級(jí)別一樣才能正常打印到文件，這里我是設(shè)置成了deubg級(jí)別。這里可設(shè)置的級(jí)別有4種，分別如下：

• redis.LOG_DEBUG

• redis.LOG_VERBOSE

• redis.LOG_NOTICE

• redis.LOG_WARNING

在應(yīng)用端，我們設(shè)置接收返回的數(shù)據(jù)類型是List，所以在Lua腳本中，返回的類型用table與之對應(yīng)，并且放到table變量中的內(nèi)容，得是字符串，應(yīng)用端才能通過反序列化，正常解析。下圖是輸出lua返回值的打印信息:

感謝各位的閱讀！關(guān)于“SpringBoot怎么通過redisTemplate調(diào)用lua腳本并打印調(diào)試信息到redis log”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識(shí)，如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到吧！

當(dāng)前題目：SpringBoot怎么通過redisTemplate調(diào)用lua腳本并打印調(diào)試信息到redislog
網(wǎng)頁地址：http://bm7419.com/article30/jdsdpo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供小程序開發(fā)、面包屑導(dǎo)航、網(wǎng)站內(nèi)鏈、自適應(yīng)網(wǎng)站、網(wǎng)站收錄、網(wǎng)站導(dǎo)航

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)