diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ConsumerFactoryBean.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ConsumerFactoryBean.java
index e8450e439ebdeb4da9f417499290c72deb876647..951053291a34bf3a907e31acde544d927e3249e3 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ConsumerFactoryBean.java
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ConsumerFactoryBean.java
@@ -11,6 +11,8 @@ public class ConsumerFactoryBean implements FactoryBean<DefaultMQPushConsumer>,I
 
     private DefaultMQPushConsumer consumer;
 
+    private String instanceName; // 不同集群不同值
+
     private String consumerGroup;
 
     private String namesrvAddr;
@@ -21,6 +23,10 @@ public class ConsumerFactoryBean implements FactoryBean<DefaultMQPushConsumer>,I
 
     private MessageListenerConcurrently messageListener;
 
+    public void setInstanceName(String instanceName) {
+        this.instanceName = instanceName;
+    }
+
     public void setConsumerGroup(String consumerGroup) {
         this.consumerGroup = consumerGroup;
     }
@@ -59,6 +65,7 @@ public class ConsumerFactoryBean implements FactoryBean<DefaultMQPushConsumer>,I
     @Override
     public void afterPropertiesSet() throws Exception {
         consumer = new DefaultMQPushConsumer(consumerGroup);
+        consumer.setInstanceName(instanceName);
         consumer.setNamesrvAddr(namesrvAddr);
         consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.subscribe(topic, tags);
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ProducerFactoryBean.java b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ProducerFactoryBean.java
index 250409930e62e365e4b01329ee508cf9785bfb52..0649142687a19542b87a36cfbdb95184229d8588 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ProducerFactoryBean.java
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/java/org/hongxi/whatsmars/mq/rocketmq/spring/ProducerFactoryBean.java
@@ -9,10 +9,16 @@ public class ProducerFactoryBean implements FactoryBean<DefaultMQProducer>,Initi
 
     private DefaultMQProducer producer;
 
+    private String instanceName; // 不同集群不同值
+
     private String producerGroup;
 
     private String namesrvAddr;
 
+    public void setInstanceName(String instanceName) {
+        this.instanceName = instanceName;
+    }
+
     public void setProducerGroup(String producerGroup) {
         this.producerGroup = producerGroup;
     }
@@ -39,6 +45,7 @@ public class ProducerFactoryBean implements FactoryBean<DefaultMQProducer>,Initi
     @Override
     public void afterPropertiesSet() throws Exception {
         producer = new DefaultMQProducer(producerGroup);
+        producer.setInstanceName(instanceName);
         producer.setNamesrvAddr(namesrvAddr);
         producer.start();
     }
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
index 95da05ad4895e12ed66ea6b9172962299d4700ed..2801cee65a8213b891d453289c160df8317c2a20 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-consumer.xml
@@ -6,6 +6,7 @@
        default-autowire="byName">
 
     <bean class="org.hongxi.whatsmars.mq.rocketmq.spring.ConsumerFactoryBean">
+        <property name="instanceName" value="DEFAULT" />
         <property name="consumerGroup" value="quick_start_consumer_group" />
         <property name="namesrvAddr" value="127.0.0.1:9876" />
         <property name="topic" value="TopicTest" />
diff --git a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml
index 9137e518bd231e2b3279195cb7d61e1801188c8f..350addcb9b1380714731ce6f0bc7b253f73510a8 100644
--- a/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml
+++ b/whatsmars-mq/whatsmars-mq-rocketmq/src/main/resources/spring/rocketmq-producer.xml
@@ -6,6 +6,7 @@
        default-autowire="byName">
 
     <bean id="defaultMQProducer" class="org.hongxi.whatsmars.mq.rocketmq.spring.ProducerFactoryBean">
+        <property name="instanceName" value="DEFAULT" />
         <property name="producerGroup" value="quick_start_producer_group" />
         <property name="namesrvAddr" value="127.0.0.1:9876" />
     </bean>