停止

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

折叠所有页面

这个函数需要流数据框架的MATLAB^®生产服务器™而且MATLAB编译SDK™．

语法

停止(esp)

停止(esp）的开发版本，停止使用本地测试服务器处理事件流MATLAB制作服务器)．异步事件处理开始于开始函数继续执行，直到处理器到达流的末尾或显式调用停止函数。

假设你有一个卡夫卡^®服务器在网络地址上运行kafka.host.com: 9092有一个主题RecamanSequence．

还假设您有一个有状态流分析函数recamanSum初始化函数initRecamanSum．

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

k = kafkaStream(“kafka.host.com”, 9092,“RecamanSequence”）;

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

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

启动测试服务器，这还将打开生产服务器编译器(MATLAB编译器SDK)应用程序。

startServer (esp);

若要从应用程序启动测试服务器，请单击测试客户端然后开始．有关如何使用该应用程序的示例，请参见用MATLAB测试客户端数据集成(MATLAB编译器SDK)．

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

开始(esp);

在生产服务器编译器App，测试服务器接收数据。

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

停止(esp);

命令关闭服务器stopServer功能或按停止在应用程序界面。

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

R2022b中引入