8.10. 자카르타 엔터프라이즈 빈 호출에 대한 사용자 정의 로드 밸런싱 정책 구현
jboss-ejb-client.properties
파일의 사용은 더 이상 사용되지 않습니다 .
서버 간에 애플리케이션의 Jakarta Enterprise Beans 호출의 균형을 맞추기 위해 대체 또는 사용자 지정 로드 밸런싱 정책을 구현할 수 있습니다.
Jakarta Enterprise Beans 호출에 대한 AllClusterNodeSelector
를 구현할 수 있습니다. AllClusterNodeSelector
의 노드 선택 동작은 대규모 클러스터(노드 수 > 20)에서도 AllClusterNodeSelector
가 사용 가능한 모든 클러스터 노드를 사용한다는 점을 제외하고 기본 선택기와 유사합니다. 연결되지 않은 클러스터 노드가 반환되면 자동으로 열립니다. 다음 예제에서는 AllClusterNodeSelector
구현을 보여줍니다.
package org.jboss.as.quickstarts.ejb.clients.selector; import java.util.Arrays; import java.util.Random; import java.util.logging.Level; import java.util.logging.Logger; import org.jboss.ejb.client.ClusterNodeSelector; public class AllClusterNodeSelector implements ClusterNodeSelector { private static final Logger LOGGER = Logger.getLogger(AllClusterNodeSelector.class.getName()); @Override public String selectNode(final String clusterName, final String[] connectedNodes, final String[] availableNodes) { if(LOGGER.isLoggable(Level.FINER)) { LOGGER.finer("INSTANCE "+this+ " : cluster:"+clusterName+" connected:"+Arrays.deepToString(connectedNodes)+" available:"+Arrays.deepToString(availableNodes)); } if (availableNodes.length == 1) { return availableNodes[0]; } final Random random = new Random(); final int randomSelection = random.nextInt(availableNodes.length); return availableNodes[randomSelection]; } }
Jakarta Enterprise Beans 호출에 대한 SimpleLoadFactorNodeSelector
를 구현할 수도 있습니다. SimpleLoadFactorNodeSelector
의 부하 분산은 부하 요인에 따라 수행됩니다. 로드 계수(2/3/4)는 각 노드의 부하와 관계없이 노드 이름(A/B/C)에 따라 계산됩니다. 다음 예는 SimpleLoadFactorNodeSelector
구현을 보여줍니다.
package org.jboss.as.quickstarts.ejb.clients.selector; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.logging.Level; import java.util.logging.Logger; import org.jboss.ejb.client.DeploymentNodeSelector; public class SimpleLoadFactorNodeSelector implements DeploymentNodeSelector { private static final Logger LOGGER = Logger.getLogger(SimpleLoadFactorNodeSelector.class.getName()); private final Map<String, List<String>[]> nodes = new HashMap<String, List<String>[]>(); private final Map<String, Integer> cursor = new HashMap<String, Integer>(); private ArrayList<String> calculateNodes(Collection<String> eligibleNodes) { ArrayList<String> nodeList = new ArrayList<String>(); for (String string : eligibleNodes) { if(string.contains("A") || string.contains("2")) { nodeList.add(string); nodeList.add(string); } else if(string.contains("B") || string.contains("3")) { nodeList.add(string); nodeList.add(string); nodeList.add(string); } else if(string.contains("C") || string.contains("4")) { nodeList.add(string); nodeList.add(string); nodeList.add(string); nodeList.add(string); } } return nodeList; } @SuppressWarnings("unchecked") private void checkNodeNames(String[] eligibleNodes, String key) { if(!nodes.containsKey(key) || nodes.get(key)[0].size() != eligibleNodes.length || !nodes.get(key)[0].containsAll(Arrays.asList(eligibleNodes))) { // must be synchronized as the client might call it concurrent synchronized (nodes) { if(!nodes.containsKey(key) || nodes.get(key)[0].size() != eligibleNodes.length || !nodes.get(key)[0].containsAll(Arrays.asList(eligibleNodes))) { ArrayList<String> nodeList = new ArrayList<String>(); nodeList.addAll(Arrays.asList(eligibleNodes)); nodes.put(key, new List[] { nodeList, calculateNodes(nodeList) }); } } } } private synchronized String nextNode(String key) { Integer c = cursor.get(key); List<String> nodeList = nodes.get(key)[1]; if(c == null || c >= nodeList.size()) { c = Integer.valueOf(0); } String node = nodeList.get(c); cursor.put(key, Integer.valueOf(c + 1)); return node; } @Override public String selectNode(String[] eligibleNodes, String appName, String moduleName, String distinctName) { if (LOGGER.isLoggable(Level.FINER)) { LOGGER.finer("INSTANCE " + this + " : nodes:" + Arrays.deepToString(eligibleNodes) + " appName:" + appName + " moduleName:" + moduleName + " distinctName:" + distinctName); } // if there is only one there is no sense to choice if (eligibleNodes.length == 1) { return eligibleNodes[0]; } final String key = appName + "|" + moduleName + "|" + distinctName; checkNodeNames(eligibleNodes, key); return nextNode(key); } }
jboss-ejb-client.properties 파일 구성
구현 클래스(AllClusterNodeSelector 또는
)의 이름으로 remote SimpleLoadFactorNodeSelector
.cluster.ejb.clusternode.selector
속성을 추가해야 합니다. 선택기는 호출 시 사용할 수 있는 구성된 모든 서버가 표시됩니다. 다음 예제에서는 AllClusterNodeSelector
를 클러스터 노드 선택기로 사용합니다.
remote.clusters=ejb remote.cluster.ejb.clusternode.selector=org.jboss.as.quickstarts.ejb.clients.selector.AllClusterNodeSelector remote.cluster.ejb.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false remote.cluster.ejb.connect.options.org.xnio.Options.SSL_ENABLED=false remote.cluster.ejb.username=test remote.cluster.ejb.password=password remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED=false remote.connections=one,two remote.connection.one.host=localhost remote.connection.one.port = 8080 remote.connection.one.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false remote.connection.one.username=user remote.connection.one.password=user123 remote.connection.two.host=localhost remote.connection.two.port = 8180 remote.connection.two.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS=false
Jakarta Enterprise Beans 클라이언트 API 사용
PropertiesBasedEJBClientConfiguration
생성자의 목록에 remote.cluster.ejb.clusternode.selector
속성을 추가해야 합니다. 다음 예제에서는 AllClusterNodeSelector
를 클러스터 노드 선택기로 사용합니다.
Properties p = new Properties(); p.put("remote.clusters", "ejb"); p.put("remote.cluster.ejb.clusternode.selector", "org.jboss.as.quickstarts.ejb.clients.selector.AllClusterNodeSelector"); p.put("remote.cluster.ejb.connect.options.org.xnio.Options.SASL_POLICY_NOANONYMOUS", "false"); p.put("remote.cluster.ejb.connect.options.org.xnio.Options.SSL_ENABLED", "false"); p.put("remote.cluster.ejb.username", "test"); p.put("remote.cluster.ejb.password", "password"); p.put("remote.connectionprovider.create.options.org.xnio.Options.SSL_ENABLED", "false"); p.put("remote.connections", "one,two"); p.put("remote.connection.one.port", "8080"); p.put("remote.connection.one.host", "localhost"); p.put("remote.connection.two.port", "8180"); p.put("remote.connection.two.host", "localhost"); EJBClientConfiguration cc = new PropertiesBasedEJBClientConfiguration(p); ContextSelector<EJBClientContext> selector = new ConfigBasedEJBClientContextSelector(cc); EJBClientContext.setSelector(selector); p = new Properties(); p.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming"); InitialContext context = new InitialContext(p);
jboss-ejb-client.xml 파일 구성
서버에서 서버 간 통신에 부하 분산 정책을 사용하려면 클래스를 애플리케이션과 함께 패키징하고 META-INF
폴더에 있는 jboss-ejb-client.xml
설정 내에 구성합니다. 다음 예제에서는 AllClusterNodeSelector
를 클러스터 노드 선택기로 사용합니다.
<jboss-ejb-client xmlns:xsi="urn:jboss:ejb-client:1.2" xsi:noNamespaceSchemaLocation="jboss-ejb-client_1_2.xsd"> <client-context deployment-node-selector="org.jboss.ejb.client.DeploymentNodeSelector"> <ejb-receivers> <!-- This is the connection to access the application. --> <remoting-ejb-receiver outbound-connection-ref="remote-ejb-connection-1" /> </ejb-receivers> <!-- Specify the cluster configurations applicable for this client context --> <clusters> <!-- Configure the 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>
보안과 함께 위의 구성을 사용하려면 ejb-security-realm-1을 클라이언트-
서버 구성에 추가해야 합니다. 다음 예제에서는 보안 영역(ejb-security-realm-1)
을 추가하기 위한 CLI 명령을 보여줍니다. 값은 "test" 사용자의 base64 인코딩 암호입니다.
/core-service=management/security-realm=ejb-security-realm-1:add() /core-service=management/security-realm=ejb-security-realm-1/server-identity=secret:add(value=cXVpY2sxMjMr)
서버 간 통신에 부하 분산 정책을 사용해야 하는 경우 클래스를 애플리케이션 또는 모듈과 함께 패키징할 수 있습니다. 이 클래스는 최상위 EAR 아카이브의 META
설정 파일에서 구성됩니다. 다음 예제에서는 배포 노드 선택기로 -INF 디렉터리에 있는 jboss-
ejb-clientRoundRobinNodeSelector
를 사용합니다.
<jboss-ejb-client xmlns="urn:jboss:ejb-client:1.2"> <client-context deployment-node-selector="org.jboss.example.RoundRobinNodeSelector"> <ejb-receivers> <remoting-ejb-receiver outbound-connection-ref="..."/> </ejb-receivers> ... </client-context> </jboss-ejb-client>
독립 실행형 서버를 실행하는 경우 start 옵션 -Djboss.node.name=
또는 서버 구성 파일 standalone.xml
을 사용하여 서버 이름을 구성합니다. 서버 이름이 고유한지 확인합니다. 관리형 도메인을 실행하는 경우 호스트 컨트롤러는 이름이 고유함을 자동으로 확인합니다.