[大数据]谷粒商城高级篇之SpringBoot整合es

SpringBoot整合ES

创建shop-search项目,导入对应版本的依赖

 <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.4.2</version>
 </dependency>
<!--由于springboot里面依赖默认es的依赖版本和我们的不一样，所以需要修改版本信息 -->
<properties>
        <java.version>1.8</java.version>
        <elasticsearch.version>7.4.2</elasticsearch.version>
</properties>

es的配置文件编写

@Configuration
public class ShopElasticConfig {
    
    public static final RequestOptions COMMON_OPTIONS;

    static {
        RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();

        COMMON_OPTIONS = builder.build();
    }
    
    @Bean
    public RestHighLevelClient esRestClient(){
        RestHighLevelClient client = new RestHighLevelClient(
                RestClient.builder(
                        new HttpHost("192.168.56.10", 9200, "http") //对应地址和端口号
                )
        );
        return client;
    }
}

再进行测试是否

//注意我们之前common里面有mysql相关依赖，启动的时候要排除 
@Test
    void contextLoads() {
        System.out.println(client);
    }

	//使用es简单添加数据
    @Test
    public void indexData() throws IOException {
        IndexRequest indexRequest =  new IndexRequest("users");
        indexRequest.id("1");//设置数据id

        User user = new User();
        user.setAge(22);
        user.setUserName("test");
        user.setSex("man");

        String jsonString = JSON.toJSONString(user);
        indexRequest.source(jsonString,XContentType.JSON); //要设置类型

        // 执行保存操作
        IndexResponse index = client.index(indexRequest, ShopElasticConfig.COMMON_OPTIONS);

        System.out.println(index);
    }

    @Data
    class User{
        private String userName;
        private String sex;
        private Integer age;
    }

再通过kibana验证

GET users/_search
//返回数据
{
  "took" : 5,
  "timed_out" : false,
  "_shards" : {
    "total" : 1,
    "successful" : 1,
    "skipped" : 0,
    "failed" : 0
  },
  "hits" : {
    "total" : {
      "value" : 1,
      "relation" : "eq"
    },
    "max_score" : 1.0,
    "hits" : [
      {
        "_index" : "users",
        "_type" : "_doc",
        "_id" : "1",
        "_score" : 1.0,
        "_source" : {
          "age" : 22,
          "sex" : "man",
          "userName" : "test"
        }
      }
    ]
  }
}

复杂检索

@Data
@ToString
static class Acount {
    private int account_number;
    private int balance;
    private String firstname;
    private String lastname;
    private int age;
    private String gender;
    private String address;
    private String employer;
    private String email;
    private String city;
    private String state;
}

@Test
void searchData() throws IOException {
    // 1. 创建检索请求
    SearchRequest searchRequest = new SearchRequest();
    // 指定索引
    searchRequest.indices("bank");
    // 指定 DSL 即检索条件  sourceBuilder 封装的条件
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();

    // 构建检索条件  address 包含 mill
    searchSourceBuilder.query(QueryBuilders.matchQuery("address", "mill"));
    // 聚合条件  按照年龄值分布进行聚合
    TermsAggregationBuilder ageAgg = AggregationBuilders.terms("ageAgg").field("age").size(10);
    searchSourceBuilder.aggregation(ageAgg);
    // 计算平均薪资
    AvgAggregationBuilder balanceAvg = AggregationBuilders.avg("balanceAvg").field("balance");
    searchSourceBuilder.aggregation(balanceAvg);

    System.out.println("检索条件：" + searchSourceBuilder.toString());
    searchRequest.source(searchSourceBuilder);

    // 执行检索, 获得响应
    SearchResponse searchResponse = client.search(searchRequest, ShopElasticConfig.COMMON_OPTIONS);

    // 分析结果
    // 获取所有查到的记录
    SearchHits hits = searchResponse.getHits();
    SearchHit[] searchHits = hits.getHits();
    for (SearchHit hit : searchHits) {
        // 数据字符串
        String jsonString = hit.getSourceAsString();

        Acount account = JSON.parseObject(jsonString, Acount.class);
        System.out.println(account);
    }

    // 获取检索的分析信息(聚合数据等)
    Aggregations aggregations = searchResponse.getAggregations();

    // for (Aggregation aggregation : aggregations.asList()) {
    //     System.out.println("当前聚合名：" + aggregation.getName());
    // }

    Terms ageAgg1 = aggregations.get("ageAgg");
    for (Terms.Bucket bucket : ageAgg1.getBuckets()) {
        String keyAsString = bucket.getKeyAsString();
        System.out.println("年龄：" + keyAsString + "===>" + bucket.getDocCount());
    }

    Avg balanceAvg1 = aggregations.get("balanceAvg");
    System.out.println("平均薪资: " + balanceAvg1.getValue());
}