fix:发送消息

rocketmq-demo/pom.xml

@@ -18,6 +18,11 @@
             <artifactId>rocketmq-client</artifactId>
             <version>4.8.0</version>
         </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <version>1.18.6</version>
+        </dependency>
     </dependencies>
 
 </project>
\ No newline at end of file

rocketmq-demo/shuyu.iml

@@ -24,5 +24,6 @@
     <orderEntry type="library" name="Maven: commons-logging:commons-logging:1.2" level="project" />
     <orderEntry type="library" name="Maven: commons-collections:commons-collections:3.2.2" level="project" />
     <orderEntry type="library" name="Maven: org.apache.commons:commons-lang3:3.4" level="project" />
+    <orderEntry type="library" name="Maven: org.projectlombok:lombok:1.18.6" level="project" />
   </component>
 </module>
\ No newline at end of file

rocketmq-demo/src/main/java/base/consumer/Consumer.java

@@ -22,6 +22,7 @@ public class Consumer {
         DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1");
         //2.指定Nameserver地址
         consumer.setNamesrvAddr("47.119.161.70:9876;47.119.163.226:9876");
+        consumer.setVipChannelEnabled(false);
         //3.订阅主题Topic和Tag
         consumer.subscribe("base", "*");
         //设定消费模式：负载均衡|广播模式

rocketmq-demo/src/main/java/base/producer/AsyncProducer.java

@@ -16,6 +16,7 @@ public class AsyncProducer {
         DefaultMQProducer producer = new DefaultMQProducer("group1");
         //2.指定Nameserver地址
         producer.setNamesrvAddr("47.119.161.70:9876;47.119.163.226:9876");
+        producer.setSendMessageWithVIPChannel(false);
         //3.启动producer
         producer.start();
         for (int i = 0; i < 10; i++) {

rocketmq-demo/src/main/java/base/producer/OneWayProducer.java

 package base.producer;
-
 import org.apache.rocketmq.client.exception.MQBrokerException;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.common.message.Message;
-
 import java.util.concurrent.TimeUnit;
-
 /**
  * 发送单向消息
  */
 public class OneWayProducer {
-
     public static void main(String[] args) throws Exception, MQBrokerException {
         //1.创建消息生产者producer，并制定生产者组名
         DefaultMQProducer producer = new DefaultMQProducer("group1");
         //2.指定Nameserver地址
         producer.setNamesrvAddr("47.119.161.70:9876;47.119.163.226:9876");
+        producer.setSendMessageWithVIPChannel(false);
         //3.启动producer
         producer.start();
-
         for (int i = 0; i < 3; i++) {
             //4.创建消息对象，指定主题Topic、Tag和消息体
             /**
@@ -29,12 +25,10 @@ public class OneWayProducer {
             Message msg = new Message("base", "Tag3", ("Hello World，单向消息" + i).getBytes());
             //5.发送单向消息
             producer.sendOneway(msg);
-
             //线程睡1秒
             TimeUnit.SECONDS.sleep(5);
         }
-
         //6.关闭生产者producer
         producer.shutdown();
     }
-}
+}
\ No newline at end of file

rocketmq-demo/src/main/java/base/producer/SyncProducer.java

@@ -17,6 +17,7 @@ public class SyncProducer {
         DefaultMQProducer producer = new DefaultMQProducer("group1");
         //2.指定Nameserver地址
         producer.setNamesrvAddr("47.119.161.70:9876;47.119.163.226:9876");
+        producer.setSendMessageWithVIPChannel(false);
         //3.启动producer
         producer.start();
 

springboot-rocketmq-consumer/target/classes/application.properties

-rocketmq.name-server=192.168.25.135:9876;192.168.25.138:9876
+rocketmq.name-server=47.119.161.70:9876;47.119.163.226:9876
 rocketmq.producer.group=my-group
\ No newline at end of file

springboot-rocketmq-producer/target/classes/application.properties

-rocketmq.name-server=192.168.25.135:9876;192.168.25.138:9876
+rocketmq.name-server=47.119.161.70:9876;47.119.163.226:9876
 rocketmq.producer.group=my-group
\ No newline at end of file