Docker撰写--遇到“errorCode”：“ERR_DIRECT_INVOKE”，“message”：“调用API尚未准备好”错误。

Question

我正在https://github.com/dapr/go-sdk..上第一次试用Dapr到Dapr。

..。试图在我的Windows 10计算机上使用golang和Docker构建Dapr服务--使用VSCode --并遇到连接到它的服务的问题。

我已经设置了docker组合文件来完成以下简单的配置。并试图使用curl通过Dapr API连接到服务。

=> Dapr SideCar (taskapidapr)

我是根据https://github.com/dapr/go-sdk/blob/main/example/Makefile中的示例编写的，但是使用了Docker。

当我试图连接到服务时，请使用

curl -d "ping“内容类型:文本/纯文本；charset=UTF-8 "http://localhost:8300/v1.0/invoke/taskapi/method/echo”

我遇到了以下错误。

{"errorCode":"ERR_DIRECT_INVOKE"，"message":"invoke尚未准备好“}

而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桌面上运行良好.

​

​

​

​

Answer 1

在这里输入图像描述

{
"errorCode": "ERR_DIRECT_INVOKE",
"message": "invoke API is not ready"

}

和你的一样