CentOS 7 RocketMQをインストールして使用


RocketMQ紹介
Apache RocketMQ™オープンソースの分散メッセージングとストリームデータプラットフォームです.
  • RocketMQ Github: https://github.com/apache/incubator-rocketmq/
  • RocketMQドキュメント:http://rocketmq.apache.org/docs

  • インストール依存
    64bit OS, Linux/Unix/Mac + 64bit OS, Linux/Unix/Mac + Maven 3.2.x + Git
  • インストール依存
  • #   maven
    [root@linuxprobe ~]# sudo wget http://repos.fedorapeople.org/repos/dchen/apache-maven/epel-apache-maven.repo -O /etc/yum.repos.d/epel-apache-maven.repo
    [root@linuxprobe ~]# yum install apache-maven -y
    
    #   git
    [root@linuxprobe ~]# yum install git -y

    CentOS7 安装RocketMQ并使用_第1张图片
  • クローンおよびパッケージ
  • [root@linuxprobe ~]# cd /opt
    [root@linuxprobe opt]# git clone -b develop https://github.com/apache/incubator-rocketmq.git
    [root@linuxprobe ~]# cd incubator-rocketmq
    [root@linuxprobe incubator-rocketmq]# mvn -Prelease-all -DskipTests clean install -U (          )
    [root@linuxprobe incubator-rocketmq]# cd distribution/target/apache-rocketmq

    CentOS7 安装RocketMQ并使用_第2张图片
  • サービス
  • を開始
    [root@linuxprobe apache-rocketmq]# nohup sh bin/mqnamesrv &
    #     
    [root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log

    CentOS7 安装RocketMQ并使用_第3张图片
  • Broker
  • を起動
    #   hosts  
    [root@linuxprobe ~]# cat /etc/hosts
    127.0.0.1   localhost localhost.localdomain linuxprobe.com 
    10.1.1.87 linuxprobe.com 
    # 
    [root@linuxprobe apache-rocketmq]# nohup sh bin/mqbroker -n linuxprobe.com:9876 &
    [root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/broker.log

    CentOS7 安装RocketMQ并使用_第4张图片
    CentOS7 安装RocketMQ并使用_第5张图片
    ブローカーサービスが正常に起動したことが図からわかります
  • 送信および送迎メッセージ
  • 環境変数の事前設定:NAMESRV_ADDR
    [root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
    #               
    [root@linuxprobe apache-rocketmq]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    SendResult [sendStatus=SEND_OK, msgId= ...
    [root@linuxprobe apache-rocketmq]# sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    ConsumeMessageThread_%d Receive New Messages: [MessageExt...

    CentOS7 安装RocketMQ并使用_第6张图片
    CentOS7 安装RocketMQ并使用_第7张图片
    筆者がここでメッセージ取得プログラムを実行中にブロックが発生した(未解決)
  • サービス停止
  • [root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
    [root@linuxprobe apache-rocketmq]# sh bin/mqshutdown namesrv

    mqshutdown-rocketmq
    リファレンスリンク
  • http://rocketmq.apache.org/docs/quick-start/
  • http://rocketmq.apache.org/docs/faq/