Browse Source

fix 权限

18339543638 3 years ago
parent
commit
c6a15aad2a

+ 2 - 1
nb-common/ws-common/src/main/java/com/nb/common/websocket/filter/DefaultPubMsgFilter.java

@@ -1,6 +1,7 @@
 package com.nb.common.websocket.filter;
 package com.nb.common.websocket.filter;
 
 
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONUtil;
 import cn.hutool.json.JSONUtil;
 import com.nb.common.websocket.msg.MessagingRequest;
 import com.nb.common.websocket.msg.MessagingRequest;
 import com.nb.common.websocket.PubResponse;
 import com.nb.common.websocket.PubResponse;
@@ -21,7 +22,7 @@ import org.tio.websocket.common.WsResponse;
 public class DefaultPubMsgFilter implements PubMsgFilter {
 public class DefaultPubMsgFilter implements PubMsgFilter {
     @Override
     @Override
     public boolean doFilter(ChannelContext channelContext, MessagingRequest source) {
     public boolean doFilter(ChannelContext channelContext, MessagingRequest source) {
-        if(source.getKey()!=null){
+        if(StrUtil.isBlank(source.getKey())){
             Tio.send(channelContext, WsResponse.fromText(JSONUtil.toJsonStr(PubResponse.fail("","发布消息时key不能为空")), WsPacket.CHARSET_NAME));
             Tio.send(channelContext, WsResponse.fromText(JSONUtil.toJsonStr(PubResponse.fail("","发布消息时key不能为空")), WsPacket.CHARSET_NAME));
             return false;
             return false;
         }
         }