修复mq同步不成功的问题

src/main/java/cn/qg/holmes/service/k8s/MqService.java

@@ -43,11 +43,12 @@ public class MqService {
             List<Map<String, String>> qaPermissionList = new ArrayList<>();
             for (Map<String, String> permission : permissionList) {
                 if (permission.get("user").equals("rabbit_admin")) {
-                    qaPermissionList.add(permission);
+                    Map<String, String> temp = new HashMap<>();
+                    temp.putAll(permission);
+                    qaPermissionList.add(temp);
                     permission.put("user", "qa");
                     qaPermissionList.add(permission);
-                }
-                if (!permission.get("user").equals("qa") && !permission.get("user").equals("rabbit_admin")) {
+                } else if (!permission.get("user").equals("qa") && !permission.get("user").equals("rabbit_admin")) {
                     qaPermissionList.add(permission);
                 }
             }
@@ -134,6 +135,6 @@ public class MqService {
 
     public static void main(String[] args) {
         MqService mqService = new MqService();
-        mqService.setDefinitions("172.17.5.17:31426");
+        mqService.setDefinitions("172.17.5.46:32419");
     }
 }

src/main/java/cn/qg/holmes/utils/HttpClientUtils.java

@@ -171,7 +171,7 @@ public class HttpClientUtils {
     public static String doPostJson(String url, Map<String, String> headers, String json) {
         CloseableHttpClient httpClient = HttpClients.createDefault();
         CloseableHttpResponse httpResponse = null;
-        String resultString = "";
+        String resultString = null;
         try {
             // 创建Http Post请求
             HttpPost httpPost = new HttpPost(url);
@@ -183,7 +183,9 @@ public class HttpClientUtils {
             setHeader(headers, httpPost);
 
             httpResponse = httpClient.execute(httpPost);
+            if (httpResponse.getEntity() != null) {
                 resultString = EntityUtils.toString(httpResponse.getEntity(), ENCODING);
+            }
         } catch (Exception e) {
             e.printStackTrace();
         } finally {