2013-11-22 112 views
0

我正在使用Neo4j社区版以及Scala-Neo4j包装器的Scala,并且我刚刚下载了Neo4j的企业版。我看到企业版中的一些附加功能,如高性能缓存,群集和3 *生产实例。我如何使用这些功能?我是否需要对使用社区版编写的代码进行更改以利用这些功能?Neo4j - 企业版功能

回答

1

这取决于您的部署模型。

如果您在嵌入模式下使用Neo4j,通常使用GraphDatabaseFactory.newEmbeddedDatabase(path)初始化数据库。在嵌入Neo4j Enterprise时,您必须将其替换为HighlyAvailableGraphDatabaseFactory.newHighlyAvailableDatabaseBuilder(path).setConfig(map).newGraphDatabase(),其中map包含部署的配置设置,尤其是http://docs.neo4j.org/chunked/stable/ha-configuration.html中记录的ha参数。

如果部署的应用程序通过REST(服务器部署)访问Neo4j,则不应更改访问负载均衡器URL的URL。

请注意,Neo4j企业是双授权:AGPL(affero-GPL)或商业授权,请参阅http://www.neo4j.org/learn/licensing了解更多信息。

+0

我在嵌入模式下使用Neo4j。我可以得到我在我的问题中提到的功能的任何解释(高性能缓存,群集和3 *生产实例)。 – yAsH

+0

这一切都在参考手册中,请参阅http://docs.neo4j.org/chunked/stable/ha.html的Clustering和http://docs.neo4j.org/chunked/stable/operations-backup.html的在线备份和http://docs.neo4j.org/chunked/stable/configuration-caches.html#_object_cache以获得GC耐药性缓存(又名高性能缓存)。 –

0

我知道这是一个相当古老的问题,但其他人可能会觉得这很有用。可以将Scala Neo4j Wrapper与HA实例一起使用。您可以扩展GraphDatabaseServiceProvider。要获得群集等企业功能,您需要在每个群集节点上运行应用程序实例。

package graphdatabase 

import scala.collection.JavaConversions._ 

import eu.fakod.neo4jscala.{ 
    Neo4jWrapper, DatabaseService, 
    DatabaseServiceImpl, GraphDatabaseServiceProvider 
} 

import org.neo4j.cluster.ClusterSettings 
import org.neo4j.kernel.ha.HaSettings 
import org.neo4j.graphdb.factory.HighlyAvailableGraphDatabaseFactory 

object HighAvailabilityGraphDatabase extends Neo4jWrapper with GraphDatabaseServiceProvider { 

    def neo4jStoreDir = "/path/to/db" 

    // The config params will vary for each cluster node. 
    // You could use environment variables for example to configure. 
    def configParams = Map(
    ClusterSettings.server_id.name -> sys.env.get("SERVER_ID").get, // e.g. 1 
    HaSettings.ha_server.name -> sys.env.get("HA_SERVER").get, // e.g. server1:6001 
    ClusterSettings.cluster_server.name -> sys.env.get("CLUSTER_SERVER").get, // e.g.server1:5001 
    ClusterSettings.initial_hosts.name -> sys.env.get("INITIAL_HOSTS").get // e.g. server1:5001,server2:5001 
) 

    val ds: DatabaseService = { 
    val gdb = DatabaseServiceImpl(new HighlyAvailableGraphDatabaseFactory() 
     .newHighlyAvailableDatabaseBuilder(neo4jStoreDir) 
     .setConfig(mapAsJavaMap(configParams)) 
     .newGraphDatabase 
    ) 
    sys.addShutdownHook({ 
     shutdown(gdb) 
    }) 
    gdb 
    } 
} 

你也应该能够在配置配置高性能缓存,虽然我会检查the docs

然后,您可以使用Neo4j的Scala的包装,你会通过其他任何地方HighAvailabilityGraphDatabase进口。但您现在可以从其他企业功能(如实时备份)中受益。从Scala包装器访问底层的Java数据库服务也很容易。

import graphdatabase.HighAvailabilityGraphDatabase._ 

object Foo { 
    withTx { implicit db => 
    // use db.gds to access the underlying GraphDatabaseService object. 
    // otherwise create nodes etc as per usual. 
    val node = createNode 
    node("foo") = "bar" 
    } 
} 

注:您还需要确保你有Neo4j的HA在build.sbt(或类似),因为它是不包括在斯卡拉包装。

libraryDependencies ++= Seq(
    "org.neo4j" % "neo4j-ha" % "2.1.3" // Replace 2.1.3 with your version 
)