Dapr golang Docker Compose - 遇到 ""errorCode":"ERR_DIRECT_INVOKE","message":"invoke API is not ready" 错误

如何解决Dapr golang Docker Compose - 遇到 ""errorCode":"ERR_DIRECT_INVOKE","message":"invoke API is not ready" 错误

我是第一次尝试 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 "Content-type: text/plain;charset=UTF-8" "http://localhost:8300/v1.0/invoke/taskapi/method/echo"

我遇到了以下错误。

{"errorCode":"ERR_DIRECT_INVOKE","message":"invoke 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
}

docker-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 instance=442e04c9e8a6 scope=dapr.contrib type=log ver=edge

time="2021-05-24T01:06:13.6630421Z" level=debug msg="没有 mDNS 应用程序 刷新。” app_id=taskapi instance=442e04c9e8a6 scope=dapr.contrib

此外，我看到预期端口上的容器......在 Docker 桌面上运行良好......