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

This is documentation on a preview feature.

Go

Dapr 提供了帮助开发 Go 可插拔组件的包。

前期准备

应用程序创建

创建一个可插拔组件始于一个空的Go应用程序。

mkdir example
cd component
go mod init example

导入 Dapr 包

导入 Dapr 可插拔组件 SDK 包。

go get github.com/dapr-sandbox/components-go-sdk@v0.1.0

创建 main 包

main.go 中,导入 Dapr 可插拔组件包并运行应用程序。

package main

import (
	dapr "github.com/dapr-sandbox/components-go-sdk"
)

func main() {
	dapr.MustRun()
}

这将创建一个没有组件的应用程序。 您需要实现并注册一个或多个组件。

实现和注册组件

在本地测试组件

创建 Dapr 组件的 socket 目录

Dapr通过在一个公共目录中使用Unix域套接字文件与可插拔组件进行通信。 默认情况下,Dapr和可插拔组件都使用/tmp/dapr-components-sockets目录。 如果该目录尚不存在,您应该创建该目录。

mkdir /tmp/dapr-components-sockets

启动可插拔组件

可插拔组件可以通过在命令行上启动应用程序进行测试。

要启动组件,在应用程序目录中执行以下操作:

go run main.go

配置 Dapr 以使用可插拔组件

要配置Dapr使用该组件,请在资源目录中创建一个组件YAML文件。 例如,对于一个状态存储组件:

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: <component name>
spec:
  type: state.<socket name>
  version: v1
  metadata:
  - name: key1
    value: value1
  - name: key2
    value: value2

任何metadata属性将在组件实例化时通过其Store.Init(metadata state.Metadata)方法传递给组件。

启动 Dapr

要启动 Dapr(以及可选地使用该服务的服务):

dapr run --app-id <app id> --resources-path <resources path> ...

此时,Dapr sidecar 将已经启动并通过 Unix Domain Socket 连接到组件。 然后你可以通过组件进行交互:

  • 通过使用组件的服务(如果已启动),或者
  • 通过直接使用 Dapr 的 HTTP 或 gRPC API

创建容器

可插拔组件被部署为容器,作为应用程序的 sidecar 运行(如 Dapr 本身)。 创建用于Go应用程序的Dockerfile的典型docker镜像可能如下所示:

FROM golang:1.20-alpine AS builder

WORKDIR /usr/src/app

# Download dependencies
COPY go.mod go.sum ./
RUN go mod download && go mod verify

# Build the application
COPY . .
RUN go build -v -o /usr/src/bin/app .

FROM alpine:latest

# Setup non-root user and permissions
RUN addgroup -S app && adduser -S app -G app
RUN mkdir /tmp/dapr-components-sockets && chown app /tmp/dapr-components-sockets

# Copy application to runtime image
COPY --from=builder --chown=app /usr/src/bin/app /app

USER app

CMD ["/app"]

构建镜像:

docker build -f Dockerfile -t <image name>:<tag> .

下一步