add(API): 添加提出客户端接口

MrHKing · Jan 20, 2022 · 66c2b2c · 66c2b2c
1 parent 75181ca
commit 66c2b2c
Show file tree

Hide file tree

Showing 10 changed files with 22 additions and 3 deletions.
diff --git a/.idea/compiler.xml b/.idea/compiler.xml
diff --git a/mmq-web/src/main/java/org/monkey/mmq/web/controller/ApiController.java b/mmq-web/src/main/java/org/monkey/mmq/web/controller/ApiController.java
@@ -2,6 +2,7 @@
 
 import io.netty.util.internal.StringUtil;
 import org.monkey.mmq.core.consistency.model.ResponsePage;
+import org.monkey.mmq.core.consistency.model.RestResultUtils;
 import org.monkey.mmq.metadata.message.ClientMateData;
 import org.monkey.mmq.metadata.subscribe.SubscribeMateData;
 import org.monkey.mmq.service.SessionStoreService;
@@ -67,8 +68,18 @@ public Object getClients(@RequestParam int pageNo, @RequestParam int pageSize,
                 datas.size(),
                 datas.size() / pageSize,
                 datas.stream().filter(x -> x.getClientId().contains(clientId)
-                        && x.getAddress().contains(address) && x.getUser().equals(user))
+                        && x.getAddress().contains(address) && x.getUser().contains(user))
                         .skip((pageNo - 1) * pageSize).limit(pageSize).collect(Collectors.toList()));
     }
 
+    /**
+     * reject connect client.
+     */
+    @BasicApi
+    @GetMapping("/rejectClient")
+    public Object rejectClient(@RequestParam String clientId, HttpServletRequest request) {
+        sessionStoreService.rejectClient(clientId);
+        return RestResultUtils.success();
+    }
+
 }
diff --git a/work/Tomcat/localhost/ROOT/upload_05292e21_2a71_46d6_b121_0882c2a1c42a_00000000.tmp b/work/Tomcat/localhost/ROOT/upload_05292e21_2a71_46d6_b121_0882c2a1c42a_00000000.tmp
@@ -0,0 +1 @@
+1
diff --git a/work/Tomcat/localhost/ROOT/upload_05292e21_2a71_46d6_b121_0882c2a1c42a_00000001.tmp b/work/Tomcat/localhost/ROOT/upload_05292e21_2a71_46d6_b121_0882c2a1c42a_00000001.tmp
@@ -0,0 +1 @@
+10
diff --git a/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000001.tmp b/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000001.tmp
@@ -0,0 +1 @@
+paho1640921025845000001
diff --git a/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000002.tmp b/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000002.tmp
@@ -0,0 +1 @@
+paho1640921025845000001
diff --git a/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000003.tmp b/work/Tomcat/localhost/ROOT/upload_15d13a7b_1be2_4f8a_9950_5ec8ca58aea0_00000003.tmp
@@ -0,0 +1 @@
+paho1640921025845000001
diff --git a/work/Tomcat/localhost/ROOT/upload_98bb9a31_589f_4f58_9d02_9dea13a6b634_00000004.tmp b/work/Tomcat/localhost/ROOT/upload_98bb9a31_589f_4f58_9d02_9dea13a6b634_00000004.tmp
@@ -0,0 +1 @@
+1
diff --git a/work/Tomcat/localhost/ROOT/upload_98bb9a31_589f_4f58_9d02_9dea13a6b634_00000005.tmp b/work/Tomcat/localhost/ROOT/upload_98bb9a31_589f_4f58_9d02_9dea13a6b634_00000005.tmp
@@ -0,0 +1 @@
+10
diff --git a/work/Tomcat/localhost/ROOT/upload_99c060d3_6ed9_4ca3_ba74_5c2ce4c25a0f_00000000.tmp b/work/Tomcat/localhost/ROOT/upload_99c060d3_6ed9_4ca3_ba74_5c2ce4c25a0f_00000000.tmp
@@ -0,0 +1 @@
+paho1640921025845000001