在我们对使用 jackrabbit 的应用程序进行了一些性能测试之后,我们面临着并发修改 jackrabbit 存储库的巨大问题。当我们在多线程仿真中添加节点或编辑它们时会出现问题。然后我写了一个非常简单的测试,它告诉我们问题不在我们的环境中。
有它:
简单的无状态 Bean
@无状态
@Local(TestFacadeLocal.class)
@Remote(TestFacadeRemote.class)
公共类 TestFacadeBean 实现 TestFacadeRemote,TestFacadeLocal {
公共无效doAction(int name)抛出异常{
新的 TestSynch().doAction(name);
}
}
简单类
公共类TestSynch {
公共无效doAction(int name)抛出异常{
会话 session = ((Repository) new InitialContext().
查找("java:jcr/local")).login(
new SimpleCredentials("username", "pwd".toCharArray()));
添加列表 = new ArrayList();
节点文件夹 = session.getRootNode().getNode("test");
for (int i = 0; i <= 100; i++) {
子节点 = folder.addNode("" + System.currentTimeMillis(),
“nt:文件夹”);
child.addMixin("mix:versionable");
添加.add(child);
}
// 保存 butch 更改
session.save();
//检查所有创建的节点
对于(节点节点:添加){
session.getWorkspace().getVersionManager().checkin(node.getPath());
}
}
}
和测试类
公共类测试{
私人int c = 0;
私人int countAll = 50;
private ExecutorService executor = Executors.newFixedThreadPool(5);
公共 ExecutorService getExecutor() {
返回执行者;
}
公共静态无效主要(字符串[]参数){
测试 test = new Test();
尝试 {
test.start();
} 捕捉(异常 e){
e.printStackTrace();
}
}
私人无效开始()抛出异常{
长时间 = System.currentTimeMillis();
TestFacadeRemote testBean = (TestFacadeRemote) getContext().
查找(“测试/TestFacadeBean/远程”);
for (int i = 0; i < countAll; i++) {
getExecutor().execute(new TestInstallerThread(i, testBean));
}
getExecutor().shutdown();
while (!getExecutor().isTerminated()) {
尝试 {
线程.sleep(500);
} 捕捉(InterruptedException e){
e.printStackTrace();
}
}
System.out.println(c + " 关机 " +
(System.currentTimeMillis() - 时间));
}
类 TestInstallerThread 实现 Runnable {
私人整数 = 0;
TestFacadeRemote testBean;
公共 TestInstallerThread(int number, TestFacadeRemote testBean) {
this.number = 数字;
this.testBean = testBean;
}
@覆盖
公共无效运行(){
尝试 {
System.out.println("安装数据" + number);
testBean.doAction(数字);
System.out.println("STOP" + number);
} 捕捉(异常 e){
e.printStackTrace();
C++;
}
}
}
公共上下文 getContext() 抛出 NamingException {
属性属性 = 新属性();
//初始化道具
.....................
返回新的 InitialContext(属性);
}
}
如果我用池中的 1 个线程初始化 executor,所有这些都没有任何错误。如果我用 5 个线程初始化执行程序,有时会出现错误:
在客户端
java.lang.RuntimeException: javax.transaction.RollbackException: [com.arjuna.ats.internal.jta.transaction.arjunacore.commitwhenaborted] [com.arjuna.ats.internal.jta.transaction.arjunacore.commitwhenaborted] 无法提交因为交易处于中止状态
在 org.jboss.aspects.tx.TxPolicy.handleEndTransactionException(TxPolicy.java:198)
开始时在服务器上警告
ItemStateReferenceCache [ItemStateReferenceCache.java:176] 覆盖缓存条目 187554a7-4c41-404b-b6ee-3ce2a9796a70
接着
javax.jcr.RepositoryException: org.apache.jackrabbit.core.state.ItemStateException: 已经有一个 id 为 52fb4b2c-3ef4-4fc5-9b79-f20a6b2e9ea3/{http://www.jcp.org/jcr/1.0 的属性状态实例}创建
在 org.apache.jackrabbit.core.PropertyImpl.restoreTransient(PropertyImpl.java:195) ~[jackrabbit-core-2.2.7.jar:2.2.7]
在 org.apache.jackrabbit.core.ItemSaveOperation.restoreTransientItems(ItemSaveOperation.java:879) [jackrabbit-core-2.2.7.jar:2.2.7]
我们已尝试将此方法和其他工作流程同步,以将多线程调用作为一个线程处理。没有什么帮助。
还有一件事——当我们在没有 ejb 层的情况下做了类似的测试时——一切都很好。看起来容器包装在自己的事务中,然后全部崩溃。
也许有人面临这样的问题。提前致谢。