Alibaba Cloud Service Mesh:Manage Spring Cloud services

O Spring Cloud é um padrão com diversas implementações, como Spring Cloud Netflix, Spring Cloud Alibaba e Spring Cloud Consul. Para o ASM, a principal diferença entre essas implementações é o registro de serviço utilizado. A tabela a seguir lista o suporte à migração do ASM para diferentes versões do Spring Cloud.

A aplicação consiste em um serviço consumidor e um serviço provedor. O serviço provedor possui duas versões, v1 e v2, ambas registradas em um registro Nacos. O serviço consumidor obtém os endereços do serviço provedor no registro Nacos e balanceia as requisições entre eles. Ao receber uma requisição, o serviço consumidor a encaminha para um provedor e retorna a resposta correspondente. As duas versões do provedor retornam respostas diferentes:

• O provedor v1 responde a uma requisição echo com Hello Nacos Discovery From v1xxx.

• O provedor v2 responde a uma requisição echo com Hello Nacos Discovery From v2xxx.

Na resposta, .xxx é um espaço reservado para o parâmetro passado à API echo. Por exemplo, se uma requisição para /echo/world for enviada ao provedor v1, ele retornará Hello Nacos Discovery From v1world.

Método 1: Para todas as versões e registros

1. Conecte-se ao cluster do plano de controle usando kubectl. Para mais informações, consulte Access Istio resources on the control plane by using kubectl.

2. Crie um EnvoyFilter no cluster ASM.

   1. Crie um arquivo chamado any-spring-cloud-support.yaml com o seguinte conteúdo.

      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"

      Modifique os parâmetros no arquivo YAML conforme suas necessidades de negócio. Os parâmetros são descritos abaixo:

      • portNumber: A porta do serviço Spring Cloud. Se as portas não forem uniformes, remova este parâmetro. Caso seja possível consolidar as portas, configure vários recursos EnvoyFilter, cada um vinculado a uma portNumber específica.

      • pod_cidrs: O CIDR de pod do cluster ACK ou ACK Serverless. Para encontrar esse valor, faça login no Container Service Management Console e acesse a página Cluster Information. Na aba Cluster Resources, localize o bloco CIDR do Pod em VPC e utilize esse valor para o parâmetro.

   2. Execute o comando a seguir para aplicar o EnvoyFilter.

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

Método 2: Apenas para registros Nacos

1. Conecte-se ao cluster do plano de controle usando kubectl. Para mais informações, consulte Access Istio resources on the control plane by using kubectl.

2. Crie um ServiceEntry.

   1. Crie um arquivo chamado external-nacos-svc.yaml com o seguinte conteúdo.

      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

      No arquivo YAML anterior, 8848 é a porta padrão do Nacos. Se você usa um servidor Nacos autogerenciado e alterou a porta, modifique também o parâmetro number adequadamente.

   2. Execute o comando a seguir para criar o ServiceEntry.

      kubectl apply -f external-nacos-svc.yaml

3. Crie um EnvoyFilter.

   1. Crie um arquivo chamado external-envoyfilter.yaml com o seguinte conteúdo.

      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. Execute o comando a seguir para criar o EnvoyFilter.

      kubectl apply -f external-envoyfilter.yaml

Solução de problemas de serviços do Spring Cloud

1. Verifique se a interceptação de tráfego está ativada para a porta ou endereço IP do Nacos.

   • Ao utilizar o método reverse_dns, é obrigatório interceptar os endereços IP dos pods.

   • Caso utilize o método de script Lua, intercepte o endereço IP do Servidor Nacos e o endereço IP do cluster.

2. Para interceptar o processo de registro, crie o EnvoyFilter antes das cargas de trabalho. Se uma carga de trabalho foi criada primeiro, realize uma atualização contínua nela.

3. Confirme se existe um Kubernetes Service do tipo ClusterIP para cada serviço.

4. Identifique qual método você usou para ativar o suporte ao Spring Cloud no plano de controle do ASM.

   Se você usar Method 2, a versão do SDK do cliente Nacos deve ser anterior a 2,0. O SDK do cliente Nacos 2,0 e posteriores usa gRPC para se conectar ao servidor, o que torna Method 2 incompatível. Method 1 não depende da versão do Nacos e suporta todas as versões.

5. Verifique a versão do sidecar dos serviços. Se a versão da imagem do sidecar for anterior a 1.13.4.32, apenas o plano de controle da instância ASM foi atualizado, mas não o plano de dados. Execute uma atualização contínua nas implantações de serviço afetadas.