在wildlfy9中，如何在独立模式下使用两个节点进行有状态的ejb会话复制（集群）
Posted
技术标签:
【中文标题】在wildlfy9中，如何在独立模式下使用两个节点进行有状态的ejb会话复制（集群）【英文标题】：In wildlfy9, how to make stateful ejb session replication with two node in standalone mode(Clustering) 【发布时间】：2016-01-05 15:33:07 【问题描述】：我想用 ear 项目做集群。我找到了一种使用standalone-ha.xml 配置在集群中独立运行的解决方案。 我跟着下面的文章。它工作正常。 Clustering in domain mode with wildfly9 但我想运行具有耳朵和有状态 ejb 的 ERP 项目。 所以我以独立模式运行集群。
我有两台机器ip不同 例如
1.10.10.10.10 节点1
-
20.20.20.20 节点2
两台机器都有 wildfly9，出于测试目的，我创建了一个带有 web 组件的示例有状态 ejb 项目。
我运行服务器的命令是：
standalone.bat -c standalone-ha.xml -b 10.10.10.10 -u 230.0.0.4 -Djboss.node.name=node1
和
./standalone.sh -c standalone-ha.xml -b 20.20.20.20 -u 230.0.0.4 -Djboss.node.name=node2
我的项目 Test.war 有有状态的 ejb 和 servlet 和 jsp 。 1)Bank.java 是有状态的ejb，它实现了远程和本地接口
@Stateful(passivationCapable=true)
public class Bank implements BankRemote,BankLocal
private int amount=0;
@Override
public boolean withdraw(int amount)
if(amount<=this.amount)
this.amount-=amount;
return true;
else
return false;
@Override
public void deposit(int amount)
this.amount+=amount;
@Override
public int getBalance()
return amount;
2)OpenAccount.java 是servlet
@WebServlet("/OpenAccount")
public class OpenAccount extends HttpServlet
protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
try
HttpSession bankSession = request.getSession();
BankRemote bank = (BankRemote) bankSession.getAttribute("remote");
if(bank == null)
System.out.println("Session is Null So initialized with new session");
Properties p = new Properties();
/*p.put("jboss.naming.client.ejb.context", true);*/
p.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
InitialContext context=new InitialContext();
BankRemote b=(BankRemote)context.lookup("java:global/Test/Bank!com.ejb.BankRemote");
request.getSession().setAttribute("remote",b);
else
System.out.println("Session is present id is :["+bankSession.getId()+"]");
request.getRequestDispatcher("/operation.jsp").forward(request, response);
catch(Exception e)System.out.println(e);
3)index.jsp 是主页包含以下单行重定向到 servlet
<a href="OpenAccount">Open Account</a>
4)从servlet转发过来的operation.jsp是：
<body>
<form action="operationprocess.jsp">
Enter Amount:<input type="text" name="amount"/><br>
Choose Operation:
Deposit<input type="radio" name="operation" value="deposit"/>
Withdraw<input type="radio" name="operation" value="withdraw"/>
Check balance<input type="radio" name="operation" value="checkbalance"/>
<br>
<input type="submit" value="submit">
</form>
</body>4)operationprocess.jsp是
<body>
<%
try
BankRemote remote=(BankRemote)session.getAttribute("remote");
String operation=request.getParameter("operation");
String amount=request.getParameter("amount");
if(remote != null)
if(operation!=null)
try
if(operation.equals("deposit"))
remote.deposit(Integer.parseInt(amount));
out.print("Amount successfully deposited!");
else
if(operation.equals("withdraw"))
boolean status=remote.withdraw(Integer.parseInt(amount));
if(status)
out.print("Amount successfully withdrawn!");
else
out.println("Enter less amount");
else
out.println("Current Amount: "+remote.getBalance());
catch(NumberFormatException numex)
out.println("Number is not valid");
else
out.print("Session is null");
catch(Exception ee)
System.out.println("in jsp exception");
ee.printStackTrace();
%>
<hr/>
<jsp:include page="operation.jsp"></jsp:include>
</body>5)web.xml 包含
<distributable/>
启用集群的标签。
6) 类路径也有 jboss-ejb-client.properties
remote.clusters=ejb
remote.cluster.ejb.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false
remote.cluster.ejb.connect.options.org.xnio.Options.SSL_ENABLED=false
有了所有这些，我在两个服务器上部署了 Test.war 并尝试使用 apache_mode_cluster 访问，即 10.10.10.10/Test/。它正在调用 ejb 并给我输出但是当
1) 我关闭 10.10.10.10 服务器并刷新浏览器（未清除浏览器历史记录以维护会话），那时它给了我错误，例如可分发容器不适用于相同的应用程序。
2) 10.10.10.10 已关闭，我清除历史记录并再次访问 url 10.10.10.10/测试它重定向到 20.20.20.20 服务器即 node2 并成功运行。 但是会话没有被复制。
请帮助我。 Standalone-ha.xml -- 子系统 infinispan 是：
<cache-container name="server" default-cache="default" module="org.wildfly.clustering.server" aliases="singleton cluster">
<transport lock-timeout="60000"/>
<replicated-cache name="default" mode="SYNC">
<transaction mode="BATCH"/>
</replicated-cache>
</cache-container>
<cache-container name="web" default-cache="dist" module="org.wildfly.clustering.web.infinispan">
<transport lock-timeout="60000"/>
<distributed-cache name="dist" mode="ASYNC" owners="2" l1-lifespan="0">
<locking isolation="REPEATABLE_READ"/>
<transaction mode="BATCH"/>
<file-store/>
</distributed-cache>
</cache-container>
<cache-container name="ejb" default-cache="dist" module="org.wildfly.clustering.ejb.infinispan" aliases="sfsb">
<transport lock-timeout="60000"/>
<distributed-cache name="dist" mode="ASYNC" owners="2" l1-lifespan="0">
<locking isolation="REPEATABLE_READ"/>
<transaction mode="BATCH"/>
<file-store/>
</distributed-cache>
</cache-container>
【问题讨论】：
请从您的standalone-ha.xml 文件中发布inifnispan子系统<subsystem xmlns="urn:jboss:domain:infinispan:3.0">的内容。
标签cluster-analysis（别名：clustering）指的是数据挖掘任务，而不是服务器load-balancing或cluster-computing。请多注意选择合适的标签及其描述。
脚本 ????????? o.O
【参考方案1】：
我遇到了类似的问题 (post) 并开始观看您的帖子。过了一会儿，我明白了是什么原因造成的。
也许你有类似的问题。看看吧。
【讨论】：
以上是关于在wildlfy9中，如何在独立模式下使用两个节点进行有状态的ejb会话复制（集群）的主要内容，如果未能解决你的问题，请参考以下文章