1. 安装
Elasticsearch 安装非常简单, 下载, 解压, 启动, 搞定
wget https://download.elastic.co/elasticsearch/elasticsearch/elasticsearch-1.7.1.zip
unzip elasticsearch-1.7.1.zip
cd elasticsearch-1.7.1/bin
./elasticsearch
启动日志如下, 表示成功
[2015-09-02 09:55:28,779][INFO ][http ] [Eleggua] bound_address {inet[/0.0.0.0:9202]}, publish_address {inet[/192.168.0.101:9202]}
[2015-09-02 09:55:28,779][INFO ][node ] [Eleggua] started
打开浏览器访问 http://192.168.0.101:9202, 响应如下:
{ "status" : 200, "name" : "Eleggua", "cluster_name" : "elasticsearch", "version" : { "number" : "1.7.1", "build_hash" : "b88f43fc40b0bcd7f173a1f9ee2e97816de80b19", "build_timestamp" : "2015-07-29T09:54:16Z", "build_snapshot" : false, "lucene_version" : "4.10.4" }, "tagline" : "You Know, for Search" }
2. 使用JAVA API 构建索引,查询
public class Student { private int id; private String name; private String address; private int age; public Student(int id, int age, String name, String address){ this.id = id; this.age = age; this.name = name; this.address = address; } public int getId() { return id; } public void setId(int id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } public String getAddress() { return address; } public void setAddress(String address) { this.address = address; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } }
import net.sf.json.JSONObject; 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.search.SearchType; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.ImmutableSettings; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.index.query.QueryBuilders; import com.league.elasticsearch.pojo.Student; public class App { private static final String SERVER = "192.168.0.101"; public static void main(String[] args) { // 创建连接的客户端 Settings settings = ImmutableSettings.settingsBuilder().put("client.transport.sniff", true).put("cluster.name", "elasticsearch") .build(); TransportClient client = new TransportClient(settings); client.addTransportAddress(new InetSocketTransportAddress(SERVER, 9300)); //createIndex(client); //getData(client); query(client); client.close(); } // 创建索引 public static void createIndex(TransportClient client) { Student student = new Student(103161066, 20, "zhangsan", "beijing of china"); String jsonValue = JSONObject.fromObject(student).toString(); IndexResponse response = client.prepareIndex("student_index", "student_info", "stu_103161066").setSource(jsonValue).execute().actionGet(); System.out.println(response.getId()); } //获取数据 public static void getData(TransportClient client){ GetResponse responseGet = client.prepareGet("student_index", "student_info", "stu_103161066").execute().actionGet(); System.out.println(responseGet.getSourceAsString()); } public static void query(TransportClient client){ SearchRequestBuilder builder = client.prepareSearch("student_index").setTypes("student_info").setSearchType(SearchType.DEFAULT).setFrom(0).setSize(100); builder.setQuery(QueryBuilders.termQuery("address", "beijing")); SearchResponse response = builder.execute().actionGet(); System.out.println("response: " + response); System.out.println("======================="); System.out.println(response.getHits().getTotalHits()); System.out.println("======================="); System.out.println(response.getHits().getHits()[0].getSourceAsString()); } }
MAVEN POM.XML
<repositories> <repository> <id>spring-milestone</id> <name>Spring Maven MILESTONE Repository</name> <url>http://repo.spring.io/libs-milestone</url> </repository> <repository> <id>com.springsource.repository.maven.release</id> <url>http://maven.springframework.org/release/</url> <snapshots> <enabled>false</enabled> </snapshots> </repository> <repository> <id>oracleReleases</id> <name>Oracle Released Java Packages</name> <url>http://download.oracle.com/maven</url> </repository> <repository> <id>JBossRepo1</id> <name>Jboss1</name> <url>https://repository.jboss.org/nexus/content/groups/public-jboss/</url> </repository> <repository> <id>JBossRepo</id> <name>Jboss</name> <url>https://repository.jboss.org/nexus/content/repositories/releases/</url> </repository> </repositories> <dependencies> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>1.7.1</version> </dependency> <dependency> <groupId>net.sf.json-lib</groupId> <artifactId>json-lib</artifactId> <version>2.4</version> <classifier>jdk15</classifier> </dependency> </dependencies>
更多JAVA API, 请参见 https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/index.html
相关推荐
消费kafka数据,然后批量导入到Elasticsearch,本例子使用的kafka版本0.10,es版本是6.4,使用bulk方式批量导入到es中,也可以一条一条的导入,不过比较慢。 <dependency> <groupId>org.elasticsearch</groupId> ...
<elasticsearch.version>5.6.0</elasticsearch.version> <spring-version>5.0.0.RC3</spring-version> <fastjson-version>1.2.7</fastjson-version> <junit-version>4.12</junit-version> <slf4j-version>1.7.5...
<groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>5.4.2</version> <!--<version>6.5.4</version>--> </dependency> <!-- 添加字段需要的JAR --> <!...
<artifactId>changgou-service-search-api</artifactId> <version>1.0-SNAPSHOT</version> </dependency> <dependency> <groupId>com.robod</groupId> <artifactId>changgou-service-goods-api</artifactId> ...
包含所因的索引建立、删除、查看,批量创建索引;搜索Query、过滤器 、分组高亮显示;以及创建Mapping
<br><br>类结构<br> BaseSplitter(分词基类)<br> │<br> ├─SingleSplitter(一元切分)<br> │<br> ├─DoubleSplitter(二元切分)<br> │<br> └─DefaultSplitter(词义切分)────NICTCLAS(中科院分词...
<artifactId>elasticsearch-spring-boot-starter</artifactId> <version>1.2.0.RELEASE</version> </dependency> 2)application.yml spring: elasticsearch: cluster-nodes: 192.168.19.131:9300
资源来自maven仓库,maven配置如下所区jar包 <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>transport</artifactId> <version>6.3.2</version> </dependency>
正则表达式教程<br> 正则表达式(regular expression)描述了一种字符串匹配的模式,可以用来检查一个串是否含有某种子串、将匹配的子串做替换或者从某个串中取出符合某个条件的子串等。<br><br>列目录时, dir *....
重新登录Elasticsearch Appender 将日志事件直接从Logback发送到Elasticsearch。 日志是异步传递的(即不在主线程上),因此不会阻止程序的执行。 请注意,如果Elasticsearch关闭并且待办事项队列已满或生产者程序...
连接es所需jar包 <!-- ... <groupId>org.elasticsearch.plugin</groupId> <artifactId>x-pack-sql-jdbc</artifactId> <version>6.8.15</version> </dependency>
<groupId>org.elasticsearch.client</groupId> <artifactId>transport</artifactId> <version>${elasticsearch.version}</version> </dependency> 配置client bean @Configuration public class Config {...
<artifactId>elasticsearch-migration</artifactId> <version>1.0.5</version> </dependency> 指标 这些索引是在首次运行时创建的,它们也可以跟踪迁移。 迁移版本索引(elasticsearch_migration_ver
基于Elasticsearch的Java Rest高级客户端的elasticsearch-sql查询... < groupId>io.github.iamazy.elasticsearch.dsl</ groupId> < artifactId>elasticsearch-sql</ artifactId> < version>${isql-version}</ v
神奇狗 Wonderdog使ElasticSearch易于与Hadoop连接。 它提供了几种功能: 您可以在自己的Hadoop... < artifactId>elasticsearch</ artifactId> < version>1.0-SNAPSHOT</ version> </ dependency> ... </ depen
ranger-2.1.0-elasticsearch-plugin.tar.gz
由于很多文章都是只有ranger的安装说明,却没有编译后的tar包,而且编译的时间有点长,编译期间会出现各种问题,导致编译不过,特此上传编译后的包,来提供大家下载
这个存储库包含一个 ElasticSearch 实例,可以在 Consul 和 Registrator 环境中使用。 用法 docker run --rm \ --name elasticsearch- < i> \ --env SERVICE_NAME= < cluster> \ --env SERVICE_9200_TAGS=http \...
fatfs工程样例,包含一下平台: Directory Platform <generic> Generic microcontrollers <lpc23xx> NXP LPC2300 (LPC... <v850> NEC V850ES (UPD70F3716, 32-bit) <win32> Windows (Visual C++), ANSI/Unicode
<artifactId>share-elasticsearch</artifactId> <version>5.x.x</version> </dependency> 2.业务集成重写common/BaseUtil.java即可 3.ES Version VS Log4j Vesion ES version Log4j version 5.6.x 2