Add dubbo-samples-async-result

2-advanced/dubbo-samples-async-result/dubbo-samples-async-result-consumer/pom.xml

@@ -0,0 +1,85 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<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">
+  <modelVersion>4.0.0</modelVersion>
+  <parent>
+    <groupId>org.apache.dubbo</groupId>
+    <artifactId>dubbo-samples-async-result</artifactId>
+    <version>1.0-SNAPSHOT</version>
+  </parent>
+
+  <artifactId>dubbo-samples-async-result-consumer</artifactId>
+
+  <properties>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+  <dependencies>
+    <!-- dubbo -->
+    <dependency>
+      <groupId>org.apache.dubbo</groupId>
+      <artifactId>dubbo</artifactId>
+      <version>${dubbo.version}</version>
+      <scope>provided</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.dubbo</groupId>
+      <artifactId>dubbo-spring-boot-starter</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.apache.dubbo</groupId>
+      <artifactId>dubbo-zookeeper-curator5-spring-boot-starter</artifactId>
+    </dependency>
+
+
+    <!-- spring starter -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter</artifactId>
+    </dependency>
+
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-log4j2</artifactId>
+    </dependency>
+
+    <!-- api interface -->
+    <dependency>
+      <groupId>org.apache.dubbo</groupId>
+      <artifactId>dubbo-samples-async-result-interface</artifactId>
+      <version>1.0-SNAPSHOT</version>
+    </dependency>
+
+    <!-- test -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>org.junit.jupiter</groupId>
+      <artifactId>junit-jupiter</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+
+  <build>
+    <plugins>
+      <plugin>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-maven-plugin</artifactId>
+        <executions>
+          <execution>
+            <goals>
+              <goal>repackage</goal>
+            </goals>
+          </execution>
+        </executions>
+      </plugin>
+    </plugins>
+  </build>
+
+</project>

2-advanced/dubbo-samples-async-result/dubbo-samples-async-result-consumer/src/main/java/org/apache/dubbo/ConsumerApplication.java

@@ -0,0 +1,30 @@
+/*
+ * 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;
+
+import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+@EnableDubbo
+public class ConsumerApplication {
+    public static void main(String[] args) {
+        SpringApplication.run(ConsumerApplication.class, args);
+    }
+}

2-advanced/dubbo-samples-async-result/dubbo-samples-async-result-consumer/src/main/java/org/apache/dubbo/HiConsumer.java

@@ -0,0 +1,95 @@
+/*
+ * 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;
+
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.apache.dubbo.rpc.RpcContext;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.TimeUnit;
+
+@Component
+public class HiConsumer {
+    private static final Logger logger = LoggerFactory.getLogger(HiConsumer.class);
+
+    @DubboReference(async = true, check = false)
+    private HiService hiService;
+
+
+    public void asyncCallMethod1() {
+
+        CompletableFuture<String> future = hiService.sayHelloAsync("Alice");
+
+        future.whenComplete((result, error) -> {
+            if (error != null) {
+                logger.debug("failed: {}", error.getMessage());
+            } else {
+                logger.info("result: {}", result);
+            }
+        });
+
+        future.thenApply(result -> "[PROCESSED] " + result.toUpperCase())
+                .thenAccept(processed -> logger.info("result: {}", processed));
+
+        try {
+            String result = future.get(3000, TimeUnit.MILLISECONDS);
+            logger.info("sync wait result: {}", result);
+        } catch (Exception e) {
+            logger.debug(e.getMessage());
+        }
+    }
+
+
+    public void asyncCallMethod2() {
+
+        String syncResult = hiService.sayHello("Bob");
+        logger.info("sync return value (usually null, meaningless): {}", syncResult);
+
+        CompletableFuture<Object> future = RpcContext.getServiceContext().getCompletableFuture();
+
+        if (future != null) {
+            future.whenComplete((result, error) -> {
+                if (error != null) {
+                    logger.error(error.getMessage());
+                } else {
+                    logger.info("async callback result: {}", result);
+                }
+            });
+
+            future.thenApply(result -> "[PROCESSED] " + ((String) result).toUpperCase())
+                    .thenAccept(processed -> logger.info("result: {}", processed));
+
+            try {
+                Object result = future.get(3000, TimeUnit.MILLISECONDS);
+                logger.info("sync wait result: {}", result);
+            } catch (Exception e) {
+                logger.debug(e.getMessage());
+            }
+        }
+    }
+
+
+    public void compareDemo() {
+        asyncCallMethod1();
+        asyncCallMethod2();
+    }
+
+}

2-advanced/dubbo-samples-async-result/dubbo-samples-async-result-consumer/src/main/resources/application.yaml

@@ -0,0 +1,30 @@
+# 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.
+dubbo:
+  application:
+    name: dubbo-samples-async-result-consumer
+  protocol:
+    name: tri
+    port: -1
+  registry:
+    address: zookeeper://${zookeeper.address:127.0.0.1}:2181
+
+logging:
+  level:
+    org.apache.dubbo: DEBUG
+    org.apache.dubbo.rpc.AsyncRpcResult: DEBUG
+  pattern:
+    console: "%d{HH:mm:ss.SSS} %highlight{%-5p} [%t] %c{1.}:%L - %m%n"