add springgateway,B and C add dubbo 2, upgrade the version to 3.0.1 (#155)

* feature:加入各种注释

* feature:加入SpringCloudGatewy、B服务和C服务增加2个dubbo注册接口、升级版本为3.0.1

* feature:修改helm版本

Author: xinlunanxinlunan

mse-go-demo/a-server/go.mod

@@ -4,6 +4,7 @@ go 1.19
 
 require (
 	google.golang.org/grpc v1.40.0
+	google.golang.org/protobuf v1.27.1
 )
 
 require (
@@ -12,5 +13,4 @@ require (
 	golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd // indirect
 	golang.org/x/text v0.3.0 // indirect
 	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
-	google.golang.org/protobuf v1.27.1 // indirect
 )

mse-go-demo/b-server/go.mod

@@ -4,6 +4,7 @@ go 1.19
 
 require (
 	google.golang.org/grpc v1.40.0
+	google.golang.org/protobuf v1.27.1
 )
 
 require (
@@ -12,5 +13,4 @@ require (
 	golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd // indirect
 	golang.org/x/text v0.3.0 // indirect
 	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
-	google.golang.org/protobuf v1.27.1 // indirect
 )

mse-go-demo/c-server/go.mod

@@ -4,6 +4,7 @@ go 1.19
 
 require (
 	google.golang.org/grpc v1.40.0
+	google.golang.org/protobuf v1.27.1
 )
 
 require (
@@ -12,5 +13,4 @@ require (
 	golang.org/x/sys v0.0.0-20200323222414-85ca7c5b95cd // indirect
 	golang.org/x/text v0.3.0 // indirect
 	google.golang.org/genproto v0.0.0-20200526211855-cb27e3aa2013 // indirect
-	google.golang.org/protobuf v1.27.1 // indirect
 )

mse-simple-demo/A/Dockerfile

@@ -36,6 +36,7 @@ FROM dragonwell-registry.cn-hangzhou.cr.aliyuncs.com/dragonwell/dragonwell:8-ext
 COPY --from=hengyunabc/arthas:latest /opt/arthas /opt/arthas
 
 COPY --from=build /app/target/A.jar /app/target/A.jar
+#COPY  ./target/A.jar /app/target/A.jar
 
 EXPOSE 20001
 ENTRYPOINT ["sh", "-c"]

mse-simple-demo/A/build.sh

@@ -1,10 +1,16 @@
 #!/bin/sh
+
+export REGISTRY=${REGISTRY}
+
+export appName=spring-cloud-a
+export version=3.0.1
+
 set -e
 
 cd "$(dirname "$0")"
 
-docker build --platform linux/amd64 . -t ${REGISTRY}spring-cloud-a:2.0.3
+docker build --platform linux/amd64 . -t ${REGISTRY}${appName}:${version}
 
 if [ -n "${REGISTRY}" ]; then
-    docker push ${REGISTRY}spring-cloud-a:2.0.3
-fi
+    docker push ${REGISTRY}${appName}:${version}
+fi

mse-simple-demo/A/pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.alibabacloud.mse.demo</groupId>
     <artifactId>A</artifactId>
-    <version>2.0.2</version>
+    <version>${all.project.version}</version>
     <packaging>jar</packaging>
 
     <name>A</name>

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

@@ -3,6 +3,7 @@
 import com.alibabacloud.mse.demo.a.service.FeignClientTest;
 import com.alibabacloud.mse.demo.b.service.HelloServiceB;
 import com.alibaba.fastjson.JSON;
+import com.alibabacloud.mse.demo.b.service.HelloServiceBTwo;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
@@ -51,6 +52,9 @@ class AController {
     @Reference(application = "${dubbo.application.id}", version = "1.2.0")
     private HelloServiceB helloServiceB;
 
+    @Reference(application = "${dubbo.application.id}", version = "1.2.0")
+    private HelloServiceBTwo helloServiceBTwo;
+
     @Autowired
     String serviceTag;
 
@@ -68,6 +72,7 @@ private void init() {
                     .setConnectTimeout(1000)
                     .setSocketTimeout(1000)
                     .build();
+            //在阿里云中判断在哪个地区的内网服务地址，如杭州会输出cn-hangzhou-g
             HttpGet req = new HttpGet("http://100.100.100.200/latest/meta-data/zone-id");
             req.setConfig(requestConfig);
             HttpResponse response = client.execute(req);
@@ -81,6 +86,7 @@ private void init() {
     @GetMapping("/a")
     public String a(HttpServletRequest request) throws ExecutionException, InterruptedException {
         StringBuilder headerSb = new StringBuilder();
+        //枚举创建完后无法更改
         Enumeration<String> enumeration = request.getHeaderNames();
         while (enumeration.hasMoreElements()) {
             String headerName = enumeration.nextElement();
@@ -90,7 +96,7 @@ public String a(HttpServletRequest request) throws ExecutionException, Interrupt
                 headerSb.append(headerName + ":" + headerVal + ",");
             }
         }
-
+        //这是rpc调用的方式
         String result = loadBalancedRestTemplate.getForObject("http://sc-B/b", String.class);
 
         return "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" +
@@ -228,6 +234,24 @@ public String dubbo(HttpServletRequest request) {
                 helloServiceB.hello(JSON.toJSONString(request.getParameterMap()));
     }
 
+
+    @ApiOperation(value = "Dubbo 全链路灰度入口", tags = {"入口应用"})
+    @GetMapping("/dubbo2")
+    public String dubbo2(HttpServletRequest request) {
+        StringBuilder headerSb = new StringBuilder();
+        Enumeration<String> enumeration = request.getHeaderNames();
+        while (enumeration.hasMoreElements()) {
+            String headerName = enumeration.nextElement();
+            Enumeration<String> val = request.getHeaders(headerName);
+            while (val.hasMoreElements()) {
+                String headerVal = val.nextElement();
+                headerSb.append(headerName + ":" + headerVal + ",");
+            }
+        }
+        return "A" + serviceTag + "[" + inetUtils.findFirstNonLoopbackAddress().getHostAddress() + "]" + " -> " +
+                helloServiceBTwo.hello(JSON.toJSONString(request.getParameterMap()));
+    }
+
     @ApiOperation(value = "Dubbo 限流测试", tags = {"入口应用"})
     @GetMapping("/dubbo-flow")
     public String dubbo_flow(HttpServletRequest request) {

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

@@ -6,6 +6,7 @@
 @Component
 public class FeignClientFallback implements FallbackFactory<FeignClientTest> {
 
+
     static class FeignClientTestFallback implements FeignClientTest {
 
         private final String finalMsg;
@@ -30,6 +31,7 @@ public String circuit_breaker_exception_b() {
         }
     }
 
+    //
     @Override
     public FeignClientTest create(Throwable throwable) {
         if (throwable == null) {

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

@@ -9,6 +9,7 @@
  * @author yushan
  * @date 2023年02月21日
  */
+//这是springcloud  RPCFeignClient的调用方式
 @Component
 @FeignClient(name = "sc-B", fallbackFactory = FeignClientFallback.class)
 public interface FeignClientTest {

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

@@ -0,0 +1,7 @@
+package com.alibabacloud.mse.demo.b.service;
+
+public interface HelloServiceBTwo {
+    String hello(String name);
+    String slow();
+    String exception();
+}