Overview
MongoDB 驱动程序可以压缩发送到 MongoDB 服务器和从 MongoDB 服务器接收的消息。这会减少每次操作的数据传输量。压缩可以提高在受限网络上的性能,并降低与运行 MongoDB Atlas 相关的数据传输费用。
压缩在传输协议级别运行,因此它适用于您的应用程序执行的每项操作。如果您指定了多种算法,驱动程序将使用列表中 MongoDB 服务器也支持的第一种算法。
压缩算法
MongoDB 驱动程序支持以下压缩算法:
网络压缩优势
MongoDB Atlas 对跨云区域、云提供商以及您的基础设施与 MongoDB Atlas 之间的数据传输收费。网络压缩可减少您的应用程序发送和接收的数据量,这可以降低这些数据传输费用。要了解有关定价的更多信息,请参阅数据传输费用。
网络压缩还能提高生产力。压缩后的消息在网络上传输所需的时间更短,这可以缩短应用程序的响应时间。压缩还可以减少 MongoDB 流量所使用的带宽,从而为同一网络上的其他应用程序留出更多可用带宽。
当您选择压缩算法时,请考虑以下指南:
使用 Zstandard 可在压缩效率和资源使用之间取得平衡。对于大多数应用程序,Zstandard 是一个不错的默认选择。
对于对延迟敏感且需要最小计算开销的应用程序,请使用 Snappy。
使用 zlib 以实现 MongoDB 驱动程序和环境之间的广泛兼容性。
提示
监控 CPU 使用率
压缩以 CPU 使用率为代价换取网络带宽。启用网络压缩后,请监控应用程序的 CPU 利用率,以确认这种权衡是否对您的工作负载有利。要了解有关这些权衡的更多信息,请参阅MongoDB 中的 CPU 利用率和网络压缩博客文章。
版本兼容性
下表列出了每个压缩算法支持的最低驱动程序和 MongoDB 服务器版本:
启用网络压缩
要为您的 MongoDB 连接启用网络压缩,请安装所需的依赖项并指定要使用的压缩算法。
压缩算法依赖关系
下表列出了每个算法以及它所需的依赖项(如有):
压缩算法 | 依赖项 |
|---|---|
snappy | 下载 |
zlib | 无。该驱动程序原生支持 zlib 压缩。 |
Zstandard | 下载 |
指定压缩算法
您可以通过以下方式指定算法来启用连接压缩:
将
compressors参数添加到ConnectionString实例从
MongoClientSettings构建器调用compressorList()方法
要在ConnectionString实例中对连接启用压缩,请指定 compressors 参数。您可以为 compressors 参数指定以下一个或多个值:
以下示例演示如何指定 Snappy、Zlib 和 Zstandard 作为连接的压缩算法:
// Replace the placeholders with values from your MongoDB deployment's connection stringval connectionString = ConnectionString("mongodb+srv://<db_username>:<db_password>@<cluster-url>/?compressors=snappy,zlib,zstd")
// Create a new client with your settingsval mongoClient = MongoClient.create(connectionString)要在MongoClientSettings中启用压缩,请调用CompressorList()构建器方法并将一个或多个MongoCompressor实例作为参数传递。
您可以通过从MongoCompressor调用以下方法来指定压缩算法:
createSnappyCompressor()用于 Snappy 压缩createZlibCompressor()用于zlib压缩createZstdCompressor()用于 Zstandard 压缩
以下示例演示如何指定 Snappy、Zlib 和 Zstandard 作为连接的压缩算法:
// Replace the placeholder with your MongoDB deployment's connection stringval uri = "<connection string>"
val settings = MongoClientSettings.builder() .applyConnectionString(ConnectionString(uri)) .compressorList( listOf( MongoCompressor.createSnappyCompressor(), MongoCompressor.createZlibCompressor(), MongoCompressor.createZstdCompressor()) ) .build()
// Create a new client with your settingsval mongoClient = MongoClient.create(settings)