add 规则引擎集群

jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/cluster/ClusterDeviceMessageConnector.java

@@ -79,6 +79,11 @@ public class ClusterDeviceMessageConnector extends DeviceMessageConnector {
                             Object obj = message.getMessage();
                             if(obj instanceof ClusterMessage){
                                 msg= (ClusterMessage) obj;
+                                String fromServer = msg.getFromServer();
+                                if(this.serverId.equals(fromServer)){
+                                    //消息消费者排除自身
+                                    return Mono.empty();
+                                }
                             }
                             if(msg==null){
                                 return Mono.empty();