API配置

whatsmars-dubbo/whatsmars-dubbo-consumer/src/test/java/org/hongxi/whatsmars/dubbo/demo/consumer/Consumer.java

+package org.hongxi.whatsmars.dubbo.demo.consumer;
+
+import com.alibaba.dubbo.config.ApplicationConfig;
+import com.alibaba.dubbo.config.ReferenceConfig;
+import com.alibaba.dubbo.config.RegistryConfig;
+import org.hongxi.whatsmars.dubbo.demo.api.DemoService;
+
+public class Consumer {
+
+    public static void main(String[] args) {
+        ApplicationConfig application = new ApplicationConfig();
+        application.setName("demo-consumer");
+
+        RegistryConfig registry = new RegistryConfig();
+        registry.setAddress("zookeeper://127.0.0.1:2181");
+
+        ReferenceConfig<DemoService> reference = new ReferenceConfig<>();
+        reference.setApplication(application);
+        reference.setRegistry(registry);
+        reference.setInterface(DemoService.class);
+        reference.setVersion("1.0.0");
+
+        DemoService demoService = reference.get();
+        System.out.println(demoService.sayHello("hongxi"));
+    }
+}

whatsmars-dubbo/whatsmars-dubbo-provider/src/test/java/org/hongxi/whatsmars/dubbo/demo/provider/Provider.java

+package org.hongxi.whatsmars.dubbo.demo.provider;
+
+import com.alibaba.dubbo.config.ApplicationConfig;
+import com.alibaba.dubbo.config.ProtocolConfig;
+import com.alibaba.dubbo.config.RegistryConfig;
+import com.alibaba.dubbo.config.ServiceConfig;
+import org.hongxi.whatsmars.dubbo.demo.api.DemoService;
+
+public class Provider {
+
+    public static void main(String[] args) throws Exception {
+        ApplicationConfig application = new ApplicationConfig();
+        application.setName("demo-provider");
+
+        RegistryConfig registry = new RegistryConfig();
+        registry.setAddress("zookeeper://127.0.0.1:2181");
+
+        ProtocolConfig protocol = new ProtocolConfig();
+        protocol.setName("dubbo");
+        protocol.setPort(20882);
+
+        ServiceConfig<DemoService> service = new ServiceConfig<>();
+        service.setApplication(application);
+        service.setRegistry(registry);
+        service.setProtocol(protocol);
+        service.setInterface(DemoService.class);
+        service.setRef(new DemoServiceImpl2());
+        service.setVersion("1.0.0");
+
+        service.export();
+
+        System.in.read(); // press any key to exit
+    }
+}