指南：发布消息并订阅主题

了解如何使用一个服务向主题发送消息，并在另一个服务中订阅该主题

现在，你已了解 Dapr 发布/订阅构建块提供的功能，请了解它如何在你的服务中工作。下面的示例代码粗略地描述了一个使用两个服务处理订单的应用程序，每个服务都使用 Dapr sidecars：

使用 Dapr 订阅消息队列中主题的结帐服务。
使用 Dapr 向 RabbitMQ 发布消息的订单处理服务。

Dapr 将在符合 CloudEvents v1.0 的信封中自动包装用户有效负载，对 Content-Type 头值使用 datacontenttype 属性。了解更多关于使用CloudEvents的消息。

下面的示例演示了您的应用程序如何发布和订阅名为orders的主题。

注意

如果你还没有，请尝试使用发布/订阅快速入门快速了解如何使用发布/订阅。

设置发布/订阅组件

第一步是设置发布/订阅组件：

Self-Hosted (CLI)
Kubernetes

When you run dapr init, Dapr creates a default Redis pubsub.yaml and runs a Redis container on your local machine, located:

在Windows上，在 %UserProfile%\.dapr\components\pubsub.yaml
在Linux/MacOS上，在~/.dapr/components/pubsub.yaml

使用 pubsub.yaml 组件，您可以轻松更换底层组件而无需更改应用程序代码。在此示例中，我们使用 RabbitMQ。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: order-pub-sub
spec:
  type: pubsub.rabbitmq
  version: v1
  metadata:
  - name: host
    value: "amqp://localhost:5672"
  - name: durable
    value: "false"
  - name: deletedWhenUnused
    value: "false"
  - name: autoAck
    value: "false"
  - name: reconnectWait
    value: "0"
  - name: concurrency
    value: parallel
scopes:
  - orderprocessing
  - checkout

您可以通过创建一个包含该文件的组件目录（在此示例中为myComponents），并在使用dapr run命令行界面时使用--resources-path标志，来使用另一个pubsub component来覆盖此文件。

Dotnet
Java
Python
Go
Javascript

dapr run --app-id myapp --resources-path ./myComponents -- dotnet run

dapr run --app-id myapp --resources-path ./myComponents -- mvn spring-boot:run

dapr run --app-id myapp --resources-path ./myComponents -- python3 app.py

dapr run --app-id myapp --resources-path ./myComponents -- go run app.go

dapr run --app-id myapp --resources-path ./myComponents -- npm start

To deploy this into a Kubernetes cluster, fill in the metadata connection details of the pub/sub component in the YAML below, save as pubsub.yaml, and run kubectl apply -f pubsub.yaml.

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: order-pub-sub
spec:
  type: pubsub.rabbitmq
  version: v1
  metadata:
  - name: connectionString
    value: "amqp://localhost:5672"
  - name: protocol
    value: amqp  
  - name: hostname
    value: localhost 
  - name: username
    value: username
  - name: password
    value: password 
  - name: durable
    value: "false"
  - name: deletedWhenUnused
    value: "false"
  - name: autoAck
    value: "false"
  - name: reconnectWait
    value: "0"
  - name: concurrency
    value: parallel
scopes:
  - orderprocessing
  - checkout

订阅主题

Dapr 允许您的应用程序有两种方法来订阅 topics：

声明，其中订阅是在外部文件中定义的。
编程式，订阅在用户代码中定义。

详细了解声明式和程序化订阅方法文档。这个示例演示了一个声明式订阅。

创建一个名为subscription.yaml的文件，并粘贴以下内容：

apiVersion: dapr.io/v2alpha1
kind: Subscription
metadata:
  name: order-pub-sub
spec:
  topic: orders
  routes: 
    default: /checkout
  pubsubname: order-pub-sub
scopes:
- orderprocessing
- checkout

上面的示例显示了对主题 orders 的事件订阅，用于 pubsub 组件 order-pub-sub。

route字段告诉Dapr将所有主题消息发送到应用程序中的/checkout端点。
scopes 字段使得此订阅适用于具有 orderprocessing 和 checkout 的应用程序。

将 subscription.yaml 放在与你的 pubsub.yaml 组件相同的目录中。当 Dapr 启动时，它将加载组件和订阅。

下面是利用 Dapr SDK 订阅你在 subscription.yaml 中定义的主题的代码示例。

Dotnet
Java
Python
Go
JavaScript

//dependencies 
using System.Collections.Generic;
using System.Threading.Tasks;
using System;
using Microsoft.AspNetCore.Mvc;
using Dapr;
using Dapr.Client;
//code
namespace CheckoutService.controller
{
    [ApiController]
    public class CheckoutServiceController : Controller
    {
         //Subscribe to a topic 
        [Topic("order-pub-sub", "orders")]
        [HttpPost("checkout")]
        public void getCheckout([FromBody] int orderId)
        {
            Console.WriteLine("Subscriber received : " + orderId);
        }
    }
}