ElasticSearch（七）：Java操作elasticsearch基于smartcn中文分词查询

package com.gxy.ESChap01;  2 
import java.net.InetAddress;  4 
import org.elasticsearch.action.search.SearchRequestBuilder;  6 import org.elasticsearch.action.search.SearchResponse;  7 import org.elasticsearch.client.transport.TransportClient;  8 import org.elasticsearch.common.settings.Settings;  9 import org.elasticsearch.common.transport.InetSocketTransportAddress; 10 import org.elasticsearch.index.query.QueryBuilder; 11 import org.elasticsearch.index.query.QueryBuilders; 12 import org.elasticsearch.search.SearchHit; 13 import org.elasticsearch.search.SearchHits; 14 import org.elasticsearch.transport.client.PreBuiltTransportClient; 15 import org.junit.After; 16 import org.junit.Before; 17 import org.junit.Test; 18 /**
 * 使用smartcn分词查询 20  * @author 郭祥跃 21  * 22  */
public class ESQuerySmartcn { 24     private static String host="192.168.56.3"; // 服务器地址
    private static int port=9300; // 端口
    
    public static final String CLUSTER_NAME = "my-application"; //集群名称
    
    private TransportClient client=null; 30     
    private static final String ANALYZER="smartcn"; 32     
    private static Settings settings= Settings.builder() 34             .put("cluster.name",CLUSTER_NAME) 35             .put("client.transport.sniff", true) 36  .build(); 37     
    //获取客户端
    @SuppressWarnings({ "resource", "unchecked" }) 40  @Before 41     public void getClient() throws Exception { 42         try { 43             client = new PreBuiltTransportClient(settings) 44                     .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host),port)); 45         } catch (Exception e) { 46             // TODO Auto-generated catch block
 e.printStackTrace(); 48  } 49  } 50     
    //关闭客户端
 @After 53     public void close() { 54         if(client!=null) { 55  client.close(); 56  } 57  } 58     /**
 * 条件分词查询 60      */
 @Test 62     public void search() { 63         SearchRequestBuilder srb=client.prepareSearch("book").setTypes("kehuan"); 64         SearchResponse sr=srb.setQuery(QueryBuilders.matchQuery("title", "三体").analyzer(ANALYZER)) 65                 .setFetchSource(new String[] {"title","price"},null) 66  .execute() 67  .actionGet(); 68         SearchHits hits=sr.getHits(); 69         for(SearchHit hit:hits){ 70  System.out.println(hit.getSourceAsString()); 71  } 72  } 73     /**
 * 多字段条件分词查询 75      */
 @Test 77     public void search2() { 78         SearchRequestBuilder srb=client.prepareSearch("book").setTypes("kehuan"); 79         SearchResponse sr=srb.setQuery(QueryBuilders.multiMatchQuery("美国宇宙红岸", "title","content") 80  .analyzer(ANALYZER)) 81                 .setFetchSource(new String[] {"title","price"},null) 82  .execute() 83  .actionGet(); 84         SearchHits hits=sr.getHits(); 85         for(SearchHit hit:hits){ 86  System.out.println(hit.getSourceAsString()); 87  } 88  } 89 }