diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java
index 890c6f21..046f3a33 100644
--- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java
+++ b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java
@@ -51,9 +51,9 @@ public class RocketMQClientTemplate extends AbstractMessageSendingTemplate<Strin
 
     private SimpleConsumerBuilder simpleConsumerBuilder;
 
-    private Producer producer;
+    private volatile Producer producer;
 
-    private SimpleConsumer simpleConsumer;
+    private volatile SimpleConsumer simpleConsumer;
 
     private RocketMQMessageConverter rocketMQMessageConverter = new RocketMQMessageConverter();
 
@@ -61,10 +61,14 @@ public class RocketMQClientTemplate extends AbstractMessageSendingTemplate<Strin
 
     public Producer getProducer() {
         if (Objects.isNull(producer)) {
-            try {
-                return producerBuilder.build();
-            } catch (ClientException e) {
-                throw new RuntimeException(e);
+            synchronized (RocketMQClientTemplate.class) {
+                if (Objects.isNull(producer)) {
+                    try {
+                        this.producer =  producerBuilder.build();
+                    } catch (ClientException e) {
+                        throw new RuntimeException(e);
+                    }
+                }
             }
         }
         return producer;
@@ -77,10 +81,14 @@ public void setProducer(Producer producer) {
 
     public SimpleConsumer getSimpleConsumer() {
         if (Objects.isNull(simpleConsumer)) {
-            try {
-                return simpleConsumerBuilder.build();
-            } catch (ClientException e) {
-                throw new RuntimeException(e);
+            synchronized (RocketMQClientTemplate.class) {
+                if (Objects.isNull(simpleConsumer)) {
+                    try {
+                        this.simpleConsumer = simpleConsumerBuilder.build();
+                    } catch (ClientException e) {
+                        throw new RuntimeException(e);
+                    }
+                }
             }
         }
         return simpleConsumer;