Elasticsearch入门系列~通过Java一系列操作Elasticsearch

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.sun.elasticsearch</groupId> <artifactId>Elasticsearch01</artifactId> <version>0.0.1-SNAPSHOT</version> <dependencies> <!-- Elasticsearch核心依赖包 --> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>transport</artifactId> <version>5.5.2</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> <!-- 日志依赖 --> <dependency> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId> <version>1.7.21</version> <scope>test</scope> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.logging.log4j/log4j-core --> <dependency> <groupId>org.apache.logging.log4j</groupId> <artifactId>log4j-core</artifactId> <version>2.8.2</version> </dependency> <!-- https://mvnrepository.com/artifact/com.google.code.gson/gson --> <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.8.0</version> </dependency> </dependencies></project>

package com.sun.elasticsearch; import java.net.InetAddress; import java.net.UnknownHostException; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.transport.client.PreBuiltTransportClient; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; /** * Elasticsearch的基本测试 * @ClassName: ElasticsearchTest1 * @author sunt * @date 2017年11月22日 * @version V1.0 */ public class ElasticsearchTest1 { private Logger logger = LoggerFactory.getLogger(ElasticsearchTest1.class); public final static String HOST = "192.168.1.140"; public final static int PORT = 9300;//http请求的端口是9200，客户端是9300 /** * 测试Elasticsearch客户端连接 * @Title: test1 * @author sunt * @date 2017年11月22日 * @return void * @throws UnknownHostException */ @SuppressWarnings("resource") @Test public void test1() throws UnknownHostException { //创建客户端 TransportClient client = new PreBuiltTransportClient(Settings.EMPTY).addTransportAddresses( new InetSocketTransportAddress(InetAddress.getByName(HOST),PORT)); logger.debug("Elasticsearch connect info:" + client.toString()); //关闭客户端 client.close(); } }

private Logger logger = LoggerFactory.getLogger(ElasticsearchTest2.class); public final static String HOST = "192.168.1.140"; public final static int PORT = 9300; //http请求的端口是9200，客户端是9300 private TransportClient client = null; /** * 获取客户端连接信息 * @Title: getConnect * @author sunt * @date 2017年11月23日 * @return void * @throws UnknownHostException */ @SuppressWarnings({ "resource", "unchecked" }) @Before public void getConnect() throws UnknownHostException { client = new PreBuiltTransportClient(Settings.EMPTY).addTransportAddresses( new InetSocketTransportAddress(InetAddress.getByName(HOST),PORT)); logger.info("连接信息:" + client.toString()); } /** * 关闭连接 * @Title: closeConnect * @author sunt * @date 2017年11月23日 * @return void */ @After public void closeConnect() { if(null != client) { logger.info("执行关闭连接操作..."); client.close(); } }

/** * 创建索引库 * @Title: addIndex1 * @author sunt * @date 2017年11月23日 * @return void * 需求:创建一个索引库为：msg消息队列,类型为：tweet,id为1 * 索引库的名称必须为小写 * @throws IOException */ @Test public void addIndex1() throws IOException { IndexResponse response = client.prepareIndex("msg", "tweet", "1").setSource(XContentFactory.jsonBuilder() .startObject().field("userName", "张三") .field("sendDate", new Date()) .field("msg", "你好李四") .endObject()).get(); logger.info("索引名称:" + response.getIndex() + "\n类型:" + response.getType() + "\n文档ID:" + response.getId() + "\n当前实例状态:" + response.status()); }

/** * 添加索引:传入json字符串 * @Title: addIndex2 * @author sunt * @date 2017年11月23日 * @return void */ @Test public void addIndex2() { String jsonStr = "{" + "\"userName\":\"张三\"," + "\"sendDate\":\"2017-11-30\"," + "\"msg\":\"你好李四\"" + "}"; IndexResponse response = client.prepareIndex("weixin", "tweet").setSource(jsonStr,XContentType.JSON).get(); logger.info("json索引名称:" + response.getIndex() + "\njson类型:" + response.getType() + "\njson文档ID:" + response.getId() + "\n当前实例json状态:" + response.status()); }

/** * 创建索引-传入Map对象 * @Title: addIndex3 * @author sunt * @date 2017年11月23日 * @return void */ @Test public void addIndex3() { Map<String, Object> map = new HashMap<String,Object>(); map.put("userName", "张三"); map.put("sendDate", new Date()); map.put("msg", "你好李四"); IndexResponse response = client.prepareIndex("momo", "tweet").setSource(map).get(); logger.info("map索引名称:" + response.getIndex() + "\n map类型:" + response.getType() + "\n map文档ID:" + response.getId() + "\n当前实例map状态:" + response.status()); }

/** * 传递json对象 * 需要添加依赖:gson * @Title: addIndex4 * @author sunt * @date 2017年11月23日 * @return void */ @Test public void addIndex4() { JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("userName", "张三"); jsonObject.addProperty("sendDate", "2017-11-23"); jsonObject.addProperty("msg","你好李四"); IndexResponse response = client.prepareIndex("qq", "tweet").setSource(jsonObject, XContentType.JSON).get(); logger.info("jsonObject索引名称:" + response.getIndex() + "\n jsonObject类型:" + response.getType() + "\n jsonObject文档ID:" + response.getId() + "\n当前实例jsonObject状态:" + response.status()); }

/** * 从索引库获取数据 * @Title: getData1 * @author sunt * @date 2017年11月23日 * @return void */ @Test public void getData1() { GetResponse getResponse = client.prepareGet("msg", "tweet", "1").get(); logger.info("索引库的数据:" + getResponse.getSourceAsString()); }

/** * 更新索引库数据 * @Title: updateData * @author sunt * @date 2017年11月23日 * @return void */ @Test public void updateData() { JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("userName", "王五"); jsonObject.addProperty("sendDate", "2008-08-08"); jsonObject.addProperty("msg","你好,张三，好久不见"); UpdateResponse updateResponse = client.prepareUpdate("msg", "tweet", "1") .setDoc(jsonObject.toString(),XContentType.JSON).get(); logger.info("updateResponse索引名称:" + updateResponse.getIndex() + "\n updateResponse类型:" + updateResponse.getType() + "\n updateResponse文档ID:" + updateResponse.getId() + "\n当前实例updateResponse状态:" + updateResponse.status()); }

/** * 根据索引名称，类别，文档ID 删除索引库的数据 * @Title: deleteData * @author sunt * @date 2017年11月23日 * @return void */ @Test public void deleteData() { DeleteResponse deleteResponse = client.prepareDelete("msg", "tweet", "1").get(); logger.info("deleteResponse索引名称:" + deleteResponse.getIndex() + "\n deleteResponse类型:" + deleteResponse.getType() + "\n deleteResponse文档ID:" + deleteResponse.getId() + "\n当前实例deleteResponse状态:" + deleteResponse.status()); }