SpringBoot整合ES-High-Level-Client

/**
 * es配置类
 * 1. 导入依赖
 * 2. 编写配置，给容器注入一个RestHighLevelClient
 */
@Configuration
public class ElasticSearchConfig {
	
    // ES通用配置，是公用的
    public static final RequestOptions COMMON_OPTIONS;

    static {
        RequestOptions.Builder builder = RequestOptions.DEFAULT.toBuilder();
        COMMON_OPTIONS = builder.build();
    }
	
    // 将ES实例注入到IOC容器，后续都注入此实例使用即可
    @Bean
    public RestHighLevelClient esRestClient() {
        return new RestHighLevelClient(
                RestClient.builder(new HttpHost("127.0.0.1", 9200, "http"))
        );
    }
}

@SpringBootTest
class ElaTests {

	@Autowired
	private RestHighLevelClient client;

	/**
	 * 存储测试用例
	 */
	@SneakyThrows
	@Test
	void indexData() {
         // 获取users 索引（数据库）。如果没有会创建
		IndexRequest indexRequest = new IndexRequest("users");
         // id为1
		indexRequest.id("1");
		// indexRequest.source("userName", "zhangsan", "age", 18, "gender", "男");
		User user = new User("zhangsan",  "男", 18);
        // 通过json存储 
		String s = JSONObject.toJSONString(user);
		indexRequest.source(s, XContentType.JSON);

		// 执行操作
		IndexResponse index = client.index(indexRequest, ElasticSearchConfig.COMMON_OPTIONS);
		System.out.println(index);
	}

	@Data
	@AllArgsConstructor
	@NoArgsConstructor
	class User {
		private String userName;
		private String gender;
		private Integer age;
	}
	
    /**
	 * 查询
	 */
	@SneakyThrows
	@Test
	void searchData() {
		// 1.创建检索请求
		SearchRequest searchRequest = new SearchRequest();
		// 2.指定索引
		searchRequest.indices("bank");
		// 3.指定检索条件
		SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
		// 3.1 构造条件，对应具体的es的json中的语句
		//sourceBuilder.query();
		//sourceBuilder.from()
		//sourceBuilder.size();
		sourceBuilder.query(QueryBuilders.matchQuery("address", "mill"));
		// 3.2按照年龄的值分布聚合
		TermsAggregationBuilder ageAgg = AggregationBuilders.terms("ageAgg").field("age").size(10);
		sourceBuilder.aggregation(ageAgg);
		// 3.3计算平均值
		searchRequest.source(sourceBuilder);
		AvgAggregationBuilder balanceAvg = AggregationBuilders.avg("balanceAvg").field("balance");
		sourceBuilder.aggregation(balanceAvg);
		System.out.println(sourceBuilder.toString());

		// 4.执行检索
		SearchResponse search = client.search(searchRequest, ElasticSearchConfig.COMMON_OPTIONS);

		// 5.分析结果
		System.out.println(search.toString());
		// 5.1获取查到的数据
		SearchHits hits = search.getHits();
		SearchHit[] searchHits = hits.getHits();
		for (SearchHit hit : searchHits) {
			// 命中的记录信息
			String sourceAsString = hit.getSourceAsString();
			Account account = JSONObject.parseObject(sourceAsString, Account.class);
			System.out.println("account: " + account);
		}
		// 5.2获取检索的分析信息
		Aggregations aggregations = search.getAggregations();
		Terms ageAgg1 = aggregations.get("ageAgg");
		for (Terms.Bucket bucket : ageAgg1.getBuckets()) {
			System.out.println("年龄：" + bucket.getKeyAsString() + "  总数" + bucket.getDocCount());
		}

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

	/**
	 *
	 * （1）、冗余保存，方便检索
	 * {
	 *     b:1
	 *     skuTittle:离散数学及其应用
	 *     price：128
	 *     saleCount:99
	 *     attrs:[
	 *     		{页数：500页}
	 *     		{作者：肯尼斯.H.罗森}
	 *     ]
	 * }
	 * （2）：节省了空间，但是拿spu查询的时候，回携带非常多的spuId，消耗过多的请求带宽，网络阻塞IO
	 * sku索引 {
	 *     bId:1
	 *     attrId:11
	 *     xxxx
	 * }
	 * attr索引{
	 *     attrId:11
	 *     attrs:[
	 *     		{作者：肯尼斯.H.罗森}
	 *     ]
	 * }
	 */

	@Test
	void contextLoads() {
		System.out.println(client);
	}

}