第一个 Dubbo 应用
Java RMI 簡介
Java RMI （Remote Method Invocation）- 遠程方法調用，能夠讓客戶端像使用本地調用一樣調用服務端 Java 虛擬機中的對象方法。RMI 是面向對象語言領域對 RPC （Remote Procedure Call）的完善，用戶無需依靠 IDL 的幫助來完成分布式調用，而是通過依賴接口這種更簡單自然的方式。
Java RMI 工作原理
一個典型的 RMI 調用如下圖所示：
RMI Flow.png | center
(來源：https://www.cs.rutgers.edu/~pxk/417/notes/images/rpc-rmi_flow.png)
Java RMI 基本概念
Java RMI 是 Java 領域創建分布式應用的技術基石。后續的 EJB 技術，以及現代的分布式服務框架，其中的基本理念依舊是 Java RMI 的延續。在 RMI 調用中，有以下幾個核心的概念：
對于第一點，客戶端需要依賴接口，而服務端需要提供該接口的實現。
對于第二點，在 J2SE 1.5 版本之前需要通過 rmic 預先編譯好客戶端的 Stub 對象和服務端的 Skeleton 對象。在之后的版本中，不再需要事先生成 Stub 和 Skeleton 對象。
下面通過示例代碼簡單的展示 RMI 中的服務注冊和發現
服務端的服務注冊
| Hello obj = new HelloImpl(); // #1 Hello stub = (Hello) UnicastRemoteObject.exportObject(obj, 0); // #2 Registry registry = LocateRegistry.createRegistry(1099); // #3 registry.rebind("Hello", stub); // #4 |
說明：
客戶端的服務發現
| Registry registry = LocateRegistry.getRegistry(); // #1 Hello stub = (Hello) registry.lookup("Hello"); // #2 String response = stub.sayHello(); // #3 |
說明：
理解 RMI 的工作原理和基本概念，對掌握現代分布式服務框架很有幫助，建議進一步的閱讀 RMI 官方教材?[1]。
Dubbo 基本概念
現代的分布式服務框架的基本概念與 RMI 是類似的，同樣是使用 Java 的 Interface 作為服務契約，通過注冊中心來完成服務的注冊和發現，遠程通訊的細節也是通過代理類來屏蔽。具體來說，Dubbo 在工作時有以下四個角色參與：
dubbo-architecture.png | left | 827x516
部署階段
- 服務提供者在指定端口暴露服務，并向注冊中心注冊服務信息。
- 服務消費者向注冊中心發起服務地址列表的訂閱。
運行階段
- 注冊中心向服務消費者推送地址列表信息。
- 服務消費者收到地址列表后，從其中選取一個向目標服務發起調用。
- 調用過程服務消費者和服務提供者的運行狀態上報給監控中心。
基于 API 的 Dubbo 應用
Dubbo 的應用一般都是通過 Spring 來組裝的。為了快速獲得一個可以工作的 Dubbo 應用，這里的示例摒棄了復雜的配置，而改用面向 Dubbo API 的方式來構建服務提供者和消費者，另外，注冊中心和監控中心在本示例中也不需要安裝和配置。
在生產環境，Dubbo 的服務需要一個分布式的服務注冊中心與之配合，比如，ZooKeeper。為了方便開發，Dubbo 提供了直連[2]以及組播[3]兩種方式，從而避免額外搭建注冊中心的工作。在本例中，將使用組播的方式來完成服務的注冊和發現。
定義服務契約
| public interface GreetingsService {String sayHi(String name); // #1 } |
說明：
提供契約的實現
| public class GreetingsServiceImpl implements GreetingsService { // #1@Overridepublic String sayHi(String name) {return "hi, " + name; // #2} } |
說明：
實現 Dubbo 服務提供方
| public class Application {public static void main(String[] args) throws IOException {ServiceConfig<GreetingsService> service = new ServiceConfig<>(); // #1service.setApplication(new ApplicationConfig("first-dubbo-provider")); // #2service.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234")); // #3service.setInterface(GreetingsService.class); // #4service.setRef(new GreetingsServiceImpl()); // #5service.export(); // #6System.in.read(); // #7} } |
說明：
實現 Dubbo 服務調用方
| public class Application {public static void main(String[] args) {ReferenceConfig<GreetingsService> reference = new ReferenceConfig<>(); // #1reference.setApplication(new ApplicationConfig("first-dubbo-client")); // #2reference.setRegistry(new RegistryConfig("multicast://224.5.6.7:1234")); // #3reference.setInterface(GreetingsService.class); // #4GreetingsService greetingsService = reference.get(); // #5String message = greetingsService.sayHi("dubbo"); // #6System.out.println(message); // #7} } |
說明：
運行
完整的示例在?https://github.com/dubbo/dubbo-samples/tree/master/dubbo-samples-api?上提供。在完整的示例中，由于配置了?exec-maven-plugin，可以很方便的在命令行下通過 maven 的方式執行。當然，您也可以在 IDE 里直接執行，但是需要注意的是，由于使用了組播的方式來發現服務，運行時需要指定?-Djava.net.preferIPv4Stack=true。
構建示例
通過以下的命令來同步示例代碼并完成構建：
| $ git clone https://github.com/dubbo/dubbo-samples.git $ cd dubbo-samples/dubbo-samples-api/ $ mvn clean package INFO] Scanning for projects... [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Building dubbo-samples-api 1.0-SNAPSHOT [INFO] ------------------------------------------------------------------------ [INFO] [INFO] --- maven-clean-plugin:2.5:clean (default-clean) @ dubbo-samples-api --- ... [INFO] ------------------------------------------------------------------------ [INFO] BUILD SUCCESS [INFO] ------------------------------------------------------------------------ [INFO] Total time: 2.182 s [INFO] Finished at: 2018-05-28T14:56:08+08:00 [INFO] Final Memory: 20M/353M [INFO] ------------------------------------------------------------------------ |
當看到?BUILD SUCCESS?的時候表明構建完成，下面就可以開始進入運行階段了。
運行服務端
通過運行以下的 maven 命令來啟動服務提供者：
| $ mvn -Djava.net.preferIPv4Stack=true -Dexec.mainClass=com.alibaba.dubbo.samples.server.Application exec:java [INFO] Scanning for projects... [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Building dubbo-samples-api 1.0-SNAPSHOT [INFO] ------------------------------------------------------------------------ [INFO] [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dubbo-samples-api --- log4j:WARN No appenders could be found for logger (com.alibaba.dubbo.common.logger.LoggerFactory). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. first-dubbo-provider is running. |
當?first-dubbo-provider is running.?出現時，代表服務提供者已經啟動就緒，等待客戶端的調用。
運行客戶端
通過運行以下的 maven 命令來調用服務：
| $ mvn -Djava.net.preferIPv4Stack=true -Dexec.mainClass=com.alibaba.dubbo.samples.client.Application exec:java [INFO] Scanning for projects... [INFO] [INFO] ------------------------------------------------------------------------ [INFO] Building dubbo-samples-api 1.0-SNAPSHOT [INFO] ------------------------------------------------------------------------ [INFO] [INFO] --- exec-maven-plugin:1.6.0:java (default-cli) @ dubbo-samples-api --- log4j:WARN No appenders could be found for logger (com.alibaba.dubbo.common.logger.LoggerFactory). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. hi, dubbo |
可以看到，?hi, dubbo?是從服務提供者返回的執行結果。
快速生成 Dubbo 應用
Dubbo 還提供了一個公共服務快速搭建基于 Spring Boot 的 Dubbo 應用。訪問?http://start.dubbo.io?并按照下圖所示來生成示例工程：
dubbo initializr.png | left | 827x835
說明：
在本例中展示的是服務提供者，同樣的，通過在生成界面選取?client?來生成對應的服務消費者。
運行
用 IDE 打開生成好的工程，可以發現應用是一個典型的 Spring Boot 應用。程序的入口如下所示：
| @SpringBootApplication public class DemoApplication {public static void main(String[] args) {new EmbeddedZooKeeper(2181, false).start(); // #1SpringApplication.run(DemoApplication.class, args); // #2} } |
說明：
可以直接在 IDE 中運行，輸出結果如下：
bash 2018-05-28 16:59:38.072 INFO 59943 --- [ main] a.b.d.c.e.WelcomeLogoApplicationListener : ████████▄ ███ █▄ ?█████████▄ ?█████████▄ ▄██████▄ ███ ?███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ▄███▄▄▄██? ▄███▄▄▄██? ███ ███ ███ ███ ███ ███ ??███???██▄ ??███???██▄ ███ ███ ███ ███ ███ ███ ███ ██▄ ███ ██▄ ███ ███ ███ ▄███ ███ ███ ███ ███ ███ ███ ███ ███ ████████? ████████? ▄█████████? ▄█████████? ?██████? :: Dubbo Spring Boot (v0.1.0) : https://github.com/dubbo/dubbo-spring-boot-project:: Dubbo (v2.0.1) : https://github.com/alibaba/dubbo:: Google group : http://groups.google.com/group/dubbo2018-05-28 16:59:38.079 INFO 59943 --- [ main] e.OverrideDubboConfigApplicationListener : Dubbo Config was overridden by externalized configuration {dubbo.application.name=dubbo-demo-server, dubbo.application.qosAcceptForeignIp=false, dubbo.application.qosEnable=true, dubbo.application.qosPort=22222, dubbo.registry.address=zookeeper://localhost:2181?client=curator, dubbo.registry.id=my-registry, dubbo.scan.basePackages=com.example} #1...2018-05-28 16:59:39.624 INFO 59943 --- [ main] com.example.demo.DemoApplication : Started DemoApplication in 1.746 seconds (JVM running for 2.963)說明：
通過 Telnet 管理服務
生成工程的時候如果選擇了激活?qos?的話，就可以通過?telnet?或者?nc?來管理服務、查看服務狀態。
bash $ telnet localhost 22222 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'.████████▄ ███ █▄ ?█████████▄ ?█████████▄ ▄██████▄ ███ ?███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ███ ▄███▄▄▄██? ▄███▄▄▄██? ███ ███ ███ ███ ███ ███ ??███???██▄ ??███???██▄ ███ ███ ███ ███ ███ ███ ███ ██▄ ███ ██▄ ███ ███ ███ ▄███ ███ ███ ███ ███ ███ ███ ███ ███ ████████? ████████? ▄█████████? ▄█████████? ?██████? dubbo> dubbo>ls As Provider side: +------------------------------+---+ | Provider Service Name |PUB| +------------------------------+---+ |com.example.HelloService:1.0.0| Y | +------------------------------+---+ As Consumer side: +---------------------+---+ |Consumer Service Name|NUM| +---------------------+---+目前?qos?支持以下幾個命令，更詳細的信息請查閱官方文檔[4]：
- ls：列出消費者、提供者信息
- online：上線服務
- offline：下線服務
- help：聯機幫助
總結
在本文中，從 RMI 開始，介紹了 Java 領域分布式調用的基本概念，也就是基于接口編程、通過代理將遠程調用偽裝成本地、通過注冊中心完成服務的注冊和發現。
然后為了簡單起見，使用簡單的組播注冊方式和直接面向 Dubbo API 編程的方式介紹了如何開發一個 Dubbo 的完整應用。深入的了解?ServiceConfig?和?ReferenceConfig?的用法，對于進一步的使用 Spring XML 配置、乃至 Spring Boot 的編程方式有這很大的幫助。
最后，簡單的介紹了如何通過 Dubbo 團隊提供的公共服務?start.dubbo.io?快速搭建基于 Spring Boot 的 Dubbo 應用，并通過?qos?來做 Dubbo 服務的簡單運維。
企業級互聯網架構Aliware，讓您的業務能力云化：https://www.aliyun.com/aliware
from:?http://jm.taobao.org/2018/06/13/%E5%BA%94%E7%94%A8/
總結
以上是生活随笔為你收集整理的第一个 Dubbo 应用的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Activiti总体框架分析
- 下一篇： java中byte, iso-8859-