动态远程 EJB 调用

Dynamic Remote EJB call

我找了很久但实际上没有找到适合我的情况的正确答案。

一般我想在不知道它的所有方法的情况下调用远程 EJB。 据我所知,我需要使用反射来完成它。

问题是我是否应该在客户端使用接口? 通常我使用接口进行 EJB 调用,但我想我需要使用字节码操作在运行时创建动态接口???

最后的想法是在运行时(热部署)将新应用程序部署到 jboss 服务器,并通过管理服务器(来自 EJB 的主应用程序)从新部署的应用程序调用 EJB。 所以我可以在运行时 add/delete/update logic/EJBs

但是远程EJB 并不是每次都一样(取决于它应该执行的任务)。 所以我需要为我想调用的每个新部署的 application/ejb 动态创建一个接口或 class 。 Client/admin 只知道 JNDI 名称。

让我们假设这是我的接口和来自热部署应用程序的 ejb 代码。 请考虑这只是 n 个中的一个 EJB。

远程 EJB 接口:

import javax.ejb.Remote;

@Remote
public interface EJBInterface {

    public void www();
    public void store();
}

远程 EJB:

import javax.ejb.Stateless;

import com.xx.yy.EJBInterface;

@Stateless
public class EJBStuff implements EJBInterface{

    @Override
    public void www() {
       //Do some stuff
    }

    @Override
    public void store() {
       //Do some stuff
    }
}

在 client/admin 方面,我想调用 EJB。 我应该使用接口还是直接使用 class 来实现??? 此外,我假设我需要向每个热部署应用程序添加一个通用 EJB,它为我提供了来自我想调用的 EJB 的信息,因此我可以在 client/admin 端创建一个 class 或接口。

如果我应该在 client/admin 端或 class 上创建一个接口并在没有接口视图的情况下调用 EJB,有人有意见吗??? 我需要另一个 class 来为我提供来自远程 EJB 的信息???

谢谢指教。

您的问题的解决方案是 "Command Design Pattern"。我的示例是一个 Web 客户端,以避免由 JNDI 查找引起的不便(无论如何这不是问题的一部分)

EJB模块代码(Command、CommandType、CommandMgr、HelloBean)

命令class用于抽象调用SLSBs的参数化方法:

package x;

import java.util.HashMap;
import java.util.Map;

public class Command
{
  private int type;
  private final Map<String,Object> params = new HashMap<>();

  public Command( int type_ ) { type = type_; }
  public int getType() { return type; }
  public Map<String,Object> getParams() { return params; }
  public Object getParamByKey( String key_ ) { return params.get( key_ ); }
}

CommandType 枚举描述的可用命令类型:

public enum CommandType { UNKNOWN, HELLO }

CommandMgr 是接收命令消息的远程业务接口:

package x;

import javax.ejb.Remote;

@Remote
public interface CommandMgr
{
  public Object send( Command command_ );
}

CommandMgrImpl class 实现业务接口:

package x;

import java.security.InvalidParameterException;
import javax.ejb.Stateless;
import javax.inject.Inject;

@Stateless( name = "commandMgr" )
public class CommandMgrImp implements CommandMgr
{

  @Inject
  private HelloBean helloBean;

  @Override
  public Object send( Command command_ )
  {
    if ( command_ != null )
      switch ( command_.getType() )
      {
        case 1:
          return helloBean.sayHello( (String) command_.getParamByKey( "name" ) );
        default:
          return null;
      }
    else
      throw new InvalidParameterException( "CommandMgrImp.send() : command_=null");
  }

}

HelloBean 是通过远程接口间接访问的会话 bean 之一:

package x;

import javax.enterprise.context.ApplicationScoped;
import javax.inject.Named;

@Named
@ApplicationScoped
public class HelloBean
{
  public String sayHello( String name_ )
  {
    return "Hello " + name_ + "!";
  }
}

Web 客户端代码是一个常见的 JSF Web 模块(一个页面和一个 EJB 注入的支持 bean):

hellopage.xhtml:

<?xml version='1.0' encoding='UTF-8' ?>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml"
      xmlns:h="http://xmlns.jcp.org/jsf/html"
      xmlns:f="http://xmlns.jcp.org/jsf/core">
  <h:head>
    <title>Facelet Title</title>
  </h:head>
  <h:body>
    <h:form>
    <h:panelGrid columns="3">
      Enter your name:<h:inputText id="name" value="#{commandClient.name}"/>
      <h:commandButton value="Submit">
        <f:ajax listener="#{commandClient.updateMessage}" execute="@form" render="msg"/>
      </h:commandButton>
    </h:panelGrid>
      <h:messages id="msg"/>
    </h:form>
  </h:body>
</html>

CommandClient 是一个视图范围的托管 bean:

package x;

import java.io.Serializable;
import javax.ejb.EJB;
import javax.faces.application.FacesMessage;
import javax.faces.context.FacesContext;
import javax.faces.event.AjaxBehaviorEvent;
import javax.faces.view.ViewScoped;
import javax.inject.Named;

@Named
@ViewScoped
public class CommandClient implements Serializable
{
  private String name;

  @EJB
  private CommandMgr commandMgr;

  public String getName()
  {
    return name;
  }

  public void setName( String name_ )
  {
    name = name_;
  }

  public void updateMessage( AjaxBehaviorEvent event_ )
  {
    Command cmd = createHelloCommand();
    FacesMessage msg = new FacesMessage( (String) commandMgr.send( cmd ) );
    FacesContext.getCurrentInstance().addMessage( "name", msg );
  }

  protected Command createHelloCommand()
  {
    Command cmd = new Command( CommandType.HELLO.ordinal() );
    cmd.getParams().put( "name", name );
    return cmd;
  }

}