RocketMQ CenterOS 下的安装（最新版）

小灰灰 2022-12-03 13:08 162阅读 0赞

# 获取安装包 #

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

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

# 解压安装包 #

由于RocketMQ 官方没有提供tar文件，所以需要下载unzip的工具包用于在CenterOS 下解压文件

## 安装unzip的安装包 ##

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

## 测试unzip工具![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 2] ##

## 解压安装包 ##

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

# 运行RocketMQ-mqnamesrv服务 #

## 进入bin目录 ##

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

sh bin/mqnamesrv &

![在这里插入图片描述][20200903170910947.png_pic_center]  
查看运行日志 `tail -f ~/logs/rocketmqlogs/namesrv.log`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 3]

## 运行RocketMQ-broker服务 ##

在当时目录下执行`sh bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true &`  
![在这里插入图片描述][20200903171216554.png_pic_center]查看运行日志`tail -f ~/logs/rocketmqlogs/broker.log`  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 4]  
查看是否运行正常`sh mqadmin clusterList -n localhost:9876`  
![在这里插入图片描述][20200903172308397.png_pic_center]

# 脚本测试 #

export NAMESRV\_ADDR=localhost:9876  
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 5]  
收到的内容sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 6]

# Java代码测试 #

## 提供者 ##

// 实例化消息生产者Producer
            DefaultMQProducer producer = new DefaultMQProducer("test_sync_group");
            producer.setCreateTopicKey("AUTO_CREATE_TOPIC_KEY");
            // 设置NameServer的地址
            producer.setNamesrvAddr("10.168.1.248: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();
            }
    
        }

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

## 消费者 ##

public static void main(String[] args) { 
            DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_3");
    
            consumer.setNamesrvAddr("10.168.1.248: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 8]

# 总结 #

*  No route info of this topic
 *  [sendDefaultImpl call timeout][]

[Link 1]: 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/4d62923a9d8c4105baa8e0e9dfe952a3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/0e597b50cfde44e6a9156f1eee7ef0f4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/b40fa4e501b34900967c41a7882d9940.png
[2020090317034450.png_pic_center]: /images/20221123/3e6711e9fe01477bb8da461ff40194bb.png
[20200903170740597.png_pic_center]: /images/20221123/bc4be01cbeff490583beed50696b27d2.png
[20200903170910947.png_pic_center]: /images/20221123/bdb206b6723145f986273102ae17e0f9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221123/b51fa872f506437ab8b1ef974a6d08b5.png
[20200903171216554.png_pic_center]: /images/20221123/f9b57052004d4900bc0059ab733d264e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221123/521a27f1fbb34eb39d21edec117d4339.png
[20200903172308397.png_pic_center]: /images/20221123/a5cee9038f4b45818f7688667672cce7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221123/dcb376bb4ef54d4f987d4e5c202882cc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221123/a8a7d3af5c0e4d4db639378cb027a9ad.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221123/c761ff70f175495e9afdf3fe0eb9ea91.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2VsdmlzaGVoYWk_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221123/73287287a08a456bb51df773602b88b6.png
[sendDefaultImpl call timeout]: https://editor.csdn.net/md/?articleId=108397695