to #63

Author: flystar32

mse-simple-demo/A/pom.xml

@@ -68,6 +68,12 @@
             <version>2.7.7</version>
         </dependency>
 
+        <dependency>
+            <groupId>com.spring4all</groupId>
+            <artifactId>swagger-spring-boot-starter</artifactId>
+            <version>1.7.0.RELEASE</version>
+        </dependency>
+
 
     </dependencies>
 

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

@@ -1,30 +1,18 @@
-/*
- * Copyright (C) 2018 the original author or authors.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *      https://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
 
 package com.alibabacloud.mse.demo;
 
 import java.io.File;
 import java.io.FileReader;
 import java.io.IOException;
 import java.util.Enumeration;
+import java.util.List;
 import java.util.Properties;
 
 import javax.servlet.http.HttpServletRequest;
 
 import com.alibabacloud.mse.demo.service.HelloServiceB;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
 import org.apache.dubbo.config.annotation.Reference;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.SpringApplication;
@@ -91,6 +79,14 @@ public String dubbo(HttpServletRequest request) {
             return "A"+SERVICE_TAG+"[" + request.getLocalAddr() + "]" + " -> " +
                     helloServiceB.hello("A");
         }
+
+        @GetMapping("swagger-demo")
+        @ApiOperation(value = "这是一个演示swagger的接口 ", tags = {"首页操作页面"})
+        public String swagger(@ApiParam(name = "name", value = "我是姓名", required = true) String name,
+                              @ApiParam(name = "age", value = "我是年龄", required = true)int age,
+                              @ApiParam(name = "aliware-products", value = "我是购买阿里云原生产品列表", required = true) List<String> aliwareProducts) {
+            return "hello swagger";
+        }
     }
 
     public static String SERVICE_TAG="";

mse-simple-demo/A/src/main/java/com/alibabacloud/mse/demo/service/MqConsumer.java

@@ -1,33 +1,41 @@
 package com.alibabacloud.mse.demo.service;
 
-//import com.pingpongx.ocean.context.BusinessContext;
 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;
 import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
 import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
 import org.apache.rocketmq.common.message.MessageExt;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.cloud.commons.util.InetUtils;
 import org.springframework.stereotype.Component;
+import org.springframework.web.client.RestTemplate;
 
-/**
- * @author zhujy
- */
 @Slf4j
 @Component
 public class MqConsumer implements MessageListenerConcurrently {
 
+    @Autowired
+    RestTemplate restTemplate;
+
+    @Autowired
+    InetUtils inetUtils;
+
     @SneakyThrows
     @Override
     public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext consumeConcurrentlyContext) {
         try {
             MessageExt messageExt = list.get(0);
             String topic = messageExt.getTopic();
-            String tags = messageExt.getTags();
             String messageString = new String(messageExt.getBody(), StandardCharsets.UTF_8);
+            String result =  "A"+ AApplication.SERVICE_TAG+"[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
+                    restTemplate.getForObject("http://sc-B/b", String.class);
 
-            log.info("topic:{},tags:{},messageString:{}", topic, tags, messageString);
+            log.info("topic:{},producer:{},invoke result:{}", topic, messageString, result);
 
             return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
         } finally {

mse-simple-demo/B/src/main/java/com/alibabacloud/mse/demo/BApplication.java

@@ -32,9 +32,6 @@
 import java.io.IOException;
 import java.util.Properties;
 
-/**
- * @author <a href="mailto:[email protected]">Jim</a>
- */
 @SpringBootApplication
 public class BApplication {
 

mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/CApplication.java

@@ -32,9 +32,6 @@
 import java.io.IOException;
 import java.util.Properties;
 
-/**
- * @author <a href="mailto:[email protected]">Jim</a>
- */
 @SpringBootApplication
 public class CApplication {
 

mse-simple-demo/C/src/main/java/com/alibabacloud/mse/demo/service/HelloServiceCImpl.java

@@ -2,14 +2,17 @@
 
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 import org.apache.dubbo.config.annotation.DubboService;
+import org.apache.dubbo.rpc.RpcContext;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.common.message.Message;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.cloud.commons.util.InetUtils;
 
 import java.nio.charset.StandardCharsets;
+
 import static com.alibabacloud.mse.demo.CApplication.SERVICE_TAG;
 
 @Slf4j
@@ -25,19 +28,22 @@ public class HelloServiceCImpl implements HelloServiceC {
     @Value("${rocketmq.consumer.topic}")
     private String topic;
 
-
-
     @Override
     public String hello(String name) {
 
         String value = "C" + SERVICE_TAG + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]";
+        String invokerTag="";
+        String userData = RpcContext.getContext().getAttachment("__microservice_tag__");
+        if (!StringUtils.isEmpty(userData)) {
+            invokerTag = StringUtils.substringBefore(userData,",").split("\"")[3];
+        }
 
         try {
             Message msg = new Message();
             msg.setTopic(topic);
-            msg.setTags(SERVICE_TAG);
             msg.setBody(value.getBytes(StandardCharsets.UTF_8));
             producer.send(msg);
+            log.info("topic:{},messageString:{},__microservice_tag__:{}", topic, value, StringUtils.trimToNull(invokerTag));
         } catch (Exception e) {
             log.error("error:", e);
         }