ELASTICSEARCH的java客户端和springboot整合(二)

迈不过友情╰ 2022-01-21 09:33 388阅读 0赞

SpringBoot整合TransportClient

目录

  1.                   SpringBoot整合TransportClient

一.1redis的整合

1.启动一个redis的结点(单节点)

2.配置单节点的内容

3.配置类中读取属性生成返回的JedisShardedPool

一.2rabbitmq的整合

1.直接利用springboot自动整合

2.生产端注入RabbitTemplate

3.消费端异步监听的声明式注解@RabbitListener

一.3es的整合

3.配置类读取属性

4.配置类初始化TransportClient对象

6.创建一个main类

7.创建ESController类

1.先添加一些数据

2.运行代码测试

1.redis的整合

一.1redis的整合

1.启动一个redis的结点(单节点)

2.配置单节点的内容

  • redis.nodes
  • redis.maxTotal
  • redis.minIdle
  • redis.maxIdle

3.配置类中读取属性生成返回的JedisShardedPool

一.2rabbitmq的整合

1.直接利用springboot自动整合

2.生产端注入RabbitTemplate

3.消费端异步监听的声明式注解@RabbitListener

一.3es的整合

  • springboot版本1.5.2.RELEASE—>2.X的es版本
  • es的版本历史:随着es的发展形成了一个庞大的家族
  • springboot版本2.1.X.RELEASE—>5.x以上的es

手动整合:TransportClient交给框架维护,注入使用

1.Pom.xml依赖

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.   <modelVersion>4.0.0</modelVersion>
  5.   <groupId>cn.tedu</groupId>
  6.   <artifactId>springboot-elasticsearch</artifactId>
  7.   <version>0.0.1-SNAPSHOT</version>
  8.   <packaging>jar</packaging>
  10.   <name>springboot-elasticsearch</name>
  11.   <url>http://maven.apache.org</url>
  12.   <parent>
  13.       <groupId>org.springframework.boot</groupId>
  14.       <artifactId>spring-boot-starter-parent</artifactId>
  15.       <version>1.5.2.RELEASE</version>
  16.   </parent>
  17.   <properties>
  18.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  19.   </properties>
  21.   <dependencies>
  22.       <dependency>
  23.           <groupId>org.springframework.boot</groupId>
  24.           <artifactId>spring-boot-starter-web</artifactId>
  25.       </dependency>
  26.     <dependency>
  27.       <groupId>junit</groupId>
  28.       <artifactId>junit</artifactId>
  29.       <version>3.8.1</version>
  30.       <scope>test</scope>
  31.     </dependency>
  32.     <dependency>
  33.         <groupId>org.elasticsearch</groupId>
  34.         <artifactId>elasticsearch</artifactId>
  35.         <version>5.5.2</version>
  36.     </dependency>
  37.     <!-- es的java客户端 TransportClient  -->
  38.     <dependency>
  39.         <groupId>org.elasticsearch.client</groupId>
  40.         <artifactId>transport</artifactId>
  41.         <version>5.5.2</version>
  42.     </dependency>
  43.     <!-- Java对象转换json字符串 -->
  44.     <dependency>
  45.         <groupId>com.fasterxml.jackson.core</groupId>
  46.         <artifactId>jackson-databind</artifactId>
  47.         <version>2.8.7</version>
  48.     </dependency>
  49.   </dependencies>
  50. </project>

2.准备配置prop**erties**

20190609161452527.png

需要多个可以追加

3.配置类读取属性

@ConfigurationProperties(prefix=”es”)

private List nodes;

20190609161717807.png

4.配置类初始化TransportClient对象

  1. //初始化连接对象
  2.     @Bean
  3.     public TransportClient initEsClient() throws Exception{
  4.         //新建一个client对象,setting对象(配置集群名称)
  5.         TransportClient client=
  6.                 new PreBuiltTransportClient(Settings.EMPTY);
  7.         //添加负载均衡器的结点信息,如果是集群,可以多次添加多个节点信息
  9.         for (String node : nodes) {//10.9.9.9:9300
  10.             String host=node.split(":")[0];
  11.             int port=Integer.parseInt(node.split(":")[1]);
  12.             client.addTransportAddress(new InetSocketTransportAddress(
  13.                     InetAddress.getByName(host), port));
  14.         }
  15.         return client;
  16.     }
  17.     public List<String> getNodes() {
  18.         return nodes;
  19.     }
  21.     public void setNodes(List<String> nodes) {
  22.         this.nodes = nodes;
  23.     }

6.**创建一个main类**

  1. package com.jt;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class StarterES {
  8.     public static void main(String[] args) {
  9.         SpringApplication.run(StarterES.class, args);
  10.     }
  11. }

7.创建ESController类

  1. @RestController
  2. public class ESController {
  3.     @Autowired
  4.     private TransportClient client;
  5.     @RequestMapping("search")
  6.     public String searchArticle
  7.     (String name,String text,Integer page,Integer rows){
  8.         MatchQueryBuilder query1=QueryBuilders.matchQuery(name, text);//进行默认的分词器解析
  9.         //java 编,程,思,想
  10.         //搜索api获取搜索结果
  11.         SearchResponse response1 = client.prepareSearch("index06")
  12.         .setFrom((page-1)*rows).setSize(rows).setQuery(query1).get();
  13.         long total = response1.getHits().totalHits;
  14.         System.out.println(total);
  15.         SearchHit[] hits = response1.getHits().getHits();
  16.         String reMsg="";
  17.         for (SearchHit hit : hits) {
  18.             reMsg=reMsg+hit.getSourceAsString();
  19.         }
  20.         return reMsg;
  21.     }
  22. }

1.先添加一些数据

  1. curl -XPUT -d '{"id":1,"title":"es简介1","content":"es好用好用真好用1"}' http://10.42.60.249:9200/index06/article/1
  2. curl -XPUT -d '{"id":2,"title":"es简介2","content":"es好用好用真好用2"}' http://10.42.60.249:9200/index06/article/2
  3. curl -XPUT -d '{"id":3,"title":"es简介3","content":"es好用好用真好用3"}' http://10.42.60.249:9200/index06/article/3
  4. curl -XPUT -d '{"id":4,"title":"es简介4","content":"es好用好用真好用4"}' http://10.42.60.249:9200/index06/article/4
  5. curl -XPUT -d '{"id":5,"title":"es简介5","content":"es好用好用真好用5"}' http://10.42.60.249:9200/index06/article/5
  6. curl -XPUT -d '{"id":6,"title":"es简介6","content":"es好用好用真好用6"}' http://10.42.60.249:9200/index06/article/6
  7. curl -XPUT -d '{"id":7,"title":"es简介7","content":"es好用好用真好用7"}' http://10.42.60.249:9200/index06/article/7
  8. curl -XPUT -d '{"id":8,"title":"es简介8","content":"es好用好用真好用8"}' http://10.42.60.249:9200/index06/article/8
  9. curl -XPUT -d '{"id":9,"title":"es简介9","content":"es好用好用真好用9"}' http://10.42.60.249:9200/index06/article/9
  10. curl -XPUT -d '{"id":10,"title":"es简介10","content":"es好用好用真好用10"}' http://10.42.60.249:9200/index06/article/10
  11. curl -XPUT -d '{"id":11,"title":"es简介11","content":"es好用好用真好用11"}' http://10.42.60.249:9200/index06/article/11

2.运行代码测试

20190609164041258.png

实现通过代码获取ES中的数据

20190609164218252.png

#

发表评论

表情：
评论列表 （有 0 条评论，388人围观）

还没有评论，来说两句吧...

相关阅读