为使用WebSocket构建的双向通信应用带来基于服务网格的全链路灰度

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

kuebctl apply -f- <<EOF
apiVersion: v1
kind: Service
metadata:
  name: wsk-svc
spec:
  selector:
    app: wsk
  sessionAffinity: ClientIP
  sessionAffinityConfig:
    clientIP:
      timeoutSeconds: 10
  ports:
    - protocol: TCP
      port: 5000
      targetPort: 5000
      name: http-ws
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: wsk-deploy
  labels:
    app: wsk
    version: v1
spec:
  replicas: 1
  selector:
    matchLabels:
      app: wsk
      version: v1
  template:
    metadata:
      labels:
        app: wsk
        track: stable
        version: v1
      annotations:
        instrumentation.opentelemetry.io/inject-nodejs: "true"
        instrumentation.opentelemetry.io/container-names: "websocket-base"
    spec:
      containers:
        - name: websocket-base
          image: "registry-cn-hangzhou.ack.aliyuncs.com/dev/asm-socketio-sample:669297ea"
          imagePullPolicy: Always
          ports:
          - name: websocket
            containerPort: 5000
---
apiVersion: v1
kind: Service
metadata:
  name: helloworld
  labels:
    app: helloworld
spec:
  ports:
  - port: 5000
    name: http
  selector:
    app: helloworld
---
apiVersion: v1
kind: ServiceAccount
metadata:
  name: helloworld
  labels:
    account: helloworld
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: helloworld-v1
  labels: 
    apps: helloworld
    version: v1
spec:
  replicas: 1
  selector:
    matchLabels:
      app: helloworld
      version: v1
  template:
    metadata:
      labels:
        app: helloworld
        version: v1
    spec:
      serviceAccount: helloworld
      serviceAccountName: helloworld
      containers:
      - name: helloworld
        image: registry-cn-hangzhou.ack.aliyuncs.com/ack-demo/examples-helloworld-v1:1.0
        imagePullPolicy: IfNotPresent 
        ports:
        - containerPort: 5000
---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: helloworld-v2
  labels: 
    apps: helloworld
    version: v2
spec:
  replicas: 1
  selector:
    matchLabels:
      app: helloworld
      version: v2
  template:
    metadata:
      labels:
        app: helloworld
        version: v2
    spec:
      serviceAccount: helloworld
      serviceAccountName: helloworld
      containers:
      - name: helloworld
        image: registry-cn-hangzhou.ack.aliyuncs.com/ack-demo/examples-helloworld-v2:1.0
        imagePullPolicy: IfNotPresent 
        ports:
        - containerPort: 5000
EOF

import os from 'os';
import fetch from 'node-fetch';
import http from 'http'
import socketio from "socket.io";
const ifaces = os.networkInterfaces();
const makeRequest = async (url, baggage) => {
  try {
    let headers = {}
    if (!!baggage) {
      headers['baggage'] = baggage
    }
    const response = await fetch(url, {
      headers
    });
    if (!response.ok) {
      throw new Error(`HTTP error! status: ${response.status}`);
    }
    const data = await response.text(); // 或者 response.json() 如果你需要 JSON 数据
    return data;
  } catch (error) {
    console.error('Error fetching the data:', error);
    return 'error';
  }
}
const privateIp = (() => {
  return Object.values(ifaces).flat().find(val => {
    return (val.family == 'IPv4' && val.internal == false);
  }).address;
})();
const randomOffset = Math.floor(Math.random() * 10);
const intervalOffset = (30+randomOffset) * Math.pow(10,3);
// WebSocket Server
const socketPort = 5000;
const socketServer = http.createServer();
const io = socketio(socketServer, {
  path: '/'
});
// Handlers
io.on('connection', client => {c
  console.log('New incoming Connection from', client.id);
  client.on('test000', async (message) => {
    console.log('Message from the client:',client.id,'->',message);
    const response = await makeRequest('http://helloworld:5000/hello', client.handshake.headers['baggage']);
    client.emit("hello", response, resp => {
      console.log('Response from the client:',client.id,'->',resp);
    })
  })
});
const emitOk = async () => {
  const response = await makeRequest('http://helloworld:5000/hello');
  let log0 = `I am the host: ${privateIp}. I am healty. Hello message: ${response}`;
  console.log(log0);
  io.emit("okok", log0);
}
setInterval(() => {
  emitOk();
}, intervalOffset);
// Web Socket listen
socketServer.listen(socketPort);

kubectl apply -f- <<EOF
apiVersion: networking.istio.io/v1beta1
kind: VirtualService
metadata:
  name: ws
  namespace: default
spec:
  gateways:
    - default/ws-gateway
  hosts:
    - '*'
  http:
    - route:
        - destination:
            host: wsk-svc
            port:
              number: 5000
EOF

import uuid from 'uuid';
import io from 'socket.io-client';
const client = io('http://{ASM网关IP}:30080', {
  reconnection: true,
  reconnectionDelay: 500,
  transports: ['websocket'],
  extraHeaders: {
    'version': 'v2'
  }
});
const clientId = uuid.v4();
let disconnectTimer;
client.on('connect', function(){
  console.log("Connected!", clientId);
  setTimeout(function() {
    console.log('Sending first message');
    client.emit('test000', clientId);
  }, 500);
  // clear disconnection timeout
  clearTimeout(disconnectTimer);
});
client.on('okok', function(message) {
  console.log('The server has a message for you:', message);
})
client.on('hello', (arg, callback) => {
  console.log('the server respond to your test000: ' + arg);
  callback("got it");
})
client.on('disconnect', function(){
  console.log("Disconnected!");
  disconnectTimer = setTimeout(function() {
    console.log('Not reconnecting in 30s. Exiting...');
    process.exit(0);
  }, 10000);
});
client.on('error', function(err){
  console.error(err);
  process.exit(1);
});
setInterval(function() {
  console.log('Sending repeated message');
  client.emit('test000', clientId);
}, 5000);

❯ node client_socket.js
Connected! ffcff9b2-2e41-4334-b64c-60512bdb7c7a
Sending first message
the server respond to your test000: Hello version: v2, instance: helloworld-v2-7b94944d69-wcckk
The server has a message for you: I am the host: 192.168.1.60. I am healty. Hello message: Hello version: v1, instance: helloworld-v1-978dbcf9-vsvw8
Sending repeated message
the server respond to your test000: Hello version: v2, instance: helloworld-v2-7b94944d69-wcckk
Sending repeated message
the server respond to your test000: Hello version: v2, instance: helloworld-v2-7b94944d69-wcckk
Sending repeated message
the server respond to your test000: Hello version: v2, instance: helloworld-v2-7b94944d69-wcckk

The server has a message for you: I am the host: 192.168.1.60. I am healty. Hello message: Hello version: v1, instance: helloworld-v1-978dbcf9-vsvw8