triple-flowcontrol test

dubbo-samples-triple-flowcontrol/README.MD

@@ -0,0 +1,51 @@
+## Triple-Samples
+
+[Triple](https://dubbo.apache.org/zh/docs/concepts/rpc-protocol/) is an application layer's protocol based on HTTP/2,
+which supports interoperating with GRPC protocol naturally using Protobuf serialization. For non-protobuf applications,
+triple provides a compatible mode to upgrade without code modifications. So it is smooth to migrate to triple.
+
+This sample project contains most scenarios of Dubbo and non-Dubbo interoperation.
+
+## Before Start
+
+Generate protobuf class for IDE hints.
+
+```shell
+mvn clean -DskipTests=true
+```
+
+### For beginners
+
+1. Start a zookeeper or config other registry in `TriStubServer`
+   and `TriStubClient`
+2. Build with `mvn clean install` to generate protobuf classes.
+3. Run `TriStubServer`
+4. Run `TriStubClient`
+
+### For dubbo2 or non-prototbuf users
+
+Run `TriPojoServer` and `TriPojoClient`.
+
+Dubbo3 will wrap request and response with a protobuf wrapper automatically, so it is still compatible with GRPC.
+
+### For Dubbo developers
+
+Code under `test` folder is a general interoperation test suite for both Dubbo/Dubbo and Dubbo/GRPC.
+
+#### Dubbo/Dubbo test
+
+1. Run `org.apache.dubbo.sample.tri.TriGrpcProvider`
+2. Run `TriClientTest` , `TriPojoClientTest`
+   and `TriGenericTest`
+
+#### Dubbo/GRPC test
+
+##### GRPC --> Dubbo
+
+1. Run `org.apache.dubbo.sample.tri.TriGrpcProvider`
+2. Run `GrpcClientTest`
+
+##### Dubbo --> GRPC
+
+1. Run `org.apache.dubbo.sample.tri.grpc.GrpcServer`
+2. Run `TriClientTest`

dubbo-samples-triple-flowcontrol/case-configuration.yml

@@ -0,0 +1,49 @@
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you 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
+#
+#     http://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.
+
+services:
+  dubbo-samples-triple-flowcontrol:
+    type: app
+    basedir: .
+    checkPorts:
+      - 2181
+      - 50052
+      - 50053
+    mainClass: org.apache.dubbo.sample.tri.flowcontrol.TriFlowcontrolServer
+
+  dubbo-samples-triple-flowcontrol-test:
+    type: test
+    basedir: .
+    tests:
+      # tri-->tri
+      - "org.apache.dubbo.sample.tri.flowcontrol/TriFlowcontrolClientTest.class"
+
+    systemProps:
+      - zookeeper.host=dubbo-samples-triple-flowcontrol
+      - zookeeper.port=2181
+      - provider.host=dubbo-samples-triple-flowcontrol
+      - provider.port=50052
+      - grpc.provider.port=50053
+    waitPortsBeforeRun:
+      - dubbo-samples-triple-flowcontrol:2181
+      - dubbo-samples-triple-flowcontrol:50052
+      - dubbo-samples-triple-flowcontrol:50053
+    depends_on:
+      - dubbo-samples-triple-flowcontrol
+
+
+
+

dubbo-samples-triple-flowcontrol/case-versions.conf

@@ -0,0 +1,24 @@
+#
+#
+#   Licensed to the Apache Software Foundation (ASF) under one or more
+#   contributor license agreements.  See the NOTICE file distributed with
+#   this work for additional information regarding copyright ownership.
+#   The ASF licenses this file to You 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
+#
+#       http://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.
+#
+
+# Supported component versions of the test case
+
+# Spring app
+dubbo.version=[ >=3.1.0 ]
+spring.version=4.*, 5.*
+compiler.version=0.0.*, 3.*

dubbo-samples-triple-flowcontrol/pom.xml

@@ -0,0 +1,192 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+  ~  Licensed to the Apache Software Foundation (ASF) under one or more
+  ~  contributor license agreements.  See the NOTICE file distributed with
+  ~  this work for additional information regarding copyright ownership.
+  ~  The ASF licenses this file to You 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
+  ~
+  ~      http://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.
+  -->
+
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>dubbo-samples-all</artifactId>
+        <groupId>org.apache.dubbo</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>dubbo-samples-triple-flowcontrol</artifactId>
+
+    <properties>
+        <source.level>1.8</source.level>
+        <target.level>1.8</target.level>
+        <dubbo.version>3.0.8</dubbo.version>
+        <grpc.version>1.44.1</grpc.version>
+        <junit.version>4.12</junit.version>
+        <spring-test.version>4.3.16.RELEASE</spring-test.version>
+        <maven-compiler-plugin.version>3.7.0</maven-compiler-plugin.version>
+        <maven-failsafe-plugin.version>2.21.0</maven-failsafe-plugin.version>
+        <spring-boot.version>1.5.13.RELEASE</spring-boot.version>
+        <protoc.version>3.19.4</protoc.version>
+        <compiler.version>0.0.4.1</compiler.version>
+    </properties>
+
+    <dependencies>
+
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo</artifactId>
+            <version>${dubbo.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>3.19.4</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-dependencies-zookeeper-curator5</artifactId>
+            <version>${dubbo.version}</version>
+            <type>pom</type>
+        </dependency>
+        <dependency>
+            <groupId>io.grpc</groupId>
+            <artifactId>grpc-all</artifactId>
+            <version>${grpc.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>junit</groupId>
+            <artifactId>junit</artifactId>
+            <version>${junit.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>${spring-test.version}</version>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.testcontainers</groupId>
+            <artifactId>testcontainers</artifactId>
+            <version>1.12.3</version>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <profiles>
+        <!-- For jdk 11 above JavaEE annotation -->
+        <profile>
+            <id>javax.annotation</id>
+            <activation>
+                <jdk>[1.11,)</jdk>
+            </activation>
+            <dependencies>
+                <dependency>
+                    <groupId>javax.annotation</groupId>
+                    <artifactId>javax.annotation-api</artifactId>
+                    <version>1.3.2</version>
+                </dependency>
+            </dependencies>
+        </profile>
+    </profiles>
+
+    <build>
+        <extensions>
+            <extension>
+                <groupId>kr.motd.maven</groupId>
+                <artifactId>os-maven-plugin</artifactId>
+                <version>1.6.1</version>
+            </extension>
+        </extensions>
+        <plugins>
+            <plugin>
+                <groupId>org.xolstice.maven.plugins</groupId>
+                <artifactId>protobuf-maven-plugin</artifactId>
+                <version>0.6.1</version>
+                <configuration>
+                    <protocArtifact>com.google.protobuf:protoc:${protoc.version}:exe:${os.detected.classifier}
+                    </protocArtifact>
+                    <pluginId>grpc-java</pluginId>
+                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}
+                    </pluginArtifact>
+                    <protocPlugins>
+                        <protocPlugin>
+                            <id>dubbo</id>
+                            <groupId>org.apache.dubbo</groupId>
+                            <artifactId>dubbo-compiler</artifactId>
+                            <version>${compiler.version}</version>
+                            <mainClass>org.apache.dubbo.gen.tri.Dubbo3TripleGenerator</mainClass>
+                        </protocPlugin>
+                    </protocPlugins>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>compile</goal>
+                            <goal>test-compile</goal>
+                            <goal>compile-custom</goal>
+                            <goal>test-compile-custom</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${maven-compiler-plugin.version}</version>
+                <configuration>
+                    <source>${source.level}</source>
+                    <target>${target.level}</target>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-dependency-plugin</artifactId>
+                <version>3.2.0</version>
+                <executions>
+                    <execution>
+                        <id>copy-dependencies</id>
+                        <phase>prepare-package</phase>
+                        <goals>
+                            <goal>copy-dependencies</goal>
+                        </goals>
+                        <configuration>
+                            <outputDirectory>
+                                ${project.build.directory}/lib
+                            </outputDirectory>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <!-- Build an executable JAR -->
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-jar-plugin</artifactId>
+                <version>3.1.0</version>
+                <configuration>
+                    <archive>
+                        <manifest>
+                            <addClasspath>true</addClasspath>
+                            <classpathPrefix>lib/</classpathPrefix>
+                            <mainClass>TriStubServer</mainClass>
+                        </manifest>
+                    </archive>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

dubbo-samples-triple-flowcontrol/src/main/java/org/apache/dubbo/sample/tri/flowcontrol/TriFlowcontrolServer.java

@@ -0,0 +1,76 @@
+/*
+ *  Licensed to the Apache Software Foundation (ASF) under one or more
+ *  contributor license agreements.  See the NOTICE file distributed with
+ *  this work for additional information regarding copyright ownership.
+ *  The ASF licenses this file to You 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
+ *
+ *      http://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 org.apache.dubbo.sample.tri.flowcontrol;
+
+import org.apache.dubbo.common.constants.CommonConstants;
+import org.apache.dubbo.common.context.Lifecycle;
+import org.apache.dubbo.config.ApplicationConfig;
+import org.apache.dubbo.config.ProtocolConfig;
+import org.apache.dubbo.config.RegistryConfig;
+import org.apache.dubbo.config.ServiceConfig;
+import org.apache.dubbo.config.bootstrap.DubboBootstrap;
+import org.apache.dubbo.sample.tri.flowcontrol.api.PojoGreeter;
+import org.apache.dubbo.sample.tri.flowcontrol.flowcontrol.PojoGreeterImpl;
+import org.apache.dubbo.sample.tri.flowcontrol.util.EmbeddedZooKeeper;
+import org.apache.dubbo.sample.tri.flowcontrol.util.TriSampleConstants;
+
+import java.io.IOException;
+
+/**
+ * A sample for using tri protocol with manual java interface and POJO
+ */
+public class TriFlowcontrolServer implements Lifecycle {
+    private final int port;
+
+    public TriFlowcontrolServer(int serverPort) {
+        this.port = serverPort;
+    }
+
+    public static void main(String[] args) throws IOException {
+        TriFlowcontrolServer server = new TriFlowcontrolServer(TriSampleConstants.SERVER_PORT);
+        server.initialize();
+        server.start();
+        System.in.read();
+    }
+
+    @Override
+    public void initialize() throws IllegalStateException {
+        new EmbeddedZooKeeper(TriSampleConstants.ZK_PORT, false).start();
+    }
+
+    @Override
+    public void start() throws IllegalStateException {
+        ServiceConfig<PojoGreeter> service = new ServiceConfig<>();
+        service.setInterface(PojoGreeter.class);
+        service.setRef(new PojoGreeterImpl());
+
+        System.setProperty("dubbo.rpc.tri.initial-window-size","65535");
+
+        DubboBootstrap bootstrap = DubboBootstrap.getInstance();
+        bootstrap.application(new ApplicationConfig("tri-stub-server"))
+                .registry(new RegistryConfig(TriSampleConstants.ZK_ADDRESS))
+                .protocol(new ProtocolConfig(CommonConstants.TRIPLE, port))
+                .service(service)
+                .start();
+    }
+
+    @Override
+    public void destroy() throws IllegalStateException {
+        DubboBootstrap.getInstance().stop();
+    }
+}