php cdi
考虑尝试一个简单的Java EE 7原型应用程序,该应用程序涉及JAX-RS(REST),WebSockets和CDI。
注意 :不想让它成为破坏者-但本文主要讨论我在尝试使用Web套接字和使用CDI作为“胶水”(在Java EE应用程序中)使用REST时遇到的问题。 整合并未实现,但是仍然吸取了一些教训:-)
这个想法是使用REST端点作为Web套接字端点的“提要”,从而将数据“推送”到所有连接的客户端:
- JAX-RS端点,它从其他来源接收数据(可能是实时的)作为Web套接字端点的输入
- 将CDI事件用作黑白JAX-RS和WebSocket端点的粘合点,并“触发”有效载荷
@Path("/feed") public class RESTFeed {@InjectEvent<String> event;@POST@Consumes(MediaType.TEXT_PLAIN)public void push(String msg) {event.fire(msg);} }
- 在WebSocket端点实现中使用CDI Observer方法将数据推送到连接的客户端:
public void onMsg(@Observes String msg) {//different WS enpoint instance - notice the hash code value in the server logSystem.out.println("WS End point class ID -- " + this.hashCode());try {client.getBasicRemote().sendText(msg);} catch (IOException ex) {Logger.getLogger(ServerEndpoint.class.getName()).log(Level.SEVERE, null, ex);} }
当然,目前还没有考虑到更详细的信息,例如性能,异步通信等。 更多实验
但这有可能吗?
这是我执行的步骤
- 部署代码
- 浏览到http:// localhost:8080 / Explore-WebSocket-CDI-Integration-Maven /并作为Web套接字客户端连接
- 使用Postman在REST端点上触发HTTP POST请求
繁荣! Observer方法中的NullPointerException –我等待了几秒钟,然后现实击中了我!
根本原因(据我了解)
- WebSocket端点的行为
WebSocket端点与JAX-RS资源类相似,因为每个连接的客户端都有一个Web套接字端点类的实例(至少默认情况下)。 WebSocket规范中明确提到了这一点。 客户端(对等方)连接后,就会创建一个唯一的实例,并且可以安全地将Web套接字会话对象(对等方的表示形式)作为实例变量进行缓存。 IMO,这是一个简单干净的编程模型
- 但是CDI容器还有其他计划!
REST端点一旦触发CDI事件(响应POST请求),CDI容器就会创建WebSocket终结点(在本例中为CDI Observer)的其他实例。 为什么? 因为CDI bean本质上是上下文相关的 。 该应用程序不控制CDI bean的实例。 它只是使用它们(通过@Inject)。 由容器决定创建和销毁bean实例,并确保在相同上下文中执行的bean可以使用适当的实例。 容器如何确定上下文呢? 通过范围 -应用程序,会话,请求等…..
(再次,在CDI规范中明确提到)
因此,问题的要点是没有WebSocket终结点当前上下文的实例–因此,CDI将创建一个新实例以传递消息。 当然,这意味着实例变量将指向null,因此将指向NPE(Duh!)
。
WebSocket端点将使用哪个CDI范围? 我尝试了@ ApplicationScoped,@ SessionScoped和@RequestScoped却没有太多运气–仍然是一个新实例和一个NPE
还有其他选择吗?
- 将会话集定义为静态变量将达到目的:
private static Set<Session> peers = Collections.synchronizedSet(new HashSet());
但是,如果只是需要在观察者方法中处理特定于客户端的状态(只能作为实例变量处理),则IMO只是一种黑客手段,因此不可行–它势必会保持未初始化的状态。
- 服务器发送事件 ? 但最终,SSE!= WebSocket。 如果用例要求服务器端仅“推送”,则可以选择。 SSE尚不是Java EE标准-Java EE 8可能使之成为可能
解决方法
我不是专家,但是我想这取决于WebSocket规范,以便更清楚地说明如何将其与CDI结合使用。 鉴于CDI是Java EE规范中必不可少的一部分,因此将其与其他规范(特别是以HTML5为中心的规范,例如JAX-RS,WebSocket等)进行无缝集成非常重要。
Bruno Borges的这篇文章链接了与JMS,CDI和WebSocket有关的类似问题以及它们如何相互集成。
我错过了明显的事情吗? 您有任何意见/解决方案吗? 请随时鸣叫! :-)
示例代码在GitHub上可用 (如果您想看一看)。 我在GlassFish 4.1和Wildfly 8.2.0上尝试过
我想现在就这些了。 :-)
干杯!
翻译自: https://www.javacodegeeks.com/2015/02/integrating-cdi-websockets.html
php cdi