springboot中通過(guò)lua腳本來(lái)獲取序列號(hào)的方法
更新時(shí)間：2020年06月09日 10:52:56 作者：fhf2424045058
這篇文章主要介紹了springboot中通過(guò)lua腳本來(lái)獲取序列號(hào)的方法，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
序言：
事件：此web項(xiàng)目的功能及其簡(jiǎn)單，就是有客戶端來(lái)訪問(wèn)redis序列號(hào)服務(wù)時(shí)發(fā)送jison報(bào)文，項(xiàng)目已經(jīng)在測(cè)試環(huán)境成功運(yùn)行2周了，具體的代碼我就直接上了，此博客僅是自己的記錄，同學(xué)們可做參考！
一、工程目錄結(jié)構(gòu)
二、配置文件
1、pom.xml
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.2.6.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.test</groupId> <artifactId>seq-gen</artifactId> <version>0.0.1-SNAPSHOT</version> <name>seq-gen</name> <description>generate sequence from redis</description> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> </properties> <dependencies> <!--引入日志依賴--> <!--<dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.21</version> </dependency> <dependency> <groupId>commons-logging</groupId> <artifactId>commons-logging</artifactId> <version>1.2</version> </dependency>--> <!-- log4j2的api、core和web包 --> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-api</artifactId> <version>2.11.1</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.11.1</version> </dependency> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-web</artifactId> <version>2.11.1</version> </dependency> <!-- slf4j與log4j2的連接包 --> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-slf4j-impl</artifactId> <version>2.11.1</version> </dependency> <!-- log4j與log4j2的連接包 --> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-1.2-api</artifactId> <version>2.11.1</version> </dependency> <!-- log4j2支撐完全異步模式的關(guān)鍵api --> <dependency> <groupId>com.lmax</groupId> <artifactId>disruptor</artifactId> <version>3.4.2</version> </dependency> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-api</artifactId> <version>1.7.21</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.62</version> </dependency> <dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> <exclusions> <exclusion> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-logging</artifactId> </exclusion> </exclusions> </dependency> <!-- 熱部署,集成測(cè)試--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <optional>true</optional> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <source>1.8</source> <target>1.8</target> </configuration> </plugin> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <executions> <execution> <goals> <goal>repackage</goal> </goals> </execution> </executions> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-surefire-plugin</artifactId> <version>2.4.2</version> <configuration> <skipTests>true</skipTests> </configuration> </plugin> </plugins> </build> </project>
2、applicaiton.properties
spring.redis.database= 0 spring.redis.host= 127.0.0.1 spring.redis.port= 6379 spring.redis.pool.max-active= 8 spring.redis.pool.max-wait= -1ms spring.redis.pool.max-idle= 8 spring.redis.pool.min-idle= 0 spring.redis.pool.timeout= 2000ms server.port= 8085
3、luaScripts腳本
local function get_next_seq()
--KEYS[1]:第一個(gè)參數(shù)代表存儲(chǔ)序列號(hào)的key 相當(dāng)于代碼中的業(yè)務(wù)類型
local key = tostring(KEYS[1])
--KEYS[2]:第二個(gè)參數(shù)代表序列號(hào)增長(zhǎng)速度
local incr_amoutt = tonumber(KEYS[2])
--KEYS[3]`:第四個(gè)參數(shù)為序列號(hào) (yyMMddHHmmssSSS + 兩位隨機(jī)數(shù))
local seq = tonumber(KEYS[3])
--序列號(hào)過(guò)期時(shí)間大小,單位是秒
-- local month_in_seconds = 24 * 60 * 60 * 7
--Redis的 SETNX 命令可以實(shí)現(xiàn)分布式鎖,用于解決高并發(fā)
--如果key不存在,將 key 的值設(shè)為 seq，設(shè)置成成功返回1 未設(shè)置返回0
--若給定的 key 已經(jīng)存在，則 SETNX 不做任何動(dòng)作，獲取下一個(gè)按照步增的值
if (1 == redis.call('setnx', key, seq)) --不存在key，
then
--設(shè)置key的生存時(shí)間 為 month_in_seconds秒
-- 由于序列號(hào)需要永久有效，不能過(guò)期，所以取消這個(gè)設(shè)置，需要的可以取消注釋
-- redis.call('expire', key, month_in_seconds)
--將序列返回給調(diào)用者
return seq
else
--key值存在,直接獲取下一個(gè)增加的值
local nextSeq = redis.call('incrby', key, incr_amoutt)
return nextSeq
end
end
return get_next_seq()
4、log4j2.xml
<?xml version="1.0" encoding="UTF-8"?>
<!--日志級(jí)別以及優(yōu)先級(jí)排序: OFF > FATAL > ERROR > WARN > INFO > DEBUG > TRACE > ALL -->
<!--Configuration后面的status，這個(gè)用于設(shè)置log4j2自身內(nèi)部的信息輸出，可以不設(shè)置，當(dāng)設(shè)置成trace時(shí)，你會(huì)看到log4j2內(nèi)部各種詳細(xì)輸出-->
<!--monitorInterval：Log4j能夠自動(dòng)檢測(cè)修改配置 文件和重新配置本身，設(shè)置間隔秒數(shù)-->
<configuration status="INFO" monitorInterval="30" packages="org.apache.logging.log4j.core.layout">
<Properties>
<Property name="baseDir">logs</Property>
</Properties>
<!--先定義所有的appender-->
<appenders>
<!-- 這個(gè)輸出控制臺(tái)的配置 -->
<Console name="Console" target="SYSTEM_OUT">
<!-- 控制臺(tái)只輸出level及以上級(jí)別的信息（onMatch），其他的直接拒絕（onMismatch） -->
<ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
<!-- 這個(gè)都知道是輸出日志的格式 -->
<PatternLayout pattern="[%date{DEFAULT}]-[%highlight{%level}]-[%threadName]-[%-class{4}:%line]-%msg%n"/>
</Console>
<!-- 這個(gè)會(huì)打印出所有的info及以下級(jí)別的信息，每次大小超過(guò)size，則這size大小的日志會(huì)自動(dòng)存入按年份-月份建立的文件夾下面并進(jìn)行壓縮，作為存檔-->
<RollingFile name="RollingFileInfo" fileName="${baseDir}/seq_all.log"
filePattern="${baseDir}/$${date:yyyy-MM}/all-%d{yyyy-MM-dd}-%i.log">
<!--控制臺(tái)只輸出level及以上級(jí)別的信息（onMatch），其他的直接拒絕（onMismatch）-->
<ThresholdFilter level="info" onMatch="ACCEPT" onMismatch="DENY"/>
<PatternLayout pattern="[%date{DEFAULT}]-[%highlight{%level}]-[%threadName]-[%-class{4}:%line]-%msg%n"/>
<Policies>
<TimeBasedTriggeringPolicy/>
<SizeBasedTriggeringPolicy size="500 MB"/>
</Policies>
</RollingFile>
<RollingFile name="RollingFileWarn" fileName="${baseDir}/seq_warn.log"
filePattern="${baseDir}/$${date:yyyy-MM}/warn-%d{yyyy-MM-dd}-%i.log">
<ThresholdFilter level="warn" onMatch="ACCEPT" onMismatch="DENY"/>
<PatternLayout pattern="[%date{DEFAULT}]-[%highlight{%level}]-[%threadName]-[%-class{4}:%line]-%msg%n"/>
<Policies>
<TimeBasedTriggeringPolicy/>
<SizeBasedTriggeringPolicy size="100 MB"/>
</Policies>
<!-- DefaultRolloverStrategy屬性如不設(shè)置，則默認(rèn)為最多同一文件夾下7個(gè)文件，這里設(shè)置了20 -->
<DefaultRolloverStrategy max="20"/>
</RollingFile>
<RollingFile name="RollingFileErrorCommon" fileName="${baseDir}/seq_error.log"
filePattern="${baseDir}/$${date:yyyy-MM}/error-%d{yyyy-MM-dd}-%i.log">
<ThresholdFilter level="error" onMatch="ACCEPT" onMismatch="DENY"/>
<PatternLayout pattern="[%date{DEFAULT}]-[%highlight{%level}]-[%threadName]-[%-class{4}:%line]-%msg%n"/>
<Policies>
<TimeBasedTriggeringPolicy/>
<SizeBasedTriggeringPolicy size="100 MB"/>
</Policies>
</RollingFile>
</appenders>
<!--然后定義logger，只有定義了logger并引入的appender，appender才會(huì)生效-->
<loggers>
<!--過(guò)濾掉spring和mybatis的一些無(wú)用的DEBUG信息-->
<logger name="org.springframework" level="DEBUG"></logger>
<logger name="org.mybatis" level="DEBUG"></logger>
<logger name="com.alicl oud.openservices.tablestore" level="ERROR" additivity="false">
<appender-ref ref="RollingFileOtsError"/>
</logger>
<root level="INFO">
<appender-ref ref="Console"/>
<appender-ref ref="RollingFileInfo"/>
<appender-ref ref="RollingFileWarn"/>
<appender-ref ref="RollingFileErrorCommon"/>
</root>
</loggers>
</configuration>
三、代碼部分
1、啟動(dòng)類
package com.test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class SeqGenApplication {
private static final Logger log = LoggerFactory.getLogger(SeqGenApplication.class);
public static void main(String[] args) {
SpringApplication.run(SeqGenApplication.class, args);
log.info("start SeqGenApplication sucessfully........");
}
}
2、Bean
package com.test.bean;
import com.alibaba.fastjson.annotation.JSONField;
/**
* Copyright (C), 2019-2020
*
* 此類是請(qǐng)求和響應(yīng)中對(duì)應(yīng)的屬性
*
* @author fanhf
* @date 2020-03-25
* @version v1.0.0
*/
public class RspBean {
public RspBean(){}
/* 開(kāi)始序列號(hào) */
@JSONField(name = "SNNumB")
private Integer sNNumB;
/* 從redis中獲取的序列號(hào) */
@JSONField(name = "SNNumE")
private Integer sNNumE;
/* 發(fā)起方操作流水 */
@JSONField(name = "OprNumb")
private String oprNumb;
/* 落地方操作時(shí)間 */
@JSONField(name = "OprTime")
private String oprTime;
/* 返回碼 */
@JSONField(name = "BizOrderResult")
private String bizOrderResult;
/* 返回碼描述 */
@JSONField(name = "ResultDesc")
private String resultDesc;
public Integer getSNNumB() {
return sNNumB;
}
public void setSNNumB(Integer sNNumB) {
this.sNNumB = sNNumB;
}
public Integer getSNNumE() {
return sNNumE;
}
public void setSNNumE(Integer sNNumE) {
this.sNNumE = sNNumE;
}
public String getOprNumb() {
return oprNumb;
}
public void setOprNumb(String oprNumb) {
this.oprNumb = oprNumb;
}
public String getOprTime() {
return oprTime;
}
public void setOprTime(String oprTime) {
this.oprTime = oprTime;
}
public String getBizOrderResult() {
return bizOrderResult;
}
public void setBizOrderResult(String bizOrderResult) {
this.bizOrderResult = bizOrderResult;
}
public String getResultDesc() {
return resultDesc;
}
public void setResultDesc(String resultDesc) {
this.resultDesc = resultDesc;
}
@Override
public String toString() {
return "RspBean{" +
"sNNumB=" + sNNumB +
", sNNumE=" + sNNumE +
", oprNumb='" + oprNumb + '\'' +
", oprTime='" + oprTime + '\'' +
", bizOrderResult='" + bizOrderResult + '\'' +
", resultDesc='" + resultDesc + '\'' +
'}';
}
}
3、Controller
package com.test.controller;
import com.test.bean.RspBean;
import com.test.service.RedisService;
import com.test.util.CommonUtils;
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import java.util.HashMap;
import java.util.Map;
/**
* Copyright (C), 2019-2020
*
* 此類是web層的入口，用來(lái)接收json請(qǐng)求
*
* @author fanhf
* @date 2020-03-29
* @version v1.0.0
*/
@RestController
public class RedisControlLer {
private static final Logger log = LoggerFactory.getLogger(RedisControlLer.class);
@Autowired
private RedisTemplate<String, String> redisTemplate;
@Autowired
private RedisService redisService;
@PostMapping(path = "/app/v1/sync/bizOrder/QuerySerialNumber", consumes = "application/json", produces = "application/json")
public String rcvReq(@RequestBody String jsonparam){
String prettyJson= CommonUtils.prettyJson(jsonparam);
log.info("receive requset: ");
log.info("\r\n"+prettyJson);
JSONObject jsonObject = new JSONObject();
RspBean rw = new RspBean();
String response = null;
Map<String ,String> jsonMap = new HashMap<String,String>();
try {
// 將報(bào)文放入map中
jsonMap = CommonUtils.putReq2Map(jsonparam);
response = redisService.createResponse(jsonMap);
prettyJson = CommonUtils.prettyJson(response);
log.info("send Response: ");
log.info("\r\n"+prettyJson);
} catch (Exception ex) {
if (null == jsonObject || 0 == jsonObject.size()) {
try {
String oprNumb = jsonMap.get("oprNumb");
rw.setOprNumb(oprNumb);
rw.setBizOrderResult("30000");
rw.setResultDesc(ex.getMessage());
JSONObject json = (JSONObject) JSONObject.toJSON(rw);
response = json.toString();
} catch (Exception e) {
e.printStackTrace();
}
return response;
}
}
return response;
}
}
4、Service
package com.test.service;
import java.util.Map;
public interface RedisService {
String createResponse(Map<String, String> jsonMap);
}
ServiceImpl
package com.test.service;
import com.test.bean.RspBean;
import com.test.util.CommonUtils;
import com.test.util.RedisUtil;
import com.alibaba.fastjson.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.*;
/**
* Copyright (C), 2019-2020
*
* 此類是service處理層，根據(jù)接收到的序列名稱和步長(zhǎng)值，從redis中獲取序列號(hào)，再對(duì)返回的信息進(jìn)行組裝
* 以及對(duì)異常情況時(shí)返回?cái)?shù)據(jù)的處理
*
* @author fanhf
* @date 2020-04-05
* @version v1.0.0
*/
@Component
@Service
public class RedisServiceImpl implements RedisService {
private static final Logger log = LoggerFactory.getLogger(RedisServiceImpl.class);
@Override
public String createResponse(Map<String, String> jsonMap) {
String response = null;
RspBean rw = null;
JSONObject json = null;
// 之所以要遍歷map是因?yàn)榕聜鬟^(guò)來(lái)的key值有小寫的，怕get不到對(duì)應(yīng)的值
String key = null;
String sNNameValue = null;
String increAmountValue = null;
for (Map.Entry<String, String> entry : jsonMap.entrySet()) {
key = entry.getKey();
if ("SNName".equalsIgnoreCase(key)) {
sNNameValue = entry.getValue();
} else if("SNNum".equalsIgnoreCase(key)){
increAmountValue = entry.getValue();
}
}
String seq="0";
// 從redis中獲取序列號(hào)（根據(jù)序列號(hào)名稱和步長(zhǎng)獲取序列號(hào)）
List<String> busilist = Arrays.asList(sNNameValue,increAmountValue,seq);
Long seqFromRedis = null;
try {
seqFromRedis = RedisUtil.getBusiSeq(busilist);
} catch (Exception e) {
log.error("cannot get seq from redis cluster ,please check redis cluster"+ "_" + e.getMessage(), e);
}
log.info("seqFromRedis:{}", seqFromRedis);
String oprNumb = jsonMap.get("OprNumb");
String oprTime = CommonUtils.getCurDateTimestamp();
try {
rw = new RspBean();
int sNNumB;
if(!StringUtils.isEmpty(seqFromRedis)){
sNNumB=seqFromRedis.intValue();
rw.setSNNumB(sNNumB);
rw.setSNNumE(sNNumB+Integer.parseInt(increAmountValue));
rw.setBizOrderResult("00000");
rw.setResultDesc("Success");
}else{
rw.setSNNumB(0);
rw.setSNNumE(0);
rw.setBizOrderResult("30000");
rw.setResultDesc("business handles failed....");
}
rw.setOprNumb(oprNumb);
rw.setOprTime(oprTime);
json = (JSONObject) JSONObject.toJSON(rw);
response = json.toString();
} catch (Exception e) {
log.error("boxing response of json happend error "+ "_" + e.getMessage(), e);
if (rw != null) {
rw.setBizOrderResult("30000");
rw.setResultDesc("business handles failed......");
json = (JSONObject) JSONObject.toJSON(rw);
response = json.toString();
}
log.info("send Response: [ {} ]", response );
jsonMap.put("responseToWzw", response);
return response;
}
return response;
}
}
5、Utils
5.1 CommonUtils
package com.test.util;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.Date;
import java.util.Map;
/**
* 工具類
* @author fanhf
* @date 2020-04-01
* @version v1.0.0
*/
public class CommonUtils {
private static final Logger log = LoggerFactory.getLogger(CommonUtils.class);
public static Map<String, String> putReq2Map(String jsonparam) {
// 將json字符串轉(zhuǎn)換為json對(duì)象
return (Map<String, String>) JSONObject.parse(jsonparam);
}
/**
* @Description 獲取系統(tǒng)當(dāng)前時(shí)間
* @return 時(shí)間字符串
*/
public static String getCurDateTimestamp(){
DateTimeFormatter dateTimeFormatter=DateTimeFormatter.ofPattern("yyyyMMddHHmmss");
LocalDateTime localDateTime = LocalDateTime.now();
String now=localDateTime.format(dateTimeFormatter);
return now;
}
/**
* 美化json格式，將一行json轉(zhuǎn)為為有回車換行的json
* @param reqJson
* @return 美化后的json
*/
public static String prettyJson(String reqJson){
JSONObject object = JSONObject.parseObject(reqJson);
String prettyJson = JSON.toJSONString(object, SerializerFeature.PrettyFormat, SerializerFeature.WriteMapNullValue,SerializerFeature.WriteDateUseDateFormat);
return prettyJson;
}
}
5.2 ReadConfigsPathUtil
package com.test.util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.IOException;
import java.util.Properties;
/**
* @ Description : 用來(lái)獲取linux和windows的config的絕對(duì)路徑
* @ Author : fanhf
* @ CreateDate : 2020/4/11 0:33
* @ UpdateUser : fanhf
* @ UpdateDate : 2020/4/11 0:33
* @ UpdateRemark : 修改內(nèi)容
* @ Version : 1.0.0
*/
public class ReadConfigsPathUtil {
private static final Logger log = LoggerFactory.getLogger(ReadConfigsPathUtil.class);
private ReadConfigsPathUtil() {}
private static Properties properties = null;
/**
* @Description 獲取linux和windows系統(tǒng)中config的目錄
* @param configPath lua腳本的相對(duì)路徑
* @return linux和windows系統(tǒng)中config的目錄的絕對(duì)路徑
*/
public static String getPropertiesPath(String configPath) {
String sysPath = getRelativePath();
log.info("sysPath:{}",sysPath);
String filepath = new StringBuffer(sysPath)
.append(File.separator)
.append("config")
.append(File.separator)
.append(configPath).toString();
log.info("filepath:{}",filepath);
return filepath;
}
/**
* @Description 獲取系統(tǒng)字符型屬性
* @author add by fanhf
* @date 2020-04-08
*/
public static String getRelativePath() {
return System.getProperty("user.dir");
}
/**
* @Description 讀取lua腳本的內(nèi)容
* @param luaScriptPath lua腳本的絕對(duì)路徑
* @return 讀取到的lua腳本的內(nèi)容
* @author add by fanhf
* @date 2020-04-15
*/
public static String readFileContent(String luaScriptPath) {
String filename = getPropertiesPath(luaScriptPath);
File file = new File(filename);
BufferedReader reader = null;
StringBuffer sbf = new StringBuffer();
try {
reader = new BufferedReader(new FileReader(file));
String tempStr;
while ((tempStr = reader.readLine()) != null) {
sbf.append(tempStr);
sbf.append("\r\n");
}
reader.close();
return sbf.toString();
} catch (IOException e) {
e.printStackTrace();
} finally {
if (reader != null) {
try {
reader.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
return sbf.toString();
}
}
5.3 RedisUtil
package com.test.util;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.EncodedResource;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.data.redis.core.script.DefaultScriptExecutor;
import org.springframework.data.redis.core.script.RedisScript;
import org.springframework.stereotype.Component;
import org.springframework.util.FileCopyUtils;
import java.io.IOException;
import java.util.List;
/**
* @ Description : 用來(lái)加載和讀取lua腳本并加載
* @ Author : fanhf
* @ CreateDate : 2020/4/01 0:32
* @ UpdateUser : fanhf
* @ UpdateDate : 2020/4/01 0:32
* @ UpdateRemark : 修改內(nèi)容
* @ Version : 1.0.0
*/
@Component
public class RedisUtil {
private static final Logger log = LoggerFactory.getLogger(RedisUtil.class);
private static StringRedisTemplate redisStringTemplate;
private static RedisScript<Long> redisScript;
private static DefaultScriptExecutor<String> scriptExecutor;
private RedisUtil(StringRedisTemplate template) throws IOException {
RedisUtil.redisStringTemplate = template;
// 之所以會(huì)注釋掉是由于這段代碼可以直接讀取resource目錄下的非application.properties的文件，
// 但是這個(gè)方法在生產(chǎn)和測(cè)試環(huán)境不適用，因?yàn)榕渲梦募仨毐┞冻醮虻膉ar包里
// ClassPathResource luaResource = new ClassPathResource("luaScript/genSeq.lua");
// EncodedResource encRes = new EncodedResource(luaResource, "UTF-8");
// String luaString = FileCopyUtils.copyToString(encRes.getReader());
String luaString = ReadConfigsPathUtil.readFileContent("luaScript/genSeq.lua");
redisScript = new DefaultRedisScript<>(luaString, Long.class);
scriptExecutor = new DefaultScriptExecutor<>(redisStringTemplate);
}
public static Long getBusiSeq(List<String> Busilist) throws Exception{
Long seqFromRedis = scriptExecutor.execute(redisScript, Busilist);
return seqFromRedis;
}
}
總結(jié)
到此這篇關(guān)于springboot中通過(guò)lua腳本來(lái)獲取序列號(hào)的文章就介紹到這了,更多相關(guān)springboot中通過(guò)lua腳本來(lái)獲取序列號(hào)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
MyBatis-Plus枚舉和自定義主鍵ID的實(shí)現(xiàn)步驟
這篇文章主要給大家介紹了關(guān)于MyBatis-Plus枚舉和自定義主鍵ID的相關(guān)資料,文中通過(guò)實(shí)例代碼以及圖文介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2022-02-02
Java的DataInputStream和DataOutputStream數(shù)據(jù)輸入輸出流
這里我們來(lái)看一下Java的DataInputStream和DataOutputStream數(shù)據(jù)輸入輸出流的使用示例,兩個(gè)類分別繼承于FilterInputStream和FilterOutputStream:2016-06-06
Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案
這篇文章主要介紹了Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-07-07
java實(shí)現(xiàn)拉鉤網(wǎng)上的FizzBuzzWhizz問(wèn)題示例
這篇文章主要介紹了java實(shí)現(xiàn)拉鉤網(wǎng)上的FizzBuzzWhizz問(wèn)題示例,需要的朋友可以參考下2014-05-05
這篇文章主要介紹了Java擴(kuò)展Nginx之共享內(nèi)存的相關(guān)資料,需要的朋友可以參考下2023-07-07
SpringBoot使用AES對(duì)JSON數(shù)據(jù)加密和解密的實(shí)現(xiàn)方法
這篇文章主要介紹了SpringBoot使用AES對(duì)JSON數(shù)據(jù)加密和解密的實(shí)現(xiàn)方法,文章通過(guò)代碼示例介紹的非常詳細(xì),對(duì)我們的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-08-08
這篇文章主要介紹了TreeSet判斷重復(fù)元素解析及代碼示例，具有一定借鑒價(jià)值,需要的朋友可以參考下2018-01-01
這篇文章主要為大家詳細(xì)介紹了java設(shè)計(jì)模式之單例模式，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下2017-10-10
CSRF是一種非常常見(jiàn)的Web攻擊方式，其實(shí)是很好防御的，但是由于經(jīng)常被很多開(kāi)發(fā)者忽略，進(jìn)而導(dǎo)致很多網(wǎng)站實(shí)際上都存在 CSRF 攻擊的安全隱患，這篇文章主要介紹了SpringBoot 如何防御 CSRF 攻擊,需要的朋友可以參考下2023-05-05
解決Spring?AOP攔截抽象類(父類)中方法失效問(wèn)題
這篇文章主要介紹了解決Spring?AOP攔截抽象類(父類)中方法失效問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-11-11