消息中间件RocketMQ的安装与部署:

官方简介:

RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:

  • 能够保证严格的消息顺序

  • 提供丰富的消息拉取模式

  • 高效的订阅者水平扩展能力

  • 实时的消息订阅机制

  • 亿级消息堆积能力

1.安装RocketMQ

安装环境:

JavaMaven

2.JDK和maven就不说了,直接看RocketMQ吧

3.wget https://github.com/alibaba/RocketMQ/archive/v3.0.8-beta1.tar.gz

  tar -zxvf v3.0.8-beta1.tar.gz

  cd RocketMQ-3.0.8-beta1

  sh install.sh

  cd devenv

4.RocketMQ部署

  Producer、Consumer、Broker都可以分布式部署。Producer、Consumer通过Name Server来寻找Broker,Broker启动后,会定时将要发布的Topic注册到NameServer

4.1 启动nameserver

   [root@dubbo bin]# ./ mqnamesrv &   

   在生产环境部署nameserver,请参考以下软硬件要求

   https://github.com/alibaba/RocketMQ/wiki/system_requirements

4.2 启动broker

   [root@dubbo bin]# ./ mqbroker -n "192.168.30.49:9876" &

4.3 关闭nameserver和broker  

   [root@dubbo bin]# ./mqshutdown mqnamesrv

   Useage: mqshutdown broker | namesrv