suguo
/
jetlinks-community
mirror of https://gitee.com/jetlinks/jetlinks-community.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

使用新的script api

This commit is contained in:
zhouhao 2022-09-26 17:27:23 +08:00
parent c2e39e9ca9
commit 8d2d26a28a
2 changed files with 24 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
jetlinks-components/network-component/tcp-component/pom.xml
View File

@ -36,6 +36,13 @@
<version>1.9</version>
</dependency>
<dependency>
<groupId>org.jetlinks.community</groupId>
<artifactId>script-component</artifactId>
<version>${project.version}</version>
<scope>compile</scope>
</dependency>
</dependencies>
</project>

35
jetlinks-components/network-component/tcp-component/src/main/java/org/jetlinks/community/network/tcp/parser/strateies/ScriptPayloadParserBuilder.java
View File

@ -8,6 +8,9 @@ import org.jetlinks.community.ValueObject;
import org.jetlinks.community.network.tcp.parser.PayloadParser;
import org.jetlinks.community.network.tcp.parser.PayloadParserBuilderStrategy;
import org.jetlinks.community.network.tcp.parser.PayloadParserType;
import org.jetlinks.community.script.CompiledScript;
import org.jetlinks.community.script.Script;
import org.jetlinks.community.script.Scripts;
import java.util.HashMap;
import java.util.Map;
@ -47,24 +50,20 @@ public class ScriptPayloadParserBuilder implements PayloadParserBuilderStrategy
String lang = config.getString("lang")
.orElseThrow(() -> new IllegalArgumentException("lang不能为空"));
DynamicScriptEngine engine = DynamicScriptEngineFactory.getEngine(lang);
if (engine == null) {
throw new IllegalArgumentException("不支持的脚本:" + lang);
}
String id = DigestUtils.md5Hex(script);
if (!engine.compiled(id)) {
engine.compile(id, script);
}
doCreateParser(id,engine);
return ()-> doCreateParser(id, engine);
CompiledScript compiledScript = Scripts
.getFactory(lang)
.compile(Script.of("tcp-network-payload-parser", script));
return () -> {
PipePayloadParser parser = new PipePayloadParser();
Map<String, Object> ctx = new HashMap<>();
ctx.put("parser", parser);
compiledScript.call(ctx);
return parser;
};
}
@SneakyThrows
private PipePayloadParser doCreateParser(String id,DynamicScriptEngine engine){
PipePayloadParser parser = new PipePayloadParser();
Map<String, Object> ctx = new HashMap<>();
ctx.put("parser", parser);
engine.execute(id, ctx).getIfSuccess();
return parser;
}
}