使用EJBContext getContextData – 这样安全吗?

我打算使用EJBContext将一些属性从应用程序层(特别是消息驱动的bean)传递给持久性生命周期回调,该回调无法直接注入或传递参数(EclipseLink中的会话侦听器,实体生命周期回调等) ,该回调是通过JNDI获取EJBContext

这似乎工作,但有任何隐藏的陷阱,如我缺少的线程安全或对象寿命? (假设传递的属性值是不可变的,如String或Long。)

示例bean代码

 @MessageDriven public class MDB implements MessageListener { private @Resource MessageDrivenContext context; public void onMessage(Message m) { context.getContextData().put("property", "value"); } } 

然后是使用EJBContext的回调

 public void callback() { InitialContext ic = new InitialContext(); EJBContext context = (EJBContext) ic.lookup("java:comp/EJBContext"); String value = (String) context.getContextData().get("property"); } 

我想知道的是,我可以确定contextData映射内容只对当前调用/线程可见吗? 换句话说,如果两个线程同时运行callback方法,并且都从JNDI查找EJBContext ,它们实际上获得了不同的contextData映射内容?

而且,这实际上是如何工作的 – 从JNDI查找返回的EJBContext最终是一个ThreadLocal的结构的包装器对象?

我认为一般来说,该方法的契约是启用拦截器+ webservice上下文和bean之间的通信。 因此, 只要没有创建新的调用上下文 ,上下文就应该可用于所有代码。 因此,它应该绝对是线程安全的。

EJB 3.1规范的第12.6节说明如下:

InvocationContext对象提供的元数据使拦截器方法能够控制调用链的行为。 上下文数据在单独的业务方法调用或生命周期回调事件中不可共享。 如果由于在Web服务端点上调用而调用拦截器,则getContextData返回的映射将是JAX-WS MessageContext

此外,getContextData方法在4.3.3中描述:

getContextData方法使业务方法,生命周期回调方法或超时方法能够检索与其调用关联的任何拦截器/ webservices上下文。

在实际实现方面,JBoss AS执行以下操作:

 public Map getContextData() { return CurrentInvocationContext.get().getContextData(); } 

CurrentInvocationContext使用基于线程本地链接列表的堆栈来弹出并推送当前调用上下文。

请参阅org.jboss.ejb3.context.CurrentInvocationContext 。 调用上下文只是懒惰地创建一个简单的HashMap ,就像在org.jboss.ejb3.interceptor.InvocationContextImpl中一样。

Glassfish做了类似的事情。 它还获得一个调用 ,并从调用管理器执行此操作,调用管理器还使用基于线程局部数组列表的堆栈来弹出并再次推送这些调用上下文。

GlassFish实现的JavaDoc在这里特别有趣:

此TLS变量存储ArrayList。 ArrayList包含ComponentInvocation对象,这些对象表示此线程上的调用堆栈。 对ArrayList的访问不需要同步,因为每个线程都有自己的ArrayList。

就像在JBoss AS中一样,GlassFish也懒得创建一个简单的HashMap ,在本例中是com.sun.ejb.EjbInvocation 。 对GlassFish案例感兴趣的是,Web服务连接更容易在源中发现。

我无法直接帮助您解决有关EJBContext的问题,因为在JEE6中添加了getContextData方法,但仍然没有太多关于它的文档。

但是,有另一种方法可以使用TransactionSynchronizationRegistry在EJB,拦截器和生命周期回调之间传递上下文数据。 概念和示例代码可以在Adam Bien的博客文章中找到。

javax.transaction.TransactionSynchronizationRegistry包含类似Map的结构,可用于在事务内传递状态。 它从旧的J2EE 1.4天开始就完美运行,并且与线程无关。

因为Interceptor在与ServiceFacade相同的事务中执行,所以甚至可以在@AroundInvoke方法中设置状态。 TransactionSynchronizationRegistry (TSR)可以直接注入到Interceptor中。

这里的示例使用@Resource注入来获取TransactionSynchronizationRegistry ,但也可以从InitialContext查找它,如下所示:

 public static TransactionSynchronizationRegistry lookupTransactionSynchronizationRegistry() throws NamingException { InitialContext ic = new InitialContext(); return (TransactionSynchronizationRegistry)ic.lookup("java:comp/TransactionSynchronizationRegistry"); }