RocketMQ入门篇-三分钟入门RocketMQ

素颜马尾好姑娘i 2023-02-21 11:46 29阅读 0赞

> 微信公众号：**Java患者**  
> 专注Java领域技术分享

### RocketMQ入门Demo ###

首先在window中安装好RocketMQ

#### 依赖 ####

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

#### 生产者 ####

package com.zero.day1;
    
    import org.apache.rocketmq.client.producer.DefaultMQProducer;
    import org.apache.rocketmq.client.producer.SendResult;
    import org.apache.rocketmq.common.message.Message;
    import org.apache.rocketmq.remoting.common.RemotingHelper;
    
    public class SyncProducerDemo {
    
        public static void main(String[] args) {
            DefaultMQProducer producer = null;
            try {
                producer = new DefaultMQProducer("TopicTst");
                producer.setNamesrvAddr("127.0.0.1:9876");
    
                producer.start();
    
                for (int i = 0; i < 100; i++) {
                    Message msg = new Message("TopicTst", "TagA", "Hello RocketMQ".getBytes(RemotingHelper.DEFAULT_CHARSET));
                    SendResult sendResult = producer.send(msg);
                    System.out.println("返回内容" + sendResult);
    
                }
            } catch (Exception e) {
                e.printStackTrace();
            }finally {
                producer.shutdown();
            }
    
        }
    }

#### 消费者 ####

package com.zero.day1;
    
    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.common.message.MessageExt;
    
    import java.util.List;
    
    public class ConsumerDemo {
    
        public static void main(String[] args) {
            try{
                DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("TopicTst");
                consumer.setNamesrvAddr("127.0.0.1:9876");
    
                consumer.subscribe("TopicTst", "*");
                consumer.registerMessageListener(new MessageListenerConcurrently() {
                    public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
                        System.out.println("Receive: " + list);
                        return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                    }
                });
                consumer.start();
            }catch (Exception e) {
                e.printStackTrace();
            }
    
    
        }
    }

#### 启动 ####

![format_png][]

![format_png 1][]

#### 可能出现的错误 ####

org.apache.rocketmq.client.exception.MQClientException: No route info of this topic, TopicTest

自动创建Topic失败了,改成手动创建topic

mqadmin updateTopic -b 127.0.0.1:10911 -n 127.0.0.1:9876 -t TopicTest

或者改成自动创建Topic

Window: mqbroker.cmd -n localhost:9876 autoCreateTopicEnable=true
    Linux:nohup sh mqbroker -n 192.168.180.133:9876 autoCreateTopicEnable=true

#### 插件部署 ####

##### 安装 #####

在window安装RocketMQ插件

首先git下载文件 地址：https://github.com/apache/rocketmq-externals.git

![format_png 2][]

##### 配置 #####

下载之后 今日rocketmq-console\\src\\main\\resource 修改application.properties文件

##### 编译启动 #####

进入rocketmq-console

执行

mvn clean package -Dmaven.test.skip=true

##### 启动后台 #####

在target目录下 执行

java -jar rocketmq-console-ng-1.0.0.jar

启动浏览器 输入127.0.0.1:8001

![format_png 3][]

专注分享Java技术，跟我一起学习吧

长按识别二维码关注

![format_png 4][]

![format_png 5][]

往期精彩 [RocketMQ入门篇-安装][RocketMQ_-]  
[ActiveMQ高级篇-联合JMS详解][ActiveMQ_-_JMS]  
[ActiveMQ进阶篇-整合Spring][ActiveMQ_-_Spring]  
[ActiveMQ入门篇][ActiveMQ]

[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJMelZRZHA5c2NpYlRFaElvU3RScFFOUFoxQWhtMGZ6c1plUnoxaEpMZmRhU1NpY2xXUE5mT3lGZy82NDA?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJLc3hYMFdLQnZVRnVXbmU2bkw2cWhiOVF1MlpHRVFpYkZ1TXpKaWNHVE45Wnd4Y1p3U09kcEs4Zy82NDA?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJ4cDFlWkk4ZnNmRFdyNTZ0aWFENlJWaWNDRW05eTFlZXNmUjlIZkdqdFZmTVhxaWJKWkYwMzRjU3cvNjQw?x-oss-process=image/format,png
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJNSnpSdWpkdng5aWFmbXo5MjZpYWNjeHJzb3JkUWljdHVacGlhNTRMNDVGdG1YTUJQeGtqR3c1R09nLzY0MA?x-oss-process=image/format,png
[format_png 4]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJkN3dQTTZnaDl4TjBqSGxtRWljTzZHYkJIOFFpY2NZWjRSZmJxMzZOTWlhU1hTakVkTlFmaWJTUURnLzY0MA?x-oss-process=image/format,png
[format_png 5]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9PalpmWGtUTTYxN1VDMVJHN1ZMWWZZSXljM3ZpYmZnbnJMeWJDcURMYmJxdkkyeVVJNHpzN3NTOWM5YkV2aWEwcmNabUIybFdvbk9DekY3UmV3d3ZUT0lnLzY0MA?x-oss-process=image/format,png
[RocketMQ_-]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea1406d0dd638fc6f95922c38d42e3fb8e3c7dfdb971844513582fb00d8df0a0abaa4184a731&idx=1&mid=2247484333&scene=21&sn=34879ffb5c8d98b83d86a74289f07ec1#wechat_redirect
[ActiveMQ_-_JMS]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea140617dd638f013543a269163cddb4af9ff648c7103336e0117f4566c93d3e1c6931ff08fd&idx=1&mid=2247484266&scene=21&sn=d086b44d092bfadb72423ec0f1ee4c22#wechat_redirect
[ActiveMQ_-_Spring]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea140614dd638f02ad9fbc7bcad508e68c95aec59a41bd48da807e74bc5316f3617f54edbbd1&idx=1&mid=2247484265&scene=21&sn=cdb685a35beea554a2a0f4041dac94bc#wechat_redirect
[ActiveMQ]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea140615dd638f03579c0382c78e17468533cf4930896a0e6cb9f15f80f9d1d3801a5e38e40a&idx=1&mid=2247484264&scene=21&sn=958022b3074b7a4d1462a8d68b6b1a10#wechat_redirect