使用springboot如何实现集成 - 行业资讯 - 肥雀云

　　介绍

这篇文章运用简单易懂的例子给大家介绍使用springboot如何实现集成,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。

1。导入maven依赖

 & lt; dependency>
　　& lt; groupId> org.springframework.boot
　　& lt; artifactId> spring-boot-starter-dataelasticsearch
　　& lt; dependency>

注意保持版本一致我用的是土壤质素版本的

& lt; properties> 　　& lt; java.version> 1.8 & lt;/java.version> 　　& lt; elasticsearch.version> 7.6.2 　　& lt; !——自定义版本保持版本一致——比; 　　& lt;/properties>

2。编写配置类相当于xlm导入文档

@ configuration 　　公开课ESConfig { 　　　　@ bean 　　公共RestHighLevelClient RestHighLevelClient () { 　　RestHighLevelClient RestHighLevelClient=new RestHighLevelClient ( 　　RestClient.builder ( 　　9100年新HttpHost (“localhost",“http") 　　）　　); 　　返回restHighLevelClient; 　　}

注意这里的端口号一定不能搞错

3测试书写添加索引

@Test 　　空白contextLoads()抛出IOException {//1 .创建索引的请求　　CreateIndexRequest CreateIndexRequest=new CreateIndexRequest (“mao");//2。执行请求获得响应　　CreateIndexResponse CreateIndexResponse=estHighLevelClient.indices ()。创建(createIndexRequest RequestOptions.DEFAULT); 　　System.out.println (createIndexResponse); 　　}

4。查询索引是否存在

 @Test//查询索引是否存在
　　空白existIndex()抛出IOException {
　　GetIndexRequest GetIndexRequest=new GetIndexRequest (“test");//获得索引请求
　　布尔存在=estHighLevelClient.indices ()。存在(getIndexRequest RequestOptions.DEFAULT);
　　System.out.println(存在);
　　}

5。删除索引

@Test//删除　　空白delIndex()抛出IOException { 　　DeleteIndexRequest DeleteIndexRequest=new DeleteIndexRequest (“test"); 　　AcknowledgedResponse删除=estHighLevelClient.indices () delete (deleteIndexRequest RequestOptions.DEFAULT); 　　System.out.println(删除); 　　System.out.println (delete.isAcknowledged ()); 　　}

6。添加文档数据第一要设置实体类导入阿里巴巴JSON工具类

 @ data
　　@Accessors(链=true)//实体类
　　
　　公开课用户{
　　私人字符串名称;
　　私人字符串年龄;
　　}

 @Test//添加文档
　　空白addDocument()抛出IOException {//创建对象啊
　　用户用户=新用户().setAge (“13”) .setName (“mao");//创建请求
　　IndexRequest请求=new IndexRequest (“mao");//设置规则把/测试/_doc/id
　　request.id (“1“);
　　request.timeout (“1 s");//将请求放入josn
　　request.source (JSON.toJSONString(用户),XContentType.JSON);//客户端发送请求
　　IndexResponse指数=estHighLevelClient。指数(请求,RequestOptions.DEFAULT);//获取响应结果
　　System.out.println (index.toString ());
　　System.out.println (index.status ());

 & lt; dependency>
　　& lt; groupId> com.alibaba
　　& lt; artifactId> fastjson
　　& lt; version> 1.2.47
　　& lt;/dependency>

7。修改文档

 @Test//更新文档操作
　　空白GengXin()抛出IOException {
　　UpdateRequest UpdateRequest=new UpdateRequest (“mao",“1“);//请求更新文档
　　updateRequest.timeout (“1 s");//设置超时时间
　　用户用户=新用户().setName(“张三“).setAge (“26”);
　　updateRequest.doc (JSON.toJSONString(用户),XContentType.JSON);//将对象封装丢进去XContentType方法将要传输的数据进行告知=estHighLevelClient UpdateResponse更新。更新(updateRequest RequestOptions.DEFAULT);//发送请求
　　System.out.println(更新);
　　}

8。批量增加

 @Test//批量丢入数据
　　空白TestBulkIndexRequest()抛出IOException {
　　BulkRequest BulkRequest=new BulkRequest ();//大批量导入数据本质是为循环
　　bulkRequest.timeout (“10 s");
　　ArrayList用户=new ArrayList<在();
　　(int i=0; i<10;我+ +){
　　用户。添加新用户().setName(“张三“+我+“号“).setAge (““+ i));
　　}//批处理请求
　　for (int i=0; i< users.size();我+ +){
　　bulkRequest.add (
　　新IndexRequest (“mao")
　　.id (““+ (i + 1))
　　.source (JSON.toJSONString (users.get (i)), XContentType.JSON)
　　);
　　
　　}
　　BulkResponse散装=estHighLevelClient。散装(bulkRequest RequestOptions.DEFAULT);
　　System.out.println(散装);
　　System.out.println (bulk.hasFailures());//查询是否失败
　　
　　}使用springboot如何实现集成