消息中间件nats java 客户端消费

要使用Java客户端消费NATS消息中间件，您需要使用NATS Java客户端库。以下是使用NATS Java客户端消费消息的基本步骤：

1. 在您的Java项目中添加NATS Java客户端库的依赖。您可以在Maven或Gradle配置文件中添加以下依赖项：

   Maven:

   <dependency>
       <groupId>io.nats</groupId>
       <artifactId>nats-client</artifactId>
       <version>2.11.0</version>
   </dependency>
   

   Gradle:

   implementation 'io.nats:nats-client:2.11.0'
   

2. 在代码中导入相关类：

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

3. 创建NATS连接并订阅消息：

   Options options = new Options.Builder().server("nats://localhost:4222").build();
   Connection connection = Nats.connect(options);
   
   Dispatcher dispatcher = connection.createDispatcher((msg) -> {
       // 处理收到的消息
       System.out.println("Received message: " + new String(msg.getData()));
   });
   
   // 订阅消息
   dispatcher.subscribe("subject");
   

4. 在需要的时候关闭连接：

   connection.close();
   

以上代码将在nats://localhost:4222上创建一个NATS连接，并订阅名为"subject"的消息。当收到消息时，将打印消息内容。

请确保替换nats://localhost:4222为您的NATS服务器的地址和端口，以及根据您的实际需求进行其他自定义设置。

有关更多详细信息和示例，请参阅NATS Java客户端库的文档：https://github.com/nats-io/nats.jav