问题描述
我是第一次尝试 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 桌面上运行良好......
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)