This is an automated email from the ASF dual-hosted git repository.
albumenj pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo-samples.git
The following commit(s) were added to refs/heads/master by this push:
new fc436732 Add always demo for API (#713)
fc436732 is described below
commit fc4367328a2e1ad97203567a52d96d9e2f2b1032
Author: Albumen Kevin <[email protected]>
AuthorDate: Sun Jan 29 11:44:58 2023 +0800
Add always demo for API (#713)
---
.../AlwaysApplication.java} | 35 +++++++++++++++-------
.../apache/dubbo/samples/provider/Application.java | 2 ++
2 files changed, 26 insertions(+), 11 deletions(-)
diff --git
a/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
b/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/client/AlwaysApplication.java
similarity index 61%
copy from
1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
copy to
1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/client/AlwaysApplication.java
index 1cefa594..36d5b836 100644
---
a/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
+++
b/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/client/AlwaysApplication.java
@@ -15,28 +15,41 @@
* limitations under the License.
*/
-package org.apache.dubbo.samples.provider;
+package org.apache.dubbo.samples.client;
+import java.io.IOException;
+import java.util.Date;
+
+import org.apache.dubbo.config.ReferenceConfig;
import org.apache.dubbo.config.RegistryConfig;
-import org.apache.dubbo.config.ServiceConfig;
import org.apache.dubbo.config.bootstrap.DubboBootstrap;
import org.apache.dubbo.samples.api.GreetingsService;
-public class Application {
+public class AlwaysApplication {
private static final String ZOOKEEPER_HOST =
System.getProperty("zookeeper.address", "127.0.0.1");
private static final String ZOOKEEPER_PORT =
System.getProperty("zookeeper.port", "2181");
private static final String ZOOKEEPER_ADDRESS = "zookeeper://" +
ZOOKEEPER_HOST + ":" + ZOOKEEPER_PORT;
- public static void main(String[] args) {
- ServiceConfig<GreetingsService> service = new ServiceConfig<>();
- service.setInterface(GreetingsService.class);
- service.setRef(new GreetingsServiceImpl());
+ public static void main(String[] args) throws IOException {
+ ReferenceConfig<GreetingsService> reference = new ReferenceConfig<>();
+ reference.setInterface(GreetingsService.class);
DubboBootstrap.getInstance()
- .application("first-dubbo-provider")
+ .application("first-dubbo-consumer")
.registry(new RegistryConfig(ZOOKEEPER_ADDRESS))
- .service(service)
- .start()
- .await();
+ .reference(reference)
+ .start();
+
+ GreetingsService service = reference.get();
+ while (true) {
+ try {
+ String message = service.sayHi("dubbo");
+ System.out.println(new Date() + " Receive result ======> " +
message);
+ Thread.sleep(1000);
+ } catch (Throwable t) {
+ t.printStackTrace();
+ }
+ }
}
+
}
diff --git
a/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
b/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
index 1cefa594..e9343fcd 100644
---
a/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
+++
b/1-basic/dubbo-samples-api/src/main/java/org/apache/dubbo/samples/provider/Application.java
@@ -17,6 +17,7 @@
package org.apache.dubbo.samples.provider;
+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;
@@ -35,6 +36,7 @@ public class Application {
DubboBootstrap.getInstance()
.application("first-dubbo-provider")
.registry(new RegistryConfig(ZOOKEEPER_ADDRESS))
+ .protocol(new ProtocolConfig("dubbo", -1))
.service(service)
.start()
.await();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
