本页采用了机器翻译。点击此处可查看最新英文版本。

start

开始使用本地测试服务器处理事件流

自 R2022b 起

全页折叠

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

    语法

    start(esp)
    start(esp,port,host)

    说明

    start(esp) 开始使用在默认主机名 localhost 和端口号 9910 上运行的本地测试服务器（MATLAB Production Server 的开发版本）处理事件流。从 start 函数启动的异步事件处理一直持续到处理器到达流的末尾或者您明确调用 stop。

    注意

    在使用 start 开始事件处理之前，您必须使用 startServer 启动本地测试服务器。

    示例

    start(esp,port,host) 指定本地测试服务器正在运行的计算机的端口号和主机名。

    示例

    全部折叠

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

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

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

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

    创建一个运行 EventStreamProcessor 函数并由 recamanSum 函数初始化的 initRecamanSum 对象。

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

    启动本地测试服务器，同时打开 Production Server 存档编译器 (MATLAB Compiler SDK)。

    startServer(esp);

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

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

    start(esp);

    在 Production Server 存档编译器中，测试服务器接收数据。

    完成事件处理的测试后，使用 stop 函数停止事件处理，使用 stopServer 函数关闭服务器。

    输入参数

    全部折叠

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

    测试服务器运行的端口号，指定为 [0, 65,535] 范围内的整数。

    示例: 9920

    运行本地测试服务器的计算机的主机名，指定为字符串或字符向量。

    示例: '144.213.5.7' 或 'localhost'

    数据类型: string | char

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | | |

    主题