JAVA之ElasticSearch

       ElasticSearch是一个基于Lucene的搜索服务器。它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java开发的，并作为Apache许可条款下的开放源码发布，是当前流行的企业级搜索引擎。设计用于云计算中，能够达到实时搜索，稳定，可靠，快速，安装使用方便。

       当建立一个网站或应用程序，并要添加搜索功能，但是想要完成搜索工作的创建是非常困难的。我们希望搜索解决方案要运行速度快，我们希望能有一个零配置和一个完全免费的搜索模式，我们希望能够简单地使用JSON通过HTTP来索引数据，我们希望我们的搜索服务器始终可用，我们希望能够从一台开始并扩展到数百台，我们要实时搜索，我们要简单的多租户，我们希望建立一个云的解决方案。因此我们利用Elasticsearch来解决所有这些问题以及可能出现的更多其它问题。

      安装步骤：

      ① elasticsearch依赖java，所以先要安装jre；

      ② 进入官方下载 https://www.elastic.co/downloads/elasticsearch linux选tar.gz压缩包；

      ③ 解压 tar -zxvf elasticsearch-5.5.2.tar.gz 

      ④ 新建用户 不能用root用户运行 

              useradd elastic

              chown -R elastic:elastic /home/data/elasticsearch/elasticsearch-5.5.2/   (根据自己的具体目录)

      ⑤ 使用elastic用户运行elasticsearch

          su elastic

         sh /home/data/elasticsearch/elasticsearch-5.5.2/bin/elasticsearch -d

      常见出错解决办法：

        ERROR: [2] bootstrap checks failed

          [1]: max file descriptors [4096] for elasticsearch process is too low, increase to at least [65536]

          [2]: max virtual memory areas vm.max_map_count [65530] is too low, increase to at least [262144]

         ①：修改/etc/security/limits.conf文件，添加或修改如下行： （请切换到root用户 然后强制修改文件）

          *        hard    nofile           65536

          *        soft    nofile           65536

         ② sudo sysctl -w vm.max_map_count=2621441

    通过命令 curl http://localhost:9200返回如下则安装成功

    {

      "name" : "K22mJd5",

      "cluster_name" : "elasticsearch",

      "cluster_uuid" : "R2qfXKtrQl2PwKdJMmPuMA",

      "version" : {

      "number" : "5.5.2",

      "build_hash" : "b2f0c09",

      "build_date" : "2017-08-14T12:33:14.154Z",

      "build_snapshot" : false,

      "lucene_version" : "6.6.0"

      } ,

      "tagline" : "You Know, for Search" 

    }

    如果我们比如集群以及其他机器连接 ，则需要配置下。

    可以修改 vi /home/elasticsearch/elasticsearch/config/elasticsearch.yml 文件

    把 network.host 和 http.port 前面的 备注去掉 然后Host改成你的局域网IP即可

    最后需要关闭防火墙 

    systemctl stop firewalld.service

    systemctl disable firewalld.service   禁止防火墙开机启动

    通过如上步骤就可以在其他机器连接elasticsearch了。

    JAVA使用elasticsearch

    pom中引用

<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>transport</artifactId>
    <version>5.5.2</version>
</dependency>

     测试代码：

package com.geek.test;

import java.net.InetAddress;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import java.util.UUID;

import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.xcontent.XContentFactory;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import com.google.gson.JsonObject;

public class ElasticSearchTest {
    private static String host = "192.168.221.128"; // 服务器地址
    private static int port = 9300; // 端口

    private TransportClient client = null;

    /**
     * 连接
     */
    @Before
    public void getCient() throws Exception {
        client = new PreBuiltTransportClient(Settings.EMPTY)
                .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host), port));
    }

    /**
     * 关闭连接
     */
    @After
    public void close() {
        if (client != null) {
            client.close();
        }
    }

    /**
     * 添加索引
     */
    @Test
    public void testPrepareIndex() throws Exception {
        IndexResponse response = client.prepareIndex("elastdb", "account", "1")
                .setSource(XContentFactory.jsonBuilder().startObject().field("username", "liuwei")
                        .field("birthday", new Date()).field("password", "liuwei").endObject())
                .get();
        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }

    /**
     * 添加索引
     */
    @Test
    public void testIndex2() throws Exception {
        String json = "{" + ""username":"liuwei"," + ""birthday":"1997-01-06"," + ""password":"liuwei""
                + "}";

        IndexResponse response = client.prepareIndex("elastdb", "account", "2").setSource(json, XContentType.JSON)
                .get();
        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }

    /**
     * 添加索引
     */
    @Test
    public void testIndex3() throws Exception {
        Map<String, Object> json = new HashMap<String, Object>();
        json.put("username", "liuwei");
        json.put("birthday", new Date());
        json.put("password", UUID.randomUUID().toString());

        IndexResponse response = client.prepareIndex("elastdb", "account", "3").setSource(json).get();
        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }

    /**
     * 添加索引
     */
    @Test
    public void testIndex4() throws Exception {
        JsonObject jsonObject = new JsonObject();
        jsonObject.addProperty("username", "liuwei");
        jsonObject.addProperty("birthday", "1997-01-06");
        jsonObject.addProperty("password", "liuwei");

        IndexResponse response = client.prepareIndex("elastdb", "account", "4")
                .setSource(jsonObject.toString(), XContentType.JSON).get();
        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }

    @Test
    public void testGet() {
        GetResponse response = client.prepareGet("elastdb", "account", "1").get();
        System.out.println(response.getSourceAsString());
    }

    @Test
    public void testUpdate() {
        SimpleDateFormat format = new SimpleDateFormat("yyyy-mm-dd");
        JsonObject json = new JsonObject();
        json.addProperty("username", "liuwei");
        json.addProperty("birthday", "1997-01-01");
        json.addProperty("password", UUID.randomUUID().toString());
        UpdateResponse response = client.prepareUpdate("elastdb", "account", "1")

                .setDoc(json.toString(), XContentType.JSON).get();
        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }
    @Test
    public void testDelete() {
        DeleteResponse response = client.prepareDelete("elastdb", "account", "4").get();

        System.out.println("索引名称：" + response.getIndex());
        System.out.println("类型：" + response.getType());
        System.out.println("文档ID：" + response.getId());
        System.out.println("当前实例状态：" + response.status());
    }
    @Test
	public void testIndex() throws Exception {
		JsonArray jsonArray = new JsonArray();

		JsonObject jsonObject = new JsonObject();
		jsonObject.addProperty("title", "前任3：再见前任");
		jsonObject.addProperty("publishDate", "2017-12-29");
		jsonObject.addProperty("content",
				"一对好基友孟云（韩庚 饰）和余飞（郑恺 饰）跟女友都因为一点小事宣告分手，并且“拒绝挽回，死不认错”。两人在夜店、派对与交友软件上放飞人生第二春，大肆庆祝“黄金单身期”，从而引发了一系列好笑的故事。孟云与女友同甘共苦却难逃“五年之痒”，余飞与女友则棋逢敌手相爱相杀无绝期。然而现实的“打脸”却来得猝不及防：一对推拉纠结零往来，一对纠缠互怼全交代。两对恋人都将面对最终的选择：是再次相见？还是再也不见？");
		jsonObject.addProperty("director", "田羽生");
		jsonObject.addProperty("price", "35");
		jsonArray.add(jsonObject);

		JsonObject jsonObject2 = new JsonObject();
		jsonObject2.addProperty("title", "机器之血");
		jsonObject2.addProperty("publishDate", "2017-12-29");
		jsonObject2.addProperty("content",
				"2007年，Dr.James在半岛军火商的支持下研究生化人。研究过程中，生化人安德烈发生基因突变大开杀戒，将半岛军火商杀害，并控制其组织，接管生化人的研究。Dr.James侥幸逃生，只好寻求警方的保护。特工林东（成龙 饰）不得以离开生命垂危的小女儿西西，接受证人保护任务...十三年后，一本科幻小说《机器之血》的出版引出了黑衣生化人组织，神秘骇客李森（罗志祥 饰）（被杀害的半岛军火商的儿子），以及隐姓埋名的林东，三股力量都开始接近一个“普通”女孩Nancy（欧阳娜娜 饰）的生活，想要得到她身上的秘密。而黑衣人幕后受伤隐藏多年的安德烈也再次出手，在多次缠斗之后终于抓走Nancy。林东和李森，不得不以身犯险一同前去解救，关键时刻却发现李森竟然是被杀害的半岛军火商的儿子，生化人的实验记录也落入了李森之手......");
		jsonObject2.addProperty("director", "张立嘉");
		jsonObject2.addProperty("price", "45");
		jsonArray.add(jsonObject2);

		JsonObject jsonObject3 = new JsonObject();
		jsonObject3.addProperty("title", "星球大战8：最后的绝地武士");
		jsonObject3.addProperty("publishDate", "2018-01-05");
		jsonObject3.addProperty("content",
				"《星球大战：最后的绝地武士》承接前作《星球大战：原力觉醒》的剧情，讲述第一军团全面侵袭之下，蕾伊（黛西·雷德利 Daisy Ridley 饰）、芬恩（约翰·博耶加 John Boyega 饰）、波·达默龙（奥斯卡·伊萨克 Oscar Isaac 饰）三位年轻主角各自的抉 择和冒险故事。前作中觉醒强大原力的蕾伊独自寻访隐居的绝地大师卢克·天行者（马克·哈米尔 Mark Hamill 饰），在后者的指导下接受原力训练。芬恩接受了一项几乎不可能完成的任务，为此他不得不勇闯敌营，面对自己的过去。波·达默龙则要适应从战士向领袖的角色转换，这一过程中他也将接受一些血的教训。");
		jsonObject3.addProperty("director", "莱恩·约翰逊");
		jsonObject3.addProperty("price", "55");
		jsonArray.add(jsonObject3);

		JsonObject jsonObject4 = new JsonObject();
		jsonObject4.addProperty("title", "羞羞的铁拳");
		jsonObject4.addProperty("publishDate", "2017-12-29");
		jsonObject4.addProperty("content",
				"靠打假拳混日子的艾迪生（艾伦 饰），本来和正义感十足的体育记者马小（马丽 饰）是一对冤家，没想到因为一场意外的电击，男女身体互换。性别错乱后，两人互坑互害，引发了拳坛的大地震，也揭开了假拳界的秘密，惹来一堆麻烦，最终两人在“卷莲门”副掌门张茱萸（沈腾 饰）的指点下，向恶势力挥起了羞羞的铁拳。");
		jsonObject4.addProperty("director", "宋阳 / 张吃鱼");
		jsonObject4.addProperty("price", "35");
		jsonArray.add(jsonObject4);

		JsonObject jsonObject5 = new JsonObject();
		jsonObject5.addProperty("title", "战狼2");
		jsonObject5.addProperty("publishDate", "2017-07-27");
		jsonObject5.addProperty("content",
				"故事发生在非洲附近的大海上，主人公冷锋（吴京 饰）遭遇人生滑铁卢，被“开除军籍”，本想漂泊一生的他，正当他打算这么做的时候，一场突如其来的意外打破了他的计划，突然被卷入了一场非洲国家叛乱，本可以安全撤离，却因无法忘记曾经为军人的使命，孤身犯险冲回沦陷区，带领身陷屠杀中的同胞和难民，展开生死逃亡。随着斗争的持续，体内的狼性逐渐复苏，最终孤身闯入战乱区域，为同胞而战斗。");
		jsonObject5.addProperty("director", "吴京");
		jsonObject5.addProperty("price", "38");
		jsonArray.add(jsonObject5);

		for (int i = 0; i < jsonArray.size(); i++) {
			JsonObject jo = jsonArray.get(i).getAsJsonObject();
			IndexResponse response = client.prepareIndex("film", "dongzuo").setSource(jo.toString(), XContentType.JSON)
					.get();
			System.out.println("索引名称：" + response.getIndex());
			System.out.println("类型：" + response.getType());
			System.out.println("文档ID：" + response.getId());
			System.out.println("当前实例状态：" + response.status());
		}
	}

	@Test
	public void testSearchAll() {
		SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();// 查询所有
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}

	@Test
	public void testSearchPage() {
		SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery()).setFrom(1).setSize(2).execute()
				.actionGet();
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}

	@Test
	public void testSeachOrder() {
		SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery())
				.addSort("publishDate", SortOrder.ASC).execute().actionGet();
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}

	/*
	 * 数据列过滤
	 */
	@Test
	public void testSearchInclude() throws Exception {
		SearchRequestBuilder srb = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse sr = srb.setQuery(QueryBuilders.matchAllQuery())
				.setFetchSource(new String[] { "title", "price" }, null).execute().actionGet(); // 分页排序所有
		SearchHits hits = sr.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}

	/*
	 * 条件查询
	 */
	@Test
	public void testSearchByCondition() {
		SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = builder.setQuery(QueryBuilders.matchQuery("title", "战"))
				.setFetchSource(new String[] { "title", "price" }, null).execute().actionGet();
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}

	/*
	 * 条件查询且高亮显示
	 */
	@Test
	public void testSearchByConditionHigntLight() {
		HighlightBuilder highlightBuilder = new HighlightBuilder();
		highlightBuilder.preTags("<h2>");
		highlightBuilder.postTags("</h2>");
		highlightBuilder.field("title");
		SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = builder.setQuery(QueryBuilders.matchQuery("title", "战")).highlighter(highlightBuilder)
				.setFetchSource(new String[] { "title", "price" }, null)

				.execute().actionGet();
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
			System.out.println(hit.getHighlightFields());
		}
	}

	/*
	 * 多条件查询
	 */
	@Test
	public void testSearchByMulCondition() {
		QueryBuilder queryBuilder1 = QueryBuilders.matchPhraseQuery("title", "战");
		QueryBuilder queryBuilder2 = QueryBuilders.matchPhraseQuery("content", "星球");
		QueryBuilder queryBuilder3=QueryBuilders.rangeQuery("publishDate").gt("2018-01-01");
		SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");
		SearchResponse response = builder.setQuery(QueryBuilders.boolQuery().must(queryBuilder1).must(queryBuilder2))
				.execute().actionGet();
		SearchHits hits = response.getHits();
		for (SearchHit hit : hits) {
			System.out.println(hit.getSourceAsString());
		}
	}
	@Test
	public void testMultiMatchQuery()throws Exception{
	    SearchRequestBuilder srb=client.prepareSearch("film2").setTypes("dongzuo");
//	    SearchResponse sr=srb.setQuery(QueryBuilders.multiMatchQuery("非洲星球", "title","content").analyzer("smartcn"))
	    		  SearchResponse sr=srb.setQuery(QueryBuilders.multiMatchQuery("非洲星球", "title","content"))
	    		.setFetchSource(new String[]{"title","price"}, null)
	        .execute()
	        .actionGet(); 
	    SearchHits hits=sr.getHits();
	    for(SearchHit hit:hits){
	        System.out.println(hit.getSourceAsString());
	    }
	}
}

package com.geek.test;
import java.net.InetAddress;import java.text.SimpleDateFormat;import java.util.Date;import java.util.HashMap;import java.util.Map;import java.util.UUID;
import org.apache.http.client.methods.RequestBuilder;import org.elasticsearch.action.delete.DeleteResponse;import org.elasticsearch.action.get.GetResponse;import org.elasticsearch.action.index.IndexResponse;import org.elasticsearch.action.search.SearchRequestBuilder;import org.elasticsearch.action.search.SearchResponse;import org.elasticsearch.action.update.UpdateResponse;import org.elasticsearch.client.transport.TransportClient;import org.elasticsearch.cluster.routing.allocation.decider.EnableAllocationDecider.Rebalance;import org.elasticsearch.common.settings.Settings;import org.elasticsearch.common.transport.InetSocketTransportAddress;import org.elasticsearch.common.xcontent.XContentFactory;import org.elasticsearch.common.xcontent.XContentType;import org.elasticsearch.index.query.QueryBuilder;import org.elasticsearch.index.query.QueryBuilders;import org.elasticsearch.search.SearchHit;import org.elasticsearch.search.SearchHits;import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;import org.elasticsearch.search.sort.SortOrder;import org.elasticsearch.transport.client.PreBuiltTransportClient;import org.junit.After;import org.junit.Before;import org.junit.Test;
import com.google.gson.JsonArray;import com.google.gson.JsonObject;
public class ElasticSearchTest {private static String host = "192.168.221.131"; // 服务器地址private static int port = 9300; // 端口
private TransportClient client = null;
/** * 连接 */@Beforepublic void getCient() throws Exception {client = new PreBuiltTransportClient(Settings.EMPTY).addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host), port));}
/** * 关闭连接 */@Afterpublic void close() {if (client != null) {client.close();}}
/** * 添加索引 */@Testpublic void testPrepareIndex() throws Exception {IndexResponse response = client.prepareIndex("elastdb", "account", "1").setSource(XContentFactory.jsonBuilder().startObject().field("username", "liuwei").field("birthday", new Date()).field("password", "liuwei").endObject()).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
/** * 添加索引 */@Testpublic void testIndex2() throws Exception {String json = "{" + ""username":"liuwei"," + ""birthday":"1997-01-06"," + ""password":"liuwei""+ "}";
IndexResponse response = client.prepareIndex("elastdb", "account", "2").setSource(json, XContentType.JSON).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
/** * 添加索引 */@Testpublic void testIndex3() throws Exception {Map<String, Object> json = new HashMap<String, Object>();json.put("username", "liuwei");json.put("birthday", new Date());json.put("password", UUID.randomUUID().toString());
IndexResponse response = client.prepareIndex("elastdb", "account", "3").setSource(json).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
/** * 添加索引 */@Testpublic void testIndex4() throws Exception {JsonObject jsonObject = new JsonObject();jsonObject.addProperty("username", "liuwei");jsonObject.addProperty("birthday", "1997-01-06");jsonObject.addProperty("password", "liuwei");
IndexResponse response = client.prepareIndex("elastdb", "account", "4").setSource(jsonObject.toString(), XContentType.JSON).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
@Testpublic void testGet() {GetResponse response = client.prepareGet("elastdb", "account", "1").get();System.out.println(response.getSourceAsString());}
@Testpublic void testUpdate() {SimpleDateFormat format = new SimpleDateFormat("yyyy-mm-dd");JsonObject json = new JsonObject();json.addProperty("username", "liuwei");json.addProperty("birthday", "1997-01-01");json.addProperty("password", UUID.randomUUID().toString());UpdateResponse response = client.prepareUpdate("elastdb", "account", "1")
.setDoc(json.toString(), XContentType.JSON).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
@Testpublic void testDelete() {DeleteResponse response = client.prepareDelete("elastdb", "account", "4").get();
System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}
@Testpublic void testIndex() throws Exception {JsonArray jsonArray = new JsonArray();
JsonObject jsonObject = new JsonObject();jsonObject.addProperty("title", "前任3：再见前任");jsonObject.addProperty("publishDate", "2017-12-29");jsonObject.addProperty("content","一对好基友孟云（韩庚 饰）和余飞（郑恺 饰）跟女友都因为一点小事宣告分手，并且“拒绝挽回，死不认错”。两人在夜店、派对与交友软件上放飞人生第二春，大肆庆祝“黄金单身期”，从而引发了一系列好笑的故事。孟云与女友同甘共苦却难逃“五年之痒”，余飞与女友则棋逢敌手相爱相杀无绝期。然而现实的“打脸”却来得猝不及防：一对推拉纠结零往来，一对纠缠互怼全交代。两对恋人都将面对最终的选择：是再次相见？还是再也不见？");jsonObject.addProperty("director", "田羽生");jsonObject.addProperty("price", "35");jsonArray.add(jsonObject);
JsonObject jsonObject2 = new JsonObject();jsonObject2.addProperty("title", "机器之血");jsonObject2.addProperty("publishDate", "2017-12-29");jsonObject2.addProperty("content","2007年，Dr.James在半岛军火商的支持下研究生化人。研究过程中，生化人安德烈发生基因突变大开杀戒，将半岛军火商杀害，并控制其组织，接管生化人的研究。Dr.James侥幸逃生，只好寻求警方的保护。特工林东（成龙 饰）不得以离开生命垂危的小女儿西西，接受证人保护任务...十三年后，一本科幻小说《机器之血》的出版引出了黑衣生化人组织，神秘骇客李森（罗志祥 饰）（被杀害的半岛军火商的儿子），以及隐姓埋名的林东，三股力量都开始接近一个“普通”女孩Nancy（欧阳娜娜 饰）的生活，想要得到她身上的秘密。而黑衣人幕后受伤隐藏多年的安德烈也再次出手，在多次缠斗之后终于抓走Nancy。林东和李森，不得不以身犯险一同前去解救，关键时刻却发现李森竟然是被杀害的半岛军火商的儿子，生化人的实验记录也落入了李森之手......");jsonObject2.addProperty("director", "张立嘉");jsonObject2.addProperty("price", "45");jsonArray.add(jsonObject2);
JsonObject jsonObject3 = new JsonObject();jsonObject3.addProperty("title", "星球大战8：最后的绝地武士");jsonObject3.addProperty("publishDate", "2018-01-05");jsonObject3.addProperty("content","《星球大战：最后的绝地武士》承接前作《星球大战：原力觉醒》的剧情，讲述第一军团全面侵袭之下，蕾伊（黛西·雷德利 Daisy Ridley 饰）、芬恩（约翰·博耶加 John Boyega 饰）、波·达默龙（奥斯卡·伊萨克 Oscar Isaac 饰）三位年轻主角各自的抉 择和冒险故事。前作中觉醒强大原力的蕾伊独自寻访隐居的绝地大师卢克·天行者（马克·哈米尔 Mark Hamill 饰），在后者的指导下接受原力训练。芬恩接受了一项几乎不可能完成的任务，为此他不得不勇闯敌营，面对自己的过去。波·达默龙则要适应从战士向领袖的角色转换，这一过程中他也将接受一些血的教训。");jsonObject3.addProperty("director", "莱恩·约翰逊");jsonObject3.addProperty("price", "55");jsonArray.add(jsonObject3);
JsonObject jsonObject4 = new JsonObject();jsonObject4.addProperty("title", "羞羞的铁拳");jsonObject4.addProperty("publishDate", "2017-12-29");jsonObject4.addProperty("content","靠打假拳混日子的艾迪生（艾伦 饰），本来和正义感十足的体育记者马小（马丽 饰）是一对冤家，没想到因为一场意外的电击，男女身体互换。性别错乱后，两人互坑互害，引发了拳坛的大地震，也揭开了假拳界的秘密，惹来一堆麻烦，最终两人在“卷莲门”副掌门张茱萸（沈腾 饰）的指点下，向恶势力挥起了羞羞的铁拳。");jsonObject4.addProperty("director", "宋阳 / 张吃鱼");jsonObject4.addProperty("price", "35");jsonArray.add(jsonObject4);
JsonObject jsonObject5 = new JsonObject();jsonObject5.addProperty("title", "战狼2");jsonObject5.addProperty("publishDate", "2017-07-27");jsonObject5.addProperty("content","故事发生在非洲附近的大海上，主人公冷锋（吴京 饰）遭遇人生滑铁卢，被“开除军籍”，本想漂泊一生的他，正当他打算这么做的时候，一场突如其来的意外打破了他的计划，突然被卷入了一场非洲国家叛乱，本可以安全撤离，却因无法忘记曾经为军人的使命，孤身犯险冲回沦陷区，带领身陷屠杀中的同胞和难民，展开生死逃亡。随着斗争的持续，体内的狼性逐渐复苏，最终孤身闯入战乱区域，为同胞而战斗。");jsonObject5.addProperty("director", "吴京");jsonObject5.addProperty("price", "38");jsonArray.add(jsonObject5);
for (int i = 0; i < jsonArray.size(); i++) {JsonObject jo = jsonArray.get(i).getAsJsonObject();IndexResponse response = client.prepareIndex("film", "dongzuo").setSource(jo.toString(), XContentType.JSON).get();System.out.println("索引名称：" + response.getIndex());System.out.println("类型：" + response.getType());System.out.println("文档ID：" + response.getId());System.out.println("当前实例状态：" + response.status());}}
@Testpublic void testSearchAll() {SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery()).execute().actionGet();// 查询所有SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}
@Testpublic void testSearchPage() {SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery()).setFrom(1).setSize(2).execute().actionGet();SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}
@Testpublic void testSeachOrder() {SearchRequestBuilder requestBuilder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = requestBuilder.setQuery(QueryBuilders.matchAllQuery()).addSort("publishDate", SortOrder.ASC).execute().actionGet();SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}
/* * 数据列过滤 */@Testpublic void testSearchInclude() throws Exception {SearchRequestBuilder srb = client.prepareSearch("film").setTypes("dongzuo");SearchResponse sr = srb.setQuery(QueryBuilders.matchAllQuery()).setFetchSource(new String[] { "title", "price" }, null).execute().actionGet(); // 分页排序所有SearchHits hits = sr.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}
/* * 条件查询 */@Testpublic void testSearchByCondition() {SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = builder.setQuery(QueryBuilders.matchQuery("title", "战")).setFetchSource(new String[] { "title", "price" }, null).execute().actionGet();SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}
/* * 条件查询且高亮显示 */@Testpublic void testSearchByConditionHigntLight() {HighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.preTags("<h2>");highlightBuilder.postTags("</h2>");highlightBuilder.field("title");SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = builder.setQuery(QueryBuilders.matchQuery("title", "战")).highlighter(highlightBuilder).setFetchSource(new String[] { "title", "price" }, null)
.execute().actionGet();SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());System.out.println(hit.getHighlightFields());}}
/* * 多条件查询 */@Testpublic void testSearchByMulCondition() {QueryBuilder queryBuilder1 = QueryBuilders.matchPhraseQuery("title", "战");QueryBuilder queryBuilder2 = QueryBuilders.matchPhraseQuery("content", "星球");QueryBuilder queryBuilder3=QueryBuilders.rangeQuery("publishDate").gt("2018-01-01");SearchRequestBuilder builder = client.prepareSearch("film").setTypes("dongzuo");SearchResponse response = builder.setQuery(QueryBuilders.boolQuery().must(queryBuilder1).must(queryBuilder2)).execute().actionGet();SearchHits hits = response.getHits();for (SearchHit hit : hits) {System.out.println(hit.getSourceAsString());}}@Testpublic void testMultiMatchQuery()throws Exception{    SearchRequestBuilder srb=client.prepareSearch("film2").setTypes("dongzuo");//    SearchResponse sr=srb.setQuery(QueryBuilders.multiMatchQuery("非洲星球", "title","content").analyzer("smartcn"))     SearchResponse sr=srb.setQuery(QueryBuilders.multiMatchQuery("非洲星球", "title","content"))   .setFetchSource(new String[]{"title","price"}, null)        .execute()        .actionGet();     SearchHits hits=sr.getHits();    for(SearchHit hit:hits){        System.out.println(hit.getSourceAsString());    }}}