Alibaba Cloud Service Mesh:Access services using the WebSocket protocol in ASM

Se connecter au cluster ACK

Connectez-vous au cluster ACK à l'aide de kubectl. Pour plus d'informations, consultez la rubrique Obtenir le fichier kubeconfig d'un cluster et utiliser kubectl pour se connecter au cluster.

Déployer le serveur WebSocket

Cet exemple utilise le serveur WebSocket Python de la communauté WebSocket. Pour plus d'informations sur la personnalisation du déploiement du serveur, consultez la rubrique Déployer sur Kubernetes.

1. Créez un fichier nommé websockets-server.yaml avec le contenu suivant :

   apiVersion: v1
   kind: Service
   metadata:
     name: websockets-server
     labels:
       app: websockets-server
   spec:
     type: ClusterIP
     ports:
       - port: 8080
         targetPort: 80
         name: http-websocket
     selector:
       app: websockets-server
   ---
   apiVersion: apps/v1
   kind: Deployment
   metadata:
     name: websockets-server
     labels:
       app: websockets-server
   spec:
     selector:
       matchLabels:
         app: websockets-server
     template:
       metadata:
         labels:
           app: websockets-server
       spec:
         containers:
         - name: websockets-test
           image: registry.cn-beijing.aliyuncs.com/aliacs-app-catalog/istio-websockets-test:1.0
           ports:
           - containerPort: 80

2. Appliquez le manifeste au namespace default :

   kubectl apply -f websockets-server.yaml -n default

Déployer le client WebSocket

L'image du client WebSocket est construite à partir du Dockerfile suivant :

FROM python:3.9-alpine
RUN pip3 install websockets

1. Créez un fichier nommé websockets-client.yaml avec le contenu suivant :

   apiVersion: v1
   kind: Service
   metadata:
     name: websockets-client
     labels:
       app: websockets-client
   spec:
     type: ClusterIP
     ports:
       - port: 8080
         targetPort: 80
         name: http-websockets-client
     selector:
       app: websockets-client
   ---
   apiVersion: apps/v1
   kind: Deployment
   metadata:
     name: websockets-client-sleep
     labels:
       app: websockets-client
   spec:
     selector:
       matchLabels:
         app: websockets-client
     template:
       metadata:
         labels:
           app: websockets-client
       spec:
         containers:
         - name: websockets-client
           image: registry.cn-beijing.aliyuncs.com/aliacs-app-catalog/istio-websockets-client-test:1.0
           command: ["sleep", "14d"]

2. Appliquez le manifeste au namespace default :

   kubectl apply -f websockets-client.yaml -n default

Ouvrir un shell dans le pod client

Utilisez l'une des méthodes suivantes :

Option A : Console ACK

1. Connectez-vous à la console ACK. Dans le volet de navigation de gauche, cliquez sur Clusters.

2. Sur la page Clusters, recherchez le cluster cible et cliquez sur son nom. Dans le volet de gauche, choisissez Workloads > Pods.

3. Sur la page Pods, recherchez websockets-client et cliquez sur Terminal dans la colonne Actions. Ensuite, cliquez sur websockets-client.

Option B : kubectl

kubectl exec -it -n <namespace> websockets-client-sleep...  -c websockets-client -- sh

Remplacez <namespace> par le namespace où le client est déployé (par exemple, default).

Tester la connexion WebSocket

Connectez-vous au serveur WebSocket :

python3 -m websockets ws://websockets-server.<namespace>.svc.cluster.local:8080

Sortie attendue :

Connected to ws://websockets-server.default.svc.cluster.local:8080.

Saisissez hello et world pour vérifier que le serveur echo renvoie chaque message :

> hello
< hello
> world
< world
Connection closed: 1000 (OK).

Vérifier les journaux du proxy sidecar

Consultez les journaux des deux proxys sidecar pour confirmer que la connexion WebSocket utilisait HTTP/1.1.

Journaux du proxy sidecar côté client :

1. Sur la page Pods, cliquez sur le nom du pod client WebSocket.

2. Cliquez sur l'onglet Logs et sélectionnez istio-proxy dans la liste déroulante Container.

Le journal contient une entrée avec protocol: HTTP/1.1 :

{..."upstream_host":"10.208.0.105:80","bytes_sent":23,"protocol":"HTTP/1.1",...}

Journaux du proxy sidecar côté serveur :

1. Sur la page Pods, cliquez sur le nom du pod serveur WebSocket.

2. Cliquez sur l'onglet Logs et sélectionnez istio-proxy dans la liste déroulante Container.

Le journal affiche également protocol: HTTP/1.1 :

{..."downstream_local_address":"10.208.0.105:80","upstream_local_address":"127.0.**.**:53983","protocol":"HTTP/1.1",...}

Client (HTTP/1.1 Upgrade) --> Client sidecar --> HTTP/2 CONNECT --> Server sidecar --> HTTP/1.1 Upgrade --> Server

Créer une règle de destination

1. Connectez-vous à la console ASM.

2. Dans le volet de navigation de gauche, choisissez Service Mesh > Mesh Management.

3. Sur la page Mesh Management, recherchez l'instance ASM cible. Cliquez sur le nom de l'instance ou cliquez sur Manage dans la colonne Actions.

4. Dans le volet de navigation de gauche de la page des détails, choisissez Traffic Management Center > DestinationRule. Sur la page qui s'affiche, cliquez sur Create from YAML.

5. Sélectionnez default dans la liste déroulante Namespace, collez le code YAML suivant dans l'éditeur de code, puis cliquez sur Create : La définition de h2UpgradePolicy sur UPGRADE active HTTP/2 pour les connexions au serveur WebSocket.

   apiVersion: networking.istio.io/v1beta1
   kind: DestinationRule
   metadata:
     labels:
       provider: asm
     name: websockets-server
   spec:
     host: websockets-server
     trafficPolicy:
       connectionPool:
         http:
           h2UpgradePolicy: UPGRADE

Créer un filtre Envoy

Par défaut, WebSocket ne fonctionne pas avec le protocole HTTP/2. Cependant, Envoy prend en charge le tunneling de WebSocket sur HTTP/2. Définissez le paramètre allow_connect sur true sur le sidecar côté serveur afin que le serveur WebSocket prenne en charge les connexions HTTP/2.

1. Connectez-vous à la console ASM.

2. Dans le volet de navigation de gauche, choisissez Service Mesh > Mesh Management.

3. Sur la page Mesh Management, recherchez l'instance ASM cible. Cliquez sur le nom de l'instance ou cliquez sur Manage dans la colonne Actions.

4. Dans le volet de navigation de gauche de la page des détails, choisissez Plugin Extension Center > Market Place.

5. Sur la page Market Place, cliquez sur Template that sets the allow_connect parameter to true to allow updated protocol connections.

6. Sur la page Plugin Detail, cliquez sur l'onglet Plugin Config. Dans la section Plugin Effective scope, sélectionnez Workload Scope et cliquez sur Add workloads to effective scope.

7. Dans la boîte de dialogue Add workloads to effective scope, définissez les paramètres comme suit :

   • Namespace : default

   • Workload Type : Deployment

   • Dans la section Select workloads, sélectionnez websockets-server, cliquez sur l'icône pour la déplacer vers la section selected, puis cliquez sur OK.

8. Dans l'éditeur de code YAML de la section Plugin Config, saisissez patch_context: SIDECAR_INBOUND, activez Plugin Switch et attendez que le plug-in soit activé.

Une fois le plug-in activé, ASM crée automatiquement un filtre Envoy. Le code YAML généré est similaire au suivant :

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  name: h2-upgrade-wss
  labels:
    asm-system: 'true'
    provider: asm
spec:
  workloadSelector:
    labels:
      app: websockets-server
  configPatches:
  - applyTo: NETWORK_FILTER
    match:
      context: SIDECAR_INBOUND
      proxy:
        proxyVersion: '^1\.*.*'
      listener:
        filterChain:
          filter:
            name: "envoy.filters.network.http_connection_manager"
    patch:
      operation: MERGE
      value:
        typed_config:
          '@type': type.googleapis.com/envoy.extensions.filters.network.http_connection_manager.v3.HttpConnectionManager
          http2_protocol_options:
            allow_connect: true

Tester la connexion WebSocket sur HTTP/2

Exécutez la commande suivante depuis le pod client :

python3 -m websockets ws://websockets-server.<namespace>.svc.cluster.local:8080

Sortie attendue :

Connected to ws://websockets-server.default.svc.cluster.local:8080.

Saisissez hello et world pour vérifier la réponse echo :

> hello
< hello
> world
< world
Connection closed: 1000 (OK).

Vérifier la mise à niveau du protocole dans les journaux du proxy sidecar

Journaux du proxy sidecar côté client :

1. Sur la page Pods, cliquez sur le nom du pod client WebSocket.

2. Cliquez sur l'onglet Logs et sélectionnez istio-proxy dans la liste déroulante Container.

Le journal côté client affiche protocol: HTTP/1.1 car le client émet la requête en HTTP/1.1 :

{..."authority":"websockets-server.default.svc.cluster.local:8080","upstream_service_time":null,"protocol":"HTTP/1.1",...}

Journaux du proxy sidecar côté serveur :

1. Sur la page Pods, cliquez sur le nom du pod serveur WebSocket.

2. Cliquez sur l'onglet Logs et sélectionnez istio-proxy dans la liste déroulante Container.

Le journal côté serveur affiche protocol: HTTP/2, confirmant que le sidecar a mis à niveau la connexion :

{..."method":"GET","upstream_local_address":"127.0.**.**:34477","protocol":"HTTP/2",...}