Alibaba Cloud Service Mesh:Gerencie serviços do Spring Cloud

Método 1: DNS reverso (todos os registros)

1. Conecte o kubectl ao plano de controle do ASM. Consulte Usar kubectl no plano de controle para acessar recursos do Istio.

2. Crie um arquivo chamado any-spring-cloud-support.yaml: Substitua os valores abaixo conforme seu ambiente:

   Parâmetro	Descrição	Onde encontrar
   portNumber	Porta do seu serviço Spring Cloud. Remova este parâmetro para corresponder a todas as portas ou crie recursos EnvoyFilter separados para direcionar portas específicas.	Configuração da aplicação
   pod_cidrs	Bloco CIDR de pod do cluster ACK ou ACK Serverless.	No Console de Gerenciamento do Container Service, acesse Clusters, clique em seu cluster e abra a aba Cluster Resources. Clique no link da VPC para visualizar o bloco CIDR do vSwitch.

      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:
             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"

3. Aplique o EnvoyFilter:

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

Método 2: Filtro Lua (apenas Nacos)

1. Conecte o kubectl ao plano de controle do ASM. Consulte Usar kubectl no plano de controle para acessar recursos do Istio.

2. Crie um arquivo chamado external-nacos-svc.yaml para definir uma entrada de serviço para o servidor Nacos: Substitua <your-nacos-server-host> pelo endpoint do servidor Nacos (por exemplo, mse-xxx-p.nacos-ans.mse.aliyuncs.com). A porta 8848 é a porta padrão do Nacos. Caso seu Nacos autogerenciado utilize uma porta diferente, atualize o valor de number.

      kind: ServiceEntry
      metadata:
        name: external-nacos-svc
      spec:
        hosts:
        - "<your-nacos-server-host>"  # Example: mse-xxx-p.nacos-ans.mse.aliyuncs.com
        location: MESH_EXTERNAL
        ports:
        - number: 8848
          name: http
        resolution: DNS

3. Aplique a entrada de serviço:

      kubectl apply -f external-nacos-svc.yaml

4. Crie um arquivo chamado external-envoyfilter.yaml para o EnvoyFilter baseado em Lua:

      apiVersion: networking.istio.io/v1alpha3
      kind: EnvoyFilter
      metadata:
        labels:
          provider: "asm"
          asm-system: "true"
        name: nacos-subscribe-lua
        namespace: istio-system
      spec:
        configPatches:
        - 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:
             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()
                     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

5. Aplique o EnvoyFilter:

      kubectl apply -f external-envoyfilter.yaml

Observar o comportamento padrão (antes das regras de roteamento)

1. Obtenha o endereço IP do gateway de entrada:

   1. Faça login no console do ASM.

   2. No painel de navegação à esquerda, escolha Service Mesh > Mesh Management.

   3. Clique no nome da sua instância do ASM e escolha ASM Gateways > Ingress Gateway.

   4. Anote o Service address na página Ingress Gateway.

2. Envie várias solicitações ao serviço consumidor: As respostas alternam entre V1 e V2 em round-robin: Isso confirma que o consumidor descobre ambas as versões do provedor por meio do Nacos e distribui o tráfego uniformemente. Nenhuma regra de roteamento do Istio está ativa neste momento.

      curl <ingress-gateway-ip>/echo/world

      Hello Nacos Discovery From v1world
      Hello Nacos Discovery From v2world
      Hello Nacos Discovery From v1world
      Hello Nacos Discovery From v2world

Aplicar regras de roteamento (após)

1. Crie um arquivo chamado service-provider.yaml para definir uma regra de destino com subconjuntos baseados em versão:

      apiVersion: networking.istio.io/v1alpha3
      kind: DestinationRule
      metadata:
        name: service-provider
      spec:
        host: service-provider
        subsets:
        - name: v1
          labels:
            label: v1
        - name: v2
          labels:
            label: v2

2. Aplique a regra de destino:

      kubectl apply -f service-provider.yaml

3. Crie um arquivo chamado service-provider-vs.yaml para definir um serviço virtual que roteia solicitações /echo/hello para V1 e todas as outras solicitações para V2:

      apiVersion: networking.istio.io/v1alpha3
      kind: VirtualService
      metadata:
        name: service-provider
      spec:
        hosts:
        - service-provider
        http:
        - name: "hello-v1"
          match:
          - uri:
              prefix: "/echo/hello"
          route:
          - destination:
              host: service-provider
              subset: v1
        - name: "default"
          route:
          - destination:
              host: service-provider
              subset: v2

4. Aplique o serviço virtual:

      kubectl apply -f service-provider-vs.yaml

5. Teste as regras de roteamento: Todas as respostas agora vêm apenas da V1: Compare isso com o comportamento de round-robin observado anteriormente: Solicitações /echo/hello agora são roteadas exclusivamente para V1, enquanto todas as outras vão para V2. Os CRDs do Istio assumiram o roteamento de tráfego do Spring Cloud, confirmando que o ASM gerencia os serviços.

      curl <ingress-gateway-ip>/echo/hello

      Hello Nacos Discovery From v1hello
      Hello Nacos Discovery From v1hello

O tráfego não é interceptado pela malha

Verifique se o bloqueio de tráfego está habilitado para a porta ou endereço IP do registro:

• Método 1 (DNS reverso): É necessário bloquear o endereço IP do pod. Certifique-se de que o valor pod_cidrs no seu EnvoyFilter abranja o bloco CIDR de pod correto do seu cluster ACK.

• Método 2 (filtro Lua): É necessário bloquear o endereço IP do servidor Nacos e o endereço IP do cluster.

Os serviços não estão se registrando corretamente

Isso geralmente ocorre quando o EnvoyFilter não estava ativo antes do início dos serviços. O filtro deve interceptar o processo de registro desde o começo. Reinicie as implantações afetadas:

kubectl rollout restart deployment <deployment-name>

Confirme também se cada serviço Spring Cloud possui um recurso de serviço Kubernetes correspondente com um endereço IP de cluster.

As regras de roteamento não estão entrando em vigor

Duas causas comuns:

1. Versão do SDK cliente do Nacos (apenas Método 2): O Método 2 exige SDK cliente do Nacos anterior à versão 2,0. A versão 2.0+ usa gRPC em vez de HTTP, o que é incompatível com o filtro Lua. Mude para o Método 1 se o seu SDK cliente do Nacos for 2,0 ou posterior — o Método 1 funciona com todas as versões do Nacos.

2. Versão desatualizada do sidecar: Se a versão da imagem do sidecar for anterior a 1.13.4.32, o plano de dados pode não ter sido atualizado após um upgrade do plano de controle. Reinicie as implantações afetadas para obter a versão mais recente do sidecar.