问题：

在Wild lfy9中，如何在独立模式下使用两个节点进行有状态ejb会话复制（集群）

百里弘致

2023-03-14

我想用ear项目做集群。我发现了一个在集群中使用standalone-ha.xml配置独立运行的解决方案。我关注了下面的文章。它工作得很好。使用wildfly9在域模式下进行集群，但我想运行ERP项目，该项目具有ear和有状态ejb。所以我在独立模式下运行集群。

我有两台不同ip的机器，例如

节点1

这两台机器都有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

我的项目测试。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）开放账户.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）操作.jsp从 servlet 转发的是：

<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>

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）网站。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服务器，即节点2并成功运行。但是不会复制会话。

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

共有1个答案

祁霖

2023-03-14

我也有类似的问题（帖子），开始关注你的帖子。过了一会儿，我知道了原因。

也许你有类似的问题。来看看吧。

类似资料：

如何在独立模式下在mesos上运行Spark

我已经在我的本地安装了mesos，并按照mesos设置中提到的进行了配置。现在我想在本地机器上安装的mesos上运行spark。我已经根据官方文档配置了spark，并在我的本地机器上运行了单节点hadoop集群。Spark二进制包被复制到hdfs根目录，我已经在spark-env.sh中设置了以下属性：是Spark-Defaults.conf：
使用DB时的EJB有状态会话bean与无状态会话bean

对于有状态会话bean(SFSB)和无状态会话bean(SLSB)的用法，我有点困惑。我知道SFSB与客户保持状态。这很有帮助：什么时候使用有状态会话bean而不是无状态会话bean？这里和许多其他地方提供的示例是SFSB的购物车。 “如果一个任务需要一系列方法调用（不止一次），并且您需要保留以前的结果以在下一次调用中使用它们，那么就可以使用SFSB”--Source。这将更像是签出（页面之间
何时在无状态会话bean上使用有状态会话bean？

问题内容：有状态会话Bean定义如下：有状态会话Bean对象的状态由其实例变量的值组成。在有状态会话Bean中，实例变量代表唯一的客户端Bean会话的状态。因为客户端与其bean进行交互（“交谈”），所以这种状态通常称为对话状态。无状态会话Bean定义如下：无状态会话Bean无状态会话Bean不会与客户端保持对话状态。当客户端调用无状态Bean的方法时，该Bean的实例变量可能包含特定于该
何时在休眠状态下使用独立条件？

问题内容：什么时候使用独立标准？使用分离标准而不是普通标准有什么好处？谢谢！问题答案：根据文档一些应用程序需要在“分离模式”下创建条件查询，在该模式下，Hibernate会话不可用。此类可以在任何地方实例化，然后可以通过将会话传递到来获得一个Criteria 。所有方法都具有与Criteria接口的相应方法相同的语义和行为。
如何使用Spark独立集群在工作节点上管理多个执行器？

从本文来看，默认情况下，工作节点使用该节点的所有内存（减去1 GB）。但是我明白，通过使用，我们可以使用更少的内存。例如，如果节点的总内存为32 GB，但我指定为16 GB，那么Spark worker在该节点上使用的内存不会超过16 GB？但是执行人呢？假设我希望每个节点运行2个执行器，那么可以通过在期间将执行器内存指定为的一半来实现吗？如果我希望每个节点运行4个执行器，可以通过将执行器内存指
在servlet中使用有状态会话bean

我正在使用Glassfish服务器（一个简单的购物车）尝试我的第一个EJB。我打算为每个Http会话使用CartBean。如果我的车豆跟着-

在Wild lfy9中，如何在独立模式下使用两个节点进行有状态ejb会话复制（集群）

共有1个答案

相关问答

相关文章

相关阅读

相关工具

相关文档