Dubbo3 GoogleProtobuf 對(duì)象泛化調(diào)用

對(duì) Google Protobuf 對(duì)象進(jìn)行泛化調(diào)用

泛化接口調(diào)用方式主要用于客戶(hù)端沒(méi)有 API 接口及模型類(lèi)元的情況，參考 泛化調(diào)用。 一般泛化調(diào)用只能用于生成的服務(wù)參數(shù)為POJO的情況，而 GoogleProtobuf 的對(duì)象是基于 Builder 生成的非正常POJO，可以通過(guò) protobuf-json 泛化調(diào)用。

GoogleProtobuf 序列化相關(guān)的Demo可以參考 protobuf-demo

通過(guò)Spring對(duì)Google Protobuf對(duì)象泛化調(diào)用

在 Spring 中配置聲明 generic = “protobuf-json”

<dubbo:reference id="barService" interface="com.foo.BarService" generic="protobuf-json" />

在 Java 代碼獲取 barService 并開(kāi)始泛化調(diào)用：

GenericService barService = (GenericService) applicationContext.getBean("barService");
Object result = barService.$invoke("sayHello",new String[]{"org.apache.dubbo.protobuf.GooglePbBasic$CDubboGooglePBRequestType"}, new Object[]{"{\"double\":0.0,\"float\":0.0,\"bytesType\":\"Base64String\",\"int32\":0}"});

通過(guò) API 方式對(duì) Google Protobuf 對(duì)象泛化調(diào)用

ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>();
// 弱類(lèi)型接口名
reference.setInterface(GenericService.class.getName());
reference.setInterface("com.xxx.XxxService");
// 聲明為Protobuf-json
reference.setGeneric(Constants.GENERIC_SERIALIZATION_PROTOBUF);

GenericService genericService = reference.get();
Map<String, Object> person = new HashMap<String, Object>();
person.put("fixed64", "0");
person.put("int64", "0");
// 參考google官方的protobuf 3 的語(yǔ)法，服務(wù)的每個(gè)方法中只傳輸一個(gè)POJO對(duì)象
// protobuf的泛化調(diào)用只允許傳遞一個(gè)類(lèi)型為String的json對(duì)象來(lái)代表請(qǐng)求參數(shù)
String requestString = new Gson().toJson(person);
// 返回對(duì)象是GoolgeProtobuf響應(yīng)對(duì)象的json字符串。
Object result = genericService.$invoke("sayHello", new String[] {
    "com.xxx.XxxService.GooglePbBasic$CDubboGooglePBRequestType"},
    new Object[] {requestString});

GoogleProtobuf 對(duì)象的處理

GoogleProtobuf 對(duì)象是由 Protocol 契約生成,相關(guān)知識(shí)請(qǐng)參考 ProtocolBuffers 文檔。假如有如下Protobuf 契約

syntax = "proto3";
package com.xxx.XxxService.GooglePbBasic.basic;
message CDubboGooglePBRequestType {
    double double = 1;
    float float = 2;
    int32 int32 = 3;
    bool bool = 13;
    string string = 14;
    bytes bytesType = 15;
}

message CDubboGooglePBResponseType {
    string msg = 1;
}

service CDubboGooglePBService {
    rpc sayHello (CDubboGooglePBRequestType) returns (CDubboGooglePBResponseType);
}

則對(duì)應(yīng)請(qǐng)求按照如下方法構(gòu)造

Map<String, Object> person = new HashMap<>();
person.put("double", "1.000");
person.put("float", "1.00");
person.put("int32","1" );
person.put("bool","false" );
//String 的對(duì)象需要經(jīng)過(guò)base64編碼
person.put("string","someBaseString");
person.put("bytesType","150");

GoogleProtobuf 服務(wù)元數(shù)據(jù)解析

Google Protobuf 對(duì)象缺少標(biāo)準(zhǔn)的 JSON 格式，生成的服務(wù)元數(shù)據(jù)信息存在錯(cuò)誤。請(qǐng)?zhí)砑尤缦乱蕾?lài)元數(shù)據(jù)解析的依賴(lài)。

<dependency>
    <groupId>org.apache.dubbo</groupId>
    <artifactId>dubbo-metadata-definition-protobuf</artifactId>
    <version>${dubbo.version}</version>
</dependency>

從服務(wù)元數(shù)據(jù)中也可以比較容易構(gòu)建泛化調(diào)用對(duì)象。