sidecar构架之dapr中间件

发表于 更新于 阅读次数： 阅读次数：

背景

Dapr 允许通过链接一系列中间件组件来定义自定义处理管道。 请求在路由到用户代码之前经过所有已定义的中间件组件，然后在返回到客户机之前，按相反顺序经过已定义的中间件，如下图中所示。
DdyQpe

中间件示例

uppercase中间件示例

我们拿 sidecar构架之dapr的跨物理机负载均衡的部署来继续实践一下将http请求的body内容转换为大写。

配置dapr3虚拟机

因为我们是通过dapr3(service2) 去 调用dapr1和dapr2的(service1)服务，那么我们在入口dapr3机器上配置中间件

~/.dapr/components/uppercase.yaml

1
2
3
4
5
6
7
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: uppercase
spec:
  type: middleware.http.uppercase
  version: v1

~/.dapr/config.yaml

1
2
3
4
5
6
7
8
9
10
apiVersion: dapr.io/v1alpha1
kind: Configuration
metadata:
  name: pipeline
  namespace: default
spec:
  httpPipeline:
    handlers:
    - name: uppercase
      type: middleware.http.uppercase

增加接口

我们增加一个/word的post接口，接口返回目标机器的ip和我们body参数的英文字母

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
const express = require('express')
const os = require('os');
const app = express()
const bodyParser = require('body-parser')
const port = 3000
app.use(bodyParser.json());// 添加json解析
app.use(bodyParser.urlencoded({extended: false}));

function getIpAddress() {
  var interfaces=os.networkInterfaces()

  for (var dev in interfaces) {
    let iface = interfaces[dev]

    for (let i = 0; i < iface.length; i++) {
      let {family, address, internal} = iface[i]

      if (family === 'IPv4' && address !== '127.0.0.1' && !internal) {
        return address
      }
    }
  }
}

function randomCoding(){
     //创建26个字母数组
     var arr = ['a','b','c','d','e','f','g','h','i','j','k','l','m','n','o','p','q','r','s','t','u','v','w','x','y','z'];
     var idvalue ='';
     const n = 4;
     for(var i=0;i<n;i++){
        idvalue+=arr[Math.floor(Math.random()*26)];
     }
     return idvalue;
}

app.post('/word', (req, res) => {
  const ipAddress = getIpAddress()
  const body = req.body
  body.ip = ipAddress
  res.send(body)
})

app.listen(port, () => {
  console.log(`Example app listening on port ${port}`)
})

调用结果

我们来调用/word接口，发现我们的body请求参数abc，通过middleware.http.uppercase大小写中间件，转换为大写，并向下游的service1发送请求，下游2台负载均衡的service1服务，均接受到中间件改变的大写参数。
1JMjA6

lg1r3L

相关链接

OAuth2 client credentials