因为基于Dapr的服务架构是不限语言的,我们来看看Dapr的跨语言开发。我们使用golang,python,.NET来实现跨语言的服务调用,拓扑如下
我们继续使用.NET 5的fontend和backend,新增python的flask服务,新增golang的beego服务。
1.新增python的flask服务
新增python虚拟环境flask_env
mkvirtualenv flask_env
进入flask_env,安装flask和dapr
pip install flask
pip install dapr
新增简单的flask服务,结构如下
指定服务端口5003,并调用frontend的Dapr/ip接口
from flask import Flask
from dapr.clients import DaprClient app = Flask(__name__) @app.route("/")
def call_frontend():
with DaprClient() as d:
res = d.invoke_method('frontend','Dapr/ip',None)
return res.text() app.run(port=5003)
2.新增golang的beego服务
安装beego
go get github.com/beego/bee/v2
新增beego服务
bee new goapi
项目结构如下
修改conf/app.conf中的监听端口5004
appname = daprapi
httpport = 5004
runmode = dev
修改controllers/default.go api,调用pythonapi的接口/
package controllers import (
beego "github.com/beego/beego/v2/server/web"
dapr "github.com/dapr/go-sdk/client"
"context"
) type MainController struct {
beego.Controller
} func (c *MainController) Get() {
ctx := context.Background()
client, err := dapr.NewClient()
if err != nil{
c.Data["json"] = err.Error()
c.ServeJSON()
}
// defer client.Close() resp, err := client.InvokeMethod(ctx, "pythonapi", "/", "get")
if err != nil{
c.Data["json"] = err.Error()
c.ServeJSON()
}
c.Data["json"] = string(resp)
c.ServeJSON()
}
3.启动服务并测试
启动backend
dapr run --dapr-http-port 3511 --app-port 5000 --app-id backend dotnet .\BackEnd\bin\Debug\net5.0\BackEnd.dll
启动frontend
dapr run --dapr-http-port 3501 --app-port 5001 --app-id frontend dotnet .\FrontEnd\bin\Debug\net5.0\FrontEnd.dll
启动pythonapi
dapr run --dapr-http-port 3503 --app-port 5003 --app-id pythonapi python ./flaskapi/app.py
启动goapi
dapr run --dapr-http-port 3504 --app-port 5004 --app-id goapi bee run
现在调用goapi的默认接口,调用成功!!