opt;

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/MqHandleUtil.java

@@ -32,7 +32,7 @@ public class MqHandleUtil {
      */
     public boolean sendNotifyErrorQueue(PayNotifyReqBo payNotifyReqBo,String queueKey) {
         try {
-            HashMap<String, String> map = ObjectUtil.hashMapStringAndString;
+            HashMap<String, String> map = ObjectUtil.cloneHashMapStringAndString();
             map.put("message", payNotifyReqBo.toString());
             MapRecord<String, String, String> record = StreamRecords.mapBacked(map).withStreamKey(queueKey);
             stringRedisTemplate.opsForStream().add(record);

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/src/main/java/com/liquidnet/service/dragon/utils/ObjectUtil.java

@@ -4,10 +4,7 @@ import com.alibaba.fastjson.JSONObject;
 import com.alipay.api.request.AlipayTradeWapPayRequest;
 import org.springframework.stereotype.Component;
 
-import java.util.HashMap;
-import java.util.LinkedList;
-import java.util.SortedMap;
-import java.util.TreeMap;
+import java.util.*;
 
 /**
  * @author AnJiabin <anjiabin@zhengzai.tv>
@@ -20,31 +17,22 @@ import java.util.TreeMap;
  */
 @Component
 public class ObjectUtil {
-    public static final LinkedList<Object[]> linkedListObj = new LinkedList<Object[]>();
-    public static final LinkedList<String> linkedListStr = new LinkedList<String>();
-    public static final HashMap<String, String> hashMapStringAndString = new HashMap<>();
-    public static final SortedMap<String, Object> sortedMapStringAndObj = new TreeMap<>();
-    public static final AlipayTradeWapPayRequest alipayTradeWapPayRequest = new AlipayTradeWapPayRequest();
-    public static final JSONObject jsonObjectObj = new JSONObject();
+    private static final LinkedList<Object[]> linkedListObj = new LinkedList<Object[]>();
+    private static final LinkedList<String> linkedListStr = new LinkedList<String>();
+    private static final HashMap<String, String> hashMapStringAndString = new HashMap<>();
+    private static final AlipayTradeWapPayRequest alipayTradeWapPayRequest = new AlipayTradeWapPayRequest();
+    private static final JSONObject jsonObjectObj = new JSONObject();
 
     public static LinkedList<Object[]> cloneLinkedListObj() {
-        linkedListObj.clear();
-        return linkedListObj;
+        return (LinkedList<Object[]>) linkedListObj.clone();
     }
 
     public static LinkedList<String> cloneLinkedListStr() {
-        linkedListStr.clear();
-        return linkedListStr;
+        return (LinkedList<String>) linkedListStr.clone();
     }
 
     public static HashMap<String, String> cloneHashMapStringAndString() {
-        hashMapStringAndString.clear();
-        return hashMapStringAndString;
-    }
-
-    public static SortedMap<String, Object> cloneSortedMapStringAndObj() {
-        sortedMapStringAndObj.clear();
-        return sortedMapStringAndObj;
+        return (HashMap<String, String>) hashMapStringAndString.clone();
     }
 
     public static AlipayTradeWapPayRequest cloneAlipayTradeWapPayRequest() {
@@ -52,6 +40,6 @@ public class ObjectUtil {
     }
 
     public static JSONObject cloneJsonObjectObj() {
-        return jsonObjectObj;
+        return (JSONObject) jsonObjectObj.clone();
     }
 }