Java Nats 持续消费：使用 createDispatcher 创建调度器

在 Java Nats 中，可以使用 'createDispatcher' 方法来创建一个持续消费的调度器。该调度器将订阅一个主题，并持续消费接收到的消息。

以下是一个示例代码：

import io.nats.client.Connection;
import io.nats.client.Dispatcher;
import io.nats.client.Message;
import io.nats.client.Nats;

public class NatsConsumer {
    public static void main(String[] args) {
        try {
            // 连接到Nats服务器
            Connection nc = Nats.connect();

            // 创建一个调度器
            Dispatcher d = nc.createDispatcher((msg) -> {
                // 处理接收到的消息
                System.out.println('Received message: ' + new String(msg.getData()));
            });

            // 订阅主题
            d.subscribe('my-topic');

            // 开始消费
            d.start();

            // 保持程序运行，直到按下Ctrl+C
            Thread.sleep(Integer.MAX_VALUE);

            // 关闭连接
            nc.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在上面的代码中，我们首先建立与 Nats 服务器的连接。然后，我们创建一个调度器，并通过 lambda 表达式指定消息处理逻辑。在这个例子中，我们只是简单地打印接收到的消息。

然后，我们订阅一个名为 'my-topic' 的主题，并通过调用 start 方法开始消费。start 方法将启动一个新线程来处理消息。

最后，我们通过调用 Thread.sleep 方法来保持程序运行，直到按下 Ctrl+C。在程序退出之前，我们需要调用 nc.close 方法来关闭与 Nats 服务器的连接。

通过这种方式，我们可以创建一个持续消费的调度器，并在接收到消息时执行自定义的处理逻辑。