RocketMQはよく使用されるメッセージキューです。以下、ワンクリックでテスト環境を構築し、SpringBoot3.0にインポートする方法について説明します。

テスト環境

ここではテスト環境をDocker Composeを使用してワンクリックでデプロイします。

使用するファイルは以下の通りです:

docker-compose.yamlの設定は以下の通りです：

version: '3.3'

services:

  namesrv:

    image: apache/rocketmq:4.9.4

    container_name: rmqnamesrv

    ports:

      - 9876:9876

    environment:

      JAVA_OPT_EXT: "-server -Xms512m -Xmx512m"

    volumes:

      - /opt/rocketmq/namesrv/logs:/home/rocketmq/logs

    command: sh mqnamesrv

    restart: always

  broker1:

    image: apache/rocketmq:4.9.4

    container_name: rmqbroker

    links:

      - namesrv

    ports:

      - 10909:10909

      - 10911:10911

      - 10912:10912

    environment:

      NAMESRV_ADDR: namesrv:9876

      JAVA_OPT_EXT: "-server -Xms512m -Xmx512m  -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99"

    volumes:

      - ./logs:/home/rocketmq/logs

      - ./store:/home/rocketmq/store

      - ./conf/broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf

    command: sh mqbroker -c /opt/rocketmq-4.9.4/conf/broker.conf

    restart: always

  dashbord:

    image: apacherocketmq/rocketmq-dashboard:1.0.0

    ports:

      - 10081:8080

    environment:

      JAVA_OPTS: "-Drocketmq.namesrv.addr=namesrv:9876"

    restart: always

  rmqconsole:

    image: styletang/rocketmq-console-ng

    container_name: rocketmq-console

    restart: always

    ports:

      - 11112:8080

    depends_on:

      - namesrv

    volumes:

      - /etc/localtime:/etc/localtime:ro

      - /home/rocketmq/console/logs:/root/logs

    environment:

      NAMESRV_ADDR: namesrv:9876

      JAVA_OPTS: "-Drocketmq.namesrv.addr=namesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false  -Drocketmq.broker.diskSpaceWarningLevelRatio=0.99"

broker.confの設定は以下の通りです：

brokerClusterName = DefaultCluster

brokerName = broker-1

brokerId = 0

deleteWhen = 04

fileReservedTime = 72

mapedFileSizeConsumeQueue=300000

mapedFileSizeCommitLog=1073741824

maxMessageSize=65536

autoCreateSubscriptionGroup=true

autoCreateTopicEnable=true

defaultTopicQueueNums=4

brokerRole = ASYNC_MASTER

flushDiskType = ASYNC_FLUSH

brokerIP1 = xxx.xxx.x.x //ここにあなたのローカルエリアネットワークのIPを記入してください。

これら2つのファイルを準備した後、Docker-compose.yamlがあるディレクトリで以下のコマンドを実行します。

docker compose up -d //旧バージョンではdocker-compose up -d

起動が完了したら、127.0.0.1:10081にアクセスしてダッシュボードで起動状態を確認できます。

SpringBoot3.0へのインポート

このブログを書いている時点では、まだ2.2.3バージョンです。

implementation 'org.apache.rocketmq:rocketmq-spring-boot-starter:2.2.3'

このバージョンを使用する場合は、META-INF内で手動で以下をインポートする必要があります。

org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration

上記のコードを以下の画像に示されているファイルに手動で配置してください。