This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git
The following commit(s) were added to refs/heads/new-official-website by this
push:
new e8f4fa5c9 [ISSUE #317]Polish en documents format (#318)
e8f4fa5c9 is described below
commit e8f4fa5c9575ca98a5435dc5bf6d0d1302906e55
Author: mxsm <[email protected]>
AuthorDate: Thu Oct 13 10:04:09 2022 +0800
[ISSUE #317]Polish en documents format (#318)
---
.../02quickstart.md" | 187 +++++++++++----------
1 file changed, 94 insertions(+), 93 deletions(-)
diff --git
"a/i18n/en/docusaurus-plugin-content-docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
"b/i18n/en/docusaurus-plugin-content-docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
index a9df9a09d..c37ca6d4d 100644
---
"a/i18n/en/docusaurus-plugin-content-docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
+++
"b/i18n/en/docusaurus-plugin-content-docs/version-5.0/02-\345\277\253\351\200\237\345\205\245\351\227\250/02quickstart.md"
@@ -22,10 +22,10 @@ The following instruction takes the application of RocketMQ
5.0.0 source package
Extract the source package of RocketMQ 5.0.0, then compile and build the
binary executables:
```shell
- > unzip rocketmq-all-5.0.0-source-release.zip
- > cd rocketmq-all-5.0.0-source-release/
- > mvn -Prelease-all -DskipTests clean install -U
- > cd distribution/target/rocketmq-5.0.0/rocketmq-5.0.0
+$ unzip rocketmq-all-5.0.0-source-release.zip
+$ cd rocketmq-all-5.0.0-source-release/
+$ mvn -Prelease-all -DskipTests clean install -U
+$ cd distribution/target/rocketmq-5.0.0/rocketmq-5.0.0
```
## 2. Start NameServer
@@ -76,11 +76,11 @@ Thus far, a single-Master RocketMQ cluster has been
deployed, and we are able to
Before test with tools, we need set the nameserver address to system. like
system environment variables `NAMESRV_ADDR`.
``` shell
- > export NAMESRV_ADDR=localhost:9876
- > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
+$ export NAMESRV_ADDR=localhost:9876
+$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...
- > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
+$ sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...
```
@@ -99,110 +99,111 @@ We can also try to use the client sdk to send and receive
messages.
<version>5.0.0</version>
</dependency>
```
+
3. Create topic by mqadmin cli tools.
-```shell
-$ sh bin/mqadmin updatetopic -n localhost:9876 -t TestTopic
-```
+ ```shell
+ $ sh bin/mqadmin updatetopic -n localhost:9876 -t TestTopic
+ ```
4. In the Java project you have created, create a program that sends messages
and run it with the following code:
-```java
-import org.apache.rocketmq.client.apis.*;
-import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
-import org.apache.rocketmq.client.apis.consumer.MessageListener;
-import org.apache.rocketmq.client.apis.consumer.SimpleConsumer;
-import org.apache.rocketmq.client.apis.message.Message;
-import org.apache.rocketmq.client.apis.message.MessageBuilder;
-import org.apache.rocketmq.client.apis.message.MessageView;
-import org.apache.rocketmq.client.apis.producer.Producer;
-import org.apache.rocketmq.client.apis.producer.SendReceipt;
-import java.time.Duration;
-import java.util.List;
-public class ProducerExample {
- public static void main(String[] args) throws ClientException {
- String endpoint = "localhost:8081";
- String topic = "Your Topic";
- ClientServiceProvider provider = ClientServiceProvider.loadService();
- ClientConfigurationBuilder builder =
ClientConfiguration.newBuilder().setEndpoints(endpoint);
- ClientConfiguration configuration = builder.build();
- Producer producer = provider.newProducerBuilder()
- .setTopics(topic)
- .setClientConfiguration(configuration)
- .build();
- Message message = provider.newMessageBuilder()
- .setTopic(topic)
- .setKeys("messageKey")
- .setTag("messageTag")
- .setBody("messageBody".getBytes())
- .build();
- try {
- SendReceipt sendReceipt = producer.send(message);
- System.out.println(sendReceipt.getMessageId());
- } catch (ClientException e) {
- e.printStackTrace();
- }
- }
-}
-```
+ ```java
+ import org.apache.rocketmq.client.apis.*;
+ import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
+ import org.apache.rocketmq.client.apis.consumer.MessageListener;
+ import org.apache.rocketmq.client.apis.consumer.SimpleConsumer;
+ import org.apache.rocketmq.client.apis.message.Message;
+ import org.apache.rocketmq.client.apis.message.MessageBuilder;
+ import org.apache.rocketmq.client.apis.message.MessageView;
+ import org.apache.rocketmq.client.apis.producer.Producer;
+ import org.apache.rocketmq.client.apis.producer.SendReceipt;
+ import java.time.Duration;
+ import java.util.List;
+ public class ProducerExample {
+ public static void main(String[] args) throws ClientException {
+ String endpoint = "localhost:8081";
+ String topic = "Your Topic";
+ ClientServiceProvider provider =
ClientServiceProvider.loadService();
+ ClientConfigurationBuilder builder =
ClientConfiguration.newBuilder().setEndpoints(endpoint);
+ ClientConfiguration configuration = builder.build();
+ Producer producer = provider.newProducerBuilder()
+ .setTopics(topic)
+ .setClientConfiguration(configuration)
+ .build();
+ Message message = provider.newMessageBuilder()
+ .setTopic(topic)
+ .setKeys("messageKey")
+ .setTag("messageTag")
+ .setBody("messageBody".getBytes())
+ .build();
+ try {
+ SendReceipt sendReceipt = producer.send(message);
+ System.out.println(sendReceipt.getMessageId());
+ } catch (ClientException e) {
+ e.printStackTrace();
+ }
+ }
+ }
+ ```
5. In the Java project you have created, create a consumer demo program and
run it. Apache RocketMQ support [SimpleConsumer](../04-功能行为/06consumertype.md)
and [PushConsumer](../04-功能行为/06consumertype.md).
-```java
-import org.apache.rocketmq.client.apis.*;
-import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
-import org.apache.rocketmq.client.apis.consumer.FilterExpression;
-import org.apache.rocketmq.client.apis.consumer.FilterExpressionType;
-import org.apache.rocketmq.client.apis.consumer.PushConsumer;
-
-import java.io.IOException;
-import java.util.Collections;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class PushConsumerExample {
- private static final Logger LOGGER =
LoggerFactory.getLogger(PushConsumerExample.class);
-
- private PushConsumerExample() {
- }
-
- public static void main(String[] args) throws ClientException,
IOException, InterruptedException {
- final ClientServiceProvider provider =
ClientServiceProvider.loadService();
- String endpoints = "localhost:8081";
- ClientConfiguration clientConfiguration =
ClientConfiguration.newBuilder()
- .setEndpoints(endpoints)
- .build();
- String tag = "*";
- FilterExpression filterExpression = new FilterExpression(tag,
FilterExpressionType.TAG);
- String consumerGroup = "Your ConsumerGroup";
- String topic = "Your Topic";
- PushConsumer pushConsumer = provider.newPushConsumerBuilder()
- .setClientConfiguration(clientConfiguration)
- .setConsumerGroup(consumerGroup)
- .setSubscriptionExpressions(Collections.singletonMap(topic,
filterExpression))
- .setMessageListener(messageView -> {
- // LOGGER.info("Consume message={}", messageView);
- System.out.println("Consume message!!");
- return ConsumeResult.SUCCESS;
- })
- .build();
- Thread.sleep(Long.MAX_VALUE);
- //pushConsumer.close();
- }
-}
-```
+ ```java
+ import org.apache.rocketmq.client.apis.*;
+ import org.apache.rocketmq.client.apis.consumer.ConsumeResult;
+ import org.apache.rocketmq.client.apis.consumer.FilterExpression;
+ import org.apache.rocketmq.client.apis.consumer.FilterExpressionType;
+ import org.apache.rocketmq.client.apis.consumer.PushConsumer;
+
+ import java.io.IOException;
+ import java.util.Collections;
+ import org.slf4j.Logger;
+ import org.slf4j.LoggerFactory;
+
+ public class PushConsumerExample {
+ private static final Logger LOGGER =
LoggerFactory.getLogger(PushConsumerExample.class);
+
+ private PushConsumerExample() {
+ }
+
+ public static void main(String[] args) throws ClientException,
IOException, InterruptedException {
+ final ClientServiceProvider provider =
ClientServiceProvider.loadService();
+ String endpoints = "localhost:8081";
+ ClientConfiguration clientConfiguration =
ClientConfiguration.newBuilder()
+ .setEndpoints(endpoints)
+ .build();
+ String tag = "*";
+ FilterExpression filterExpression = new FilterExpression(tag,
FilterExpressionType.TAG);
+ String consumerGroup = "Your ConsumerGroup";
+ String topic = "Your Topic";
+ PushConsumer pushConsumer = provider.newPushConsumerBuilder()
+ .setClientConfiguration(clientConfiguration)
+ .setConsumerGroup(consumerGroup)
+ .setSubscriptionExpressions(Collections.singletonMap(topic,
filterExpression))
+ .setMessageListener(messageView -> {
+ // LOGGER.info("Consume message={}", messageView);
+ System.out.println("Consume message!!");
+ return ConsumeResult.SUCCESS;
+ })
+ .build();
+ Thread.sleep(Long.MAX_VALUE);
+ //pushConsumer.close();
+ }
+ }
+ ```
## 6. Shutdown Servers
After finishing the practice, we could shut down the service by the following
commands.
```shell
-> sh bin/mqshutdown broker
+$ sh bin/mqshutdown broker
The mqbroker(36695) is running...
Send shutdown request to mqbroker(36695) OK
-> sh bin/mqshutdown namesrv
+$ sh bin/mqshutdown namesrv
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
```
\ No newline at end of file
