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を作成するコマンド:
export NAMESRV_ADDR=local host:9876
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