C#教程

关注公众号 jb51net

关闭
首页 > 软件编程 > C#教程 > C# Google.Protobuf

C#常用类库Google.Protobuf的使用小结

作者:阿蒙Armon

Google.Protobuf作为谷歌推出的高效序列化框架,成为C#开发者实现高效数据传输与存储的首选类库,本文主要介绍了C#常用类库Google.Protobuf的使用小结,感兴趣的可以了解一下

在C#分布式系统、微服务通信、跨语言交互场景中,数据序列化是核心环节。传统序列化方式(如JSON、XML)存在性能瓶颈、数据冗余、跨语言兼容性差等痛点,而Google.Protobuf(Protocol Buffers,简称Protobuf)作为谷歌推出的高效序列化框架,以“紧凑二进制、跨语言、高性能、可扩展”为核心优势,成为C#开发者实现高效数据传输与存储的首选类库,广泛应用于微服务、物联网、RPC通信等场景。

本文聚焦“简练、详细、有深度”,摒弃冗余理论,从核心价值、环境搭建、proto文件定义、序列化/反序列化、进阶特性到实战落地,全方位解析Google.Protobuf for C#的用法,帮你快速掌握其精髓,解决实际开发中的序列化与跨语言通信痛点。

一、核心定位:Google.Protobuf解决什么问题?

Google.Protobuf的核心是“高效二进制序列化框架”,区别于JSON、XML等文本序列化方式,它通过预定义的协议格式(.proto文件),将数据编译为二进制格式,核心解决传统序列化的3大痛点:

核心优势:体积小、速度快、跨语言、可扩展、类型安全,无冗余依赖,无缝集成C#各类项目(控制台、ASP.NET Core、微服务),是分布式系统通信的“数据传输标准”。

二、环境搭建:快速引入与工具配置

Google.Protobuf for C#的使用分为“安装NuGet包”与“配置proto编译工具”两步,核心是通过工具将.proto文件编译为C#实体类,无需手动编写序列化/反序列化代码。

1. 安装NuGet包(核心+辅助)

// 核心包(必装,包含Protobuf核心API与序列化/反序列化逻辑)
dotnet add package Google.Protobuf

// 辅助包(可选,用于ASP.NET Core gRPC集成,微服务场景推荐)
dotnet add package Grpc.AspNetCore

// 编译工具包(必装,用于将.proto文件编译为C#代码)
dotnet add package Google.Protobuf.Tools

2. 配置proto编译工具(关键步骤)

Protobuf的核心是.proto文件(数据结构定义文件),需通过编译工具将其转换为C#实体类,有两种配置方式(推荐方式1,自动化编译):

方式1:项目文件配置(自动化编译,推荐)

在.csproj文件中添加配置,编译项目时自动将.proto文件转为C#代码,无需手动执行命令。

<!-- 在.csproj文件的<Project&gt;标签内添加 -->
&lt;ItemGroup&gt;
  <!-- 配置proto文件,设置编译类型为Protobuf -->
  <Protobuf Include="Protos\*.proto" GrpcServices="None" /&gt;
  <!-- GrpcServices="None" 表示仅生成实体类,若需gRPC则设为Server/Client -->
</ItemGroup>

方式2:手动命令编译(灵活,适合临时调试)

通过Google.Protobuf.Tools提供的protoc.exe工具,手动执行编译命令,生成C#代码。

// 1. 进入项目根目录(Protos文件夹存放.proto文件)
// 2. 执行编译命令(适配Windows系统,其他系统替换protoc.exe为对应可执行文件)
protoc --csharp_out=./Models Protos/Student.proto
// 说明:--csharp_out=输出目录,Protos/Student.proto 为proto文件路径
// 执行后会在Models文件夹生成Student.cs实体类

3. 核心命名空间

using Google.Protobuf; // 核心API(序列化/反序列化、消息对象)
using Google.Protobuf.Collections; // 集合类型(如RepeatedField,对应proto中的repeated)

三、基础用法:proto定义与核心操作(必学)

Google.Protobuf的使用核心是“定义proto文件→编译为C#实体→序列化/反序列化”,其中proto文件定义是基础,决定了数据结构与兼容性,重点掌握proto语法、编译后实体的使用。

1. proto文件定义(核心,跨语言共用)

proto文件采用简洁的语法,定义数据结构(消息体)、字段类型、字段编号,字段编号决定了二进制格式的兼容性,不可随意修改。

常用proto版本:proto3(推荐,语法简洁,跨语言兼容性更好)、proto2(旧版本,支持更多可选配置),本文以proto3为例。

// Protos/Student.proto
syntax = "proto3"; // 声明使用proto3版本
option csharp_namespace = "ProtobufDemo.Models"; // 生成C#类的命名空间

// 定义消息体(对应C#中的类)
message Student {
  // 字段格式:类型 字段名 = 字段编号;
  int32 id = 1; // 整数类型,字段编号1(1-15占用1字节,推荐优先使用)
  string name = 2; // 字符串类型
  int32 age = 3; // 整数类型
  bool is_adult = 4; // 布尔类型
  double score = 5; // 浮点类型
  
  // 枚举类型(需先定义枚举)
  enum Gender {
    GENDER_UNSPECIFIED = 0; // proto3要求枚举第一个值必须为0,作为默认值
    MALE = 1;
    FEMALE = 2;
  }
  Gender gender = 6; // 枚举类型字段
  
  // 重复字段(对应C#中的RepeatedField<T>,类似List)
  repeated string hobbies = 7; // 字符串列表
}

// 定义嵌套消息体(对应C#中的嵌套类)
message Class {
  int32 class_id = 1;
  string class_name = 2;
  repeated Student students = 3; // 消息体列表(班级包含多个学生)
}

关键说明:

2. 编译后C#实体类的使用

配置好编译后,生成的C#实体类继承自IMessage,包含字段的get/set方法、序列化/反序列化方法,无需手动编写。

// 编译后生成的Student类(简化版,实际包含更多核心方法)
namespace ProtobufDemo.Models;

public sealed partial class Student : IMessage<Student>
{
    public int Id { get; set; }
    public string Name { get; set; } = "";
    public int Age { get; set; }
    public bool IsAdult { get; set; }
    public double Score { get; set; }
    public Student.Types.Gender Gender { get; set; }
    public RepeatedField<string> Hobbies { get; } = new RepeatedField<string>();
    
    // 嵌套枚举(对应proto中的Gender)
    public enum Types
    {
        GenderUnspecified = 0,
        Male = 1,
        Female = 2
    }
    
    // 核心方法(序列化/反序列化)
    public byte[] ToByteArray(); // 序列化为二进制数组
    public static Student ParseFrom(byte[] data); // 从二进制数组反序列化
    public void WriteTo(CodedOutputStream output); // 写入输出流
    public static Student ParseFrom(CodedInputStream input); // 从输入流读取
}

// 调用示例:创建实体、赋值、序列化/反序列化
var task = Task.Run(() =>
{
    // 1. 创建实体并赋值
    var student = new Student
    {
        Id = 101,
        Name = "张三",
        Age = 20,
        IsAdult = true,
        Score = 95.5,
        Gender = Student.Types.Gender.Male
    };
    // 给重复字段赋值(RepeatedField用法类似List)
    student.Hobbies.Add("篮球");
    student.Hobbies.Add("编程");
    
    // 2. 序列化为二进制数组(核心操作)
    byte[] bytes = student.ToByteArray();
    Console.WriteLine($"序列化后长度:{bytes.Length}"); // 体积远小于JSON
    
    // 3. 从二进制数组反序列化为实体(核心操作)
    Student deserializedStudent = Student.ParseFrom(bytes);
    Console.WriteLine($"反序列化后:{deserializedStudent.Name},{deserializedStudent.Age}岁");
    
    // 4. 嵌套消息体使用(Class类)
    var @class = new Class
    {
        ClassId = 1,
        ClassName = "计算机1班"
    };
    @class.Students.Add(student); // 添加学生到班级
});
task.Wait();

3. 核心序列化/反序列化方法(高频用法)

Google.Protobuf提供多种序列化/反序列化方式,适配不同场景(内存、文件、网络流),重点掌握以下4种:

var student = new Student { Id = 101, Name = "张三" };

// 1. 序列化为二进制数组(最常用,适合网络传输、内存存储)
byte[] bytes = student.ToByteArray();

// 2. 从二进制数组反序列化
Student student1 = Student.ParseFrom(bytes);

// 3. 序列化到文件(适合持久化存储)
using (var stream = new FileStream("student.bin", FileMode.Create))
{
    student.WriteTo(stream);
}

// 4. 从文件反序列化
using (var stream = new FileStream("student.bin", FileMode.Open))
{
    Student student2 = Student.ParseFrom(stream);
}

// 5. 序列化为JSON(可选,适合调试,需安装Google.Protobuf.JsonFormat包)
// dotnet add package Google.Protobuf.JsonFormat
string json = JsonFormatter.Default.Format(student);
// 从JSON反序列化
Student student3 = JsonParser.Default.Parse<Student>(json);

关键说明:JSON序列化仅推荐用于调试,生产环境优先使用二进制序列化,才能体现Protobuf的性能优势。

四、进阶特性:实战必备技巧(深度重点)

基础用法能满足简单序列化场景,进阶特性则针对复杂业务场景(如字段扩展、集合优化、跨语言通信、gRPC集成),是企业级开发的核心要点。

1. 字段扩展与向后兼容(核心优势)

Protobuf的最大优势之一是“向后兼容”,新增字段时,旧版本代码无需修改,仍能正常反序列化(新增字段会被忽略),废弃字段可标记为reserved,避免被复用。

// 升级后的Student.proto(新增字段,标记废弃字段)
syntax = "proto3";
option csharp_namespace = "ProtobufDemo.Models";

message Student {
  int32 id = 1;
  string name = 2;
  int32 age = 3;
  bool is_adult = 4;
  double score = 5;
  Gender gender = 6;
  repeated string hobbies = 7;
  
  // 新增字段(字段编号8,未被使用过)
  string address = 8;
  
  // 废弃字段(标记id=9为reserved,禁止后续使用)
  reserved 9;
  reserved "old_field"; // 也可通过字段名标记
  
  enum Gender {
    GENDER_UNSPECIFIED = 0;
    MALE = 1;
    FEMALE = 2;
  }
}

注意:不可修改已有字段的编号和类型,否则会破坏向后兼容,导致旧版本无法反序列化。

2. 集合类型优化(RepeatedField vs List)

proto中repeated字段编译后对应C#的RepeatedField,而非List,RepeatedField针对Protobuf序列化做了优化,性能优于List,核心优势:

var student = new Student();
// RepeatedField赋值
student.Hobbies.Add("篮球");
student.Hobbies.AddRange(new List<string> { "编程", "读书" });

// 转为List<T>
List<string> hobbyList = student.Hobbies.ToList();

// List<T>转为RepeatedField
var newHobbies = new RepeatedField<string>();
newHobbies.AddRange(hobbyList);

3. 跨语言通信(C# ↔ Java 示例)

Protobuf的核心价值是跨语言兼容,一份proto文件,可编译为不同语言的实体类,实现多语言通信。以下是C#序列化、Java反序列化的简单示例:

// C# 端:序列化Student实体为二进制数组,发送到Java端
var student = new Student { Id = 101, Name = "张三", Age = 20 };
byte[] bytes = student.ToByteArray();
// 发送bytes到Java端(通过HTTP、TCP等方式)
// Java 端:接收二进制数组,反序列化为Student实体(proto文件与C#共用)
// 1. 编译proto文件为Java实体(使用protoc工具)
// 2. 反序列化
byte[] bytes = 接收的二进制数据;
Student student = Student.parseFrom(bytes);
System.out.println("接收数据:" + student.getName() + "," + student.getAge());

关键:多语言共用同一.proto文件,确保字段编号、类型、消息体名称完全一致,即可实现无缝通信。

4. ASP.NET Core 集成(gRPC通信场景)

在微服务场景中,Google.Protobuf常与gRPC结合使用(gRPC默认使用Protobuf作为序列化方式),实现高效的跨服务通信。以下是简单集成示例:

步骤1:定义gRPC服务proto文件

// Protos/StudentService.proto
syntax = "proto3";
option csharp_namespace = "ProtobufDemo.Grpc";

// 定义gRPC服务
service StudentService {
  // 定义接口(请求参数、响应参数均为Protobuf消息体)
  rpc GetStudent (GetStudentRequest) returns (Student);
}

// 请求消息体
message GetStudentRequest {
  int32 student_id = 1;
}

// 响应消息体(复用之前定义的Student)
message Student {
  int32 id = 1;
  string name = 2;
  int32 age = 3;
}

步骤2:配置gRPC服务(Program.cs)

var builder = WebApplication.CreateBuilder(args);

// 添加gRPC服务(自动编译proto文件)
builder.Services.AddGrpc();

var app = builder.Build();

// 映射gRPC服务
app.MapGrpcService<StudentServiceImpl>();

app.Run();

步骤3:实现gRPC服务

namespace ProtobufDemo.Grpc;

public class StudentServiceImpl : StudentService.StudentServiceBase
{
    // 实现接口方法
    public override Task<Student> GetStudent(GetStudentRequest request, ServerCallContext context)
    {
        // 模拟从数据库获取学生信息
        var student = new Student
        {
            Id = request.StudentId,
            Name = "张三",
            Age = 20
        };
        return Task.FromResult(student);
    }
}

步骤4:客户端调用gRPC服务

// 客户端代码(C#)
var channel = GrpcChannel.ForAddress("https://localhost:5001");
var client = new StudentService.StudentServiceClient(channel);

// 调用gRPC接口(请求、响应均为Protobuf实体)
var response = await client.GetStudentAsync(new GetStudentRequest { StudentId = 101 });
Console.WriteLine($"获取学生:{response.Name},{response.Age}岁");

五、实战场景:完整案例(序列化存储+跨服务通信)

结合两个高频实战场景,展示Google.Protobuf的完整用法,兼顾数据持久化与跨服务通信,贴合企业级开发需求。

场景1:数据持久化(序列化到文件/数据库)

需求:将用户列表序列化后存储到文件,后续读取并反序列化,用于数据备份与恢复。

// 1. 定义proto文件(UserList.proto)
syntax = "proto3";
option csharp_namespace = "ProtobufDemo.Models";

message User {
  int32 id = 1;
  string username = 2;
  string email = 3;
}

message UserList {
  repeated User users = 1; // 存储多个用户
}

// 2. 编译后,实现序列化与持久化
public async Task PersistUserList()
{
    // 创建用户列表
    var userList = new UserList();
    userList.Users.AddRange(new List<User>
    {
        new User { Id = 1, Username = "zhangsan", Email = "zhangsan@example.com" },
        new User { Id = 2, Username = "lisi", Email = "lisi@example.com" }
    });
    
    // 1. 序列化到文件(备份)
    using (var stream = new FileStream("users.bin", FileMode.Create))
    {
        userList.WriteTo(stream);
    }
    
    // 2. 从文件反序列化(恢复)
    using (var stream = new FileStream("users.bin", FileMode.Open))
    {
        UserList restoredList = UserList.ParseFrom(stream);
        foreach (var user in restoredList.Users)
        {
            Console.WriteLine($"用户:{user.Username},邮箱:{user.Email}");
        }
    }
    
    // 3. 序列化到数据库(存储二进制数据)
    byte[] bytes = userList.ToByteArray();
    // 假设使用EF Core存储到数据库(字段类型为varbinary)
    var dbContext = new AppDbContext();
    dbContext.UserData.Add(new UserData { Data = bytes, CreateTime = DateTime.Now });
    await dbContext.SaveChangesAsync();
}

// 数据库实体
public class UserData
{
    public int Id { get; set; }
    public byte[] Data { get; set; } // 存储Protobuf序列化后的二进制数据
    public DateTime CreateTime { get; set; }
}

场景2:微服务跨服务通信(C# ↔ Python)

需求:C#微服务发送用户数据(Protobuf格式)到Python微服务,Python服务接收后反序列化并处理。

// C# 微服务:序列化User实体,通过HTTP发送到Python服务
public async Task SendToPythonService()
{
    var user = new User { Id = 1, Username = "zhangsan", Email = "zhangsan@example.com" };
    byte[] bytes = user.ToByteArray(); // 序列化为二进制
    
    // 通过HTTP发送二进制数据
    var client = new HttpClient();
    var content = new ByteArrayContent(bytes);
    content.Headers.ContentType = new MediaTypeHeaderValue("application/x-protobuf");
    var response = await client.PostAsync("http://python-service:5000/receive-user", content);
}
# Python 微服务:接收二进制数据,反序列化为User实体(共用同一proto文件)
# 1. 安装Python Protobuf包:pip install protobuf
# 2. 编译proto文件为Python代码:protoc --python_out=./ Protos/User.proto
from flask import Flask, request
import User_pb2 # 编译后的Python实体类
app = Flask(__name__)
@app.route('/receive-user', methods=['POST'])
def receive_user():
    # 接收二进制数据
    data = request.get_data()
    # 反序列化为User实体
    user = User_pb2.User()
    user.ParseFromString(data)
    # 处理数据
    print(f"接收用户:{user.username},邮箱:{user.email}")
    return "success"
if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000)

六、避坑指南与最佳实践(深度重点)

Google.Protobuf用法简洁,但细节处理不当易导致兼容性问题、性能损耗,以下是企业级开发的避坑要点和最佳实践。

1. 字段定义避坑

2. 性能避坑

3. 跨语言兼容避坑

4. 通用最佳实践

七、总结

Google.Protobuf for C#的核心价值是“高效、兼容、可扩展”,它彻底解决了传统序列化方式的性能与兼容性痛点,是分布式系统、跨语言通信、数据持久化场景的最优选择之一。

掌握Google.Protobuf的关键:熟练定义proto文件(字段编号、类型、消息体),掌握序列化/反序列化核心操作,灵活运用进阶特性(字段扩展、跨语言通信、gRPC集成),并遵循最佳实践规避常见坑。

无论是微服务通信、物联网数据传输,还是数据备份与恢复,Google.Protobuf都能凭借其高性能、跨语言的优势,降低开发成本,提升系统效率。对于C#开发者而言,掌握它,能大幅提升分布式系统开发的核心能力。

扩展建议:深入学习Protobuf的高级特性(如oneof字段、map类型、自定义序列化),结合gRPC实现微服务全链路通信,结合Docker实现跨环境部署,进一步发挥其价值。

到此这篇关于C#常用类库Google.Protobuf的使用小结的文章就介绍到这了,更多相关C# Google.Protobuf内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

您可能感兴趣的文章:
阅读全文