The documentation you are viewing is for Dapr v1.15 which is an older version of Dapr. For up-to-date documentation, see the latest version.

如何：发布消息并订阅主题

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

既然您已经了解了Dapr pubsub构建块的功能，接下来我们来看看如何在您的服务中应用它。下面的代码示例描述了一个使用两个服务处理订单的应用程序，每个服务都有Dapr sidecar：

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

Dapr会自动将用户的负载封装在符合CloudEvents v1.0的格式中，并使用Content-Type头的值作为datacontenttype属性。了解更多关于CloudEvents的消息。

以下示例展示了如何在您的应用程序中发布和订阅名为orders的主题。

注意

如果您还没有，请尝试pubsub快速入门，快速了解如何使用pubsub。

设置Pub/Sub组件

第一步是设置pubsub组件：

Self-Hosted (CLI)
Kubernetes

当您运行dapr init时，Dapr会创建一个默认的Redis pubsub.yaml并在您的本地机器上运行一个Redis容器，位置如下：

在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 CLI命令的--resources-path标志来覆盖此文件。

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

要将其部署到Kubernetes集群中，请填写以下YAML中的pub/sub组件的metadata连接详细信息，保存为pubsub.yaml，然后运行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提供了三种方法来订阅主题：

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

在声明式、流式和编程式订阅文档中了解更多信息。此示例演示了声明式订阅。

创建一个名为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字段指定此订阅适用于ID为orderprocessing和checkout的应用程序。

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

注意

此功能目前处于预览阶段。 Dapr可以实现“热重载”声明式订阅，从而在不需要重启的情况下自动拾取更新。这通过HotReload功能门启用。为了防止重新处理或丢失未处理的消息，在Dapr和您的应用程序之间的飞行消息在热重载事件期间不受影响。

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

//依赖项 
using System.Collections.Generic;
using System.Threading.Tasks;
using System;
using Microsoft.AspNetCore.Mvc;
using Dapr;
using Dapr.Client;

//代码
namespace CheckoutService.controller
{
    [ApiController]
    public class CheckoutServiceController : Controller
    {
         //订阅一个主题 
        [Topic("order-pub-sub", "orders")]
        [HttpPost("checkout")]
        public void getCheckout([FromBody] int orderId)
        {
            Console.WriteLine("订阅者接收到 : " + orderId);
        }
    }
}