Elasticsearch 在全文搜索里面基本是無敵的，在大數(shù)據(jù)里面也很有建樹，完全可以當nosql（本來也是nosql）使用。
這篇文章簡單介紹Spring Boot使用Kotlin語言連接操作 Elasticsearch。但是不會做很詳細的介紹，如果要深入了解Elasticsearch在Java/kotlin中的使用，請參考我之前編寫的《Elasticsearch Java API 手冊》 https://gitee.com/quanke/elasticsearch-java/ 里面包含使用實例，包含我們使用踩過的坑。
如果完全不了解Elasticsearch請先了解，安裝好Elasticsearch服務(wù)
有多種方式連接Elasticsearch
- Spring Data Elasticsearch
- elasticsearch Java client
- 其他第三方庫
需要注意的是，如果使用Spring Data Elasticsearch，spring boot 1.5++版本的不支持最新版本的elasticsearch。
下面是spring data elasticsearch 和elasticsearch對應(yīng)的版本
| spring data elasticsearch | elasticsearch |
|---|---|
| 3.0.0.RC2 | 5.5.0 |
| 3.0.0.M4 | 5.4.0 |
| 2.0.4.RELEASE | 2.4.0 |
| 2.0.0.RELEASE | 2.2.0 |
| 1.4.0.M1 | 1.7.3 |
| 1.3.0.RELEASE | 1.5.2 |
| 1.2.0.RELEASE | 1.4.4 |
| 1.1.0.RELEASE | 1.3.2 |
| 1.0.0.RELEASE | 1.1.1 |
我們使用的 Elasticsearch 版本是 5.5.6 ， spring boot 使用的版本是 1.5.6 而且支持 Elasticsearch5.0 以上的版本的 spring data elasticsearch 還不是 RELEASE 版本，所有我們采用的是 elasticsearch Java client 的方式,但是現(xiàn)在官方推薦更好的方式可以參考我寫的《Elasticsearch Java Rest API 手冊》 https://gitee.com/quanke/elasticsearch-java-rest ，但是這篇文章還是使用 elasticsearch Java client
構(gòu)建Spring Boot Kotlin 項目
如果構(gòu)建項目有問題的您，可以參考我之前的文章《使用Spring Boot和Kotlin創(chuàng)建RESTfull API》
使用 Gradle 構(gòu)建,在 build.gradle 文件中添加
|
1
2
3
4
|
dependencies { compile "org.elasticsearch:elasticsearch:$elasticsearch_version" compile "org.elasticsearch.client:transport:$elasticsearch_version"} |
完整的 build.gradle 文件
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
group 'name.quanke.kotlin'version '1.0-SNAPSHOT'buildscript { ext.kotlin_version = '1.2.10' ext.spring_boot_version = '1.5.4.RELEASE' ext.springfox_swagger2_version = '2.7.0' ext.mysql_version = '5.1.21' ext.mybatis_version = '1.1.1' ext.elasticsearch_version = '5.5.1' ext.fastjson_version = '1.2.7' repositories { mavenCentral() } dependencies { classpath "org.jetbrains.kotlin:kotlin-gradle-plugin:$kotlin_version" classpath("org.springframework.boot:spring-boot-gradle-plugin:$spring_boot_version")// Kotlin整合SpringBoot的默認無參構(gòu)造函數(shù)，默認把所有的類設(shè)置open類插件 classpath("org.jetbrains.kotlin:kotlin-noarg:$kotlin_version") classpath("org.jetbrains.kotlin:kotlin-allopen:$kotlin_version") }}apply plugin: 'kotlin'apply plugin: "kotlin-spring" // See https://kotlinlang.org/docs/reference/compiler-plugins.html#kotlin-spring-compiler-pluginapply plugin: 'org.springframework.boot'apply plugin: "kotlin-jpa" //https://stackoverflow.com/questions/32038177/kotlin-with-jpa-default-constructor-helljar { baseName = 'chapter11-6-8-service' version = '0.1.0'}repositories { mavenCentral()}dependencies { compile "org.jetbrains.kotlin:kotlin-stdlib-jre8:$kotlin_version" compile("org.jetbrains.kotlin:kotlin-reflect:${kotlin_version}") compile "org.springframework.boot:spring-boot-starter-web:$spring_boot_version" compile "org.elasticsearch:elasticsearch:$elasticsearch_version" compile "org.elasticsearch.client:transport:$elasticsearch_version" compile "com.alibaba:fastjson:$fastjson_version" compile "org.apache.commons:commons-lang3:3.6" testCompile "org.springframework.boot:spring-boot-starter-test:$spring_boot_version" testCompile "org.jetbrains.kotlin:kotlin-test-junit:$kotlin_version"}compileKotlin { kotlinOptions.jvmTarget = "1.8"}compileTestKotlin { kotlinOptions.jvmTarget = "1.8"} |
先寫測試基類 ElasticsearchClient
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
import com.alibaba.fastjson.JSONimport com.alibaba.fastjson.serializer.SerializerFeatureimport org.elasticsearch.action.search.SearchResponseimport org.elasticsearch.client.transport.TransportClientimport org.elasticsearch.common.settings.Settingsimport org.elasticsearch.common.transport.InetSocketTransportAddressimport org.elasticsearch.transport.client.PreBuiltTransportClientimport org.junit.Afterimport org.junit.Beforeimport java.net.InetAddress/** * Elasticsearch 5.5.1 的client 和 ElasticsearchTemplate的初始化 * 作為一個外部訪問者，請求ES的集群，對于集群而言，它是一個外部因素。 * Created by http://quanke.name on 2017/11/10. */open class ElasticsearchClient { protected var client: TransportClient? = null @Before @Throws(Exception::class) fun setUp() { val esSettings = Settings.builder() .put("cluster.name", "utan-es") //設(shè)置ES實例的名稱 .put("client.transport.sniff", true) //自動嗅探整個集群的狀態(tài)，把集群中其他ES節(jié)點的ip添加到本地的客戶端列表中 .build() /** * 這里的連接方式指的是沒有安裝x-pack插件,如果安裝了x-pack則參考 [ElasticsearchXPackClient] * 1. java客戶端的方式是以tcp協(xié)議在9300端口上進行通信 * 2. http客戶端的方式是以http協(xié)議在9200端口上進行通信 */ client = PreBuiltTransportClient(esSettings) .addTransportAddress(InetSocketTransportAddress(InetAddress.getByName("192.168.1.10"), 9300)) println("ElasticsearchClient 連接成功") } @After @Throws(Exception::class) fun tearDown() { if (client != null) { client!!.close() } } protected fun println(searchResponse: SearchResponse) { val searchHits = searchResponse.hits.hits for (searchHit in searchHits) { println(JSON.toJSONString(searchHit.source, SerializerFeature.PrettyFormat)) } }} |
運行單元測試
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
import org.elasticsearch.index.query.QueryBuilders.matchAllQueryimport org.junit.Testimport org.junit.runner.RunWithimport org.springframework.boot.test.context.SpringBootTestimport org.springframework.test.context.junit4.SpringRunner/** * Created by http://quanke.name on 2018/1/9. */@RunWith(SpringRunner::class)@SpringBootTestclass ApplicationTests : ElasticsearchClient() { @Test fun `es test"`() { val qb = matchAllQuery() val response = client!!.prepareSearch("twitter")//可以是多個index .setTypes("tweet")//可以是多個類型 .setQuery(qb) // Query 查詢條件 .get() println(response) }} |
我們寫了一個 dayu-spring-boot-starter-es ,有機會開源出來
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://www.jianshu.com/p/02d556b470ff
