java protobuf 服务端接收任意protubuf对象

Posted 2021-09-04 天涯泪小武

这个需求还算比较常见的，作为一个统一的服务端项目，有多个其他的服务在往该服务发消息，不同的服务定义的数据对象各不相同，那么如何用一个统一的对象把这些发来的消息都接收下来呢？

举例：譬如有10个服务要把自己的出入参发给服务A，服务A用来做出入参日志的记录保存工作，这10个服务都有自己的出入参，对象也各不相同，而且随时有变更的可能。作为服务A肯定是无法把这10个服务的出入参对象都定义出来，然后再做protobuf的解析的。那么就需要一个统一的类对象来接收这么些个不同的对象，本篇就是解决这个问题的。

解决方案

譬如服务1的对象是User，有字段name，address，age；

服务2的对象是Cat，有字段weight、height、color；

他们想要和服务A正常通信，进行protobuf的序列化反序列化，首先肯定是要定义统一的对象的。

我们可以定义一个对象譬如叫Wrapper，作为两端通信的proto对象类。

服务1在传输时

Wrapper wrapper = new Wrapper();
wrapper.setObject(User user);
byte[] bytes = ProtostuffUtils.serialize(wrapper);

在服务端接收到后，进行反序列化即可

Wrapper wrapper = ProtostuffUtils.deserialize(bytes, Wrapper.class);

然后从wrapper里get到object对象，然后可以进行json化，或者toString即可。

 ProtostuffUtils是Protostuff的工具类，网上找找有很多。

如果之前你的系统是通过json来彼此作为数据的载体，耗费带宽较大，那么可以考虑采用上述方式，protobuf会省下来很多带宽。