是否可以明确指示JBoss EAP 6中使用哪个EJB接收器？

Question

我正在尝试从运行在JBoss EAP 6的单独实例上的客户端服务器对运行在JBoss EAP 6的一个实例上的多个服务器进行远程调用。我已经配置了JBoss到JBoss的远程通信，并且已经阅读了范围内的EJB客户端上下文，但是两者似乎不兼容。目前，我配置了两个EJB接收器（每个远程服务器一个），但是当我尝试进行远程调用时，会出现初始化的上下文随机选择它将使用的EJB接收器。如果我有远程IP和端口，或者远程连接名称，我可以在初始化上下文时强制使用哪个EJB接收器似乎是合理的，但是唉，我不知道秘密握手。

主办xml：

<security-realm name="ejb-security-realm">
    <server-identities>
        <secret value="ZWpiUEBzc3cwcmQ="/>
    </server-identities>
</security-realm>

domain.xml：

<subsystem xmlns="urn:jboss:domain:remoting:1.2">
                <connector name="remoting-connector" socket binding="remoting" security-realm="ApplicationRealm"/>
                <outbound-connections>
                    <remote-outbound-connection name="remote-ejb-connection" outbound-socket-binding-ref="mpg1-app1" username="ejbuser" security-realm="ejb-security-realm">
                        <properties>
                            <property name="SASL_POLICY_NOANONYMOUS" value="false"/>
                            <property name="SSL_ENABLED" value="false"/>
                        </properties>
                    </remote-outbound-connection>
                    <remote-outbound-connection name="remote-ejb-connection2" outbound-socket-binding-ref="mpg2-app1" username="ejbuser" security-realm="ejb-security-realm">
                        <properties>
                            <property name="SASL_POLICY_NOANONYMOUS" value="false"/>
                            <property name="SSL_ENABLED" value="false"/>
                        </properties>
                    </remote-outbound-connection>
                </outbound-connections>
            </subsystem>
...
<socket-binding-group name="full-sockets" default-interface="public">
            ...
            <socket-binding name="remoting" port="44447"/>
            <outbound-socket-binding name="mpg1-app1">
                <remote-destination host="localhost" port="44452"/>
            </outbound-socket-binding>
            <outbound-socket-binding name="mpg2-app1">
                <remote-destination host="localhost" port="44453"/>
            </outbound-socket-binding>
</socket-binding-group>

jboss ejb客户端。xml

<jboss-ejb-client xmlns="urn:jboss:ejb-client:1.0">
    <client-context>
        <ejb-receivers>
            <remoting-ejb-receiver outbound-connection-ref="remote-ejb-connection"/>
            <remoting-ejb-receiver outbound-connection-ref="remote-ejb-connection2"/>
        </ejb-receivers>
    </client-context>
</jboss-ejb-client>

远程呼叫：

上下文ctx=null；

最终属性props=新属性（）；

道具。put（Context.URL\u PKG\u前缀，“org.jboss.ejb.client.naming”）；

试试看{

ctx=新的初始上下文（props）
MyInterfaceObject-ourInterface=ctx。查找（“ejb：“appName”/“moduleName”/“beanName”！”viewClassName）；

ourInteface。refreshProperties（）//远程方法调用

}

任何帮助都将不胜感激！

Answer 1

你试过集群节点选择器吗

jboss ejb客户端。xml

  <!-- if an outbound connection connect to a cluster a list of members is provided after successful connection.
To connect to this node this cluster element must be defined.
-->
   <clusters>
     <!-- cluster of remote-ejb-connection-1 -->
     <cluster name="ejb" security-realm="ejb-security-realm-1" username="test" cluster-node-selector="org.jboss.as.quickstarts.ejb.clients.selector.AllClusterNodeSelector">
        <connection-creation-options>
           <property name="org.xnio.Options.SSL_ENABLED" value="false" />
           <property name="org.xnio.Options.SASL_POLICY_NOANONYMOUS" value="false" />
        </connection-creation-options>
      </cluster>
   </clusters>
  </client-context>
</jboss-ejb-client>

选择器实现

    @Override
            public String selectNode(final String clusterName, final String[] connectedNodes, final String[] availableNodes) {
                    if (availableNodes.length == 1) {
                            return availableNodes[0];
                    }
                    // Go through all the nodes and point to the one you want
                    for (int i = 0; i < availableNodes.length; i++) {
                            if (availableNodes[i].contains("someoneYouInterestIn")) {
                                    return availableNodes[i];
                            }
                    }

                    final Random random = new Random();
                    final int randomSelection = random.nextInt(availableNodes.length);
                    return availableNodes[randomSelection];
            }

有关更多信息，您可以查看https://access.redhat.com/documentation/en/red-hat-jboss-enterprise-application-platform/7.0/developing-ejb-applications/chapter-8-clustered-enterprise-javab