在双节点wildfly集群中调用远程ejb

Hel*_*llo 8 java remote-access java-ee ejb-3.1 wildfly-9

我试图在节点node1和node2的集群的每个节点上调用远程ejb,但我总是得到node1.在两个节点中将EJB和客户端代码部署为EAR文件.应用程序在Wildfly 9 ApplicationServer上运行.从node1调用客户端代码.

EJB代码:

@Remote
public interface SLSBRemote {
    public void test();
}

@Stateless(mappedName="SLSBEJB")
public class SLSBEJB implements SLSBRemote {
    @Override
    public void test() 
    {
       try {
          String nodeName = System.getProperty("jboss.node.name");
          if(nodeName == null) {
             nodeName = InetAddress.getLocalHost().getHostName();
          }
          log.debug("nodename: "+nodeName);
       } catch (Exception e) {
          log.error("Error",e);
       }
    }
}
Run Code Online (Sandbox Code Playgroud)

客户代码:

public class testEjb
{
    //invoking this method from other class. Able to pass node address
    public void testBean(List<String> nodes)
    {
       Properties properties = new Properties();
       properties.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");
       Context context;
       for (String node : nodes) {
           properties.put(Context.PROVIDER_URL,"http-remoting://" + node);
           try {
             context = new InitialContext(properties);                  
             SLSBRemote slsbRemote=(SLSBRemote)context.lookup(getLookupName());
             log.debug("node:"+node+"slsbejbobject:"+slsbRemote.hashCode());
             slsbRemote.test();
           } catch (NamingException e) {
             log.error("Error ", e);
           }
       }
   }
}
Run Code Online (Sandbox Code Playgroud)

在日志中,

node: "node1", binddbejb object: 1276422461
node: "node2", binddbejb object: 1276422461
nodename: "node1_address"
nodename: "node1_address" (instead of node2_address)
Run Code Online (Sandbox Code Playgroud)

请建议

Spy*_*s K 2

为了使用集群 EJB,需要配置集群,据我所知:

  1. Wildfly 提供有状态 EJB 集群。
  2. Wild Fly 文档提供了集群故障转移场景的示例。(客户端尝试联系服务器 #1 上的 ejb,如果不可用,则客户端联系服务器 #2 上的 ejb。)
  3. 集群 Ejb 需要根据需要进行配置并正确注释。
import org.jboss.ejb3.annotation.Clustered;
import javax.ejb.Stateful;

@Stateful
@Clustered
public class MyStatefulBean {
...
}
Run Code Online (Sandbox Code Playgroud)

文档的本页给出了示例,其中详细描述了必须完成的操作。 https://docs.jboss.org/author/display/WFLY8/EJB+Services

如果应用此配置,集群中所有节点的 EJB 都可以为客户端提供服务。

但请注意,客户端通常应该完全不知道集群。客户端需要调用 ejb,并且应该由集群来决定哪个实例为客户端提供服务。