Alibaba Cloud Service Mesh:Kelola Layanan Spring Cloud

Pengenalan demo

Dalam contoh ini, Spring Cloud dengan registri Nacos digunakan. Anda dapat mengunduh kode contoh demo dari repositori nacos-examples di GitHub.

Jika layanan konsumen dan penyedia tidak diterapkan di instance ASM, yaitu injeksi proxy sidecar tidak diaktifkan untuk pod layanan, Anda dapat mengakses layanan tetapi tidak dapat mengelola layanan menggunakan sumber daya Istio.

Langkah 1: Aktifkan dukungan untuk Spring Cloud di bidang kontrol ASM

Metode 1: Berlaku untuk semua implementasi dan registri Spring Cloud

1. Gunakan kubectl untuk terhubung ke klaster di bidang kontrol. Untuk informasi lebih lanjut, lihat Gunakan kubectl di bidang kontrol untuk mengakses sumber daya Istio.

2. Buat filter Envoy di klaster ACK yang ditambahkan ke instance ASM.

   1. Buat file bernama any-spring-cloud-support.yaml dengan konten berikut:

      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"

      Modifikasi pengaturan parameter dalam file berdasarkan kebutuhan bisnis Anda. Beberapa parameter dijelaskan sebagai berikut:

      • portNumber: menentukan nomor port layanan Spring Cloud. Jika ada beberapa port, Anda dapat menghapus parameter ini. Jika port dapat dikonvergen, Anda dapat membuat beberapa filter Envoy dan mengonfigurasi nomor port di setiap filter Envoy.

      • pod_cidrs: menentukan blok CIDR pod dari klaster ACK atau ACK Serverless. Masuk ke Container Service for Kubernetes (ACK) console, buka halaman Clusters dan klik klaster yang diinginkan. Di halaman detail klaster yang muncul, klik tab Cluster Resources. Lalu, klik tautan di bagian VPC untuk melihat blok CIDR dari vSwitch di VPC.

   2. Jalankan perintah berikut untuk mengaktifkan filter com.aliyun.reverse_dns untuk layanan:

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

Method 2: Applicable to only Nacos registries

1. Gunakan kubectl untuk terhubung ke klaster di bidang kontrol. Untuk informasi lebih lanjut, lihat Gunakan kubectl di bidang kontrol untuk mengakses sumber daya Istio.

2. Buat entri layanan.

   1. Buat file external-nacos-svc.yaml yang berisi konten berikut:

      kind: ServiceEntry
      metadata:
        name: external-nacos-svc
      spec:
        hosts:
        - "NACOS_SERVER_HOST" ## Ganti variabel ini dengan titik akhir host server Nacos Anda. Contoh: mse-xxx-p.nacos-ans.mse.aliyuncs.com.
        location: MESH_EXTERNAL
        ports:
        - number: 8848
          name: http
        resolution: DNS

      Dalam file YAML sebelumnya, port 8848 adalah port default yang digunakan oleh Nacos. Jika Anda menggunakan server Nacos mandiri dan port berbeda, atur parameter number ke nomor port yang Anda gunakan.

   2. Jalankan perintah berikut untuk membuat entri layanan:

      kubectl apply -f external-nacos-svc.yaml

3. Buat filter Envoy.

   1. Buat file external-envoyfilter.yaml yang berisi konten berikut:

      apiVersion: networking.istio.io/v1alpha3
      kind: EnvoyFilter
      metadata:
        labels:
          provider: "asm"
          asm-system: "true"
        name: nacos-subscribe-lua
        namespace: istio-system
      spec:
        configPatches:
          # Patch pertama menambahkan filter lua ke 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: # Spesifikasi filter lua
             name: envoy.lua
             typed_config:
                "@type": "type.googleapis.com/envoy.extensions.filters.http.lua.v3.Lua"
                inlineCode: |
                   -- hak cipta: 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. Jalankan perintah berikut untuk membuat filter Envoy:

      kubectl apply -f external-envoyfilter.yaml

Langkah 2: Terapkan layanan Spring Cloud di klaster ACK

1. Gunakan kubectl untuk terhubung ke klaster di bidang data. Untuk informasi lebih lanjut, lihat Dapatkan file kubeconfig klaster dan gunakan kubectl untuk terhubung ke klaster.

2. Jalankan perintah berikut untuk menerapkan layanan Spring Cloud:

   export NACOS_ADDRESS=xxxx # Ganti xxxx dengan titik akhir registri MSE Nacos atau registri Nacos mandiri. Kami sarankan Anda menggunakan titik akhir virtual private cloud (VPC).
   wget https://alibabacloudservicemesh.oss-cn-beijing.aliyuncs.com/asm-labs/springcloud/demo.yaml -O demo.yaml
   sed -e "s/NACOS_SERVER_CLUSTERIP/$NACOS_ADDRESS/g" demo.yaml |kubectl apply -f -

3. Jalankan perintah berikut untuk memeriksa layanan Spring Cloud:

    kubectl get pods

   Output yang diharapkan:

   consumer-bdd464654-jn8q7       2/2     Running     0          25h
   provider-v1-66bc67fb6d-46pgl   2/2     Running     0          25h
   provider-v2-76568c45f6-85z87   2/2     Running     0          25h

Langkah 3: Buat gateway Istio dan layanan virtual

1. Buat gateway Istio.

   1. Buat file test-gateway.yaml yang berisi konten berikut:

      apiVersion: networking.istio.io/v1alpha3
      kind: Gateway
      metadata:
        name: test-gateway
      spec:
        selector:
          istio: ingressgateway # gunakan pengontrol default istio
        servers:
        - port:
            number: 80
            name: http
            protocol: HTTP
          hosts:
          - "*"

   2. Gunakan kubectl untuk terhubung ke instance ASM berdasarkan informasi dalam file kubeconfig, lalu jalankan perintah berikut untuk membuat gateway Istio:

      kubectl apply -f test-gateway.yaml

2. Buat layanan virtual.

   1. Buat file consumer.yaml yang berisi konten berikut:

      apiVersion: networking.istio.io/v1alpha3
      kind: VirtualService
      metadata:
        name: consumer
      spec:
        hosts:
        - "*"
        gateways:
        - test-gateway
        http:
        - match:
          - uri:
              prefix: /
          route:
          - destination:
              host: consumer.default.svc.cluster.local
              port:
                number: 8080

   2. Jalankan perintah berikut untuk membuat layanan virtual:

      kubectl apply -f consumer.yaml

Langkah 4: Periksa apakah ASM dapat mengelola layanan Spring Cloud

1. Kueri alamat IP gateway ingress.

   1. Masuk ke Konsol ASM. Di panel navigasi kiri, pilih Service Mesh > Mesh Management.

   2. Pada halaman Mesh Management, klik nama instance ASM. Di panel navigasi kiri, pilih ASM Gateways > Ingress Gateway.

   3. Di halaman Ingress Gateway, periksa Service address dari gateway ingress.

2. Jalankan perintah berikut untuk memulai permintaan dari gateway ingress ke layanan konsumen Spring Cloud:

   curl <Alamat IP gateway ingress>/echo/world

   Output yang diharapkan:

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

   Output menunjukkan bahwa lalu lintas dirutekan ke V1 dan V2 layanan penyedia dalam mode polling secara default.

3. Buat aturan tujuan dan layanan virtual.

   1. Buat file service-provider.yaml dengan konten berikut:

      ---
      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. Jalankan perintah berikut untuk membuat aturan tujuan:

      kubectl apply -f service-provider.yaml

   3. Buat file service-provider1.yaml dengan konten berikut.

      Layanan virtual yang dibuat akan mendefinisikan bahwa permintaan ke /echo/hello dirutekan ke layanan penyedia V1, sedangkan permintaan lainnya dirutekan ke layanan penyedia 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. Jalankan perintah berikut untuk membuat layanan virtual:

      kubectl apply -f service-provider1.yaml

4. Jalankan perintah berikut untuk memulai permintaan ke layanan konsumen Spring Cloud:

   curl <Alamat IP gateway ingress>/echo/hello

   Output yang diharapkan:

   Hello Nacos Discovery From v1hello
   Hello Nacos Discovery From v1hello

   Output menunjukkan bahwa permintaan /echo/hello dirutekan ke layanan penyedia V1, sedangkan permintaan lainnya dirutekan ke layanan penyedia V2. Hal ini menunjukkan bahwa lalu lintas Spring Cloud dikelola oleh Istio dan Custom Resource Definitions (CRD) yang disediakan oleh Istio dapat digunakan untuk mengonfigurasi aturan routing. Dengan demikian, ASM dapat mengelola layanan Spring Cloud.

FAQ

Apa yang harus saya lakukan jika layanan Spring Cloud yang saya terapkan tidak berlaku?

1. Periksa apakah pemblokiran lalu lintas diaktifkan untuk port atau alamat IP Nacos.

   • Jika menggunakan pencarian DNS terbalik, Anda harus memblokir alamat IP pod.

   • Jika menggunakan skrip Lua, Anda harus memblokir alamat IP server Nacos dan alamat IP klaster.

2. Pastikan filter Envoy dibuat sebelum membuat deployment agar proses pendaftaran dapat dicegah. Jika deployment tertentu telah dibuat sebelum filter Envoy, aktifkan pembaruan bergulir untuk deployment tersebut.

3. Periksa apakah Anda telah membuat sumber daya layanan Kubernetes dan menyediakan alamat IP klaster untuk layanan Spring Cloud.

4. Lihat metode untuk mengaktifkan dukungan Spring Cloud di bidang kontrol ASM.

   Jika Metode 2 digunakan, SDK klien Nacos harus versi lebih awal dari 2.0. SDK klien v2.0 atau lebih baru menggunakan gRPC untuk terhubung ke server. Metode 2 tidak berlaku. Metode 1 tidak memiliki persyaratan untuk versi Nacos dan berlaku untuk semua versi Nacos.

5. Periksa versi sidecar layanan. Jika versi image sidecar lebih awal dari 1.13.4.32, Anda mungkin hanya memperbarui bidang kontrol instance ASM tanpa memperbarui bidang data. Dalam hal ini, aktifkan pembaruan bergulir untuk deployment layanan.