我是第一次尝试 Dapr ......参考https://github.com/dapr/go-sdk上的 Dapr go sdk ......
...尝试在我的 Windows 10 机器上使用带有 Docker Compose 的 golang 托管 Dapr 服务 - 使用 VSCode - 并在连接到该服务时遇到问题。
我将 docker compose 文件设置为进行如下简单配置。并尝试使用 curl 通过 Dapr API 连接到服务
golang 服务（taskapi 服务）=> Dapr SideCar（taskapidapr）
我基于https://github.com/dapr/go-sdk/blob/main/example/Makefile中的示例，但使用 Docker Compose。
当我尝试使用连接连接到服务时
curl -d "ping" -H "内容类型：text/plain;charset=UTF-8" "http://localhost:8300/v1.0/invoke/taskapi/method/echo"
我遇到了以下错误。
{"errorCode":"ERR_DIRECT_INVOKE","message":"调用 API 未准备好"}
Docker 中的 Dapr 日志显示“没有要刷新的 mDNS 应用程序”。- 不知道这是否是它的原因以及如何处理它。
任何人都可以指出我所缺少的 - 非常感谢。
谢谢
- 阿萨杜
golang 包
package main
import (
"context"
"errors"
"fmt"
"log"
"net/http"
"github.com/dapr/go-sdk/service/common"
daprd "github.com/dapr/go-sdk/service/http"
)
func main() {
port := "8085"
address := fmt.Sprintf(":%s", port)
log.Printf("Creating New service at %v port", address)
log.Println()
// create a Dapr service (e.g. ":8080", "0.0.0.0:8080", "10.1.1.1:8080" )
s := daprd.NewService(address)
// add a service to service invocation handler
if err := s.AddServiceInvocationHandler("/echo", echoHandler); err != nil {
log.Fatalf("error adding invocation handler: %v", err)
}
if err := s.Start(); err != nil && err != http.ErrServerClosed {
log.Fatalf("error listenning: %v", err)
}
}
func echoHandler(ctx context.Context, in *common.InvocationEvent) (out *common.Content, err error) {
if in == nil {
err = errors.New("invocation parameter required")
return
}
log.Printf(
"echo - ContentType:%s, Verb:%s, QueryString:%s, %s",
in.ContentType, in.Verb, in.QueryString, in.Data,
)
out = &common.Content{
Data: in.Data,
ContentType: in.ContentType,
DataTypeURL: in.DataTypeURL,
}
return
}
码头工人-compose.yml
version: "3"
services:
taskapi:
image: golang:1.16
volumes:
- ..:/go/src/lekha
working_dir: /go/src/lekha/uploader
command: go run main.go
ports:
- "8085:8085"
environment:
aaa: 80
my: I am THE variable value
networks:
- lekha
taskapidapr:
image: "daprio/daprd:edge"
command: [
"./daprd",
"-app-id", "taskapi",
"-app-protocol", "http",
"-app-port", "8085",
"-dapr-http-port", "8300",
"-placement-host-address", "placement:50006",
"-log-level", "debug",
"-components-path", "/components"
]
volumes:
- "../dapr-components/:/components" # Mount our components folder for the dapr runtime to use
depends_on:
- taskapi
ports:
- "8300:8300"
networks:
- lekha
#network_mode: "service:taskapi" # Attach the task-api-dapr service to the task-api network namespace
############################
# Dapr placement service
############################
placement:
image: "daprio/dapr"
command: ["./placement", "-port", "50006"]
ports:
- "50006:50006"
networks:
- lekha
networks:
lekha:
Daprd 在日志中显示这些 mDNS 消息 - 不确定这是否是原因
time="2021-05-24T01:06:13.6629303Z" level=debug msg="刷新所有 mDNS 地址。" app_id=taskapi 实例=442e04c9e8a6 范围=dapr.contrib type=log ver=edge
time="2021-05-24T01:06:13.6630421Z" level=debug msg="没有要刷新的 mDNS 应用程序。" app_id=taskapi 实例=442e04c9e8a6 范围=dapr.contrib
此外，我看到预期端口上的容器......在 Docker 桌面上运行良好......
