Spring Boot与Kotlin 整合全文搜索引擎Elasticsearch的示例代码

dependencies { compile "org.elasticsearch:elasticsearch:$elasticsearch_version" compile "org.elasticsearch.client:transport:$elasticsearch_version"}

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的默认无参构造函数，默认把所有的类设置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"}

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") //设置ES实例的名称    .put("client.transport.sniff", true) //自动嗅探整个集群的状态，把集群中其他ES节点的ip添加到本地的客户端列表中    .build()  /**   * 这里的连接方式指的是没有安装x-pack插件,如果安装了x-pack则参考 [ElasticsearchXPackClient]   * 1. java客户端的方式是以tcp协议在9300端口上进行通信   * 2. http客户端的方式是以http协议在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))  } }}

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) }}