啟用事件流后，會有30秒~60秒的延遲時間，您可以在事件流頁面的狀態欄查看啟動進度。

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.5.0</version> <!-- 支持開源所有版本 -->
</dependency>

import com.rabbitmq.client.*;
import java.io.IOException;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;
import java.util.HashMap;
import java.util.UUID;

public class ProducerTest {
    public static void main(String[] args) throws IOException, TimeoutException {
        ConnectionFactory factory = new ConnectionFactory();
        // 設置接入點，在消息隊列RabbitMQ版控制臺實例詳情頁面查看。
        factory.setHost("xxx.xxx.aliyuncs.com");
        // 用戶名，在消息隊列RabbitMQ版控制臺靜態用戶名密碼頁面查看。
        factory.setUsername("${UserName}");
        // 密碼，在消息隊列RabbitMQ版控制臺靜態用戶名密碼頁面查看。
        factory.setPassword("${PassWord}");
        //設置為true,開啟Connection自動恢復功能；設置為false,關閉Connection自動恢復功能。
        factory.setAutomaticRecoveryEnabled(true);
        factory.setNetworkRecoveryInterval(5000);
        // 設置Vhost名稱，請確保已在消息隊列RabbitMQ版控制臺上創建完成。
        factory.setVirtualHost("${VhostName}");
        // 默認端口，非加密端口5672，加密端口5671。
        factory.setPort(5672);
        // 基于網絡環境合理設置超時時間。
        factory.setConnectionTimeout(30 * 1000);
        factory.setHandshakeTimeout(30 * 1000);
        factory.setShutdownTimeout(0);
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();        
        channel.exchangeDeclare("${ExchangeName}", "${ExchangeType}", true, false, false, null);
        channel.queueDeclare("${QueueName}", true, false, false, new HashMap<String, Object>());
        channel.queueBind("${QueueName}", "${ExchangeName}", "${BindingKey}");
        // 開始發送消息。
        for (int i = 0; i < 100; i++  ) {
            // ${ExchangeName}必須在消息隊列RabbitMQ版控制臺上已存在，并且Exchange的類型與控制臺上的類型一致。
            // BindingKey根據業務需求填入相應的BindingKey。
            AMQP.BasicProperties props = new AMQP.BasicProperties.Builder().messageId(UUID.randomUUID().toString()).build();
            channel.basicPublish("${ExchangeName}", "${BindingKey}", true, props,
                    ("消息發送Body"  + i).getBytes(StandardCharsets.UTF_8));
        }
        connection.close();
    }
}