RocketMQ入门简介

Posted 2021-01-24 i-hard-working

分布式mq功能：异步解耦、流量削峰、消息分发、保证最终一致性、方便动态扩容。

rocketmq历史：Notify(2007)->Napoli(2010)->MetaQ(2011)->RocketMQ(2012)->开源(2016)

第一代的Notify主要使用了推模型，解决了事务消；

第二代的MetaQ主要使用了拉模型，解决了顺序消息和海量堆积的问题。

RocketMQ基于长轮询的拉取方式，兼有两者的优点。

 

benchmark：运行benchmark程序的shell脚本。

bin：包含各种使用rocketmq的shell脚本和cmd脚本，比如启动NameServer的脚本mqnamesrv，启动Broker的脚本mqbroker，集群管理脚本mqadmin。

conf：一些示例配置文件，包括三种方式的broker配置文件、logback日志配置文件等，用户在写配置文件的时候，一般基于这些示例配置文件，加上自己的特殊需求即可。

lib：包括RocketMQ各个模块编译成的jar包，以及rocketmq依赖的一些jar包，比如netty、commons-lang、fastjson等。

 ============================================================================================

启动单机的消息队列服务：

首先配置%ROCKETMQ_HOME%环境变量，然后配置path环境变量，最后依次启动NameServer和Broker即可。

 

===============================================================================================

用命令行发送和接收消息：

发送：

消费：

================================================================================================