public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

add redisson

Browse Source
This commit is contained in:
houxinyu
2023-07-02 00:46:37 +08:00
parent e684db9ee8
commit 1c32e2b5c5
3 changed files with 45 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
liteflow-rule-plugin/liteflow-rule-redis/pom.xml
View File

@@ -20,6 +20,12 @@
<optional>true</optional>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>${redisson.version}</version>
</dependency>
</dependencies>
</project>

38
liteflow-rule-plugin/liteflow-rule-redis/src/main/java/com/yomahub/liteflow/parser/redis/util/RedisParserHelper.java
View File

@@ -1,9 +1,47 @@
package com.yomahub.liteflow.parser.redis.util;
import cn.hutool.core.util.ObjectUtil;
import com.yomahub.liteflow.parser.redis.exception.RedisException;
import com.yomahub.liteflow.parser.redis.vo.RedisParserVO;
import com.yomahub.liteflow.spi.holder.ContextAwareHolder;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class RedisParserHelper {
private static final Logger LOG = LoggerFactory.getLogger(RedisParserHelper.class);
private RedisParserVO redisParserVO;
private final String CHAIN_XML_PATTERN = "<chain name=\"{}\">{}</chain>";
private final String NODE_XML_PATTERN = "<nodes>{}</nodes>";
private static final String NODE_ITEM_XML_PATTERN = "<node id=\"{}\" name=\"{}\" type=\"{}\"><![CDATA[{}]]></node>";
private static final String NODE_ITEM_WITH_LANGUAGE_XML_PATTERN = "<node id=\"{}\" name=\"{}\" type=\"{}\" language=\"{}\"><![CDATA[{}]]></node>";
private static final String XML_PATTERN = "<?xml version=\"1.0\" encoding=\"UTF-8\"?><flow>{}{}</flow>";
private RedissonClient redissonClient;
public RedisParserHelper(RedisParserVO redisParserVO) {
this.redisParserVO = redisParserVO;
try{
try{
this.redissonClient = ContextAwareHolder.loadContextAware().getBean(RedissonClient.class);
}
catch (Exception ignored){
}
if(ObjectUtil.isNull(redissonClient)){
//todo get client
}
}
catch (Exception e){
throw new RedisException(e.getMessage());
}
}
}

1
pom.xml
View File

@@ -74,6 +74,7 @@
<luaj.version>3.0.1</luaj.version>
<aviator.version>5.3.3</aviator.version>
<common-io.version>2.11.0</common-io.version>
<redisson.version>3.20.0</redisson.version>
</properties>
<dependencyManagement>