小傅哥，feat：更新创建 mq 方式

docs/docker/create-topic-consumer.sh

+docker exec -it rocketmq-broker sh mqadmin updateSubGroup -c rocketmq-broker:10911 -n rocketmq-namesrv:9876 -g test_group
+docker exec -it rocketmq-broker sh mqadmin updateTopic -c rocketmq-broker:10911 -n rocketmq-namesrv:9876 -t xfg-dev-tech-rocketmq
+docker exec -it rocketmq-broker sh mqadmin updateSubGroup -c rocketmq-broker:10911 -n rocketmq-namesrv:9876 -g test_group
\ No newline at end of file

docs/docker/create-topic-producer.sh

+docker exec -it rocketmq-broker sh mqadmin updateSubGroup -n rocketmq-namesrv:9876 -g test-group -t xfg-dev-tech-rocketmq
\ No newline at end of file

docs/docker/create-topic.sh

+docker exec -it rocketmq-broker sh mqadmin updateTopic -c rocketmq-broker:10911 -n rocketmq-namesrv:9876 -t xfg-dev-tech-rocketmq

docs/docker/docker-compose-rocketmq.yml

+# /usr/local/bin/docker-compose -f /docs/dev-ops/environment/environment-docker-compose.yml up -d
+# 启动服务 docker-compose up -d
+# 关闭服务 docker-compose down
+version: '3'
+services:
+  # RocketMQ https://hub.docker.com/r/apache/rocketmq/tags
+  rocketmq-namesrv:
+    image: apache/rocketmq:4.9.7
+    container_name: rocketmq-namesrv
+    command: sh mqnamesrv
+    ports:
+      - "9876:9876"
+  rocketmq-broker:
+    image: apache/rocketmq:4.9.7
+    container_name: rocketmq-broker
+    command: sh mqbroker -n rocketmq-namesrv:9876
+    ports:
+      - "10911:10911"
+      - "10909:10909"
+    depends_on:
+      - rocketmq-namesrv
+  rocketmq-dashboard:
+    image: apacherocketmq/rocketmq-dashboard
+    container_name: rocketmq-dashboard
+    ports:
+      - "8080:8080"
+    environment:
+      - "JAVA_OPTS=-Drocketmq.config.namesrvAddr=rocketmq-namesrv:9876"
\ No newline at end of file

rocketmq-docker-compose.yml → docs/docker/rocketmq-docker-compose.yml

 version: '3'
 services:
   # https://hub.docker.com/r/xuchengen/rocketmq
+  # broker.conf brokerIP1=127.0.0.1
+  # console/config/application.properties server.port=9009
   rocketmq:
     image: livinphp/rocketmq:5.1.0
     container_name: rocketmq
     ports:
-      - 7397:7397
+      - 9009:9009
       - 9876:9876
       - 10909:10909
       - 10911:10911

pom.xml

@@ -57,6 +57,17 @@
                 <artifactId>commons-lang3</artifactId>
                 <version>3.9</version>
             </dependency>
+            <!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client-java -->
+            <dependency>
+                <groupId>org.apache.rocketmq</groupId>
+                <artifactId>rocketmq-client-java</artifactId>
+                <version>5.0.0</version>
+            </dependency>
+            <dependency>
+                <groupId>org.apache.rocketmq</groupId>
+                <artifactId>rocketmq-spring-boot-starter</artifactId>
+                <version>2.2.2</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>
 

xfg-dev-tech-app/pom.xml

@@ -60,6 +60,17 @@
             <artifactId>commons-beanutils</artifactId>
             <version>1.9.4</version>
         </dependency>
+        <!-- https://mvnrepository.com/artifact/org.apache.rocketmq/rocketmq-client-java -->
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-client-java</artifactId>
+            <version>5.0.4</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>2.2.0</version>
+        </dependency>
 
         <!-- 自身模块 begin -->
         <dependency>

xfg-dev-tech-app/src/main/java/cn/bugstack/xfg/dev/tech/Application.java

@@ -13,8 +13,15 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
 @Configurable
 public class Application {
 
-    public static void main(String[] args){
-        SpringApplication.run(Application.class);
+    public static void main(String[] args) {
+        /*
+         * 指定使用的日志框架，否则将会告警
+         * RocketMQLog:WARN No appenders could be found for logger (io.netty.util.internal.InternalThreadLocalMap).
+         * RocketMQLog:WARN Please initialize the logger system properly.
+         */
+        System.setProperty("rocketmq.client.logUseSlf4j", "true");
+
+        SpringApplication.run(Application.class, args);
     }
 
 }

xfg-dev-tech-app/src/main/resources/application-dev.yml

@@ -8,6 +8,30 @@ spring:
     url: jdbc:mysql://127.0.0.1:3306/road-map?useUnicode=true&characterEncoding=utf8&autoReconnect=true&zeroDateTimeBehavior=convertToNull&serverTimezone=UTC&useSSL=true
     driver-class-name: com.mysql.jdbc.Driver
 
+
+rocketmq:
+  name-server: 127.0.0.1:9876
+  consumer:
+    group: xfg-group
+    # 一次拉取消息最大值，注意是拉取消息的最大值而非消费最大值
+    pull-batch-size: 10
+  producer:
+    # 发送同一类消息的设置为同一个group，保证唯一
+    group: xfg-group
+    # 发送消息超时时间，默认3000
+    sendMessageTimeout: 10000
+    # 发送消息失败重试次数，默认2
+    retryTimesWhenSendFailed: 2
+    # 异步消息重试此处，默认2
+    retryTimesWhenSendAsyncFailed: 2
+    # 消息最大长度，默认1024 * 1024 * 4(默认4M)
+    maxMessageSize: 4096
+    # 压缩消息阈值，默认4k(1024 * 4)
+    compressMessageBodyThreshold: 4096
+    # 是否在内部发送失败时重试另一个broker，默认false
+    retryNextServer: false
+
+
 mybatis:
   mapper-locations: classpath:/mybatis/mapper/*.xml
   config-location:  classpath:/mybatis/config/mybatis-config.xml
@@ -16,4 +40,7 @@ mybatis:
 logging:
   level:
     root: info
+    RocketmqClient: ERROR
+    io:
+      netty: ERROR
   config: classpath:logback-spring.xml
\ No newline at end of file