2

我正在尝试使用 Scala、Spray.io、Elastic4s 和 ElasticSearch 编写一个小的 REST api。我的 ES 实例使用默认参数运行，我只是将参数 network.host 更改为 127.0.0.1。

这是我的喷雾路由定义

package com.example

import akka.actor.Actor
import spray.routing._
import com.example.core.control.CrudController

class ServiceActor extends Actor with Service {

  def actorRefFactory = context

  def receive = runRoute(routes)
}

trait Service extends HttpService {

  val crudController = new CrudController()

  val routes = {

      path("ads" / IntNumber) {
      id =>
          get {
              ctx =>
                  ctx.complete(
                    crudController.getFromElasticSearch
                  )
          }
      }
  }
}

我的 crudController ：

package com.example.core.control
import com.example._
import org.elasticsearch.action.search.SearchResponse
import scala.concurrent._
import scala.util.{Success, Failure}
import ExecutionContext.Implicits.global

class CrudController extends elastic4s
{

    def getFromElasticSearch : String = {
    val something: Future[SearchResponse] = get
    something onComplete {
        case Success(p) => println(p)
        case Failure(t) => println("An error has occured: " + t)
    }
    "GET received \n"
    }
}

还有一个特性 elastic4s 封装了对 elastic4s 的调用

package com.example

import com.sksamuel.elastic4s.ElasticClient
import com.sksamuel.elastic4s.ElasticDsl._
import scala.concurrent._
import org.elasticsearch.action.search.SearchResponse

trait elastic4s {

    def get: Future[SearchResponse] = {
    val client = ElasticClient.remote("127.0.0.1", 9300)
    client execute { search in "ads"->"categories" }
    }
}

这段代码运行良好，并给了我这个输出：

[INFO] [03/26/2014 11:41:50.957] [on-spray-can-akka.actor.default-dispatcher-4] [akka://on-spray-can/user/IO-HTTP/listener-0] Bound to localhost/127.0.0.1:8080

但是当尝试使用我的浏览器访问路由“localhost/ads/8”时，总是会触发失败案例，并且我在我的 intellij 控制台上得到了这个错误输出：

An error has occured: org.elasticsearch.transport.RemoteTransportException: [Skinhead][inet[/127.0.0.1:9300]][search]

（在我的终端上运行 elasticSearch 时没有控制台输出）

此异常是否与 ElasticSearch 有关，还是我的 Future 声明做错了？

4

1 回答 1

1

我想你应该ElasticClient.local在这种情况下使用，如 elastic4s 文档中所述：

https://github.com/sksamuel/elastic4s

To specify settings for the local node you can pass in a settings object like this:

val settings = ImmutableSettings.settingsBuilder()
      .put("http.enabled", false)
      .put("path.home", "/var/elastic/") 
val client = ElasticClient.local(settings.build)
于 2014-03-26T11:29:20.563 回答