Alibaba Cloud Service Mesh:Gérer les services Spring Cloud

Spring Cloud est une norme disposant de diverses implémentations, telles que Spring Cloud Netflix, Spring Cloud Alibaba et Spring Cloud Consul. Pour ASM, la principale différence entre ces implémentations réside dans le registre de services qu'elles utilisent. Le tableau suivant présente la prise en charge de la migration ASM pour différentes versions de Spring Cloud.

L'application se compose d'un service consommateur et d'un service fournisseur. Le service fournisseur dispose de deux versions, v1 et v2, toutes deux enregistrées auprès d'un registre Nacos. Le service consommateur récupère les adresses du service fournisseur depuis le registre Nacos et répartit la charge des requêtes entre elles. Lorsque le service consommateur reçoit une requête, il la transmet à un fournisseur et renvoie la réponse de ce dernier. Les deux versions du fournisseur renvoient des réponses différentes :

• Le fournisseur v1 répond à une requête echo par Hello Nacos Discovery From v1xxx.

• Le fournisseur v2 répond à une requête echo par Hello Nacos Discovery From v2xxx.

Dans la réponse, .xxx est un espace réservé pour le paramètre transmis à l'API echo. Par exemple, si une requête vers /echo/world est envoyée au fournisseur v1, celui-ci renvoie Hello Nacos Discovery From v1world.

Méthode 1 : Pour toutes les versions et tous les registres

1. Connectez-vous au cluster du plan de contrôle à l'aide de kubectl. Pour plus d'informations, consultez la section Accéder aux ressources Istio sur le plan de contrôle à l'aide de kubectl.

2. Créez un EnvoyFilter dans le cluster ASM.

   1. Créez un fichier nommé any-spring-cloud-support.yaml avec le contenu suivant.

      apiVersion: networking.istio.io/v1alpha3
      kind: EnvoyFilter
      metadata:
        labels:
          provider: "asm"
          asm-system: "true"
        name: any-spring-cloud-support
        namespace: istio-system
      spec:
        configPatches:
        - applyTo: HTTP_FILTER
          match:
            proxy:
              proxyVersion: "^1.*"
            context: SIDECAR_OUTBOUND
            listener:
              portNumber: 8070
              filterChain:
                filter:
                  name: "envoy.filters.network.http_connection_manager"
                  subFilter:
                    name: "envoy.filters.http.router"
          patch:
            operation: INSERT_BEFORE
            value: # reverse_dns filter specification
             name: com.aliyun.reverse_dns
             typed_config:
               "@type": "type.googleapis.com/udpa.type.v1.TypedStruct"
               type_url: type.googleapis.com/envoy.config.filter.reverse_dns.v3alpha.CommonConfig
               value:
                 pod_cidrs:
                 - "10.0.128.0/18"

      Modifiez les paramètres du fichier YAML en fonction de vos besoins métier. Les paramètres sont décrits ci-dessous :

      • portNumber : le port du service Spring Cloud. Si les ports ne sont pas uniformes, vous pouvez supprimer ce paramètre. Si les ports peuvent être consolidés, vous pouvez configurer plusieurs ressources EnvoyFilter, chacune étant liée à un portNumber spécifique.

      • pod_cidrs : le CIDR des pods du cluster ACK ou ACK Serverless. Pour trouver cette valeur, connectez-vous à la console Container Service Management et accédez à la page Cluster Information. Dans l'onglet Cluster Resources , recherchez le bloc CIDR des pods sous VPC et utilisez cette valeur pour le paramètre.

   2. Exécutez la commande suivante pour appliquer le EnvoyFilter.

      kubectl apply -f any-spring-cloud-support.yaml

Méthode 2 : Pour les registres Nacos uniquement

1. Connectez-vous au cluster du plan de contrôle à l'aide de kubectl. Pour plus d'informations, consultez la section Accéder aux ressources Istio sur le plan de contrôle à l'aide de kubectl.

2. Créez un ServiceEntry.

   1. Créez un fichier nommé external-nacos-svc.yaml avec le contenu suivant.

      kind: ServiceEntry
      metadata:
        name: external-nacos-svc
      spec:
        hosts:
        - "NACOS_SERVER_HOST"  ## Replace this with your Nacos Server HOST, for example, "mse-xxx-p.nacos-ans.mse.aliyuncs.com".
        location: MESH_EXTERNAL
        ports:
        - number: 8848
          name: http
        resolution: DNS

      Dans le fichier YAML précédent, 8848 est le port par défaut pour Nacos. Si vous utilisez un serveur Nacos autogéré et avez modifié le port, vous devez également adapter le paramètre number en conséquence.

   2. Exécutez la commande suivante pour créer le ServiceEntry.

      kubectl apply -f external-nacos-svc.yaml

3. Créez un EnvoyFilter.

   1. Créez un fichier nommé external-envoyfilter.yaml avec le contenu suivant.

      apiVersion: networking.istio.io/v1alpha3
      kind: EnvoyFilter
      metadata:
        labels:
          provider: "asm"
          asm-system: "true"
        name: nacos-subscribe-lua
        namespace: istio-system
      spec:
        configPatches:
          # The first patch adds the lua filter to the listener/http connection manager.
        - applyTo: HTTP_FILTER
          match:
            proxy:
              proxyVersion: "^1.*"
            context: SIDECAR_OUTBOUND
            listener:
              portNumber: 8848
              filterChain:
                filter:
                  name: "envoy.filters.network.http_connection_manager"
                  subFilter:
                    name: "envoy.filters.http.router"
          patch:
            operation: INSERT_BEFORE
            value: # lua filter specification
             name: envoy.lua
             typed_config:
                "@type": "type.googleapis.com/envoy.extensions.filters.http.lua.v3.Lua"
                inlineCode: |
                   -- copyright: ASM (Alibaba Cloud ServiceMesh)
                   function envoy_on_request(request_handle)
                     local request_headers = request_handle:headers()
                     -- /nacos/v1/ns/instance/list?healthyOnly=false&namespaceId=public&clientIP=10.122.63.81&serviceName=DEFAULT_GROUP%40%40service-provider&udpPort=53174&encoding=UTF-8
                     local path = request_headers:get(":path")
                     if string.match(path,"^/nacos/v1/ns/instance/list") then
                       local servicename = string.gsub(path,".*&serviceName.*40([%w.\\_\\-]+)&.*","%1")
                       request_handle:streamInfo():dynamicMetadata():set("context", "request.path", path)
                       request_handle:streamInfo():dynamicMetadata():set("context", "request.servicename", servicename)
                       request_handle:logInfo("subscribe for serviceName: " .. servicename)
                     else
                       request_handle:streamInfo():dynamicMetadata():set("context", "request.path", "")
                     end
                   end
                   function envoy_on_response(response_handle)
                     local request_path = response_handle:streamInfo():dynamicMetadata():get("context")["request.path"]
                     if request_path == "" then
                        return
                     end
                     local servicename = response_handle:streamInfo():dynamicMetadata():get("context")["request.servicename"]
                     response_handle:logInfo("modified response ip to serviceName:" .. servicename)
                     local bodyObject = response_handle:body(true)
                     local body= bodyObject:getBytes(0,bodyObject:length())
                     body = string.gsub(body,"%s+","")
                     body = string.gsub(body,"(ip\":\")(%d+.%d+.%d+.%d+)","%1"..servicename)
                     response_handle:body():setBytes(body)
                   end

   2. Exécutez la commande suivante pour créer l'EnvoyFilter.

      kubectl apply -f external-envoyfilter.yaml

Dépannage des services Spring Cloud

1. Vérifiez si l'interception du trafic est activée pour le port ou l'adresse IP de Nacos.

   • Si vous utilisez la méthode reverse_dns, vous devez intercepter les adresses IP des pods.

   • Si vous utilisez la méthode du script Lua, vous devez intercepter l'adresse IP du serveur Nacos et l'adresse IP du cluster.

2. Pour intercepter le processus d'enregistrement, vous devez créer l'EnvoyFilter avant les charges de travail. Si une charge de travail a été créée en premier, vous devez effectuer une mise à jour progressive (rolling update) sur celle-ci.

3. Vérifiez qu'un service Kubernetes de type ClusterIP existe pour chaque service.

4. Vérifiez la méthode utilisée pour activer le support Spring Cloud sur le plan de contrôle ASM.

   Si vous utilisez la Méthode 2, la version du SDK client Nacos doit être antérieure à 2,0. Le SDK client Nacos 2.0 et versions ultérieures utilise gRPC pour se connecter au serveur, ce qui rend la Méthode 2 incompatible. La Méthode 1 ne dépend pas de la version de Nacos et prend en charge toutes les versions de Nacos.

5. Vérifiez la version du sidecar des services. Si la version de l'image du sidecar est antérieure à 1.13.4.32, seul le plan de contrôle de l'instance ASM a été mis à niveau, mais pas le plan de données. Vous devez effectuer une mise à jour progressive (rolling update) sur les déploiements de services concernés.