,Dapr 是一个可移植的、事件驱动的运行时，它使任何开发人员能够轻松构建出弹性的、无状态和有状态的应用程序，并可运行在云平台或边缘计算中，它同时也支持多种编程语言和开发框架。,Dapr 官网：dapr.io/,首先，我们将创建我们的项目根文件夹来托管我们将在后续步骤中创建的所有服务。,由于我们将创建多个服务，我们将使用
docker-compose 来运行这些服务。,让我们在项目的根文件夹中创建
docker-compose.yml 文件,
Dapr placement 服务将负责管理
Dapr actors（我们的服务）之间的所有通信。,简单来说，它负责将所有通信路由到假设接收通信的相应
actor。它充当
message broker(消息代理)。,让我们继续通过添加我们的
Redis 服务来修改我们的
docker-compose.yml 文件。,将以下代码添加到
docker-compose.yml 的服务部分：,创建一个
dapr/components 文件夹。然后创建组件文件
redis-pubsub.yaml。,然后打开文件并插入我们的
Dapr pub/sub 组件的详细信息,
redisHost 是我们的
Redis 服务
redis-pub 的名称，默认
Redis 端口为
6379。,正如前面部分反复提到的，服务直接与
Dapr 通信，而不是直接与其他服务通信。
Dapr 充当所有服务的中间人。,服务通过它们自己的
Dapr sidecar 直接与
Dapr 通信，
Dapr sidecar 将通信传递给
Dapr placement，该
placement 再次将其传递给假设接收通信的服务的
Dapr sidecar。,将
redis-dapr-sidecar 服务添加到我们的
docker-compose.yml,在这里，我们使用
app-id 将
Dapr sidecar 分配给
redis-publisher，同时我们使用
redis 端口
6379。,我们还必须将 dapr/components(redis-pubsub.yaml) 文件夹挂载到
docker 容器中。,不要忘记声明
dapr-http-port。这是我们的
Dapr sidecar 的
api，允许我们调用各种
HTTP 方法。,定义您的
dapr-http-port 很重要，因为您将在此处调用各种 HTTP 调用/方法/请求。,最后，注意将
redis-dapr-sidecar 附加到
redis-publisher 网络命名空间。,我们将使用
NestJS 作为我们的
node server 作为我们的 Redis subscriber(订阅者)。,进入到项目文件夹,然后执行以下命令设置一个
NestJS node server:,对于这个项目，我们将选择
yarn 作为包管理器。,接下来，我们将设置一个
post API 端点。
Dapr 将调用这个端点，一旦它收到我们的
Redis 服务发布，它就被调用。,转到 nest-subscriber/src/app.controller.ts,将此文件中的代码替换为以下内容：,我们将
NestJS 服务器作为
Docker 容器运行。需要创建一个
Dockerfile。,然后打开文件并粘贴以下代码：,构建镜像：,在创建了我们的
NestJS 服务器和
Dockerfile 之后，我们创建了
nest-subscriber docker 服务。,将以下内容添加到
docker-compose.yml：,我们将为我们的
pub/sub 订阅定义配置。,创建一个
dapr/subscriptions 文件夹。然后创建组件文件
redis-subscription.yaml,然后打开文件并插入我们的
Dapr 订阅组件的详细信息,路由是发布
topic 时
Dapr 将调用的
API,
scope 是订阅该
topic 的服务。,
pubsubname 是 redis-pubsub，它等于我们的
redis-pubsub.yaml 文件中定义的元数据名称。,在这个项目中，如果发布了一个 topic
nest-redis-pub-topic，Dapr 将在我们的
nest-subscriber 服务中调用 API
/redis-publisher。,我们需要为我们的
NestJS 服务创建一个
sidecar，就像
redis-publisher 服务一样。,将
nest-subscriber-dapr-sidecar 服务添加到我们的
docker-compose.yml,通常
Dapr Docker 容器会在
Docker 网络中进行通信。,但是为了我们做测试，我们将打开映射暴露端口
5000 到我们的本地机器
5001。,然后在您的终端中执行以下命令：,
Dapr 的优点之一是它遵循特定的
URL 格式。这里我们只使用 Dapr sidecar HTTP 端口（5001），然后是版本号（v1.0），然后是 action（publish）。然后是我们 redis-pubsub.yaml 配置文件中定义的
pubsubname（
redis-pubsub）和
topic（nest-redis-pub-topic）。,一旦发出
HTTP post 请求。我们的
NestJS 服务器应该在 /redis-publisher 收到一个
post 请求，这将导致以下日志：,
,我们可以看到它正在通过
Dapr 接收
Redis 发布。但是我们的
NestJS 服务器无法正确处理消息。,只有
{} 被发布，而不是我们发布的消息。,我们将在下一步中解决这个问题。,注意：我们通过 redis-dapr-sidecar 的 dapr-http-port 调用发布服务。通常会有一个单独的
Docker 服务（例如另一个服务器），它有自己的
Dapr sidecar，它将调用
redis 发布服务。 在这种情况下，我们将使用该
Docker 服务的 Dapr sidecar http-port。该请求将由
sidecar 发送到
Dapr placement 服务，然后该服务将确定将请求转发到的正确
Dapr sidecar。,我们的 nest-subscriber-dapr-sidecar 向我们的
nest-subscriber 服务器发出的
post 请求的
Content-Type 将是 application/cloudevents+json 而不是
application/json,目前我们的
NestJS 服务器无法解析 application/cloudevents+json。,为了解决这个问题，我们首先需要安装
body-parser：,接下来我们需要修改我们的
NestJS 服务器
main.ts：,当我们再次发送
post 请求时，我们的
NestJS 服务器将能够处理请求正文并显示以下日志：,好了，我们现在有一个基于
Dapr 工作的
Redis Pub/Sub 分布式应用。,源码 github.com/Hacker-Linn…,以上就是Docker Compose+Nestjs构建Dapr Redis发布订阅分布式应用的详细内容，更多关于Docker Nestjs构建Redis分布式的资料请关注其它相关文章！
