[jBPM] - jbpm5 scale out reference architecture..
by Affan Dar
Affan Dar [https://community.jboss.org/people/affandar] created the discussion
"jbpm5 scale out reference architecture.."
To view the discussion, visit: https://community.jboss.org/message/717611#717611
--------------------------------------------------------------
After scavenging the forums and docs for jbpm 5 over the last week, I have drafted up the attached 'reference architecture' for a scalable jBPM 5 deployment. Would love to get feedback (aka ripped apart :) ).
Here are the key pieces:
1. A shared KnowlegeBase which acts as a repository of processes across the whole deployment (master-slave replicated with writes-to-master and reads-from-slaves etc etc)
2. There are a fixed number of KnowledgeSessions spread across DBs in a DB farm (DB1, DB2)
3. A table contains the mapping between these sessions, the database that they are stored in and the node that is assigned to these sessions. Management of the data in this table is an admin config operation (either automatic or manual).
4. A number of worker nodes which load the KnowledgeSessions that belong to them (as per the table above)
5. Another table that has mapping of processes-to-sessions. This table is updated by the worker nodes when a new process is created.
6. A router or client proxy that routes process instance managment requests as per the following rules:
- For process instance creation requests, round robin to any node
- For requests pertaining to a specific process instance, consult the table in (5) & (6) and route to appropriate node
Now how to scale out:
- If the bottleneck is the CPU/memory of the worker nodes then add more nodes and rebalance the session distribution in table (3)
- If the bottleneck is the DB capacity or disk then add a database, migrate processes/session data to the new database and update table (3)
Of course the resharding above is crude and manual and can probably be more sophisticated but would love to hear thoughts/comments on the basic idea.
Also practically speaking, I hope it is possible to migrate a session and processes to a different DB at all?
Thanks
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/717611#717611]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
11 years, 2 months
[jBPM] - Restore JBPM session
by new bee
new bee [https://community.jboss.org/people/newbird] created the discussion
"Restore JBPM session"
To view the discussion, visit: https://community.jboss.org/message/750414#750414
--------------------------------------------------------------
Hi,
I am new to JBPM and struggling to understand the flow.............
I red that we can store jbpm session,process instance,task instance and variables...etc...............
After some point, assume application crashes and want to restore all running sessions how would i do?
Do i need to get each process id/session id from the session and again start it?
If i do in the above way, from which point it will start the session like it already proesses two nodes....How it will know to start from node3? Do i need to configure that also. If how would i?
Also red in discussions that after restoring the session, we need to again register action handlers? Is it true?
What is the use task server ,task service and task client? How they are different from workitem handler?
Please reply............................................. :-/
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/750414#750414]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
11 years, 2 months
[jBPM] - Re: Restore JBPM session
by Thomas Setiabudi
Thomas Setiabudi [https://community.jboss.org/people/thomas.setiabudi] created the discussion
"Re: Restore JBPM session"
To view the discussion, visit: https://community.jboss.org/message/752944#752944
--------------------------------------------------------------
I think the process should continue from before application crash point.
Lets take the com.sample.evaluation included in the jbpm5.3 full installer.
First step, we initiate the process instance lets say we pass in krisv as the employee name
Second step, krisv look at his task list and then complete his task
Third step, john look at his task list and then complete his task
Fourth step, Mary look at her task list, but when she tries to complete her task, application crash.
so we stop everything and restart
After restart, Mary should be able to see the task in the task list and complete it.
Isn't that the default behavior right now? Or do I misunderstand your question?
Regards,
Thomas Setiabudi
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/752944#752944]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
11 years, 2 months
[jBPM] - jbpm5.3 - Spring - Manage KSessions
by Pedro Gonçalves
Pedro Gonçalves [https://community.jboss.org/people/pgoncalves] created the discussion
"jbpm5.3 - Spring - Manage KSessions"
To view the discussion, visit: https://community.jboss.org/message/747824#747824
--------------------------------------------------------------
After some research in this forum and my understanding of chapter 5 of the docs, I came to the conclusion that I will need one knowledge session per process instance.
I use jbpm5.3, with spring integration and persistence.
*1* - For what I realized, the spring integration does not allow the "one knowledge session per process instance" architecture that I require. Is that true?
*2* - I've found the possibility of defining the id of the ksession that will be loaded during boot
(...)
<jbpm:ksession id="ksession" type="stateful" kbase="kbase1">
<jbpm:configuration>
<jbpm:jpa-persistence load="1">
<jbpm:transaction-manager ref="transactionManager"/>
<jbpm:entity-manager-factory ref="entityManagerFactory2" />
</jbpm:jpa-persistence>
</jbpm:configuration>
</jbpm:ksession>
(...)
The load parameter allows to load the ksession with the given id, but it fails to do so the first time it boots (as there is no ksession in the DB). So, even if I consider to have only one ksession for all process instances, I will have to implement some workaround to load the app for the first time. It is supposed to be like that? (The goal is to create a config file that does not need to be changed)
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/747824#747824]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
11 years, 3 months
[jBPM] - Re: how to export jbpm database tables ?
by eric jiang
eric jiang [https://community.jboss.org/people/kanawalo] created the discussion
"Re: how to export jbpm database tables ?"
To view the discussion, visit: https://community.jboss.org/message/760521#760521
--------------------------------------------------------------
After I changed the DB configuation files above. I got new problem when running the EvaluationExample.java. Before that, the *.war were deployed successfully in JBoss. Anybody know what is the cause? Thanks in advance.
| 0 | 20/09 15:29:55,781[main] ERROR service.hornetq.HornetQTaskClientConnector.connect - *Unable to connect to server using configuration org-hornetq-core-remoting-impl-netty-NettyConnectorFactory?port=5445&host=127-0-0-1* |
org.jbpm.workflow.instance.WorkflowRuntimeException: [com.sample.humantask:1 - Review:2] -- Could not connect task client: on ip: 127.0.0.1 - port: 5445
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:130) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerNodeInstance(NodeInstanceImpl.java:205) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:164) |
| | at org.jbpm.workflow.instance.node.ActionNodeInstance.triggerCompleted(ActionNodeInstance.java:55) |
| | at org.jbpm.workflow.instance.node.ActionNodeInstance.internalTrigger(ActionNodeInstance.java:51) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:124) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerNodeInstance(NodeInstanceImpl.java:205) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.triggerCompleted(NodeInstanceImpl.java:164) |
| | at org.jbpm.workflow.instance.node.StartNodeInstance.triggerCompleted(StartNodeInstance.java:49) |
| | at org.jbpm.workflow.instance.node.StartNodeInstance.internalTrigger(StartNodeInstance.java:41) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:124) |
| | at org.jbpm.ruleflow.instance.RuleFlowProcessInstance.internalStart(RuleFlowProcessInstance.java:35) |
| | at org.jbpm.process.instance.impl.ProcessInstanceImpl.start(ProcessInstanceImpl.java:188) |
| | at org.jbpm.workflow.instance.impl.WorkflowProcessInstanceImpl.start(WorkflowProcessInstanceImpl.java:303) |
| | at org.jbpm.process.instance.ProcessRuntimeImpl.startProcessInstance(ProcessRuntimeImpl.java:168) |
| | at org.jbpm.process.instance.ProcessRuntimeImpl.startProcess(ProcessRuntimeImpl.java:138) |
| | at org.drools.common.AbstractWorkingMemory.startProcess(AbstractWorkingMemory.java:1082) |
| | at org.drools.impl.StatefulKnowledgeSessionImpl.startProcess(StatefulKnowledgeSessionImpl.java:320) |
| | at org.jbpm.examples.humantask.HumanTaskExample.main(HumanTaskExample.java:42) |
Caused by: java.lang.IllegalArgumentException: Could not connect task client: on ip: 127.0.0.1 - port: 5445
| | at org.jbpm.process.workitem.wsht.GenericHTWorkItemHandler.connect(GenericHTWorkItemHandler.java:119) |
| | at org.jbpm.process.workitem.wsht.GenericHTWorkItemHandler.executeWorkItem(GenericHTWorkItemHandler.java:143) |
| | at org.drools.process.instance.impl.DefaultWorkItemManager.internalExecuteWorkItem(DefaultWorkItemManager.java:70) |
| | at org.jbpm.workflow.instance.node.WorkItemNodeInstance.internalTrigger(WorkItemNodeInstance.java:105) |
| | at org.jbpm.workflow.instance.impl.NodeInstanceImpl.trigger(NodeInstanceImpl.java:124) |
| | ... 18 more |
When I open http://localhost:8080/jbpm-console/ http://localhost:8080/jbpm-console/ and logged in to it. I also got problem.
* URL: ' http://localhost:8080/gwt-console-server/rs/tasks/krisv http://localhost:8080/gwt-console-server/rs/tasks/krisv'
* Action: 'org.jboss.bpm.console.client.task.LoadTasksAction'
* Exception: 'class com.google.gwt.http.client.RequestException'
h1. HTTP Status 500 -
----
*type* Exception report
*message*
*description* The server encountered an internal error () that prevented it from fulfilling this request.
*exception*
org.jboss.resteasy.spi.UnhandledException: java.lang.NoClassDefFoundError: Could not initialize class org.jbpm.integration.console.StatefulKnowledgeSessionUtil$SessionHolder org.jboss.resteasy.core.SynchronousDispatcher.unwrapException(SynchronousDispatcher.java:345) org.jboss.resteasy.core.SynchronousDispatcher.handleApplicationException(SynchronousDispatcher.java:321) org.jboss.resteasy.core.SynchronousDispatcher.handleException(SynchronousDispatcher.java:214) org.jboss.resteasy.core.SynchronousDispatcher.handleInvokerException(SynchronousDispatcher.java:190) org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:534) org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:496) org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:119) org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:208) org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:55) org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:50) javax.servlet.http.HttpServlet.service(HttpServlet.java:847) org.jboss.bpm.console.server.util.GWTJsonFilter.doFilter(GWTJsonFilter.java:59)
*root cause*
java.lang.NoClassDefFoundError: Could not initialize class org.jbpm.integration.console.StatefulKnowledgeSessionUtil$SessionHolder org.jbpm.integration.console.StatefulKnowledgeSessionUtil.getStatefulKnowledgeSession(StatefulKnowledgeSessionUtil.java:131) org.jbpm.integration.console.SessionInitializer.<init>(SessionInitializer.java:25) org.jbpm.integration.console.TaskManagement.<init>(TaskManagement.java:51) org.jbpm.integration.console.ManagementFactory.createTaskManagement(ManagementFactory.java:26) org.jbpm.integration.console.ManagementFactory.createTaskManagement(ManagementFactory.java:19) org.jboss.bpm.console.server.TaskListFacade.getTaskManagement(TaskListFacade.java:72) org.jboss.bpm.console.server.TaskListFacade.getTasksForIdRef(TaskListFacade.java:101) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) java.lang.reflect.Method.invoke(Method.java:597) org.jboss.resteasy.core.MethodInjectorImpl.invoke(MethodInjectorImpl.java:140) org.jboss.resteasy.core.ResourceMethod.invokeOnTarget(ResourceMethod.java:255) org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:220) org.jboss.resteasy.core.ResourceMethod.invoke(ResourceMethod.java:209) org.jboss.resteasy.core.SynchronousDispatcher.getResponse(SynchronousDispatcher.java:519) org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:496) org.jboss.resteasy.core.SynchronousDispatcher.invoke(SynchronousDispatcher.java:119) org.jboss.resteasy.plugins.server.servlet.ServletContainerDispatcher.service(ServletContainerDispatcher.java:208) org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:55) org.jboss.resteasy.plugins.server.servlet.HttpServletDispatcher.service(HttpServletDispatcher.java:50) javax.servlet.http.HttpServlet.service(HttpServlet.java:847) org.jboss.bpm.console.server.util.GWTJsonFilter.doFilter(GWTJsonFilter.java:59)
Pls advise. :-/
--------------------------------------------------------------
Reply to this message by going to Community
[https://community.jboss.org/message/760521#760521]
Start a new discussion in jBPM at Community
[https://community.jboss.org/choose-container!input.jspa?contentType=1&con...]
11 years, 3 months
