关于RocketMQ的使用入门

「爱情、让人受尽委屈。」 2022-05-28 05:40 95阅读 0赞

## RocketMQ 是什么 ##

Github 上关于 RocketMQ 的介绍：  
RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性：

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

1.在pom环境中引用jar包

<dependency>    
    <groupId>com.alibaba.rocketmq</groupId>    
    <artifactId>rocketmq-client</artifactId>    
    <version>3.2.6</version>    
</dependency>  
<dependency>  
<groupId>com.alibaba.rocketmq</groupId>  
<artifactId>rocketmq-all</artifactId>  
<version>3.2.6</version>  
<type>pom</type>

</dependency>

2.编写测试类

2.1 生产测试类

![70][]

2.2 消费测试类

![70 1][]

2.3 生产、消费、监听的init（）

![70 2][]

![70 3][]

![70 4][]

4.启动mqbroker.exe,mqnamesrv.exe

下载![70 5][]解压即可看到如下目录，直接启动

![70 6][]

[70]: /images/20220528/54cdf4ca09e543cfb321cb8877f0cd1e.png
[70 1]: /images/20220528/e0cda285bc4040e0950486edd212f643.png
[70 2]: /images/20220528/a9cafabe0720495797ba9c0e37ee1032.png
[70 3]: /images/20220528/d0c0d8735e4045f99f5762b7b5ec864e.png
[70 4]: /images/20220528/3300f73ea82d40e3a49a3c2259e925ea.png
[70 5]: /images/20220528/c7a7d7cac0334b7688755a8a9ca2056b.png
[70 6]: /images/20220528/6d7031fb9ef845bc9172adf70d160e86.png