Java NATS 连接监听器：消费消息指南

在 Java 中使用 NATS 连接监听器 (ConnectionListener) 来消费数据，你需要先创建一个 NATS 连接，并注册一个连接监听器，然后在监听器的回调方法中处理接收到的消息。

以下是一个简单的示例代码：

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

public class Consumer {

    public static void main(String[] args) {
        try {
            // 创建 NATS 连接
            Connection nc = Nats.connect();

            // 注册连接监听器
            nc.setConnectionListener(new ConnectionListener() {
                @Override
                public void connectionEvent(Connection conn, Events event) {
                    if (event == Events.CONNECTED) {
                        System.out.println('已连接到 NATS 服务器');
                    } else if (event == Events.DISCONNECTED) {
                        System.out.println('已断开与 NATS 服务器的连接');
                    } else if (event == Events.RECONNECTED) {
                        System.out.println('已重新连接到 NATS 服务器');
                    }
                }
            });

            // 订阅主题并处理消息
            nc.subscribe('topic', message -> {
                String receivedData = new String(message.getData());
                System.out.println('接收到消息：' + receivedData);
            });

            // 阻塞程序，等待消息
            nc.flush(Duration.ZERO);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

在上面的示例中，我们首先创建了一个 NATS 连接，并注册了一个连接监听器。然后，我们订阅了一个主题 ('topic')，并在回调方法中处理接收到的消息。最后，我们使用 nc.flush(Duration.ZERO) 方法阻塞程序，等待消息的到来。

你可以根据自己的实际需求修改代码，并根据需要处理连接事件和消息数据。