1
@Test
2
void testMatchAll() throws IOException {
3
    // 1. Prepare Request
4
    SearchRequest request = new SearchRequest("hotel");
5
    // 2. Prepare DSL
6
    request.source()
7
        .query(QueryBuilders.matchAllQuery());
8
    // 3. Send the request
9
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
10

11
    // 4. Parse the response
12
    handleResponse(response);
13
}
14

15
private void handleResponse(SearchResponse response) {
16
    // 4. Parse the response
17
    SearchHits searchHits = response.getHits();
18
    // 4.1. Get total hits
19
    long total = searchHits.getTotalHits().value;
20
    System.out.println("Total hits: " + total);
21
    // 4.2. Documents array
22
    SearchHit[] hits = searchHits.getHits();
23
    // 4.3. Iterate
24
    for (SearchHit hit : hits) {
25
        // Get document source
26
        String json = hit.getSourceAsString();
27
        // Deserialize
28
        HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
29
        System.out.println("hotelDoc = " + hotelDoc);
30
    }
31
}

1
@Test
2
void testMatch() throws IOException {
3
    // 1. Prepare Request
4
    SearchRequest request = new SearchRequest("hotel");
5
    // 2. Prepare DSL
6
    request.source()
7
        .query(QueryBuilders.matchQuery("all", "如家"));
8
    // 3. Send request
9
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
10
    // 4. Parse the response
11
    handleResponse(response);
12

13
}

1
// term query
2
QueryBuilders.termQuery("city","杭州");
3

4
// range query
5
QueryBuilders.rangeQuery("price").gte(100).lte(150);

1
@Test
2
void testBool() throws IOException {
3
    // 1. Prepare Request
4
    SearchRequest request = new SearchRequest("hotel");
5
    // 2. Prepare DSL
6
    // 2.1 Prepare BooleanQuery
7
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
8
    // 2.2 Add term
9
    boolQuery.must(QueryBuilders.termQuery("city", "杭州"));
10
    // 2.3 Add range
11
    boolQuery.filter(QueryBuilders.rangeQuery("price").lte(250));
12

13
    request.source().query(boolQuery);
14
    // 3. Send request
15
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
16
    // 4. Parse the response
17
    handleResponse(response);
18
}

1
@Test
2
void testPageAndSort() throws IOException {
3
    // Page number and page size
4
    int page = 1, size = 5;
5

6
    // 1. Prepare Request
7
    SearchRequest request = new SearchRequest("hotel");
8
    // 2. Prepare DSL
9
    // 2.1 query
10
    request.source().query(QueryBuilders.matchAllQuery());
11
    // 2.2 sort
12
    request.source().sort("price", SortOrder.ASC);
13
    // 2.3 pagination from, size
14
    request.source().from((page - 1) * size).size(5);
15
    // 3. Send request
16
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
17
    // 4. Parse the response
18
    handleResponse(response);
19

20
}

1
@Test
2
void testHighlight() throws IOException {
3
    // 1. Prepare Request
4
    SearchRequest request = new SearchRequest("hotel");
5
    // 2. Prepare DSL
6
    // 2.1 query
7
    request.source().query(QueryBuilders.matchQuery("all", "如家"));
8
    // 2.2.Highlight
9
    request.source().highlighter(new HighlightBuilder().field("name").requireFieldMatch(false));
10
    // 3. Send request
11
    SearchResponse response = client.search(request, RequestOptions.DEFAULT);
12
    // 4. Parse the response
13
    handleResponse(response);
14
}
15

16
private void handleResponse(SearchResponse response) {
17
    // 4. Parse the response
18
    SearchHits searchHits = response.getHits();
19
    // 4.1 Get total
20
    long total = searchHits.getTotalHits().value;
21
    System.out.println("Total hits: " + total);
22
    // 4.2 Documents array
23
    SearchHit[] hits = searchHits.getHits();
24
    // 4.3 Iterate
25
    for (SearchHit hit : hits) {
26
        // Get document source
27
        String json = hit.getSourceAsString();
28
        // Deserialize
29
        HotelDoc hotelDoc = JSON.parseObject(json, HotelDoc.class);
30
        // Get highlighted results
31
        Map<String, HighlightField> highlightFields = hit.getHighlightFields();
32
        if (!CollectionUtils.isEmpty(highlightFields)) {
33
            // Get highlight result by field name
34
            HighlightField highlightField = highlightFields.get("name");
35
            if (highlightField != null) {
36
                // Get highlighted value
37
                String name = highlightField.getFragments()[0].string();
38
                // Overwrite non-highlighted result
39
                hotelDoc.setName(name);
40
            }
41
        }
42
        System.out.println("hotelDoc = " + hotelDoc);
43
    }
44
}

1
private void buildBasicQuery(RequestParams params, SearchRequest request) {
2
    // 1. Build BooleanQuery
3
    BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
4
    // 2. Keyword search
5
    String key = params.getKey();
6
    if (key == null || "".equals(key)) {
7
        boolQuery.must(QueryBuilders.matchAllQuery());
8
    } else {
9
        boolQuery.must(QueryBuilders.matchQuery("all", key));
10
    }
11
    // 3. City condition
12
    if (params.getCity() != null && !params.getCity().equals("")) {
13
        boolQuery.filter(QueryBuilders.termQuery("city", params.getCity()));
14
    }
15
    // 4. Brand condition
16
    if (params.getBrand() != null && !params.getBrand().equals("")) {
17
        boolQuery.filter(QueryBuilders.termQuery("brand", params.getBrand()));
18
    }
19
    // 5. Star condition
20
    if (params.getStarName() != null && !params.getStarName().equals("")) {
21
        boolQuery.filter(QueryBuilders.termQuery("starName", params.getStarName()));
22
    }
23
  // 6. Price
24
    if (params.getMinPrice() != null && params.getMaxPrice() != null) {
25
        boolQuery.filter(QueryBuilders
26
                         .rangeQuery("price")
27
                         .gte(params.getMinPrice())
28
                         .lte(params.getMaxPrice())
29
                        );
30
    }
31
  // 7. Put into source
32
    request.source().query(boolQuery);
33
}

1
GET /indexName/_search
2
{
3
  "query": {
4
    "match_all": {}
5
  },
6
  "sort": [
7
    {
8
      "price": "asc"
9
    },
10
    {
11
      "_geo_distance" : {
12
          "FIELD" : "latitude, longitude",
13
          "order" : "asc",
14
          "unit" : "km"
15
      }
16
    }
17
  ]
18
}

1
// 2.3. Sorting
2
String location = params.getLocation();
3
if (location != null && !location.equals("")) {
4
    request.source().sort(SortBuilders
5
                          .geoDistanceSort("location", new GeoPoint(location))
6
                          .order(SortOrder.ASC)
7
                          .unit(DistanceUnit.KILOMETERS)
8
                         );
9
}

1
// 2. Scoring control
2
FunctionScoreQueryBuilder functionScoreQuery =
3
    QueryBuilders.functionScoreQuery(
4
    // Original query, the relevance-scoring query
5
    boolQuery,
6
    // Array of function_score elements
7
    new FunctionScoreQueryBuilder.FilterFunctionBuilder[]{
8
        // One function_score element
9
        new FunctionScoreQueryBuilder.FilterFunctionBuilder(
10
            // Filter condition
11
            QueryBuilders.termQuery("isAD", true),
12
            // Scoring function
13
            ScoreFunctionBuilders.weightFactorFunction(10)
14
        )
15
    });
16
request.source().query(functionScoreQuery);

1
@Override
2
public Map<String, List<String>> filters(RequestParams params) {
3
    try {
4
        // 1. Prepare Request
5
        SearchRequest request = new SearchRequest("hotel");
6
        // 2. Prepare DSL
7
        // 2.1. query
8
        buildBasicQuery(params, request);
9
        // 2.2. set size
10
        request.source().size(0);
11
        // 2.3. aggregation
12
        buildAggregation(request);
13
        // 3. Send request
14
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
15
        // 4. Parse results
16
        Map<String, List<String>> result = new HashMap<>();
17
        Aggregations aggregations = response.getAggregations();
18
        // 4.1. Get brand results
19
        List<String> brandList = getAggByName(aggregations, "brandAgg");
20
        result.put("Brand", brandList);
21
        // 4.2. Get city results
22
        List<String> cityList = getAggByName(aggregations, "cityAgg");
23
        result.put("City", cityList);
24
        // 4.3. Get star results
25
        List<String> starList = getAggByName(aggregations, "starAgg");
26
        result.put("Star", starList);
27

28
        return result;
29
    } catch (IOException e) {
30
        throw new RuntimeException(e);
31
    }
32
}
33

34
private void buildAggregation(SearchRequest request) {
35
    request.source().aggregation(AggregationBuilders
36
                                 .terms("brandAgg")
37
                                 .field("brand")
38
                                 .size(100)
39
                                );
40
    request.source().aggregation(AggregationBuilders
41
                                 .terms("cityAgg")
42
                                 .field("city")
43
                                 .size(100)
44
                                );
45
    request.source().aggregation(AggregationBuilders
46
                                 .terms("starAgg")
47
                                 .field("starName")
48
                                 .size(100)
49
                                );
50
}
51

52
private List<String> getAggByName(Aggregations aggregations, String aggName) {
53
    // 4.1 Get the aggregation by name
54
    Terms brandTerms = aggregations.get(aggName);
55
    // 4.2 Get buckets
56
    List<? extends Terms.Bucket> buckets = brandTerms.getBuckets();
57
    // 4.3 Iterate
58
    List<String> brandList = new ArrayList<>();
59
    for (Terms.Bucket bucket : buckets) {
60
        // 4.4 Get key
61
        String key = bucket.getKeyAsString();
62
        brandList.add(key);
63
    }
64
    return brandList;
65
}

1
docker exec -it es bash
2

3
./bin/elasticsearch-plugin install <https://github.com/medcl/elasticsearch-analysis-pinyin/releases/download/v7.12.1/elasticsearch-analysis-pinyin-7.12.1.zip>
4

5
exit
6
#Restart the container
7
docker restart elasticsearch

1
PUT /test
2
{
3
  "settings": {
4
    "analysis": {
5
      "analyzer": { // Custom analyzer
6
        "my_analyzer": {  // Analyzer name
7
          "tokenizer": "ik_max_word",
8
          "filter": "py"
9
        }
10
      },
11
      "filter": { // Custom tokenizer filter
12
        "py": { // Filter name
13
          "type": "pinyin", // Filter type
14
      "keep_full_pinyin": false,
15
          "keep_joined_full_pinyin": true,
16
          "keep_original": true,
17
          "limit_first_letter_length": 16,
18
          "remove_duplicated_term": true,
19
          "none_chinese_pinyin_tokenize": false
20
        }
21
      }
22
    }
23
  },
24
  "mappings": {
25
    "properties": {
26
      "name": {
27
        "type": "text",
28
        "analyzer": "my_analyzer",
29
        "search_analyzer": "ik_smart"
30
      }
31
    }
32
  }
33
}

1
@Override
2
public List<String> getSuggestions(String prefix) {
3
    try {
4
        // 1. Prepare Request
5
        SearchRequest request = new SearchRequest("hotel");
6
        // 2. Prepare DSL
7
        request.source().suggest(new SuggestBuilder().addSuggestion(
8
            "suggestions",
9
            SuggestBuilders.completionSuggestion("suggestion")
10
            .prefix(prefix)
11
            .skipDuplicates(true)
12
            .size(10)
13
        ));
14
        // 3. Send request
15
        SearchResponse response = client.search(request, RequestOptions.DEFAULT);
16
        // 4. Parse results
17
        Suggest suggest = response.getSuggest();
18
        // 4.1 Get suggestions by name
19
        CompletionSuggestion suggestions = suggest.getSuggestion("suggestions");
20
        // 4.2 Get options
21
        List<CompletionSuggestion.Entry.Option> options = suggestions.getOptions();
22
        // 4.3 Iterate
23
        List<String> list = new ArrayList<>(options.size());
24
        for (CompletionSuggestion.Entry.Option option : options) {
25
            String text = option.getText().toString();
26
            list.add(text);
27
        }
28
        return list;
29
    } catch (IOException e) {
30
        throw new RuntimeException(e);
31
    }
32
}

1
<!--amqp-->
2
<dependency>
3
    <groupId>org.springframework.boot</groupId>
4
    <artifactId>spring-boot-starter-amqp</artifactId>
5
</dependency>

1
import cn.itcast.hotel.constants.MqConstants;
2
import org.springframework.amqp.core.Binding;
3
import org.springframework.amqp.core.BindingBuilder;
4
import org.springframework.amqp.core.Queue;
5
import org.springframework.amqp.core.TopicExchange;
6
import org.springframework.context.annotation.Bean;
7
import org.springframework.context.annotation.Configuration;
8

9
@Configuration
10
public class MqConfig {
11
    @Bean
12
    public TopicExchange topicExchange(){
13
        return new TopicExchange(MqConstants.HOTEL_EXCHANGE, true, false);
14
    }
15

16
    @Bean
17
    public Queue insertQueue(){
18
        return new Queue(MqConstants.HOTEL_INSERT_QUEUE, true);
19
    }
20

21
    @Bean
22
    public Queue deleteQueue(){
23
        return new Queue(MqConstants.HOTEL_DELETE_QUEUE, true);
24
    }
25

26
    @Bean
27
    public Binding insertQueueBinding(){
28
        return BindingBuilder.bind(insertQueue()).to(topicExchange()).with(MqConstants.HOTEL_INSERT_KEY);
29
    }
30

31
    @Bean
32
    public Binding deleteQueueBinding(){
33
        return BindingBuilder.bind(deleteQueue()).to(topicExchange()).with(MqConstants.HOTEL_DELETE_KEY);
34
    }
35
}