rocketMQ本地启动

RocketMQ是一个分布式消息队列系统，常用于海量数据的处理和消息传递。在进行RocketMQ开发之前，需要先了解如何在本地搭建一个RocketMQ环境，在这里，我们将介绍RocketMQ的本地启动方法。

一、环境搭建

1.下载RocketMQ

在官网下载RocketMQ二进制包，下载完成后解压至本地任意目录。

https://rocketmq.apache.org/dowloading/releases/

2.启动Name Server

进入解压后的RocketMQ目录，执行以下命令启动Name Server：

sh bin/mqnamesrv

如果启动成功，则会在控制台输出以下内容：

The Name Server boot success. serializeType=JSON

3.启动Broker

执行以下命令启动Broker：

sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true

其中，-n参数指定Name Server的IP地址和端口号，autoCreateTopicEnable=true参数表示开启Topic的自动创建功能。如果启动成功，则会在控制台输出以下内容：

...
INFO  [main] org.apache.rocketmq.broker.BrokerStartup - The broker[h2lz-Ultrabook.local, 192.168.0.100:10911] boot success, and it took 29ms.

启动成功后，Broker会与Name Server建立连接，并将自身注册到Name Server上。

二、代码示例

下面的示例展示了如何使用RocketMQ Producer发送一条消息，并使用Consumer接收该消息。

1.导入依赖

在pom.xml文件中添加RocketMQ的依赖：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.3.0</version>
</dependency>

2.发送消息

使用Producer发送一条消息：

public class ProducerTest {
    public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("test-group");
        producer.setNamesrvAddr("localhost:9876");
        producer.start();
        Message message = new Message("test_topic", "test_tag", "Hello World".getBytes());
        producer.send(message);
        producer.shutdown();
    }
}

其中，DefaultMQProducer是RocketMQ提供的默认Producer实现类，"test-group"用于设置Producer所属的分组。在创建Producer时，需要指定Name Server的地址和端口