RocketMQ windows下的安装（最新版）

比眉伴天荒 2022-12-03 12:57 276阅读 0赞

# RocketMQ是什么？ #

RocketMQ是Apache旗下的一款开源的高性能、高吞吐量的分布式消息中间件。

## 特性 ##

*  是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点。
 *  Producer、Consumer、队列都可以分布式。
 *  Producer向一些队列轮流发送消息，队列集合称为Topic，Consumer如果做广播消费，则一个consumer实例消费这个
 *  Topic对应的所有队列，如果做集群消费，则多个Consumer实例平均消费这个topic对应的队列集合。
 *  能够保证严格的消息顺序
 *  提供丰富的消息拉取模式
 *  高效的订阅者水平扩展能力
 *  实时的消息订阅机制
 *  亿级消息堆积能力
 *  较少的依赖

## 开发文档 ##

[点击跳转][Link 1]

# 环境及工具 #

RocketMQ 版本：4.7.1  
开发工具：IntelliJ IDEA 2020.2.1 、 JDK1.8

# 获取安装包 #

下载地址：[点击下载][Link 2]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 1]

# 解压安装包 #

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 2]

# 准备启动 #

## mqnamesrv启动 ##

### mqnamesrv.cmd 启动出错 ###

![在这里插入图片描述][20200903155547925.png_pic_center]

### 配置环境变量 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 3]

### 再次运行mqnamesrv.cmd ###

![在这里插入图片描述][20200903155702341.png_pic_center]  
![在这里插入图片描述][20200903155928299.png_pic_center]

## broker启动 ##

broker启动时可能会提示内存不够，配置文件中配置的要求是比较高的，基本都是2G的内存，也许你本机没有那么多空闲的内存，这个时需要修改下配置文件，  
编辑`runbroker.cmd`中的java配置，可根据自己的机器修改  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 4]

set "JAVA_OPT=%JAVA_OPT% -server -Xms1024m -Xmx1024m -Xmn1024m"

运行`mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true` autoCreateTopicEnable 表示会自动创建Topic  
![在这里插入图片描述][202009031603111.png_pic_center]  
启动成功。

# 代码测试 #

本遍提供的是java测试代码，你也可以用其它的脚本做测试，官网也有不同的语言请自行选择

## 提供者 ##

// 实例化消息生产者Producer
            DefaultMQProducer producer = new DefaultMQProducer("MQ_PRODUCER_GROUP");
            //producer.setCreateTopicKey("AUTO_CREATE_TOPIC_KEY"); 最新版本不需要设置。3.4版本需要
            // 设置NameServer的地址
            producer.setNamesrvAddr("127.0.1.1:9876");
            // 启动Producer实例
            try { 
                producer.start();
                for (int i = 0; i < 5; i++) { 
                    // 创建消息，并指定Topic，Tag和消息体
                    Message msg = new Message("MQTopic" /* Topic */,
                            "TagA" /* Tag */,
                            ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET) /* Message body */
                    );
                    // 发送消息到一个Broker
                    SendResult sendResult = producer.send(msg);
                    // 通过sendResult返回消息是否成功送达
                    System.out.printf("%s%n", sendResult);
                }
            }catch (Exception e){ 
    
            }finally { 
                // 如果不再发送消息，关闭Producer实例。
                producer.shutdown();
            }
    
        }

![在这里插入图片描述][20200904102121624.png_pic_center]

## 消费者 ##

public static void main(String[] args) { 
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("MQ_PUSH_CONSUMER");
    
            consumer.setNamesrvAddr("127.0.1.1:9876");
            consumer.setVipChannelEnabled(false);
            try { 
                consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
                //设置消费者拉取消息的策略，*表示消费该topic下的所有消息，也可以指定tag进行消息过滤
                consumer.subscribe("MQTopic", "*");
                consumer.registerMessageListener(new MessageListenerConcurrently() { 
                    public ConsumeConcurrentlyStatus consumeMessage(
                            List<MessageExt> msgs, ConsumeConcurrentlyContext context) { 
                        System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
                        for (MessageExt msg : msgs) { 
                            System.out.println(new String(msg.getBody()));
                        }
                        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                    }
                });
                consumer.start();
                System.out.println("Consumer Started.");
            } catch (MQClientException e) { 
                e.printStackTrace();
            }
        }

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 5]

# 总结 #

这是个简单的RocketMQ安装与测试API的功能 ，更复杂的功能扔需要探索，更需要用到实际的项目中去才会真真发现很多的更高级的功能。  
P安装RocketMQ时遇到的问题，  
1、内存不够，需要配置文件  
2、本机安装启动的时候直接用127.0.0.1启动broker 但是如果用的是服务器需要给固定IP客户端才可以连接  
如有问题，欢迎有问题及时交流。谢谢！

[Link 1]: https://github.com/apache/rocketmq/tree/master/docs/cn
[Link 2]: http://rocketmq.apache.org/release_notes/release-notes-4.7.1/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/25ed62db975d4c688f255e315845b1a2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/0aaacc0036d74378935b1d98c0d9de9c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/301201549fe9468cb6393fdbf3139949.png
[20200903155547925.png_pic_center]: /images/20221123/9ba78a3e481d4d54943dcffa2843a56d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221123/a1ac9d0cab024dacac274e9ab1fcbb72.png
[20200903155702341.png_pic_center]: /images/20221123/56090aa0e3374d7c901d922d43a66011.png
[20200903155928299.png_pic_center]: /images/20221123/0a5ec1cbf94a4f90a03d26f38dd63201.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221123/da1adda313aa4ec1be5dd667a66e4b60.png
[202009031603111.png_pic_center]: /images/20221123/f76806fd950a4b96839506c5230fc9bf.png
[20200904102121624.png_pic_center]: /images/20221123/f6bb8d2d3d924bd8acf47561863138fc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221123/e74d4bb3ba2a48eab1d7994790d96eee.png