Hello World

Dapr Hello World

环境安装

Dapr服务端的安装还是非常方便的，首先我们需要安装Dapr命令行：

# Linux
$ wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash

# Mac
$ curl -fsSL https://raw.githubusercontent.com/dapr/cli/master/install/install.sh | /bin/bash

然后运行Daprd服务程序：

$ dapr init
⌛  Making the jump to hyperspace...
Downloading binaries and setting up components
✅  Success! Dapr is up and running. To get started, go here: https://aka.ms/dapr-getting-started

接下来可以指定运行时：

# Install v0.1.0 runtime
$ dapr init --runtime-version 0.1.0

# Check the versions of cli and runtime
$ dapr --version
cli version: v0.1.0
runtime version: v0.1.0

应用运行

接下来将演示如何使Dapr在您的计算机上本地运行。您将部署一个Node.js应用，该应用订阅订购消息并保留它们。以下架构图说明了组成第一部分样本的组件：

稍后，您将部署一个Python应用程序以充当发布者。下面的架构图显示了新组件的添加：

Node.js代码

在Node.js中就是简单的Express应用：

const daprPort = process.env.DAPR_HTTP_PORT || 3500;
const stateStoreName = `statestore`;
const stateUrl = `http://localhost:${daprPort}/v1.0/state/${stateStoreName}`;

Dapr CLI为Dapr端口创建一个环境变量，默认为3500。向系统发送POST消息时，将在第3步中使用它。stateStoreName是提供给状态存储的名称。稍后您将返回到该名称，以了解该名称的配置方式。

app.post("/neworder", (req, res) => {
  const data = req.body.data;
  const orderId = data.orderId;
  console.log("Got a new order! Order ID: " + orderId);

  const state = [
    {
      key: "order",
      value: data,
    },
  ];

  fetch(stateUrl, {
    method: "POST",
    body: JSON.stringify(state),
    headers: {
      "Content-Type": "application/json",
    },
  })
    .then((response) => {
      if (!response.ok) {
        throw "Failed to persist state.";
      }

      console.log("Successfully persisted state.");
      res.status(200).send();
    })
    .catch((error) => {
      console.log(error);
      res.status(500).send({ message: error });
    });
});

该应用程序在这里公开了将接收和处理新订单消息的终结点。它首先记录传入的消息，然后通过将状态数组发布到 /state/<state-store-name> 端点来将订单ID持久化到Redis或者，您可以通过简单地将其与响应对象一起返回来保持状态：

res.json({
  state: [
    {
      key: "order",
      value: order,
    },
  ],
});

然而，这种方法并不能让你验证消息是否成功持久化。该应用还暴露了一个GET端点，/order。

app.get("/order", (_req, res) => {
  fetch(`${stateUrl}/order`)
    .then((response) => {
      if (!response.ok) {
        throw "Could not get state.";
      }

      return response.text();
    })
    .then((orders) => {
      res.send(orders);
    })
    .catch((error) => {
      console.log(error);
      res.status(500).send({ message: error });
    });
});

这将调用Redis缓存来检索 “订单 “键的最新值，这有效地让Node.js应用成为无状态。然后运行该应用：

$ dapr run --app-id nodeapp --app-port 3000 --dapr-http-port 3500 node app.js

dapr运行命令寻找默认的组件目录，在Linux/MacOS中是$HOME/.dapr/components，在Windows中是%USERPROFILE%/.dapr\components，它保存着Dapr将在运行时使用的组件的yaml定义文件。当在本地运行时，为本地开发环境提供默认定义的yaml文件被放置在这个默认组件目录下。查看组件目录下的stattore.yaml文件。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: statestore
spec:
  type: state.redis
  version: v1

你可以看到yaml文件将状态存储定义为Redis，并将其命名为statetore。这是在app.js中用来调用应用程序中的状态存储的名称。

const stateStoreName = `statestore`;
const stateUrl = `http://localhost:${daprPort}/v1.0/state/${stateStoreName}`;

然后通过以下调用可以触发该服务：

$ dapr invoke --app-id nodeapp --method neworder --data "{\"data\": { \"orderId\": \"42\" } }"
$ curl -XPOST -d @sample.json -H "Content-Type:application/json" http://localhost:3500/v1.0/invoke/nodeapp/method/neworder

在其他通过Dapr启动的服务中，我们可以通过如下方式互相调用：

dapr_port = os.getenv("DAPR_HTTP_PORT", 3500)
dapr_url = "http://localhost:{}/v1.0/invoke/nodeapp/method/neworder".format(dapr_port)

n = 0
while True:
    n += 1
    message = {"data": {"orderId": n}}

    try:
        response = requests.post(dapr_url, json=message)
    except Exception as e:
        print(e)

    time.sleep(1)

非Docker环境运行

Dapr CLI提供了一个使用slim init初始化Dapr的选项，而不需要默认创建一个依赖Docker的开发环境。安装Dapr CLI后，使用以下命令用slim init初始化Dapr。

$ dapr init --slim

在这种模式下，安装了两个不同的二进制文件daprd和placement。placement二进制文件是在Dapr自托管安装中启用actors所需要的。在这种模式下，没有安装任何默认的组件，如Redis，用于状态管理或pub/sub。这意味着，除了服务调用之外，安装时没有其他构件功能是开箱即用的。用户可以自由设置自己的环境和自定义组件。此外，如果配置了状态存储，那么基于actor的服务调用也是可能的。

$ git clone https://github.com/dapr/samples.git
$ cd samples/hello-dapr-slim

在app.js中，你会发现一个简单的express应用，它暴露了一个单一的路由和处理程序。看一下neworder处理程序：

app.post("/neworder", bodyParser.json(), (req, res) => {
  const data = req.body.data;
  const orderId = data.orderId;
  console.log("Got a new order! Order ID: " + orderId);
  res.status(200).send("Got a new order! Order ID: " + orderId);
});

这里的端点neworder，将接收和处理消息。处理程序会记录接收到的消息，并以同样的日志进行回复。然后使用Dapr运行该Node应用：

$ dapr run --app-id nodeapp --app-port 3000 --dapr-http-port 3500 node app.js

Starting Dapr with id nodeapp. HTTP Port: 3500. gRPC Port: 9165
You're up and running! Both Dapr and your app logs will appear here.
...

然后可以通过Dapr或者其他方式调用该应用：

$ dapr invoke --verb POST --app-id nodeapp --method neworder --data "{\"data\": { \"orderId\": \"41\" } }"
$ dapr invoke --verb POST --app-id nodeapp --method neworder --data '{"data": { "orderId": "41" } }'
$ curl -XPOST -d @sample.json -H "Content-Type:application/json" http://localhost:3500/v1.0/invoke/nodeapp/method/neworder

最近更新于0001-01-01