Wildfly上的EJB从另一个Wildfly调用远程EJB

Question

我目前的问题是，我的机器上运行了两个Wildfly 8.2.0最终实例。我知道，有类似的问题，但没有一个真正有助于我的问题。其中一个拥有一个宁静的应用程序，当它收到GET时，它会触发无状态会话Bean发送者豆。之后，此无状态会话 Bean 应从远程无状态会话 Bean 调用方法，该方法位于另一个 wildfly 实例上。

我将从解释我到目前为止所做的事情开始(也许我错过了一些东西，我对Java EE和Wildfly相当陌生)。

我将把带有发送方的Wildfly实例称为发送方，将带有PrintBean的实例称为接收方。

我创建了一个名为Stefan的应用程序用户，其密码Stefan，属于 guest组。在 Sender上，在 standalone full中。xml，我添加了一个安全领域

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

进入

<outbound-socket-binding name="remote-ejb">
  <remote-destination host="localhost" port="8080"/>
</outbound-socket-binding>

进入

<outbound-connections>
  <remote-outbound-connection name="remote-ejb-connection" outbound-socket-binding-ref="remote-ejb" username="Stefan" 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>

进入

我用CLI命令启动Senderstandalone.bat-cstandalone-full.xml-Djboss.socket.binding.port-偏移量=100-Djboss.node.name=Sender，用standalone.bat-cstandalone-full.xml-Djboss.node.name=接收器启动接收器。

发送方上的本地无状态会话 Bean 称为发送方 Bean：

@Stateless
public class SenderBean implements SenderService {

  private static final Logger logger = Logger.getLogger(SenderBean.class.getSimpleName());

  public void send(){
    logger.info("Trying to invoke");
    this.invoke();
  }

  private void invoke() {
    Properties clientProperties = new Properties();
    clientProperties.put("remote.connections", "default");
    clientProperties.put("remote.connection.default.port", "8080");
    clientProperties.put("remote.connection.default.host", "localhost");

    Properties properties = new Properties();
    properties.put(Context.URL_PKG_PREFIXES, "org.jboss.ejb.client.naming");        

    try {
        Context context = new InitialContext(properties);
        context = new InitialContext(properties);
        Object x = context.lookup("ejb:baseproject-ear-01.00.00-SNAPSHOT/testdomain-service-01.00.00-SNAPSHOT/Receiver/PrintBean!com.schubert.baseproject.testdomain.service.PrintService");
        logger.info("Obtained some object "+x.toString());
        logger.info("Trying to cast.");
        PrintService s = (PrintService) x;
        logger.info("Cast successful");
        logger.info("Printing using remote ejb: "+s.print("Markus"));
    } catch (NamingException e) {
        e.printStackTrace();
    }
  } 
}

接收器包含打印豆：

@Stateless
@Remote(PrintService.class)
public class PrintBean implements PrintService {

  @Override
  public String print(String name) {
    return "Hello " + name;
  }
}

现在的问题是，我总是收到一个IllegalStateException，上面写着EJBCLIENT000025：没有可用于处理的EJB接收器…

我可能做错了什么吗？我对EJB和野蝇相当陌生。您可以在 GitHub 上找到项目设置。




Answer 1

您可以在GitHub快速入门中找到两个JBoss服务器之间配置的详细说明，源代码和配置文件也提供

Answer 2

我认为问题在于InitialContext的参数，服务器配置很好。尝试按照我的例子连接到远程队列，在普通企业beans的情况下，您也可以探索这样的场景(插入正确的用户登录名和密码):

env.put(Context.PROVIDER_URL, "http-remoting://localhost:8080");
    env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");
    env.put(Context.SECURITY_PRINCIPAL, "client");
    env.put(Context.SECURITY_CREDENTIALS, "q");

    Context ctx = new InitialContext(env);
    connectionFactory = (ConnectionFactory)ctx.lookup("/jms/RemoteConnectionFactory");
    connection = connectionFactory.createConnection("client", "q");

请记住，具有开放外部访问可能性的jndi资源必须从服务器配置开始，使用java：/jboss/export/，但在客户端，您可以下拉这些词。此说明适用于WildFly，但不适用于JBoss EAP/AS和其他。您可以通过以下链接获得更多信息。

Answer 3

您应该将文件jboss-ejb-client.xml添加到您的发送方EAR(而不是WAR)。将其放在application.xml旁边。

jboss-ejb-client.xml内容：

<jboss-ejb-client>
    <client-context>
        <ejb-receivers>
            <remoting-ejb-receiver outbound-connection-ref="remote-ejb-connection"/>
        </ejb-receivers>
    </client-context>
</jboss-ejb-client> 

在发送方bean中，两行就足够了：

Context context = new InitialContext();
Object x = context.lookup("ejb:baseproject-ear-01.00.00-SNAPSHOT/testdomain-service-01.00.00-SNAPSHOT/PrintBean!com.schubert.baseproject.testdomain.service.PrintService");

请注意，我从路径中删除了“Receiver/”。您可以在服务器日志中找到JNDI绑定。