rocketmqインストールと可視化管理プラットフォームのインストール

1002 ワード

rocketmq,公式サイトからダウンロードします。文書のリンクを開始します。http://rocketmq.apache.org/docs/quick-start/ 解凍後、ルートディレクトリに入ります。
  • jdk環境変数をインストールします。
  • 起動mqnamesrv->nohup sh bin/mqnamesrv&
  • 起動mqbrook->nohup sh mqbrook-n local host:9876 at CreateTopicEnbale=true&

  • export NAMESRV_ADDR=local host:9876
  • sh bin/tools.shorg.apache.rocketmq.example.quickstart.Producer SendResult[sendStuts=SEND_OK、msgId=…
    sh bin/tools.shorg.apache.rocketmq.example.quickstart.Conssumer Consmessage Thread_%d Receive New Message:Message Ext...
    Shutdown Servers
    sh bin/mqshutdown brook er The mqbrook er(36695)is running…Send shutdown request to mqbrook er(36695)OK
    sh bin/mqshutdown namesrv The mqnamesrv(36664)is running...Send shutdown request to mqnamesrv(36664)OK
    rockett-consolieインストールリンク:https://blog.csdn.net/qq_34531925/article/details/82587358
    topicを作成するコマンド:
    ./bin/mqadmin updateTopic -n 192.168.228.130:9876 -c DefaultCluster  -t topic_name