从零演示如何基于 IDL 方式来定义 Dubbo 服务并使用 Triple 协议 ...

使用 IDL 定义服务具有更好的跨语言友好性，然而 Triple 协议并不是和 IDL 强绑定的，也可以使用 Java Interface + Pojo 的方式定义服务并启用 Triple 协议，具体可参见示例。
更多 Triple 和 IDL 使用方式，请参考官方示例
前置条件

• JDK 版本 >= 8
  
• 已安装 Maven
  

创建工程

• 首先创建一个空的 maven 工程
  1. $ mvn archetype:generate                                \
  2.     -DgroupId=org.apache.dubbo                          \
  3.     -DartifactId=tri-stub-demo                          \
  4.     -DarchetypeArtifactId=maven-archetype-quickstart    \
  5.     -DarchetypeVersion=1.4                              \
  6.     -DarchetypeGroupId=org.apache.maven.archetypes      \
  7.     -Dversion=1.0-SNAPSHOT

  复制代码
• 切换到工程目录
  1. $ cd tri-stub-demo

  复制代码
• 在 pom.xml 中设置 JDK 版本，添加 Dubbo 依赖和插件
  1. <properties>
  2.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  3.     <maven.compiler.source>1.8</maven.compiler.source>
  4.     <maven.compiler.target>1.8</maven.compiler.target>
  5. </properties>
  7. <dependencies>
  8.    <dependency>
  9.        <groupId>junit</groupId>
  10.        <artifactId>junit</artifactId>
  11.        <version>4.13</version>
  12.        <scope>test</scope>
  13.    </dependency>
  14.    <dependency>
  15.        <groupId>org.apache.dubbo</groupId>
  16.        <artifactId>dubbo</artifactId>
  17.        <version>3.0.8</version>
  18.    </dependency>
  19.    <dependency>
  20.     <groupId>org.apache.dubbo</groupId>
  21.     <artifactId>dubbo-dependencies-zookeeper-curator5</artifactId>
  22.     <type>pom</type>
  23.     <version>3.0.8</version>
  24.    </dependency>
  25.     <dependency>
  26.         <groupId>com.google.protobuf</groupId>
  27.         <artifactId>protobuf-java</artifactId>
  28.         <version>3.19.4</version>
  29.     </dependency>
  30. </dependencies>
  32. <build>
  33.     <extensions>
  34.         <extension>
  35.             <groupId>kr.motd.maven</groupId>
  36.             <artifactId>os-maven-plugin</artifactId>
  37.             <version>1.6.1</version>
  38.         </extension>
  39.     </extensions>
  40.     <plugins>
  41.         <plugin>
  42.             <groupId>org.xolstice.maven.plugins</groupId>
  43.             <artifactId>protobuf-maven-plugin</artifactId>
  44.             <version>0.6.1</version>
  45.             <configuration>
  46.                 <protocArtifact>com.google.protobuf:protoc:3.19.4:exe:${os.detected.classifier}</protocArtifact>
  47.                 <protocPlugins>
  48.                     <protocPlugin>
  49.                         <id>dubbo</id>
  50.                         <groupId>org.apache.dubbo</groupId>
  51.                         <artifactId>dubbo-compiler</artifactId>
  52.                         <version>0.0.4.1-SNAPSHOT</version>
  53.                         <mainClass>org.apache.dubbo.gen.tri.Dubbo3TripleGenerator</mainClass>
  54.                     </protocPlugin>
  55.                 </protocPlugins>
  56.             </configuration>
  57.             <executions>
  58.                 <execution>
  59.                     <goals>
  60.                         <goal>compile</goal>
  61.                     </goals>
  62.                 </execution>
  63.             </executions>
  64.         </plugin>
  65.     </plugins>
  66. </build>

  复制代码
• 添加接口定义文件src/main/proto/hello.proto，Dubbo 使用 Protobuf 作为 IDL
  1. syntax = "proto3";
  3. option java_multiple_files = true;
  4. option java_package = "org.apache.dubbo.hello";
  5. option java_outer_classname = "HelloWorldProto";
  6. option objc_class_prefix = "HLW";
  8. package helloworld;
  10. message HelloRequest {
  11.     string name = 1;
  12. }
  14. message HelloReply {
  15.     string message = 1;
  16. }
  17. service Greeter{
  18.     rpc greet(HelloRequest) returns (HelloReply);
  19. }

  复制代码
• 编译 IDL
  1. $ mvn clean install

  复制代码
  编译成功后，可以看到target/generated-sources/protobuf/java 目录下生成了代码文件
  1. $ ls org/apache/dubbo/hello/
  2. DubboGreeterTriple.java    HelloReply.java            HelloRequest.java          HelloWorldProto.java
  3. Greeter.java               HelloReplyOrBuilder.java   HelloRequestOrBuilder.java

  复制代码
• 添加服务端接口实现src/main/java/org/apache/dubbo/GreeterImpl.java
  1. package org.apache.dubbo;
  3. import org.apache.dubbo.hello.DubboGreeterTriple;
  4. import org.apache.dubbo.hello.HelloReply;
  5. import org.apache.dubbo.hello.HelloRequest;
  7. public class GreeterImpl extends DubboGreeterTriple.GreeterImplBase {
  8.    @Override
  9.    public HelloReply greet(HelloRequest request) {
  10.       return HelloReply.newBuilder()
  11.       .setMessage("Hello," + request.getName() + "!")
  12.       .build();
  13.    }
  14. }

  复制代码
• 添加服务端启动类 src/main/java/org/apache/dubbo/MyDubboServer.java
  1. package org.apache.dubbo;
  3. import org.apache.dubbo.common.constants.CommonConstants;
  4. import org.apache.dubbo.config.ApplicationConfig;
  5. import org.apache.dubbo.config.ProtocolConfig;
  6. import org.apache.dubbo.config.RegistryConfig;
  7. import org.apache.dubbo.config.ServiceConfig;
  8. import org.apache.dubbo.config.bootstrap.DubboBootstrap;
  9. import org.apache.dubbo.hello.Greeter;
  11. import java.io.IOException;
  13. public class MyDubboServer {
  15.    public static void main(String[] args) throws IOException {
  16.        ServiceConfig<Greeter> service = new ServiceConfig<>();
  17.        service.setInterface(Greeter.class);
  18.        service.setRef(new GreeterImpl());
  20.        DubboBootstrap bootstrap = DubboBootstrap.getInstance();
  21.        bootstrap.application(new ApplicationConfig("tri-stub-server"))
  22.                .registry(new RegistryConfig("multicast://127.0.0.1:2181"))
  23.                .protocol(new ProtocolConfig(CommonConstants.TRIPLE, 50051))
  24.                .service(service)
  25.                .start();
  26.        System.out.println("Dubbo triple stub server started");
  27.        System.in.read();
  28.    }
  29. }

  复制代码
• 添加客户端启动类src/main/java/org/apache/dubbo/MyDubboClient.java
  1. package org.apache.dubbo;
  3. import org.apache.dubbo.common.constants.CommonConstants;
  4. import org.apache.dubbo.config.ApplicationConfig;
  5. import org.apache.dubbo.config.ReferenceConfig;
  6. import org.apache.dubbo.config.RegistryConfig;
  7. import org.apache.dubbo.config.bootstrap.DubboBootstrap;
  8. import org.apache.dubbo.hello.Greeter;
  9. import org.apache.dubbo.hello.HelloReply;
  10. import org.apache.dubbo.hello.HelloRequest;
  12. public class MyDubboClient {
  13.    public static void main(String[] args) {
  14.       DubboBootstrap bootstrap = DubboBootstrap.getInstance();
  15.       ReferenceConfig<Greeter> ref = new ReferenceConfig<>();
  16.       ref.setInterface(Greeter.class);
  17.       ref.setProtocol(CommonConstants.TRIPLE);
  18.       ref.setProxy(CommonConstants.NATIVE_STUB);
  19.       ref.setTimeout(3000);
  20.       bootstrap.application(new ApplicationConfig("tri-stub-client"))
  21.          .registry(new RegistryConfig("zookeeper://127.0.0.1:2181"))
  22.          .reference(ref)
  23.          .start();
  25.       Greeter greeter = ref.get();
  26.       HelloRequest request = HelloRequest.newBuilder().setName("Demo").build();
  27.       HelloReply reply = greeter.greet(request);
  28.       System.out.println("Received reply:" + reply);
  29.     }
  30. }

  复制代码
• 编译代码
  1. $ mvn clean install

  复制代码
• 启动服务端
  

1. $ mvn org.codehaus.mojo:exec-maven-plugin:3.0.0:java -Dexec.main
2. Dubbo triple stub server started

复制代码

• 打开新的终端，启动客户端
  

1. $ mvn org.codehaus.mojo:exec-maven-plugin:3.0.0:java -Dexec.main
2. Received reply:message: "Hello,Demo!"

复制代码

欢迎在 https://github.com/apache/dubbo 给 Dubbo Star。
搜索关注官方微信公众号：Apache Dubbo，了解更多业界最新动态，掌握大厂面试必备 Dubbo 技能

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！