JBoss AS 7 中的集群 EJB 不平衡

我已成功设置由 2 个 JBoss AS 7 实例组成的集群，并部署了以下 SLSB：

@Stateless
@Remote(TestEJBRemote.class)
@Clustered
public class TestEJB implements TestEJBRemote {
  private static final long serialVersionUID = 1L;
  private static final Logger logger = Logger.getLogger(...);

  @Override
  public void test() {
    String nodeName = System.getProperty("jboss.node.name");
    logger.info(nodeName);
  }
}

从日志文件中我可以看到该 bean 已正确部署在集群上。然后，在客户端，我创建许多线程来查找并调用TestEJB。然而，似乎所有实例最终都在同一个节点中。

这是“jndi.properties”文件：

java.naming.factory.url.pkgs=org.jboss.ejb.client.naming

和“jboss-ejb-client.properties”：

endpoint.name=client-endpoint
remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED=false

remote.connections=default
remote.connection.default.host=192.168.0.1
remote.connection.default.port=4447
remote.connection.default.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false
remote.connection.default.username=user
remote.connection.default.password=pass

remote.clusters=ejb
remote.cluster.ejb.clusternode.selector=org.jboss.ejb.client.RandomClusterNodeSelector

在客户端我做final InitialContext ctx = new InitialContext();然后在每个线程中形成：

String name = "ejb:/test//TestEJB!" + TestEJBRemote.class.getName();
TestEJBRemote remote = (TestEJBRemote) ctx.lookup(name);
remote.test();

我做错了什么？

UPDATE

如果我仅指定连接列表中的第二个节点，我会得到：

java.lang.IllegalStateException: No EJB receiver available for handling [...] combination for invocation context org.jboss.ejb.client.EJBClientInvoc ationContext

所以这个问题可能需要首先解决......

UPDATE 2

我最终通过在从节点中设置一个应用程序用户解决了这个问题。之前，我尝试以管理用户身份进行连接，但没有成功。

现在，只要我在连接列表中指定一个从属节点（在“jboss-ejb-client.properties”中），负载平衡就可以正常工作。如果我指定主节点，则所有 EJB 将仅在该节点中结束。然而，这个解决方案对我来说已经足够了。

看起来您需要在属性构建中指定两台服务器。另外，JBoss 7.1 中似乎有一个“但是”，因此您至少应该使用 7.2，检查此链接 https://issues.jboss.org/browse/AS7-4223以下样本取自：

Properties properties = new Properties();
properties.put("endpoint.name", "farecompare-client-endpoint");
properties.put("remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED", "false");
properties.put("remote.connections", "cmc5101,cmc5102");
properties.put("remote.connection.cmc5101.host", "cmc5-101");
properties.put("remote.connection.cmc5101.port", "4447");
properties.put("remote.connection.cmc5101.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "false");
properties.put("remote.connection.cmc5102.host", "cmc5-102");
properties.put("remote.connection.cmc5102.port", "4447");
properties.put("remote.connection.cmc5102.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "false");
PropertiesBasedEJBClientConfiguration configuration = new PropertiesBasedEJBClientConfiguration(properties);
final ContextSelector ejbClientContextSelector = new ConfigBasedEJBClientContextSelector(configuration);
final ContextSelector previousSelector = EJBClientContext.setSelector(ejbClientContextSelector);
final Hashtable jndiProperties = new Hashtable();
jndiProperties.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");
final Context context = new InitialContext(jndiProperties);

Also 这个链接 https://docs.jboss.org/author/display/AS71/Clustered+EJBs可能会有帮助。 其他有用的链接 https://docs.jboss.org/author/display/AS71/EJB+invocations+from+a+remote+client+using+JNDI.