🚧 work in propress for rule engine about thingsboard

Author: sanshengshui

IOT-Guide-RateLimiting/src/main/java/iot/technology/ratelimiting/config/AppConfig.java

@@ -29,5 +29,29 @@
     <groupId>iot.technology</groupId>
     <artifactId>IOT-Guide-RuleEngine-ThingsBoard</artifactId>
 
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+            <scope>provided</scope>
+        </dependency>
+        <dependency>
+            <groupId>iot.technology</groupId>
+            <artifactId>IOT-Guide-Actor</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>${spring-boot.version}</version>
+            </plugin>
+        </plugins>
+    </build>
+
+
 
 </project>

IOT-Guide-RuleEngine-ThingsBoard/pom.xml

@@ -0,0 +1,34 @@
+create table if not exists relation
+(
+    from_id bigint null comment '源',
+    from_type varchar(255) null comment '"源"类型',
+    to_id bigint null comment '目标',
+    to_type varchar(255) null comment '目标类型',
+    relation_type_group varchar(255) null,
+    relation_type varchar(255) null
+) comment '关系表';
+
+create table if not exists rule_chain
+(
+    id bigint auto_increment
+        primary key,
+    create_time bigint null comment '创建时间',
+    name varchar(255) null,
+    type varchar(255) null,
+    first_rule_node_id bigint null
+) comment '规则链';
+
+create table if not exists rule_node
+(
+    id bigint not null
+        primary key,
+    rule_chain_id bigint not null comment '规则链编号',
+    configuration varchar(10000) null comment '配置项',
+    type varchar(255) null comment '类型',
+    name varchar(255) null comment '名称',
+    create_time bigint null comment '创建时间'
+) comment '规则点';
+
+
+
+

IOT-Guide-RuleEngine-ThingsBoard/src/main/data/sql/schema-entities.sql

@@ -1,4 +1,4 @@
-package iot.technology.thingsboard;
+package iot.technology.thingsboard.ruleengine;
 
 /**
  * @author james mu

…gsboard/RuleEngineThingsBoardServer.java …eengine/RuleEngineThingsBoardServer.javaIOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/RuleEngineThingsBoardServer.java renamed to IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/RuleEngineThingsBoardServer.java IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/RuleEngineThingsBoardServer.java renamed to IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/RuleEngineThingsBoardServer.java

@@ -0,0 +1,21 @@
+package iot.technology.thingsboard.ruleengine.common;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.ForkJoinPool;
+
+/**
+ * @author mushuwei
+ */
+public class ActorExecutors {
+
+    public static ExecutorService newWorkStealingPool(int parallelism, String namePrefix) {
+        return new ForkJoinPool(parallelism,
+                new ActorForkJoinWorkerThreadFactory(namePrefix),
+                null, true);
+    }
+
+    private static ExecutorService newWorkStealingPool(int parallelism, Class clazz) {
+        return newWorkStealingPool(parallelism, clazz.getSimpleName());
+
+    }
+}

IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/common/ActorExecutors.java

@@ -0,0 +1,29 @@
+package iot.technology.thingsboard.ruleengine.common;
+
+import lombok.NonNull;
+import lombok.ToString;
+
+import java.util.concurrent.ForkJoinPool;
+import java.util.concurrent.ForkJoinWorkerThread;
+import java.util.concurrent.atomic.AtomicLong;
+
+/**
+ * @author mushuwei
+ */
+@ToString
+public class ActorForkJoinWorkerThreadFactory implements ForkJoinPool.ForkJoinWorkerThreadFactory {
+
+    private final String namePrefix;
+    private final AtomicLong threadNumber = new AtomicLong(1);
+
+    public ActorForkJoinWorkerThreadFactory(@NonNull String namePrefix) {
+        this.namePrefix = namePrefix;
+    }
+
+    @Override
+    public ForkJoinWorkerThread newThread(ForkJoinPool pool) {
+        ForkJoinWorkerThread thread = ForkJoinPool.defaultForkJoinWorkerThreadFactory.newThread(pool);
+        thread.setName(namePrefix + "-" + thread.getPoolIndex() + "-" + threadNumber.getAndIncrement());
+        return thread;
+    }
+}

IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/common/ActorForkJoinWorkerThreadFactory.java

@@ -0,0 +1,7 @@
+package iot.technology.thingsboard.ruleengine.service;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorService {
+}

IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/service/ActorService.java

@@ -0,0 +1,21 @@
+package iot.technology.thingsboard.ruleengine.service;
+
+import iot.technology.actor.ActorSystem;
+import iot.technology.actor.core.ActorRef;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author mushuwei
+ */
+@Service
+@Slf4j
+public class ActorSystemContext {
+
+    private ActorSystem system;
+
+    private ActorRef appActor;
+
+    private int actorThroughput;
+
+}

IOT-Guide-RuleEngine-ThingsBoard/src/main/java/iot/technology/thingsboard/ruleengine/service/ActorSystemContext.java

@@ -0,0 +1,30 @@
+package iot.technology.thingsboard.ruleengine.service;
+
+import iot.technology.actor.common.ActorThreadFactory;
+import iot.technology.thingsboard.ruleengine.common.ActorExecutors;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+/**
+ * @author mushuwei
+ */
+@Service
+@Slf4j
+public class DefaultActorService implements ActorService {
+    
+
+    private ExecutorService initDispatcherExecutor(String dispatcherName, int poolSize) {
+        if (poolSize == 0) {
+            int cores = Runtime.getRuntime().availableProcessors();
+            poolSize = Math.max(1, cores / 2);
+        }
+        if (poolSize == 1) {
+            return Executors.newSingleThreadExecutor(ActorThreadFactory.forName(dispatcherName));
+        } else {
+            return ActorExecutors.newWorkStealingPool(poolSize, dispatcherName);
+        }
+    }
+}