转换了接口返回格式

smqtt-core/src/main/java/io/github/quickmsg/core/http/acl/AclQueryPolicyActor.java

@@ -16,6 +16,10 @@ import reactor.netty.http.server.HttpServerRequest;
 import reactor.netty.http.server.HttpServerResponse;
 
 import java.nio.charset.StandardCharsets;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * @author luxurong
@@ -29,14 +33,16 @@ public class AclQueryPolicyActor extends AbstractHttpActor {
 
     @Override
     public Publisher<Void> doRequest(HttpServerRequest request, HttpServerResponse response, Configuration configuration) {
-        return request
-                .receive()
-                .asString(StandardCharsets.UTF_8)
-                .map(this.toJson(PolicyModel.class))
-                .doOnNext(policyModel ->
-                        response.sendString(Mono.just(JacksonUtil.bean2Json(ContextHolder.getReceiveContext().getAclManager().get(policyModel)))).then().subscribe()
-                )
-                .then();
+        return request.receive().asString(StandardCharsets.UTF_8).map(this.toJson(PolicyModel.class)).doOnNext(policyModel -> {
+            List<Map<String, Object>> collect = ContextHolder.getReceiveContext().getAclManager().get(policyModel).stream().map(item -> {
+                Map<String, Object> map = new HashMap<>();
+                map.put("subject", item.size() >= 3 ? item.get(0) : null);
+                map.put("source", item.size() >= 3 ? item.get(1) : null);
+                map.put("action", item.size() >= 3 ? item.get(2) : null);
+                return map;
+            }).collect(Collectors.toList());
+            response.sendString(Mono.just(JacksonUtil.bean2Json(collect))).then().subscribe();
+        }).then();
     }
 
 }