Dapr .netcore与go的方法调用

• Dapr .netcore与go的方法调用
  • 创建.netcore Web API应用
  • 编写go应用程序
  • Dapr应用在Docker中的部署
    • 安装dotnetapp应用
    • 安装go应用
    • 测试
  • Dapr应用在k8s中的部署
    • 安装redis
    • 安装项目

主要回顾一下dapr是如何调用方法的。这里是通过.netcore程序调用go程序中的方法。
本章代码目录：https://gitee.com/zuxiazijiahebo/daprlearning
大致流程如下：

创建.netcore Web API应用

创建时勾选上Docker的支持。

接着添加Dapr.AspNetCore包。

在Startup.cs中添加我们的Dapr客户端服务。

services.AddDaprClient();

接着我们直接修改WeatherForecastController.cs类中的方法，通过sdk与http不同的方式发送消息给指定的dapr应用。

[ApiController]
[Route("[controller]")]
public class WeatherForecastController : ControllerBase
{
    private readonly ILogger<WeatherForecastController> _logger;
    private readonly DaprClient _daprclient;
    public WeatherForecastController(
        ILogger<WeatherForecastController> logger,
        DaprClient daprclient
        )
    {
        _daprclient = daprclient;
        _logger = logger;
    }
    [HttpGet]
    public string[] Get(int id) 
    {
        return new string[]{ "/sdk/{id}", "/http/{id}" };
    }
    [HttpGet("/sdk/{id}")]
    public async Task<string> Getsdk(int id)
    {
        Console.WriteLine("sdk begin...");
        // 调用服务
        var data = new { id = id, message = "hello [SDK]" };
        // 调用goapp的simple方法
        // InvokeMethodAsync 方法参数: 应用id,应用的方法,数据
        await _daprclient.InvokeMethodAsync<object>("goapp", "simple", data);
        // 输出发送的内容
        string result = string.Format("send Data: {0}", data);
        Console.WriteLine(result);
        return result;
    }
    [HttpGet("/http/{id}")]
    public async Task<string> Gethttp(int id)
    {
        Console.WriteLine("http begin...");
        var client = DaprClient.CreateInvokeHttpClient(appId: "goapp");
        var data = new { id = id, message = "hello [http]" };
        // http的方式
        var response = await client.PostAsJsonAsync("/simple", data);
        string result = string.Format("send Data: {0}", data);
        Console.WriteLine(result);
        return result;
    }
}

关于.netcore的Dockerfile

FROM mcr.microsoft.com/dotnet/aspnet:3.1 AS base
WORKDIR /app
EXPOSE 80
FROM mcr.microsoft.com/dotnet/sdk:3.1 AS build
WORKDIR /src
COPY ["Client.csproj", "."]
RUN dotnet restore "./Client.csproj"
COPY . .
WORKDIR "/src/."
RUN dotnet build "Client.csproj" -c Release -o /app/build
FROM build AS publish
RUN dotnet publish "Client.csproj" -c Release -o /app/publish
FROM base AS final
WORKDIR /app
COPY --from=publish /app/publish .
ENTRYPOINT ["dotnet", "Client.dll"]

编写go应用程序

然后创建go目录来编写我们的go应用程序。

在app.go中主要提供一个/simple的方法，并将它接收到的内容输出并打印出来。

package main
import (
    "encoding/json"
    "log"
    "io/ioutil"
    "net/http"
    "fmt"
    "github.com/gorilla/mux"
)
func simplemethod(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "application/json")
    w.Header().Set("Access-Control-Allow-Origin", "*")
    s, _ := ioutil.ReadAll(r.Body)
    fmt.Fprintln(w, "%s",string(s))
    fmt.Println(fmt.Sprintf("%s%s", "From dotnet app, data: ", string(s)))
    json.NewEncoder(w).Encode("go have already processed!")
}
func main() {
    router := mux.NewRouter()
    router.HandleFunc("/simple", simplemethod).Methods("POST", "OPTIONS")
    log.Fatal(http.ListenAndServe(":6000", router))
}

Dockerfile如下：

FROM golang:1.15-buster as builder
WORKDIR /dir
COPY app.go .
RUN go get -d -v
RUN CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o app .
FROM debian:buster-slim
WORKDIR /root/
COPY --from=builder /dir/app .
CMD ["./app"]

大家闲麻烦可以直接git clone https://gitee.com/zuxiazijiahebo/daprlearning.git

Dapr应用在Docker中的部署

没安装的可以参考这篇 安装Dapr
安装好后进行初始化

dapr init

安装dotnetapp应用

cd daprlearning/Client/Client/
# 生成
dotnet build
# 切换到生成好的目录下
cd ./bin/Debug/netcoreapp3.1
# dapr开启dotnetapp应用，应用端口5000，dapr边车端口3500
dapr run --app-id dotnetapp --app-port 5000 --dapr-http-port 3500 dotnet Client.dll

安装go应用

cd daprlearning/Client/Client/go
# 安装 gorilla/mux package
go get -u github.com/gorilla/mux
# 生成 go 程序
go build app.go
# dapr 启动go程序
dapr run --app-id goapp --app-port 6000 --dapr-http-port 3501 ./app

测试

我们通过如下几次请求来测试应用程序的调用情况

# 查看dotnetapp应用的两个接口
curl http://127.0.0.1:5000/weatherforecast
# 开始调用
curl http://127.0.0.1:5000/sdk/1
curl http://127.0.0.1:5000/http/2
# Dapr CLI的方式测试
dapr invoke --app-id goapp --method simple --data "{\"data\": { \"orderId\": \"42\" } }"

我们可以通过查看go应用的运行记录查看调用情况。

接着我们到zipkin中查看更详细的调用情况
访问http://localhost:9411

我们可以看到它是调用的都是该地址：POST {dapr url}/v1.0/invoke/{app-id}/method/{method}
下面是链路情况：

Dapr应用在k8s中的部署

# 初始化
dapr init -k

所有的部署都在Deploy目录下，镜像我也为大家打包好了。所以可以直接切换到Deploy目录下按照如下方式进行部署。

安装redis

我这里redis部署得很简单大家搞集群的话也是可以的。

docker pull redis:latest
docker run -itd --name redis-test -p 6379:6379 redis

查看ifconfig修改一下redis.yaml的host地址

安装项目

kubectl apply -f .
# 查看Pod状态
kubectl get pod -w

稍等几分钟就好。

进行端口代理，然后打开一个新的Session执行下面命令进行测试

kubectl port-forward --address 0.0.0.0 service/dotnetclient 8080:80

curl http://127.0.0.1:8080/weatherforecast
# 开始调用
curl http://127.0.0.1:8080/sdk/1
curl http://127.0.0.1:8080/http/2

没有输出的原因是因为镜像没有更新你们不会出现这种问题的。下面是go的日志记录情况:

待续…