SpringBoot联表查询ES门店索引和商品索引并分页返回数据

在Spring Boot环境下，可以使用Elasticsearch的Java高级客户端来实现门店索引和商品索引的联表查询，并进行分页返回门店商品集合。\n\n首先，需要在pom.xml文件中添加Elasticsearch的Java高级客户端的依赖：\n\nxml\n<dependencies>\n ...\n <dependency>\n <groupId>org.elasticsearch.client</groupId>\n <artifactId>elasticsearch-rest-high-level-client</artifactId>\n <version>7.7.0</version>\n </dependency>\n ...\n</dependencies>\n\n\n接下来，创建一个Elasticsearch的配置类，用于配置Elasticsearch的连接信息：\n\njava\n@Configuration\npublic class ElasticsearchConfig {\n\n @Value("${elasticsearch.host}")\n private String host;\n\n @Value("${elasticsearch.port}")\n private int port;\n\n @Bean\n public RestHighLevelClient elasticsearchClient() {\n RestClientBuilder builder = RestClient.builder(new HttpHost(host, port));\n RestHighLevelClient client = new RestHighLevelClient(builder);\n return client;\n }\n}\n\n\n在配置文件application.properties中添加Elasticsearch连接配置：\n\n\nelasticsearch.host=localhost\nelasticsearch.port=9200\n\n\n然后，创建一个门店商品的实体类，用于映射门店索引和商品索引的数据：\n\njava\npublic class StoreProduct {\n\n private String storeId;\n private String storeName;\n private String productId;\n private String productName;\n\n // 省略getter和setter方法\n}\n\n\n接下来，创建一个门店商品的服务类，用于进行联表查询和分页返回门店商品集合：\n\njava\n@Service\npublic class StoreProductService {\n\n @Autowired\n private RestHighLevelClient elasticsearchClient;\n\n public List<StoreProduct> getStoreProducts(int page, int size) throws IOException {\n SearchRequest searchRequest = new SearchRequest("store_product_index");\n\n SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();\n searchSourceBuilder.query(QueryBuilders.matchAllQuery());\n searchSourceBuilder.from((page - 1) * size);\n searchSourceBuilder.size(size);\n\n searchRequest.source(searchSourceBuilder);\n\n SearchResponse searchResponse = elasticsearchClient.search(searchRequest, RequestOptions.DEFAULT);\n\n List<StoreProduct> storeProducts = new ArrayList<>();\n for (SearchHit hit : searchResponse.getHits().getHits()) {\n Map<String, Object> sourceAsMap = hit.getSourceAsMap();\n StoreProduct storeProduct = new StoreProduct();\n storeProduct.setStoreId((String) sourceAsMap.get("storeId"));\n storeProduct.setStoreName((String) sourceAsMap.get("storeName"));\n storeProduct.setProductId((String) sourceAsMap.get("productId"));\n storeProduct.setProductName((String) sourceAsMap.get("productName"));\n storeProducts.add(storeProduct);\n }\n\n return storeProducts;\n }\n}\n\n\n最后，在Controller类中调用门店商品的服务类，实现分页返回门店商品集合的接口：\n\njava\n@RestController\npublic class StoreProductController {\n\n @Autowired\n private StoreProductService storeProductService;\n\n @GetMapping("/store-products")\n public List<StoreProduct> getStoreProducts(@RequestParam int page, @RequestParam int size) throws IOException {\n return storeProductService.getStoreProducts(page, size);\n }\n}\n\n\n现在，可以通过访问/store-products?page=1&size=10接口来获取分页返回的门店商品集合。