milvus java sdk 使用
时间: 2025-05-06 16:01:52 浏览: 46
### 如何使用 Milvus Java SDK
Milvus 是一款专注于向量相似度搜索的开源工具,其提供了多种编程语言的支持,其中包括 Java。以下是关于如何使用 Milvus Java SDK 的详细说明。
#### 1. 添加依赖项
为了使用 Milvus Java SDK,在 Maven 或 Gradle 构建文件中添加相应的依赖项。对于 Maven 用户:
```xml
<dependency>
<groupId>io.milvus</groupId>
<artifactId>milvus-sdk-java</artifactId>
<version>2.x.x</version> <!-- 替换为最新版本号 -->
</dependency>
```
Gradle 用户可以这样配置:
```gradle
implementation 'io.milvus:milvus-sdk-java:2.x.x' // 替换为最新版本号
```
此部分操作基于官方文档中的指导[^1]。
#### 2. 初始化连接到 Milvus 实例
在初始化阶段,创建 `RSocketClient` 对象并设置目标服务器地址和端口。以下是一个简单的代码示例用于建立与 Milvus 数据库的连接:
```java
import io.milvus.param.R;
import io.milvus.client.MilvusServiceClient;
public class MilvusConnectionExample {
public static void main(String[] args) throws Exception {
String host = "localhost";
int port = 19530;
R<MilvusServiceClient> clientResult = new MilvusServiceClient.Builder()
.withHost(host)
.withPort(port)
.build();
if (clientResult.getStatus().equals(R.Status.Success)) {
System.out.println("Connected to Milvus server successfully.");
} else {
System.err.println("Failed to connect to Milvus server.");
}
}
}
```
上述代码展示了如何通过指定主机名 (`host`) 和端口号 (`port`) 来构建客户端实例,并验证是否成功建立了连接。
#### 3. 创建集合
一旦连接被正确初始化之后,就可以执行诸如创建新集合之类的数据库管理任务了。下面是一段用来定义一个新的数据集结构的例子:
```java
import io.milvus.param.collection.CreateCollectionParam;
import io.milvus.param.FieldType;
import java.util.Arrays;
// 定义字段参数...
CreateCollectionParam param = CreateCollectionParam.newBuilder()
.withCollectionName("example_collection")
.withDescription("This is an example collection.")
.withShardsNum(2)
.addField(FieldType.INT64, "id", true, false)
.addField(FieldType.FLOAT_VECTOR, "vector", Arrays.asList(128))
.build();
milvusClient.createCollection(param);
System.out.println("Collection created!");
```
这里演示了怎样利用 `CreateCollectionParam` 类型来设定各个属性值以及调用实际的方法完成创建过程。
#### 4. 插入数据
当有了可用的数据表后,则可继续往其中插入记录条目。下面是有关于这一环节的具体实现方式之一:
```java
List<Long> ids = Arrays.asList(1L, 2L, 3L);
List<Float[]> vectors = Arrays.asList(
new Float[]{...}, // 长度应匹配预设维度大小
...
);
InsertParam insertParam = InsertParam.newBuilder()
.withCollectionName("example_collection")
.withFieldNames(Arrays.asList("id","vector"))
.withEntities(ids,vectors)
.build();
milvusClient.insert(insertParam);
System.out.println("Data inserted into the collection.");
```
这段脚本解释了如何将实体对象批量加入已存在的集合里去。
---
### 总结
以上就是针对 Milvus Java SDK 基础使用的介绍内容,涵盖了从环境搭建直至基本功能实践等多个方面知识点。更多高级特性还需查阅官方提供的详尽资料进一步学习掌握。
阅读全文
相关推荐


















