基于 TCP 的 RPC 通信协议 - dubbo

演示了如何开发基于 dubbo 协议通信的服务。

本示例演示了如何开发基于 dubbo 协议通信的服务，可在此查看 本示例的完整代码：

运行示例

你可以跟随以下步骤，尝试运行本文档对应的示例源码。

首先，可通过以下命令下载示例源码

git clone --depth=1 https://github.com/apache/dubbo-samples.git

进入示例源码目录：

cd dubbo-samples/2-advanced/dubbo-samples-dubbo

使用 maven 打包示例：

mvn clean install -DskipTests

启动提供者

运行以下命令启动提供者：

java -jar ./dubbo-samples-dubbo-provider/target/dubbo-samples-dubbo-provider-1.0-SNAPSHOT.jar

启动消费者

运行以下命令：

java -jar ./dubbo-samples-dubbo-consumer/target/dubbo-samples-dubbo-consumer-1.0-SNAPSHOT.jar

源码讲解

定义服务

首先是服务定义，使用 dubbo 协议时，我们首选需要通过 Java Interface 定义 Dubbo 服务。

public interface DemoService {
    String sayHello(String name);
}

服务提供者

其次，对于提供者一侧而言，需要提供服务的具体实现。

@DubboService
public class DemoServiceImpl implements DemoService {
    @Override
    public String sayHello(String name) {
        return "Hello " + name;
    }
}

配置使用 dubbo 协议：

dubbo:
  protocol:
    name: dubbo
    port: 20880

服务消费者

配置服务引用，如下所示：

@Component
public class Task implements CommandLineRunner {
    @DubboReference(url = "dubbo://127.0.0.1:20880/org.apache.dubbo.protocol.dubbo.demo.DemoService")
    private DemoService demoService;
}

接下来，就可以发起对远程服务的 RPC 调用了：

demoService.sayHello("world");

更多协议配置

序列化

消费者与提供者之间的调用使用 dubbo 协议，方法参数默认数据编码格式（即序列化）是 hessian2，同时你也可以设置使用其他任意序列化协议，序列化不影响 dubbo 协议的正常工作（只会对编码性能有一些影响）。

dubbo:
  protocol:
    name: dubbo
    port: 20880
    serialization: fastjson2

共享连接

对 dubbo 协议实现来说，消费端机器A与提供者机器B之间默认是使用的同一个链接，即不论在 A 与 B 之间有多少服务调用，默认都始终使用同一个 tcp 连接。当然，Dubbo 框架提供了方法可以让您调整 A 与 B 之间的 tcp 连接数。

此外，dubbo 协议还支持配置如 payload 限制、序列化、连接数、连接超时时间、心跳等，具体请参见【参考手册 - dubbo协议】。

最后修改 September 17, 2024: fix doc (8b1dd8c278)