无法通过 EsperIOSocketAdapter 接收事件

Question

我试图通过套接字将事件发送到 Esper 引擎，但遇到了一些问题。

我已经配置了 EsperIOSocketAdapter 属性，当调用 EsperIOSocketAdapter.start() 方法时，它会启动一个新的守护线程，该线程将侦听客户端，但在套接字客户端实际尝试连接之前，守护线程会随着父线程退出而退出。

我的代码片段如下：

            ConfigurationSocketAdapter adapterConfig = new ConfigurationSocketAdapter();

            SocketConfig socket = new SocketConfig();
            socket.setDataType(DataType.CSV);
            socket.setPort(6789);
            adapterConfig.getSockets().put("CourseSocket", socket);


            EsperIOSocketAdapter socketAdapter = new EsperIOSocketAdapter (adapterConfig, "CourseSocket");
            socketAdapter.start();

另一个疑问是在没有使用 SocketAdapter 的程序中，我曾经通过代码

EPRuntime.sendEvent(new TestEvent(event)); 发送事件；

使用 SocketAdapter 时，我应该使用 sendEvent() ，否则事件将自动推送到引擎中。

Answer 1

您的套接字问题似乎具有一般性，其中 JVM 正在终止，因为您没有运行任何非守护线程。将父线程（或套接字线程）设置为非守护线程，JVM 将不会终止。 （确保您实际上可以停止线程，否则您的 JVM 将顽固地关闭:)）

当您使用 SocketAdapter 时，您的“发送客户端”对于物理 EPRuntime 是远程的，但您使用远程套接字通过 EPRuntime 发送事件。套接字，如 文档。