Milvus Collection 基本操作（Java SDK）

Collection 是 Milvus 中用于组织向量数据的基本单元。一个 Collection 类似于关系数据库中的“表”，包含 schema（字段定义）、索引、分区等。

所有操作均通过MilvusServiceClient实例调用，并返回R<T>类型的结果对象（R表示 Result），可通过.getStatus()判断是否成功，.getData()获取结果数据。

0. 前置工作

要配置好MilvusServiceClient，写好yaml配置文件，spring 会自动注入

✅ 1. 创建 Collection

方法

R<RpcStatus>createCollection(CreateCollectionParamrequestParam)

示例

CreateCollectionParamparam=CreateCollectionParam.newBuilder().withCollectionName("example_collection").withSchema(schema)// 需提前定义 CollectionSchema.build();R<RpcStatus>response=client.createCollection(param);if(response.getStatus()==R.Status.Success.getCode()){System.out.println("Collection created successfully.");}

⚠️schema需通过FieldType构建，包含主键、向量字段等。

❌ 2. 删除 Collection

方法

R<RpcStatus>dropCollection(DropCollectionParamrequestParam)

示例

DropCollectionParamparam=DropCollectionParam.newBuilder().withCollectionName("example_collection").build();R<RpcStatus>response=client.dropCollection(param);

删除后无法恢复，请谨慎操作。

🔍 3. 检查 Collection 是否存在

方法

R<Boolean>hasCollection(HasCollectionParamrequestParam)

示例

HasCollectionParamparam=HasCollectionParam.newBuilder().withCollectionName("example_collection").build();R<Boolean>response=client.hasCollection(param);if(response.getData()){System.out.println("Collection exists.");}

📋 4. 查看 Collection 详细信息（Describe）

方法

R<DescribeCollectionResponse>describeCollection(DescribeCollectionParamrequestParam)

示例

DescribeCollectionParamparam=DescribeCollectionParam.newBuilder().withCollectionName("example_collection").build();R<DescribeCollectionResponse>response=client.describeCollection(param);if(response.getStatus()==R.Status.Success.getCode()){DescribeCollectionResponsedesc=response.getData();System.out.println("Schema: "+desc.getSchema());System.out.println("Shards: "+desc.getShardsNum());}

📊 5. 获取 Collection 统计信息

方法

R<GetCollectionStatisticsResponse>getCollectionStatistics(GetCollectionStatisticsParamrequestParam)

示例

GetCollectionStatisticsParamparam=GetCollectionStatisticsParam.newBuilder().withCollectionName("example_collection").build();R<GetCollectionStatisticsResponse>response=client.getCollectionStatistics(param);if(response.getStatus()==R.Status.Success.getCode()){Map<String,String>stats=response.getData().getStatsList().stream().collect(Collectors.toMap(stat->stat.getKey(),stat->stat.getValue()));System.out.println("Row count: "+stats.get("row_count"));}

📥 6. 加载 Collection 到内存（Load）

查询或搜索前必须先加载。

方法

R<RpcStatus>loadCollection(LoadCollectionParamrequestParam)

示例

LoadCollectionParamparam=LoadCollectionParam.newBuilder().withCollectionName("example_collection").build();R<RpcStatus>response=client.loadCollection(param);

可选：指定资源组（Resource Group）、副本数等。

📤 7. 释放 Collection（Release）

从内存中卸载，节省资源。

方法

R<RpcStatus>releaseCollection(ReleaseCollectionParamrequestParam)

示例

ReleaseCollectionParamparam=ReleaseCollectionParam.newBuilder().withCollectionName("example_collection").build();R<RpcStatus>response=client.releaseCollection(param);

🔄 8. 重命名 Collection

方法

R<RpcStatus>renameCollection(RenameCollectionParamrequestParam)

示例

RenameCollectionParamparam=RenameCollectionParam.newBuilder().withOldCollectionName("old_name").withNewCollectionName("new_name").build();R<RpcStatus>response=client.renameCollection(param);

注意：部分 Milvus 版本可能不支持此功能。

🗂️ 9. 列出所有 Collections

方法

R<ShowCollectionsResponse>showCollections(ShowCollectionsParamrequestParam)

示例

ShowCollectionsParamparam=ShowCollectionsParam.newBuilder().addCollectionName("example_collection")// 可选：过滤特定集合.build();R<ShowCollectionsResponse>response=client.showCollections(param);List<String>names=response.getData().getCollectionNamesList();System.out.println("Collections: "+names);

⚙️ 10. 修改 Collection 属性（如 TTL）

方法

R<RpcStatus>alterCollection(AlterCollectionParamrequestParam)

示例（设置 TTL 为 1 小时）

JsonObjectproperties=newJsonObject();properties.addProperty("collection.ttl.seconds","3600");AlterCollectionParamparam=AlterCollectionParam.newBuilder().withCollectionName("example_collection").withProperties(properties).build();R<RpcStatus>response=client.alterCollection(param);

支持的属性取决于 Milvus 版本。

🧪 附加：高阶简化接口（High-level API）

如果你使用的是high-level 接口（更易用）：

• createCollection(CreateSimpleCollectionParam)：只需指定名称、维度、相似度类型。
• listCollections(ListCollectionsParam)：返回封装好的ListCollectionsResponse。

📝 注意事项

• 所有操作默认启用自动重试机制（可配置）。
• 网络异常、服务不可用等会触发重试（非业务错误如INVALID_ARGUMENT不重试）。
• 使用withTimeout(...)可为单次操作设置超时。
• 操作前确保客户端已成功连接（构造函数中会自动执行connect）。

📚 相关类参考

如需完整示例项目，可参考 Milvus Java SDK 官方 GitHub。