在不杀死虚拟机的情况下打开Spring Data Neo4J上下文
我正在运行一个弹簧数据neo-4j应用程序(不是基于web的),在正常操作期间工作正常。
如果我关闭了Spring Context'ctx.close()',那么neo 4J数据库上的锁定就会消失。
然后,从应用程序的同一个实例中,如果我抓住另一个上下文,则会看到该锁返回,但如果尝试从该上下文中读取/写入该数据库,则会出现错误:
org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'org.springframework.data.neo4j.config.Neo4jConfiguration#0': Unsatisfied dependency expressed through bean property 'conversionService': : Error creating bean with name 'mappingInfrastructure' defined in class org.springframework.data.neo4j.config.Neo4jConfiguration: Instantiation of bean failed; nested exception is org.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public final org.springframework.data.neo4j.support.MappingInfrastructureFactoryBean org.springframework.data.neo4j.config.Neo4jConfiguration$$EnhancerByCGLIB$$64cefd6f.mappingInfrastructure() throws java.lang.Exception] threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'typeRepresentationStrategyFactory' defined in class org.springframework.data.neo4j.config.Neo4jConfiguration: Instantiation of bean failed; nested exception is org.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public final org.springframework.data.neo4j.support.typerepresentation.TypeRepresentationStrategyFactory org.springframework.data.neo4j.config.Neo4jConfiguration$$EnhancerByCGLIB$$64cefd6f.typeRepresentationStrategyFactory() throws java.lang.Exception] threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'graphDatabaseService': Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [org.neo4j.kernel.EmbeddedGraphDatabase]: Constructor threw exception; nested exception is java.lang.IllegalStateException: Unable to lock store [C:app_datagelatodataneostore], this is usually a result of some other Neo4j kernel running using the same store.; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'mappingInfrastructure' defined in class org.springframework.data.neo4j.config.Neo4jConfiguration: Instantiation of bean failed; nested exception is org.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public final org.springframework.data.neo4j.support.MappingInfrastructureFactoryBean org.springframework.data.neo4j.config.Neo4jConfiguration$$EnhancerByCGLIB$$64cefd6f.mappingInfrastructure() throws java.lang.Exception] threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'typeRepresentationStrategyFactory' defined in class org.springframework.data.neo4j.config.Neo4jConfiguration: Instantiation of bean failed; nested exception is org.springframework.beans.factory.BeanDefinitionStoreException: Factory method [public final org.springframework.data.neo4j.support.typerepresentation.TypeRepresentationStrategyFactory org.springframework.data.neo4j.config.Neo4jConfiguration$$EnhancerByCGLIB$$64cefd6f.typeRepresentationStrategyFactory() throws java.lang.Exception] threw exception; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'graphDatabaseService': Instantiation of bean failed; nested exception is org.springframework.beans.BeanInstantiationException: Could not instantiate bean class [org.neo4j.kernel.EmbeddedGraphDatabase]: Constructor threw exception; nested exception is java.lang.IllegalStateException: Unable to lock store [C:app_datagelatodataneostore], this is usually a result of some other Neo4j kernel running using the same store.
有没有办法在应用程序的单个实例中成功关闭并重新打开应用程序上下文(即不关闭虚拟机)?
我最初在图形数据库中调用shutdown(),但是由于Michael Hunger告诉我不要这样做,所以改变了这一点。
我们的问题可以像这样在我们的域中复制。
AbstractApplicationContext ctx = new FileSystemXmlApplicationContext("neo4jconfig.xml");
OurDomainService domainService = (OurDomainService) ctx.getBean(OurDomainServiceImpl.class);
// This works
domainService.save(data);
// this releases the lock
ctx.close();
// this re-creates the lock and the context looks actvive
ctx = new FileSystemXmlApplicationContext("neo4jconfig.xml");
domainService = (OurDomainService) ctx.getBean(OurDomainServiceImpl.class);
// this errors out
domainService.save(data);
这是我们用来创建上下文的XML文件。
<?xml version="1.0" encoding="UTF-8" standalone="no"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:neo4j="http://www.springframework.org/schema/data/neo4j"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/data/neo4j
http://www.springframework.org/schema/data/neo4j/spring-neo4j.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx.xsd">
<context:spring-configured/>
<context:annotation-config/>
<context:component-scan base-package="OurData" />
<neo4j:config storeDirectory="c:/app_data/data"/>
<neo4j:repositories base-package="OurData"/>
</beans>
你不应该这样做,在你的情况下,spring-context应该处理生命周期。
当你重启你的情况会发生什么?
用关闭应用程序上下文
ctx.close()
你应该使用WebApplicationContext(Utils)来通过你的web.xml来获得你配置好的Spring Context。 喜欢这个:
WebApplicationContext springContext =
WebApplicationContextUtils.getWebApplicationContext(getServletContext());
看看我最后的评论和你的回答编辑了我的完整答案。
下面的两个主要文件。
第一个使用WrappingNeoServerBootstrapper
Neo4j服务器的引导程序,它接受已实例化的{@link org.neo4j.kernel.GraphDatabaseAPI}和可选配置,并启动使用该数据库的服务器。 使用它可以在已经使用EmbeddedGraphDatabase或HighlyAvailableGraphDatabase的应用程序中启动完整的Neo4j服务器。 这为您的应用程序提供了服务器的REST API,Web管理界面和统计信息跟踪的全部好处。
package sandbox;
import org.neo4j.server.WrappingNeoServerBootstrapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.neo4j.support.Neo4jTemplate;
public class GalaxyServiceTest {
private final static Logger slf4jLogger = LoggerFactory.getLogger(GalaxyServiceTest.class);
@Autowired
private GalaxyService galaxyService;
@Autowired
private Neo4jTemplate template;
public static void main(String args[]) throws InterruptedException {
GalaxyServiceTest main = new GalaxyServiceTest();
ApplicationContextLoader loader = new ApplicationContextLoader();
loader.load(main, "/spring/helloWorldContext.xml");
// The server starts with loading of above Context.xml
WrappingNeoServerBootstrapper neoServer = loader.getApplicationContext().getBean("serverWrapper", WrappingNeoServerBootstrapper.class);
//process something in repository
main.doSomething();
// do a graceful stop
int stop = neoServer.stop(0);
slf4jLogger.info("stopping Server status code {} ", stop);
//Restart the server
neoServer.start();
slf4jLogger.info("Restarting Server ");
// Process something in Repository
main.doSomething();
}
public void doSomething() {
galaxyService.makeSomeWorlds();
Iterable<World> allWorlds = galaxyService.getAllWorlds();
for (World world : allWorlds) {
slf4jLogger.info("World Name is {}", world.toString());
}
}
}
应用程序上下文定义xml
<context:annotation-config />
<context:spring-configured/>
<context:component-scan base-package="sandbox" />
<bean id="transactionManager"
class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager">
<bean id="jotm" class="org.springframework.data.neo4j.transaction.JotmFactoryBean"/>
</property>
</bean>
<neo4j:config graphDatabaseService="graphDatabaseService" />
<bean id="serverWrapper" class="org.neo4j.server.WrappingNeoServerBootstrapper"
init-method="start" destroy-method="stop">
<constructor-arg ref="graphDatabaseService" />
</bean>
<bean id="graphDatabaseService" class="org.neo4j.kernel.EmbeddedGraphDatabase"
destroy-method="shutdown">
<constructor-arg value="target/test-db"/>
</bean>
<tx:annotation-driven mode="aspectj" transaction-manager="transactionManager"/>
<neo4j:repositories base-package="sandbox"></neo4j:repositories>
</beans>
我希望这有帮助。
链接地址: http://www.djcxy.com/p/11793.html