✨ add module actor

Author: sanshengshui

IOT-Guide-Actor/pom.xml

@@ -0,0 +1,19 @@
+<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>IOT-Guide</artifactId>
+        <groupId>iot.technology</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>IOT-Guide-Actor</artifactId>
+
+    <properties>
+        <maven.compiler.source>8</maven.compiler.source>
+        <maven.compiler.target>8</maven.compiler.target>
+    </properties>
+
+</project>

IOT-Guide-Actor/src/main/java/iot/technology/actor/Actor.java

@@ -0,0 +1,30 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface Actor {
+
+    boolean process(ActorMsg msg);
+
+    ActorRef getActorRef();
+
+    default void init() throws ActorException {
+    }
+
+    default void destroy() throws ActorException {
+    }
+
+    default InitFailureStrategy onInitFailure(int attempt, Throwable t) {
+        return InitFailureStrategy.retryWithDelay(5000L * attempt);
+    }
+
+    default ProcessFailureStrategy onProcessFailure(Throwable t) {
+        if (t instanceof Error) {
+            return ProcessFailureStrategy.stop();
+        } else {
+            return ProcessFailureStrategy.resume();
+        }
+    }
+}
+

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorCreator.java

@@ -0,0 +1,11 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorCreator {
+
+    ActorId createActorId();
+
+    Actor createActor();
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorCtx.java

@@ -0,0 +1,27 @@
+package iot.technology.actor;
+
+import java.util.List;
+import java.util.function.Predicate;
+import java.util.function.Supplier;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorCtx extends ActorRef {
+
+    ActorId getSelf();
+
+    ActorRef getParentRef();
+
+    void tell(ActorId target, ActorMsg msg);
+
+    void stop(ActorId target);
+
+    ActorRef getOrCreateChildActor(ActorId actorId, Supplier<String> dispatcher, Supplier<ActorCreator> creator);
+
+    void broadcastToChildren(ActorMsg msg);
+
+    void broadcastToChildren(ActorMsg msg, Predicate<ActorId> childFilter);
+
+    List<ActorId> filterChildren(Predicate<ActorId> childFilter);
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorException.java

@@ -0,0 +1,13 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public class ActorException extends Exception {
+
+    public static final long serialVersionUID = 8209771144711980882L;
+
+    public ActorException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorId.java

@@ -0,0 +1,7 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorId {
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorMsg.java

@@ -0,0 +1,7 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorMsg {
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorRef.java

@@ -0,0 +1,13 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorRef {
+
+    ActorId getActorId();
+
+    void tell(ActorMsg actorMsg);
+
+    void tellWithHighPriority(ActorMsg actorMsg);
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/ActorSystem.java

@@ -0,0 +1,7 @@
+package iot.technology.actor;
+
+/**
+ * @author mushuwei
+ */
+public interface ActorSystem {
+}

IOT-Guide-Actor/src/main/java/iot/technology/actor/InitFailureStrategy.java

@@ -0,0 +1,32 @@
+package iot.technology.actor;
+
+import lombok.Getter;
+import lombok.ToString;
+
+/**
+ * @author mushuwei
+ */
+@ToString
+public class InitFailureStrategy {
+    @Getter
+    private boolean stop;
+    @Getter
+    private long retryDelay;
+
+    private InitFailureStrategy(boolean stop, long retryDelay) {
+        this.stop = stop;
+        this.retryDelay = retryDelay;
+    }
+
+    public static InitFailureStrategy retryImmediately() {
+        return new InitFailureStrategy(false, 0);
+    }
+
+    public static InitFailureStrategy retryWithDelay(long ms) {
+        return new InitFailureStrategy(false, ms);
+    }
+
+    public static InitFailureStrategy stop() {
+        return new InitFailureStrategy(true, 0);
+    }
+}