CentOS 7 RocketMQをインストールして使用
6440 ワード
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インストール依存
クローンおよびパッケージ
サービス を開始
Broker を起動
ブローカーサービスが正常に起動したことが図からわかります送信および送迎メッセージ 環境変数の事前設定:NAMESRV_ADDR
筆者がここでメッセージ取得プログラムを実行中にブロックが発生した(未解決)サービス停止
リファレンスリンク http://rocketmq.apache.org/docs/quick-start/ http://rocketmq.apache.org/docs/faq/
Apache RocketMQ™オープンソースの分散メッセージングとストリームデータプラットフォームです.
インストール依存
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
[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
[root@linuxprobe apache-rocketmq]# nohup sh bin/mqnamesrv &
#
[root@linuxprobe apache-rocketmq]# tail -f ~/logs/rocketmqlogs/namesrv.log
# 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
ブローカーサービスが正常に起動したことが図からわかります
[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...
筆者がここでメッセージ取得プログラムを実行中にブロックが発生した(未解決)
[root@linuxprobe apache-rocketmq]# export NAMESRV_ADDR=linuxprobe.com:9876
[root@linuxprobe apache-rocketmq]# sh bin/mqshutdown namesrv
リファレンスリンク