如何从服务器中运行的线程触发CDI事件？

Question

我希望运行在线程中的udp服务器在每次接收到数据报时都会触发一个事件，并发送格式为json的数据。

    public class UDPServer extends Thread {

        private SocketUDPCommunication comm;

        @Inject @Notify
        private StatusChangeHandler sch;

        public UDPServer() {
            comm = new SocketUDPCommunication();
        }


        @Override
        public void run() {

            DatagramPacket response;

            comm.setPort(Utils.UDP_SERVER_PORT);
            comm.createSocket();

            while (!Thread.currentThread().isInterrupted()) {
                System.out.println("Waiting for clients to connect on port:" + comm.getSocket().getLocalPort());
                try {
                    response = comm.receiveResponse();
                } catch (SocketTimeoutException e) {
                    continue;
                }                           

                byte[] byteSend = comm.discardOffset(response);

                Status status = frameToJson(byteSend);

                Genson genson = new Genson();
                String json = genson.serialize(status);

                sch.sendChangedStatus(json);    //Raise the cdi event, sch not initialized!!
            }

        }

        @Override
        public void interrupt() {
            super.interrupt();
            comm.closeConnection();
        }
    }

已为此事件定义了一个侦听器，它将调用websocketendpoint方法向所有连接的客户端广播此消息：

    public class StatusChangeObserver {

        public void statusChanged(@Observes StatusChange sce) {
            WebsocketEndPoint.sendAll(sce.getJson());
        }
    }

    @ServerEndpoint(value="/websocket")
    public class WebsocketEndPoint {
        private static Set<Session> userSessions = Collections.synchronizedSet(new HashSet<Session>());

        @OnOpen
        public void onOpen(Session userSession) {
            System.out.println("Opening new connection");
            userSessions.add(userSession);
        }

        @OnClose
        public void onClose(Session userSession) {
            System.out.println("Connection closed. Id: " + userSession.getId());
            userSessions.remove(userSession);
        }


        public static void sendAll(String message) {
            for (Session session : userSessions) {
                if (session.isOpen()) {
                    session.getAsyncRemote().sendText(message);
                }
            }     
        }
    }

以及实际触发事件的处理程序：

    @Notify
    public class StatusChangeHandler {

        @Inject
        private Event<StatusChange> statusChangedEvent;

        public void sendChangedStatus(String json) {
            StatusChange sce = new StatusChange(json);
            statusChangedEvent.fire(sce);
        }
    }

StatusChange是一个简单的POJO，其中包含要广播的消息。@Notify限定符：

    @Qualifier
    @Retention(RUNTIME)
    @Target({METHOD, FIELD, PARAMETER, TYPE})
    public @interface Notify {
    }

这些是依赖项注入的第一步，因此我不太确定应该如何从线程内触发事件，以及如何初始化sch对象。我发现这个页面建议使用Weld和WeldContainer类来初始化CDI，但我无法在maven中找到这个类。这是正确的方法吗？在这种情况下，有人知道如何将这些类包含到我的项目中吗？

Answer 1

因为您使用的是Tomcat，所以我们讨论的是servlet环境。为此，Weld提供了一个servlet JAR，它将自动为您引导CDI。无需手动处理焊接/焊接容器。

这里有一个到Weld文档的链接，它解释了您需要的工件/依赖项以及如何使用它。

添加这些之后，CDI应该在您将应用程序部署到Tomcat时为您简单地引导。

Answer 2

这里有一个带有weld库的公共存储库。

https://mvnrepository.com/artifact/org.jboss.weld

但是，你需要什么？在什么环境下你会使用它？例如，在wildfly中，集成了cdi 1.1或cdi 1.2，您无需添加此库。

有关更多信息，请使用http://weld.cdi-spec.org/