具有 scala 客户端问题的 Hazelcast 服务器

Question

我正在尝试在我的本地机器上设置 hazelcast 服务器和客户端。我也在尝试通过 scala-client 连接到本地 Hazelcast 服务器。

对于我使用以下代码的服务器，

import com.hazelcast.config._
import com.hazelcast.Scala._



object HazelcastServer {

def main(args: Array[String]): Unit = {

val conf = new Config
serialization.Defaults.register(conf.getSerializationConfig)
serialization.DynamicExecution.register(conf.getSerializationConfig)
val hz = conf.newInstance()


val cmap = hz.getMap[String, String]("test")
cmap.put("a","A")
cmap.put("b","B")


}
}

和 hazelcast 客户端一样，

import com.hazelcast.Scala._
import client._
import com.hazelcast.client._
import com.hazelcast.config._


object Hazelcast_Client {

  def main(args:Array[String]): Unit = {

    val conf = new Config
    serialization.Defaults.register(conf.getSerializationConfig)
    serialization.DynamicExecution.register(conf.getSerializationConfig)
    val hz = conf.newClient()


    val cmap = hz.getMap("test")
    println(cmap.size())




  }

}

在我的 build.sbt 中，

libraryDependencies += "com.hazelcast" % "hazelcast" % "3.7.2"
libraryDependencies += "com.hazelcast" %% "hazelcast-scala" % "3.7.2"

我遇到错误并陷入依赖问题。

Symbol 'type <none>.config.ClientConfig' is missing from the classpath.
[error] This symbol is required by 'value com.hazelcast.Scala.client.package.conf'.
[error] Make sure that type ClientConfig is in your classpath and check for conflicting dependencies with `-Ylog-classpath`.
[error] A full rebuild may help if 'package.class' was compiled against an incompatible version of <none>.config.
[error]     val conf = new Config

我参考了hazelcast 文档。我找不到任何好的 hazelcast scala 示例来了解设置并开始使用。如果有人可以帮助解决这个问题，或者分享非常有用的 scala 示例。

Answer 1

我以前做过 Scala+Akka Hazelcast。我的 build.sbt 包括

libraryDependencies += "com.hazelcast" % "hazelcast-all" % "3.7.2"

我似乎记得 hazelcast-all 是必需的。