rocketmq-初步尝试

accompany-base/pom.xml

@@ -24,10 +24,6 @@
             <groupId>org.redisson</groupId>
             <artifactId>redisson-spring-boot-starter</artifactId>
         </dependency>
-        <dependency>
-            <groupId>org.redisson</groupId>
-            <artifactId>redisson-spring-data-20</artifactId>
-        </dependency>
     </dependencies>
 
 </project>

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/GiftSendService.java

@@ -16,6 +16,7 @@ import com.accompany.business.service.luckybag.LuckyBagPoolService;
 import com.accompany.business.service.luckybag.LuckyBagRecordService;
 import com.accompany.business.service.luckybag.filter.*;
 import com.accompany.business.service.mq.ActiveMQService;
+import com.accompany.business.service.mq.RocketMQService;
 import com.accompany.business.service.purse.UserPurseService;
 import com.accompany.business.service.room.RoomGiftValueService;
 import com.accompany.business.service.room.RoomService;
@@ -99,7 +100,8 @@ public class GiftSendService extends BaseService {
     private LuckyBagSendService luckyBagSendService;
     @Autowired
     private VipAuthItemService vipAuthItemService;
-
+    @Autowired
+    private RocketMQService rocketMQService;
 
     private List<LuckyBagGiftPrizePoolFilter> filters;
     @PostConstruct
@@ -406,6 +408,7 @@ public class GiftSendService extends BaseService {
         // 缓存消息的消费状态，便于队列消息做幂等处理
         jedisService.hwrite(RedisKey.mq_gift_status.getKey(), message.getMessId(), gson.toJson(message));
         activeMQService.sendGiftMessage(message);
+        rocketMQService.sendGiftMessage(message);
         //通知观察者已经送出礼物
         try {
             applicationContext.publishEvent(new RoomPKEvent(message));

accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/mq/RocketMQService.java

@@ -0,0 +1,29 @@
+package com.accompany.business.service.mq;
+
+import com.accompany.business.message.GiftMessage;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.rocketmq.spring.core.RocketMQTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * Created by 恒仔 on 2023/3/12.
+ */
+@Slf4j
+@Service
+public class RocketMQService {
+
+    @Autowired
+    private RocketMQTemplate rocketMQTemplate;
+
+    /**
+     * 送礼物消息，发送到MQ
+     *
+     * @param giftMessage
+     */
+    public void sendGiftMessage(GiftMessage giftMessage) {
+        log.info("sendGiftMessage gift message: {}", giftMessage);
+        rocketMQTemplate.convertAndSend("gift-queue",giftMessage);
+    }
+
+}

accompany-business/accompany-business-web/src/main/resources/application-native.yml

@@ -58,5 +58,12 @@ elasticsearch:
   roomIndex: yinyou_dev_room
   userIndex: yinyou_dev_users_202204121516
 
+## rocketmq 配置
+rocketmq:
+  name-server: 128.1.134.148:9876
+  producer:
+    group: peko-group
+    sendMessageTimeout: 300000
+
 server:
-  port: 8081
+  port: 8081

pom.xml

@@ -94,12 +94,13 @@
         <jackson-module-kotlin.version>2.9.7</jackson-module-kotlin.version>
         <jackson-mapper-asl.version>1.9.13</jackson-mapper-asl.version>
         <sud-mgp-auth-java.version>1.0.2</sud-mgp-auth-java.version>
-        <redisson.version>3.16.8</redisson.version>
+        <redisson.version>3.20.0</redisson.version>
         <kotlin.compiler.incremental>true</kotlin.compiler.incremental>
         <esayexcel.version>3.1.5</esayexcel.version>
         <googlecode-libphonenumber.version>8.12.43</googlecode-libphonenumber.version>
         <ip2region.version>2.7.0</ip2region.version>
         <opencc4j.version>1.7.2</opencc4j.version>
+        <rocketmq-spring-boot-starter.version>2.2.3</rocketmq-spring-boot-starter.version>
     </properties>
 
     <dependencyManagement>
@@ -487,17 +488,6 @@
                 <groupId>org.redisson</groupId>
                 <artifactId>redisson-spring-boot-starter</artifactId>
                 <version>${redisson.version}</version>
-                <exclusions>
-                    <exclusion>
-                        <groupId>org.redisson</groupId>
-                        <artifactId>redisson-spring-data-25</artifactId>
-                    </exclusion>
-                </exclusions>
-            </dependency>
-            <dependency>
-                <groupId>org.redisson</groupId>
-                <artifactId>redisson-spring-data-20</artifactId>
-                <version>${redisson.version}</version>
             </dependency>
             <dependency>
                 <groupId>com.googlecode.libphonenumber</groupId>
@@ -976,6 +966,13 @@
             <version>${opencc4j.version}</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.rocketmq</groupId>
+            <artifactId>rocketmq-spring-boot-starter</artifactId>
+            <version>${rocketmq-spring-boot-starter.version}</version>
+        </dependency>
+
+
     </dependencies>
 
     <build>