reorg demo app

Author: robberphex

mse-simple-demo/A/pom.xml

@@ -86,6 +86,11 @@
             <version>4.5.13</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.12.0</version>
+        </dependency>
     </dependencies>
 
     <dependencyManagement>

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/AApplication.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/AApplication.java

@@ -1,5 +1,5 @@
 
-package com.alibabacloud.mse.demo;
+package com.alibabacloud.mse.demo.a;
 
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.boot.SpringApplication;

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/AController.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/AController.java

@@ -1,6 +1,6 @@
-package com.alibabacloud.mse.demo;
+package com.alibabacloud.mse.demo.a;
 
-import com.alibabacloud.mse.demo.service.HelloServiceB;
+import com.alibabacloud.mse.demo.b.service.HelloServiceB;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -27,9 +27,7 @@
 import javax.servlet.http.HttpServletRequest;
 import java.util.Enumeration;
 import java.util.List;
-import java.util.Random;
 import java.util.concurrent.ExecutionException;
-import java.util.concurrent.TimeUnit;
 
 @Api(value = "/", tags = {"入口应用"})
 @RestController

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/Swagger2Config.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/Swagger2Config.java

@@ -1,4 +1,4 @@
-package com.alibabacloud.mse.demo;
+package com.alibabacloud.mse.demo.a;
 
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/service/MqConsumer.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/mq/MqConsumer.java

@@ -1,9 +1,8 @@
-package com.alibabacloud.mse.demo.service;
+package com.alibabacloud.mse.demo.a.mq;
 
 import java.nio.charset.StandardCharsets;
 import java.util.List;
 
-import com.alibabacloud.mse.demo.AApplication;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
@@ -19,14 +18,17 @@
 @Component
 public class MqConsumer implements MessageListenerConcurrently {
 
-    @Autowired
-    RestTemplate restTemplate;
+    private RestTemplate restTemplate;
 
-    @Autowired
-    InetUtils inetUtils;
+    private InetUtils inetUtils;
 
-    @Autowired
-    String servcieTag;
+    private String serviceTag;
+
+    public MqConsumer(RestTemplate restTemplate, InetUtils inetUtils, String serviceTag) {
+        this.restTemplate = restTemplate;
+        this.inetUtils = inetUtils;
+        this.serviceTag = serviceTag;
+    }
 
     @SneakyThrows
     @Override
@@ -35,7 +37,7 @@ public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeCo
             MessageExt messageExt = list.get(0);
             String topic = messageExt.getTopic();
             String messageString = new String(messageExt.getBody(), StandardCharsets.UTF_8);
-            String result =  "A"+ servcieTag+"[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
+            String result = "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
                     restTemplate.getForObject("http://sc-B/b", String.class);
 
             log.info("topic:{},producer:{},invoke result:{}", topic, messageString, result);

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/RocketMqConfiguration.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/mq/RocketMqConfiguration.java

@@ -1,14 +1,17 @@
-package com.alibabacloud.mse.demo;
+package com.alibabacloud.mse.demo.a.mq;
 
-import com.alibabacloud.mse.demo.service.MqConsumer;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.common.consumer.ConsumeFromWhere;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.commons.util.InetUtils;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.web.client.RestTemplate;
 
 @Slf4j
 @Configuration
@@ -24,7 +27,15 @@ public class RocketMqConfiguration {
     @Value("${rocketmq.consumer.topic}")
     private String topic;
 
-    private final MqConsumer mqConsumer;
+    @Autowired
+    @Qualifier("loadBalancedRestTemplate")
+    private RestTemplate restTemplate;
+
+    @Autowired
+    private InetUtils inetUtils;
+
+    @Autowired
+    private String serviceTag;
 
     static {
         System.setProperty("rocketmq.client.log.loadconfig", "false");
@@ -37,6 +48,12 @@ public DefaultMQPushConsumer mqPushConsumer() throws MQClientException {
         consumer.setNamesrvAddr(nameSrvAddr);
         consumer.subscribe(topic, "*");
         consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
+
+        MqConsumer mqConsumer = new MqConsumer(
+                restTemplate,
+                inetUtils,
+                serviceTag
+        );
         consumer.registerMessageListener(mqConsumer);
         log.info("完成启动rocketMq的consumer,subscribe:{}", topic);
         return consumer;

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceA.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/service/HelloServiceA.java

@@ -1,4 +1,4 @@
-package com.alibabacloud.mse.demo.service;
+package com.alibabacloud.mse.demo.a.service;
 
 public interface HelloServiceA {
     String hello(String name);

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceAImpl.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/a/service/HelloServiceAImpl.java

@@ -1,6 +1,7 @@
-package com.alibabacloud.mse.demo.service;
+package com.alibabacloud.mse.demo.a.service;
 
 
+import com.alibabacloud.mse.demo.b.service.HelloServiceB;
 import org.apache.dubbo.config.annotation.Reference;
 import org.apache.dubbo.config.annotation.Service;
 import org.springframework.beans.factory.annotation.Autowired;

mse-simple-demo/B/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceB.java renamed to mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/b/service/HelloServiceB.java

@@ -1,4 +1,4 @@
-package com.alibabacloud.mse.demo.service;
+package com.alibabacloud.mse.demo.b.service;
 
 public interface HelloServiceB {
     String hello(String name);

mse-simple-demo/A/src/main/resources/application.properties

@@ -15,7 +15,7 @@ dubbo.registry.id=nacos
 dubbo.registry.address=nacos://${nacos.host}:8848
 dubbo.registry.parameters.namespace=${nacos.namespace}
 dubbo.consumer.check=false
-dubbo.scan.base-packages=com.alibabacloud.mse.demo.service
+dubbo.scan.base-packages=com.alibabacloud.mse.demo
 dubbo.protocol.port=38080
 dubbo.registry.check=false