update example

chickenlj · Apr 27, 2024 · b2a0582 · b2a0582
1 parent 91e1b8c
commit b2a0582
Show file tree

Hide file tree

Showing 4 changed files with 84 additions and 16 deletions.
diff --git a/...ix/dubbo-samples-gateway-apisix-dubbo/dubbo-samples-gateway-apisix-dubbo-consumer/pom.xml b/...ix/dubbo-samples-gateway-apisix-dubbo/dubbo-samples-gateway-apisix-dubbo-consumer/pom.xml
@@ -42,6 +42,10 @@
             <groupId>org.apache.dubbo</groupId>
             <artifactId>dubbo-spring-boot-starter</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.apache.dubbo</groupId>
+            <artifactId>dubbo-nacos-spring-boot-starter</artifactId>
+        </dependency>
 
         <!-- spring starter -->
         <dependency>

diff --git a/...main/java/org/apache/dubbo/samples/gateway/apisix.dubbo/consumer/ConsumerApplication.java b/...main/java/org/apache/dubbo/samples/gateway/apisix.dubbo/consumer/ConsumerApplication.java
@@ -0,0 +1,31 @@
+/*
+ * 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.samples.gateway.apisix.dubbo.consumer;
+
+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);
+    }
+}
diff --git a/...o-consumer/src/main/java/org/apache/dubbo/samples/gateway/apisix.dubbo/consumer/Task.java b/...o-consumer/src/main/java/org/apache/dubbo/samples/gateway/apisix.dubbo/consumer/Task.java
@@ -0,0 +1,48 @@
+/*
+ * 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.samples.gateway.apisix.dubbo.consumer;
+
+import org.apache.dubbo.config.annotation.DubboReference;
+import org.apache.dubbo.samples.gateway.apisix.dubbo.api.DemoService;
+import org.springframework.boot.CommandLineRunner;
+import org.springframework.stereotype.Component;
+import java.util.Date;
+
+@Component
+public class Task implements CommandLineRunner {
+
+    @DubboReference
+    private DemoService demoService;
+
+    @Override
+    public void run(String... args) throws Exception {
+        String result = demoService.sayHello("world");
+        System.out.println("Receive result ======> " + result);
+
+        new Thread(()-> {
+            while (true) {
+                try {
+                    Thread.sleep(1000);
+                    System.out.println(new Date() + " Receive result ======> " + demoService.sayHello("world"));
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                    Thread.currentThread().interrupt();
+                }
+            }
+        }).start();
+    }
+}
diff --git a/...ess-dubbo-consumer/src/main/java/org/apache/dubbo/samples/gateway/consumer/task/Task.java b/...ess-dubbo-consumer/src/main/java/org/apache/dubbo/samples/gateway/consumer/task/Task.java
@@ -30,22 +30,7 @@ public class Task implements CommandLineRunner {
 
     @Override
     public void run(String... args) throws Exception {
-        System.out.println("Receive result ======> " + proxyHello());
-        System.out.println("Receive rest result ======> " + restHello());
-
-    }
-
-    private String proxyHello() {
-        return demoService.sayHello("world");
+        System.out.println("Receive result ======> " + demoService.sayHello("world"));
     }
 
-    private String restHello() {
-        RestClient defaultClient = RestClient.create();
-        ResponseEntity<String> result = defaultClient.get()
-                .uri("http://localhost:50052/demo/hello?name=world")
-                .header("Content-type", "application/json")
-                .retrieve()
-                .toEntity(String.class);
-        return result.getBody();
-    }
 }