如何在Dapr PubSub中为RabbitMQ配置Quorum Queue

要让Dapr的RabbitMQ PubSub组件创建Quorum类型队列，只需修改PubSub组件的YAML配置，添加队列类型指定参数即可，具体步骤如下：

1. 修改PubSub组件配置
   打开你的RabbitMQ PubSub组件配置文件（对应你提供的PubSub组件截图），在metadata节点中添加queueType字段并设置值为quorum：

   apiVersion: dapr.io/v1alpha1
   kind: Component
   metadata:
     name: <你的组件名称>
   spec:
     type: pubsub.rabbitmq
     version: v1
     metadata:
     - name: host
       value: "amqp://localhost:5672"
     - name: username
       value: "guest"
     - name: password
       value: "guest"
     - name: queueType
       value: "quorum" # 指定创建Quorum类型队列
   

   若需要额外自定义队列参数，也可通过queueArguments字段传入RabbitMQ原生参数：

   - name: queueArguments
     value: |
       {
         "x-queue-type": "quorum"
       }
   

2. 清理已有Classic队列
   删除RabbitMQ中已存在的对应Classic队列（对应你提供的RabbitMQ队列截图），否则Dapr会复用已存在的队列，不会重新创建Quorum类型队列。

3. 重启Dapr应用
   使用你原有的启动命令重新运行应用：

   dapr run --app-id TestApi --components-path LocalPath  --app-port 5074 dotnet run
   

相关截图参考 #

• 现有PubSub组件配置：
  
• 现有订阅组件配置：
  
• RabbitMQ中已创建的Classic队列：
  

内容的提问来源于stack exchange，提问作者Varun Tiwari