Alibaba Cloud Service Mesh:Istio サイドカープロキシ注入による予期しない WebSocket リターンコードの修正

以下の内容で sample.yaml というファイルを作成します。

    apiVersion: apps/v1
    kind: Deployment
    metadata:
      name: websocket-test
      namespace: default
      labels:
        app: websocket-test
        version: current
    spec:
      replicas: 1
      selector:
        matchLabels:
          app: websocket-test
          version: current
      template:
        metadata:
          labels:
            app: websocket-test
            version: current
        spec:
          containers:
          - name: websocket-test
            image: registry.cn-hangzhou.aliyuncs.com/aliacs-app-catalog/asm-websocketsample:v1
            imagePullPolicy: Always
            command: ["node", "ws.js"]

    ---
    apiVersion: v1
    kind: Service
    metadata:
      labels:
        app: websocket-test
      name: websocket-test
      namespace: default
    spec:
      ports:
      - name: http
        port: 80
        protocol: TCP
        targetPort: 9900
      selector:
        app: websocket-test
      type: ClusterIP

マニフェストを default 名前空間に適用します。

default 名前空間に対して自動サイドカープロキシ注入が有効化されている必要があります。詳細については、「自動サイドカープロキシ注入の有効化」をご参照ください。

    kubectl apply -f sample.yaml

Node.js アプリケーション用の package.json ファイルを作成します。

    {
      "name": "wssample",
      "version": "0.0.1",
      "main": "ws.js",
      "license": "UNLICENSED",
      "scripts": {
        "start": "node --trace-warnings ./ws.js"
      },
      "dependencies": {
        "ws": "^8.0.0"
      }
    }

WebSocket サーバーのロジックを含む ws.js ファイルを作成します。

    const WebSocket = require("ws");
    const http = require("http");
    const wss = new WebSocket.Server({ noServer: true });

    const server = http.createServer()

    server.on("upgrade", async (request, socket, head) => {
      const handleAuth = (ws) => {
        wss.emit("connection", ws, request);
      };
      wss.handleUpgrade(request, socket, head, handleAuth);
    })

    wss.on("connection", (conn, req) => {
      // デフォルトのクローズではリターンコード 1005 が送信されます。
      // サイドカープロキシ注入が有効な場合、Chrome では代わりに 1006 が報告されます。
      // conn.close()

      // カスタムリターンコード 4321。
      // サイドカープロキシ注入が有効な場合、Chrome では依然として 1006 が報告されます。
      // サイドカープロキシ注入が無効な場合、Chrome では正しく 4321 が報告されます。
      conn.close(4321, "test")
    });

    server.listen({ host: '0.0.0.0', port: 9900 });

Dockerfile を作成します。

    FROM node:16.7.0-alpine3.14
    WORKDIR /root/app
    COPY . .
    RUN yarn install

イメージをビルドし、オプション A と同様の Deployment および Service を使用してデプロイします。image フィールドをカスタムイメージのレジストリパスに置き換えます。

左側ナビゲーションウィンドウで、ASM Gateways ＞ Gateway を選択し、Create from YAML をクリックします。

Namespace を default に設定し、シナリオテンプレートを選択して、以下の YAML を貼り付け、Create をクリックします。

    apiVersion: networking.istio.io/v1beta1
    kind: Gateway
    metadata:
      name: websocket-test
      namespace: default
    spec:
      selector:
        istio: ingressgateway
      servers:
        - hosts:
            - '*'
          port:
            name: http
            number: 80
            protocol: HTTP

左側ナビゲーションウィンドウで、Traffic Management Center ＞ DestinationRule を選択し、Create from YAML をクリックします。

Namespace を default に設定し、シナリオテンプレートを選択して、以下の YAML を貼り付け、Create をクリックします。

    apiVersion: networking.istio.io/v1alpha3
    kind: DestinationRule
    metadata:
      name: websocket-test
      namespace: default
    spec:
      host: websocket-test
      subsets:
      - name: current
        labels:
          version: current

左側ナビゲーションウィンドウで、Traffic Management Center ＞ VirtualService を選択し、Create from YAML をクリックします。

Namespace を default に設定し、シナリオテンプレートを選択して、以下の YAML を貼り付け、Create をクリックします。

    apiVersion: networking.istio.io/v1alpha3
    kind: VirtualService
    metadata:
      name: websocket-test
      namespace: default
    spec:
      gateways:
      - websocket-test
      hosts:
      - '*'
      http:
      - name: default
        route:
        - destination:
            host: websocket-test
            subset: current