diff --git a/rocketmq-demo/pom.xml b/rocketmq-demo/pom.xml index 5554ad33e5500f8e7013d89a4d606ce5bf9271fa..8c60a288133cca2261fbdd61ebd0bfa2a993bda5 100644 --- a/rocketmq-demo/pom.xml +++ b/rocketmq-demo/pom.xml @@ -18,6 +18,11 @@ rocketmq-client 4.8.0 + + org.projectlombok + lombok + 1.18.6 + \ No newline at end of file diff --git a/rocketmq-demo/shuyu.iml b/rocketmq-demo/shuyu.iml index a945e9026e839d67e75ddb6e84fa774f126494f8..596b1b4a1999e6b2b1c70ecdb2745d36c883ee0b 100644 --- a/rocketmq-demo/shuyu.iml +++ b/rocketmq-demo/shuyu.iml @@ -24,5 +24,6 @@ + \ No newline at end of file diff --git a/rocketmq-demo/src/main/java/base/consumer/Consumer.java b/rocketmq-demo/src/main/java/base/consumer/Consumer.java index 2ac732bbaed9f264009afd8a194a3906b3378b61..9cb3606c738c2b28344765f86963638b53a28ade 100644 --- a/rocketmq-demo/src/main/java/base/consumer/Consumer.java +++ b/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", "*"); //设定消费模式：负载均衡|广播模式 diff --git a/rocketmq-demo/src/main/java/base/producer/AsyncProducer.java b/rocketmq-demo/src/main/java/base/producer/AsyncProducer.java index f5f2a335666a394747025b035d3ea19b959cfd9c..e9d348b360ebd12c1ccb8a1092a6620178144dcf 100644 --- a/rocketmq-demo/src/main/java/base/producer/AsyncProducer.java +++ b/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++) { diff --git a/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java b/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java index 30c0dce36d93969a2d63a837c50c4bb9db619fc6..d8903694e0079e2ac9860f0d84505db83e729259 100644 --- a/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java +++ b/rocketmq-demo/src/main/java/base/producer/OneWayProducer.java @@ -1,24 +1,20 @@ 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 diff --git a/rocketmq-demo/src/main/java/base/producer/SyncProducer.java b/rocketmq-demo/src/main/java/base/producer/SyncProducer.java index 4ef4c61aa7da746b819e7a757cc5e3de08848b02..f44a46e2b7db6ce52c72565cd48061dacd83c807 100644 --- a/rocketmq-demo/src/main/java/base/producer/SyncProducer.java +++ b/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(); diff --git a/springboot-rocketmq-consumer/target/classes/application.properties b/springboot-rocketmq-consumer/target/classes/application.properties index 915193351dce7e258ee7fd3929f8fea2bd6b926f..0fc21b3b9bc721dd1d678c0a14af83eba74dc8cf 100644 --- a/springboot-rocketmq-consumer/target/classes/application.properties +++ b/springboot-rocketmq-consumer/target/classes/application.properties @@ -1,2 +1,2 @@ -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 diff --git a/springboot-rocketmq-consumer/target/classes/cn/itcast/MQSpringBootApplication.class b/springboot-rocketmq-consumer/target/classes/cn/itcast/MQSpringBootApplication.class index 761d81d5530b345903fd04c847a526faad314b33..5f7d0fe06d14460984cf50f5cfa407bcfc4d29d8 100644 Binary files a/springboot-rocketmq-consumer/target/classes/cn/itcast/MQSpringBootApplication.class and b/springboot-rocketmq-consumer/target/classes/cn/itcast/MQSpringBootApplication.class differ diff --git a/springboot-rocketmq-consumer/target/classes/cn/itcast/mq/Consumer.class b/springboot-rocketmq-consumer/target/classes/cn/itcast/mq/Consumer.class index f13f02d4b95321ab7a5301d1852b17b00e663bcd..051aebccbb7f4b0bb1a1f1ca9d95634ea52b132d 100644 Binary files a/springboot-rocketmq-consumer/target/classes/cn/itcast/mq/Consumer.class and b/springboot-rocketmq-consumer/target/classes/cn/itcast/mq/Consumer.class differ diff --git a/springboot-rocketmq-producer/target/classes/application.properties b/springboot-rocketmq-producer/target/classes/application.properties index 915193351dce7e258ee7fd3929f8fea2bd6b926f..0fc21b3b9bc721dd1d678c0a14af83eba74dc8cf 100644 --- a/springboot-rocketmq-producer/target/classes/application.properties +++ b/springboot-rocketmq-producer/target/classes/application.properties @@ -1,2 +1,2 @@ -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 diff --git a/springboot-rocketmq-producer/target/classes/cn/itcast/MQSpringBootApplication.class b/springboot-rocketmq-producer/target/classes/cn/itcast/MQSpringBootApplication.class index cdc35793bd053ab1497343a49df9c187024a8125..b35176b4bc1e2dc49a6af7abc64489abbb9ae825 100644 Binary files a/springboot-rocketmq-producer/target/classes/cn/itcast/MQSpringBootApplication.class and b/springboot-rocketmq-producer/target/classes/cn/itcast/MQSpringBootApplication.class differ diff --git a/springboot-rocketmq-producer/target/classes/cn/itcast/mq/Producer.class b/springboot-rocketmq-producer/target/classes/cn/itcast/mq/Producer.class deleted file mode 100644 index a1e7de162a57b850a7bb6cd8dfc784d3141978c7..0000000000000000000000000000000000000000 Binary files a/springboot-rocketmq-producer/target/classes/cn/itcast/mq/Producer.class and /dev/null differ