Docker rocketmq デプロイメントの実装例

ブローカークラスタ名 = デフォルトクラスタ  
ブローカー名 = ブローカー-a  
ブローカーID = 0  
削除時 = 04  
ファイル予約時間 = 48  
ブローカーロール = ASYNC_MASTER  
フラッシュディスクタイプ = ASYNC_FLUSH  
# ローカルプログラムがクラウドホストのMQを呼び出す場合は、これをクラウドホストのIPに設定する必要があります
ブローカーIP1=10.10.101.80

バージョン: '2'
サービス:
  名前rv:
    画像: rocketmqinc/rocketmq
    コンテナ名: rmqnamesrv
    ポート:
      -9876:9876
    ボリューム:
      - /opt/rocketmq/logs:/home/rocketmq/logs
      - /opt/rocketmq/store:/home/rocketmq/store
    コマンド: sh mqnamesrv
  ブローカ：
    画像: rocketmqinc/rocketmq
    コンテナ名: rmqbroker
    ポート:
      - 10909:10909
      - 10911:10911
      - 10912:10912
    ボリューム:
      - /opt/rocketmq/logs:/home/rocketmq/logs
      - /opt/rocketmq/store:/home/rocketmq/store
      - /opt/rocketmq/conf/broker.conf:/opt/rocketmq-4.4.0/conf/broker.conf
    #コマンド: sh mqbroker -n namesrv:9876
    コマンド: sh mqbroker -n namesrv:9876 -c ../conf/broker.conf
    依存:
      -名前
    環境：
      JAVA_HOME = /usr/lib/jvm/jre
  コンソール：
    画像: styletang/rocketmq-console-ng
    コンテナ名: rocketmq-console-ng
    ポート:
      -8087:8080
    依存:
      -名前
    環境：
      -JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876 
      - Dcom.rocketmq.sendMessageWithVIPChannel=false

<!--pom.xml に依存関係を追加する-->
<依存関係>
    <グループ ID>org.apache.rocketmq</グループ ID>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <バージョン>2.0.3</バージョン>
</依存関係>

## アプリケーション.プロパティ
rocketmq.name-server=ip:9876
rocketmq.producer.group=私のグループ

@SpringBootアプリケーション
パブリッククラス ProducerApplication は CommandLineRunner を実装します {
    @リソース
    プライベート RocketMQTemplate rocketMQTemplate;

    パブリック静的void main(String[] args){
        SpringApplication.run(ProducerApplication.class、引数);
    }

    パブリック void run(String...args) 例外をスローします {
        rocketMQTemplate.convertAndSend("test-topic-1", "Hello, World!");
        rocketMQTemplate.send("test-topic-1", MessageBuilder.withPayload("Hello, World! 私は Spring のメッセージから来ました").build());
    }

}

## アプリケーション.プロパティ
rocketmq.name-server=ip:9876

@SpringBootアプリケーション
パブリッククラス ConsumerApplication{

    パブリック静的void main(String[] args){
        SpringApplication.run(ConsumerApplication.class、引数);
    }

    翻訳者
    @サービス
    @RocketMQMessageListener(トピック = "test-topic-1", コンシューマーグループ = "my-consumer_test-topic-1")
    パブリック静的クラス MyConsumer1 は RocketMQListener<String> を実装します {
        パブリックvoid onMessage(文字列メッセージ) {
            log.info("受信したメッセージ: {}", message);
        }
    }
}

-JAVA_OPTS= -Dlogging.level.root=info -Drocketmq.namesrv.addr=rmqnamesrv:9876