mq

caimei365-cloud-gateway/src/main/java/com/caimei365/cloud/config/WebConfiguration.java

@@ -1,12 +1,13 @@
 package com.caimei365.cloud.config;
 
 import com.caimei365.cloud.service.TouristService;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Configuration;
-import org.springframework.http.HttpCookie;
 import org.springframework.http.ResponseCookie;
+import org.springframework.http.HttpCookie;
 import org.springframework.http.server.reactive.ServerHttpRequest;
 import org.springframework.http.server.reactive.ServerHttpResponse;
 import org.springframework.stereotype.Component;
@@ -19,7 +20,6 @@ import reactor.core.publisher.Mono;
 import javax.annotation.PostConstruct;
 import javax.annotation.Resource;
 import java.net.InetSocketAddress;
-import java.util.List;
 import java.util.Objects;
 
 /**
@@ -28,6 +28,7 @@ import java.util.Objects;
  * @author : Charles
  * @date : 2021/3/24
  */
+@Slf4j
 @Configuration
 public class WebConfiguration implements WebFluxConfigurer {
 

caimei365-cloud-gateway/src/main/java/com/caimei365/cloud/service/TouristService.java

@@ -38,7 +38,6 @@ public class TouristService {
         Random random = new Random();
         Integer tourist = random.nextInt(900000) + 100000;
         touristId = tourist.toString();
-        log.info("touristId==="+touristId);
         sendCommonMessage("Tourist", touristId, null, 1, 1, null, null);
         return touristId;
     }
@@ -53,7 +52,6 @@ public class TouristService {
         boolean isSort = (sort != null && sort == 1);
         boolean isOneway = (oneway != null && oneway == 1);
         boolean isDelay = (delay != null && delay > 0);
-        log.info("destination----"+destination+"****message****"+message);
         if (!isAsync) {
             // 同步消息
             if (isDelay) {

caimei365-cloud-gateway/src/main/resources/application.yml

@@ -51,7 +51,7 @@ logging:
 
 # rocketmq 配置项，对应 RocketMQProperties 配置类
 rocketmq:
-  name-server: 47.107.48.218:9876  # RocketMQ Namesrv
+  name-server: 39.108.11.105:9876  # RocketMQ Namesrv
   producer:
-    group: caimei_beta_group        # 生产者分组
+    group: caimei_prod_group        # 生产者分组
     send-message-timeout: 3000     # 发送消息超时时间，单位：毫秒。默认为 3000 。