You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/06/06 02:51:06 UTC
[rocketmq] branch develop updated: [ISSUE #4323] Quickstart adds the default NamesrvAddr (#4322)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 9ca133a7d [ISSUE #4323] Quickstart adds the default NamesrvAddr (#4322)
9ca133a7d is described below
commit 9ca133a7d0059c9818fb0e6166fdcd4089189edb
Author: 李晓双 Li Xiao Shuang <64...@qq.com>
AuthorDate: Mon Jun 6 10:51:00 2022 +0800
[ISSUE #4323] Quickstart adds the default NamesrvAddr (#4322)
* Add the default NamesrvAddr
* Optimize the code
* Add comments
* Add comments
* update annotation
---
.../rocketmq/example/quickstart/Consumer.java | 24 ++++++++++------------
.../rocketmq/example/quickstart/Producer.java | 23 +++++++++++++++------
2 files changed, 28 insertions(+), 19 deletions(-)
diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java
index 07e572402..3f5232876 100644
--- a/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java
@@ -16,26 +16,27 @@
*/
package org.apache.rocketmq.example.quickstart;
-import java.util.List;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
-import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
-import org.apache.rocketmq.common.message.MessageExt;
/**
* This example shows how to subscribe and consume messages using providing {@link DefaultMQPushConsumer}.
*/
public class Consumer {
+ public static final String CONSUMER_GROUP = "please_rename_unique_group_name_4";
+ public static final String DEFAULT_NAMESRVADDR = "127.0.0.1:9876";
+ public static final String TOPIC = "TopicTest";
+
public static void main(String[] args) throws InterruptedException, MQClientException {
/*
* Instantiate with specified consumer group name.
*/
- DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_4");
+ DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(CONSUMER_GROUP);
/*
* Specify name server addresses.
@@ -48,6 +49,8 @@ public class Consumer {
* }
* </pre>
*/
+ // Uncomment the following line while debugging, namesrvAddr should be set to your local address
+// consumer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
/*
* Specify where to start in case the specific consumer group is a brand-new one.
@@ -57,19 +60,14 @@ public class Consumer {
/*
* Subscribe one more topic to consume.
*/
- consumer.subscribe("TopicTest", "*");
+ consumer.subscribe(TOPIC, "*");
/*
* Register callback to execute on arrival of messages fetched from brokers.
*/
- consumer.registerMessageListener(new MessageListenerConcurrently() {
-
- @Override
- public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs,
- ConsumeConcurrentlyContext context) {
- System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
- return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
- }
+ consumer.registerMessageListener((MessageListenerConcurrently) (msg, context) -> {
+ System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msg);
+ return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
});
/*
diff --git a/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java b/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java
index 771eea159..b2ea2a34f 100644
--- a/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java
+++ b/example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java
@@ -26,38 +26,49 @@ import org.apache.rocketmq.remoting.common.RemotingHelper;
* This class demonstrates how to send messages to brokers using provided {@link DefaultMQProducer}.
*/
public class Producer {
+
+ /**
+ * The number of produced messages.
+ */
+ public static final int MESSAGE_COUNT = 1000;
+ public static final String PRODUCER_GROUP = "please_rename_unique_group_name";
+ public static final String DEFAULT_NAMESRVADDR = "127.0.0.1:9876";
+ public static final String TOPIC = "TopicTest";
+ public static final String TAG = "TagA";
+
public static void main(String[] args) throws MQClientException, InterruptedException {
/*
* Instantiate with a producer group name.
*/
- DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");
+ DefaultMQProducer producer = new DefaultMQProducer(PRODUCER_GROUP);
/*
* Specify name server addresses.
- * <p/>
*
* Alternatively, you may specify name server addresses via exporting environmental variable: NAMESRV_ADDR
* <pre>
* {@code
- * producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876");
+ * producer.setNamesrvAddr("name-server1-ip:9876;name-server2-ip:9876");
* }
* </pre>
*/
+ // Uncomment the following line while debugging, namesrvAddr should be set to your local address
+// producer.setNamesrvAddr(DEFAULT_NAMESRVADDR);
/*
* Launch the instance.
*/
producer.start();
- for (int i = 0; i < 1000; i++) {
+ for (int i = 0; i < MESSAGE_COUNT; i++) {
try {
/*
* Create a message instance, specifying topic, tag and message body.
*/
- Message msg = new Message("TopicTest" /* Topic */,
- "TagA" /* Tag */,
+ Message msg = new Message(TOPIC /* Topic */,
+ TAG /* Tag */,
("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
);