基于 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协议】

最后修改 August 14, 2024: Update 3.3.0 doc (#3022) (a46a9d1c122)