一、修改Config
package com.mangoubiubiu.search.config; import org.apache.http.HttpHost; import org.elasticsearch.client.HttpAsyncResponseConsumerFactory; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class SearchConfig { /** * 通用设置项 基于默认规则加的设置 */ 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(); } @Bean public RestHighLevelClient esRestClient(){ RestHighLevelClient client = new RestHighLevelClient( RestClient.builder( new HttpHost("192.168.56.10", 9200, "http"))); return client; } }
二、Junit 测试保存
package com.atguigu.gulimall.search; import com.alibaba.fastjson.JSON; import com.atguigu.gulimall.search.config.SearchConfig; import lombok.Data; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.common.xcontent.XContentType; import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import java.io.IOException; @RunWith(SpringRunner.class) @SpringBootTest public class GulimallSearchApplicationTests { @Autowired private RestHighLevelClient restHighLevelClient; @Test public void contextLoads() { System.out.println(restHighLevelClient); } /** * 测试存储数据到ES * 保存更新 */ @Test public void indexData() throws IOException { IndexRequest request = new IndexRequest("users"); request.id("1"); //数据id // request.source("userName","zhangsan","age",18,"gender","男"); User user = new User(); user.setUserName("张三"); user.setAge(18); user.setGender("男"); String jsonString = JSON.toJSONString(user); request.source(jsonString, XContentType.JSON); //要保存的内容 //执行保存操作 IndexResponse index = restHighLevelClient.index(request, SearchConfig.COMMON_OPTIONS); //提前有用的响应的数据 System.out.println(index); } @Data class User{ private String userName; private String gender; private Integer age; } }
有数据,保存成功
原文地址:http://www.cnblogs.com/mangoubiubiu/p/16804554.html
1. 本站所有资源来源于用户上传和网络,如有侵权请邮件联系站长!
2. 分享目的仅供大家学习和交流,请务用于商业用途!
3. 如果你也有好源码或者教程,可以到用户中心发布,分享有积分奖励和额外收入!
4. 本站提供的源码、模板、插件等等其他资源,都不包含技术服务请大家谅解!
5. 如有链接无法下载、失效或广告,请联系管理员处理!
6. 本站资源售价只是赞助,收取费用仅维持本站的日常运营所需!
7. 如遇到加密压缩包,默认解压密码为"gltf",如遇到无法解压的请联系管理员!
8. 因为资源和程序源码均为可复制品,所以不支持任何理由的退款兑现,请斟酌后支付下载
声明:如果标题没有注明"已测试"或者"测试可用"等字样的资源源码均未经过站长测试.特别注意没有标注的源码不保证任何可用性