RabbitMQ - 訂閱者應用程式

現在讓我們建立一個訂閱者應用程式，其將從 RabbitMQ 主題接收訊息。

建立專案

使用 eclipse，選擇檔案 → 新建 → Maven 專案。選中建立簡單專案（跳過原型選擇）並單擊下一步。

輸入詳細資訊，如下所示 −

• groupId − com.tutorialspoint

• artifactId − subscriber

• version − 0.0.1-SNAPSHOT

• name − RabbitMQ 訂閱者

單擊“完成”按鈕，一個新專案將被建立。

pom.xml

現在更新 pom.xml 的內容以包含 RabbitMQ 的依賴項。

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.tutorialspoint.activemq</groupId>
   <artifactId>subscriber</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <name>RabbitMQ Subscriber</name>
   <dependencies>
      <dependency>
         <groupId>com.rabbitmq</groupId>
         <artifactId>amqp-client</artifactId>
         <version>5.14.2</version>
      </dependency>
      <dependency>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-api</artifactId>
         <version>1.7.26</version>
      </dependency>
      <dependency>
         <groupId>org.slf4j</groupId>
         <artifactId>slf4j-simple</artifactId>
         <version>1.7.26</version>
      </dependency>
   </dependencies>  
</project>

現在建立一個訂閱者類，該類將從 RabbitMQ 佇列接收訊息。

package com.tutorialspoint.rabbitmq;

import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;

public class Subscriber {
   private static String EXCHANGE = "MyExchange";
   public static void main(String[] args) throws IOException, TimeoutException {
      ConnectionFactory factory = new ConnectionFactory();
      factory.setHost("localhost");
      Connection connection = factory.newConnection();
      Channel channel = connection.createChannel();
      channel.exchangeDeclare(EXCHANGE, "fanout");

      String queueName = channel.queueDeclare().getQueue();
      channel.queueBind(queueName, EXCHANGE, "");
      System.out.println("Waiting for messages. To exit press CTRL+C");

      DeliverCallback deliverCallback = (consumerTag, delivery) -> {
         String message = new String(delivery.getBody(), StandardCharsets.UTF_8);
         System.out.println("Received '" + message + "'");
      };
      channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
   }
}

訂閱者類建立一個連線、建立一條通道、宣告交換、建立一個隨機佇列並將其與交換繫結，然後從主題接收訊息（如果有的話）。按 Ctrl + C 終止，否則它將不斷輪詢佇列以查詢訊息。

我們將在RabbitMQ - 測試應用程式一章中多次執行此應用程式以建立多個訂閱者。