我正在尝试在本地计算机上设置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示例,那么将对您有所帮助。
我之前做过Scala + Akka Hazelcast。包括我的build.sbt
libraryDependencies += "com.hazelcast" % "hazelcast-all" % "3.7.2"
我似乎记得必须进行hazelcast-all。