个人中心
gpt4 book ai didi

java - 在 wildlfy9 中，如何在独立模式下使用两个节点进行有状态的 ejb session 复制(集群)

转载 作者：塔克拉玛干 更新时间：2023-11-03 03:57:41 25 4
gpt4 key购买 nike

我想用 ear 项目做集群。我找到了一种使用 standalone-ha.xml 配置在集群中独立运行的解决方案。我按照下面的文章。它工作正常。 Clustering in domain mode with wildfly9但我想运行 ERP 项目，它有 ear 以及有状态的 ejb。所以我在独立模式下运行集群。

我有两台机器ip不一样例如

1.10.10.10.10 节点 1

  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，实现了远程和本地接口(interface)

@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 服务器并刷新浏览器(不清除浏览器历史记录以维护 session )，那时它给我错误，如可分发容器不适用于相同的应用程序。

2) 10.10.10.10 已关闭，我清除了历史记录并再次访问 url 10.10.10.10/测试它重定向到 20.20.20.20 服务器即 node2 并成功运行。但是 session 不会被复制。

请帮帮我。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>

最佳答案

我遇到了类似的问题 ( post ) 并开始观看您的帖子。过了一会儿，我明白了是什么原因造成的。

也许你有类似的问题。检查一下。

关于java - 在 wildlfy9 中，如何在独立模式下使用两个节点进行有状态的 ejb session 复制(集群)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/33008545/

25 4 0
文章推荐： java - eclipse 火星 : rebuild index of maven central repository stuck
文章推荐： c++ - 在 C++ 中使用 Dijkstra 算法对图像进行 Seam Carving
文章推荐： algorithm - 使用深度优先搜索的三角形最大和
文章推荐： java - 使用 orElseThrow 时出现循环接口(interface)错误
塔克拉玛干
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com