stop

停止使用本地测试服务器处理事件流

自 R2022b 起

此函数需要 Streaming Data Framework for MATLAB^® Production Server™ 和 MATLAB Compiler SDK™。

语法

stop(esp)

stop(esp) 停止使用本地测试服务器（MATLAB Production Server 的开发版本）处理事件流。从 start 函数启动的异步事件处理一直持续到处理器到达流的末尾或明确调用 stop 函数。

假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka^® 服务器，该服务器有一个主题 RecamanSequence。

还假设您有一个状态流处理分析函数 recamanSum 和初始化函数 initRecamanSum。

创建一个连接到 RecamanSequence 主题的 KafkaStream 对象。

ks = kafkaStream("kafka.host.com",9092,"RecamanSequence");

创建一个运行 recamanSum 函数的 EventStreamProcessor 对象。

esp = eventStreamProcessor(ks,@recamanSum,@initRecamanSum);

启动测试服务器，同时打开 Production Server Compiler (MATLAB Compiler SDK)。

startServer(esp);

要从应用程序启动测试服务器，点击 Test Client，然后单击 Start。有关如何使用该应用程序的示例，请参阅针对 MATLAB 测试客户端数据集成 (MATLAB Compiler SDK)。

导航回 MATLAB 命令提示符以开始处理事件。

start(esp);

在 Production Server Compiler 中，测试服务器接收数据。

从 MATLAB 命令提示符处，停止事件处理。

stop(esp);

然后，您可以使用 stopServer 功能或单击应用程序 UI 中的 Stop 来关闭服务器。

处理事件流的对象，指定为 EventStreamProcessor 对象。

在 R2022b 中推出