灵活配置该应用 是否允许重复创建会话

common/src/main/java/com/wecloud/im/controller/ImConversationController.java

@@ -37,7 +37,7 @@ public class ImConversationController extends BaseController {
      * 创建会话
      */
     @PostMapping("/create")
-    @ApiOperation(value = "创建会话", notes = "两个用户如果已经创建过会话,不能重复创建会话")
+    @ApiOperation(value = "创建会话", notes = "后台可配置:两个客户端如果已经创建过会话,是否重复创建会话")
     public ApiResult<ImConversationCreateVo> createImConversation(@RequestBody ImConversationCreate imConversationCreate) throws Exception {
         ApiResult<ImConversationCreateVo> imConversation = imConversationService.createImConversation(imConversationCreate);
         return imConversation;
@@ -47,17 +47,17 @@ public class ImConversationController extends BaseController {
      * 查询用户加入的所有会话 与每个会话的未读条数 成员
      */
     @PostMapping("/getList")
-    @ApiOperation(value = "查询加入的会话列表", notes = "查询用户加入的会话列表 与每个会话的未读条数 成员")
+    @ApiOperation(value = "查询加入的会话列表", notes = "查询用户加入的非隐藏状态的会话列表 与每个会话的未读条数 成员")
     public ApiResult<List<MyConversationListVo>> getMyImConversationListAndMsgCount() throws Exception {
         List<MyConversationListVo> conversationList = imConversationService.getMyImConversationListAndMsgCount();
         return ApiResult.ok(conversationList);
     }
 
     /**
-     * 修改是否单向隐藏会话
+     * 修改单向隐藏或显示会话
      */
     @PostMapping("/displayUpdate")
-    @ApiOperation(value = "修改是否单向隐藏会话", notes = "云端聊天记录不删除;假设有A和B两个用户,A删会话,B还能发; 如果B发了消息,A这边要重新把会话显示出来,并能显示之前的聊天记录")
+    @ApiOperation(value = "修改单向隐藏或显示会话", notes = "拉取会话列表不展示已隐藏状态的会话,云端聊天记录不删除;假设有A和B两个用户,A删会话,B还能发; 如果B发了消息,A这边要重新把会话显示出来,并能显示之前的聊天记录")
     public ApiResult<Boolean> updateDisplayConversation(@RequestBody ImConversationDisplayUpdate imConversationDisplayUpdate) throws Exception {
         boolean flag = imConversationService.updateDisplayConversation(imConversationDisplayUpdate);
         return ApiResult.result(flag);

common/src/main/java/com/wecloud/im/netty/core/NettyStart.java

@@ -30,8 +30,13 @@ public class NettyStart {
         // 设置不延迟发送TCP_NODELAY=true
         serverBootstrap.childOption(ChannelOption.TCP_NODELAY, true);
 
-        // 初始化服务端可连接队列
-        serverBootstrap.option(ChannelOption.SO_BACKLOG, 1000);
+//        // 初始化服务端可连接队列
+//        serverBootstrap.option(ChannelOption.SO_BACKLOG, 1000);
+
+//        //read缓存区 256k
+//        serverBootstrap.option(ChannelOption.SO_RCVBUF, 256 * 1024);
+//        // write缓存区 256k
+//        serverBootstrap.option(ChannelOption.SO_SNDBUF, 256 * 1024);
 
         // 配置io模型为nio非阻塞
         serverBootstrap.channel(NioServerSocketChannel.class);