接第24节
2、配置
1)、配置
在PafcmallElasticsearchConfig
配置类中添加如下配置:
public static final RequestOptions COMMON_OPTIONS;
static {
RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
// 这里先注释掉,目前没有用到,后边用到了再解释
// builder.addHeader("Authorization", "Bearer " + TOKEN);
// builder.setHttpAsyncResponseConsumerFactory(
// new HttpAsyncResponseConsumerFactory
// .HeapBufferedResponseConsumerFactory(30 * 1024 * 1024 * 1024));
COMMON_OPTIONS = builder.build();
}
2)、测试
在PafcmallSearchApplicationTests
测试类中添加如下代码:
/**
* 测试存储数据到es
* 更新也是可以的
*/
@Test
void indexData() throws IOException {
// 准备数据
IndexRequest indexRequest = new IndexRequest("users");//索引名
indexRequest.id("1");//数据id
// 第一种方式
// indexRequest.source("userName", "zhangsan", "age", 18, "gender", "男");
// 第二种方式(推荐使用)
User user = new User();
user.setUserName("zhangsan");
user.setAge(18);
user.setGender("男");
String jsonString = JSON.toJSONString(user);
indexRequest.source(jsonString,XContentType.JSON); //要保存的内容
// 执行操作
IndexResponse index = client.index(indexRequest, PafcmallElasticsearchConfig.COMMON_OPTIONS);
// 提取有用的数据相应
System.out.println(index);
}
@Data
class User{
private String userName;
private Integer age;
private String gender;
}
执行测试后可以看到创建索引成功:
在kibana 中查询一下:
更过配置信息请参考 java-rest-high-getting-started-request-options 和 java-rest-low-usage-request-options
参考:
版权声明:本文不是「本站」原创文章,版权归原作者所有 | 原文地址: