栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Elasticsearch 入门(一)

Elasticsearch 入门(一)

Elastic Search 入门

添加 Maven 依赖初始化客户端配置查询数据

添加 Maven 依赖
	
	    org.elasticsearch.client
	    elasticsearch-rest-high-level-client
	    7.7.1
	    
	        
	            org.elasticsearch
	            elasticsearch
	        
	    
	
	
	
	    org.elasticsearch
	    elasticsearch
	    7.7.1
	
初始化客户端配置
	@Bean
	public RestHighLevelClient restHighLevelClient() {
	    RestClientBuilder builder = RestClient.builder(this.getHosts());
	    return new RestHighLevelClient(builder);
	}
	
	private HttpHost[] getHosts() {
	    String[] httpHosts = uris.split(",");
	    return Arrays.stream(httpHosts).map(item -> {
	        String[] nodes = item.split(":");
	        return new HttpHost(nodes[0], Integer.parseInt(nodes[1]));
	    }).toArray(HttpHost[]::new);
	}
spring.elasticsearch.uris=150.158.148.77:9200,150.158.148.78:9200,150.158.148.79:9200
查询数据
    @Autowired
    private RestHighLevelClient client;

    @Test
    void searchTest() throws IOException {
        SearchRequest searchRequest = new SearchRequest("index-test");
        SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
        sourceBuilder.query(QueryBuilders.termQuery("username", "tommy"));
        searchRequest.source(sourceBuilder);
        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        // 请求状态
        RestStatus status = searchResponse.status();
        // 执行时间
        Timevalue took = searchResponse.getTook();
        // 搜索结果
        SearchHit[] searchHits = searchResponse.getHits().getHits();
        for (SearchHit searchHit : searchHits) {
            String sourceAsString = searchHit.getSourceAsString();
            System.out.println(sourceAsString);
        }
    }
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/784582.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号