bugfix

src/main/java/com/caimei365/tools/listener/IpSaveListener.java

@@ -42,33 +42,36 @@ public class IpSaveListener implements RocketMQListener<String> {
         log.info("{}收到消息：{}", this.getClass().getSimpleName(), message);
         String[] params = message.split("￥");
         //ip,接口路径，接口参数，注解名
-        String ip=params[0];
-        String path=params[1];
-        String param=params[2];
-        String saveName=params[3];
+        String ip = params[0];
+        String path = params[1];
+        String param = params[2];
+        String saveName = params[3];
         IpSavePo ipSavePo = new IpSavePo();
-        if(StringUtils.isNotBlank(param)){
+        if (StringUtils.isNotBlank(param)) {
             ipSavePo.setParams(param);
-            if(param.contains("userId")){
+            if (param.contains("userId")) {
                 String[] split = param.split("&");
                 for (String s : split) {
-                    if(s.contains("userId")&&s.contains("=")){
-                        String value = s.split("=")[1];
-                        String trim = value.trim();
-                        if(StringUtils.isNotBlank(trim)){
-                            ipSavePo.setUserId(trim);
+                    if (s.contains("userId") && s.contains("=")) {
+                        String[] split1 = s.split("=");
+                        if (split1.length > 2) {
+                            String value = split1[1];
+                            String trim = value.trim();
+                            if (StringUtils.isNotBlank(trim)) {
+                                ipSavePo.setUserId(trim);
+                            }
                         }
                     }
                 }
             }
         }
-        if(StringUtils.isNotBlank(path)){
+        if (StringUtils.isNotBlank(path)) {
             ipSavePo.setRequestUrl(path);
         }
-        if(StringUtils.isNotBlank(saveName)){
+        if (StringUtils.isNotBlank(saveName)) {
             ipSavePo.setPortName(saveName);
         }
-        if(StringUtils.isNotBlank(ip)){
+        if (StringUtils.isNotBlank(ip)) {
             ipSavePo.setIp(ip);
         }
         ipSavePo.setSaveTime(new Date());