Alibaba Cloud Service Mesh:Mengakses layanan menggunakan protokol WebSocket di ASM

Hubungkan ke kluster ACK

Hubungkan ke kluster ACK menggunakan kubectl. Untuk informasi lebih lanjut, lihat Dapatkan file kubeconfig kluster dan gunakan kubectl untuk terhubung ke kluster.

Menerapkan server WebSocket

Contoh ini menggunakan server WebSocket Python dari komunitas WebSocket. Untuk informasi lebih lanjut tentang menyesuaikan penyebaran server, lihat Deploy to Kubernetes.

1. Buat file bernama websockets-server.yaml dengan konten berikut:

   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. Terapkan manifes ke namespace default:

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

Menerapkan klien WebSocket

Citra klien WebSocket dibuat dari Dockerfile berikut:

FROM python:3.9-alpine
RUN pip3 install websockets

1. Buat file bernama websockets-client.yaml dengan konten berikut:

   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. Terapkan manifes ke namespace default:

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

Buka shell di pod client

Gunakan salah satu metode berikut:

Opsi A: Konsol ACK

1. Masuk ke Konsol ACK. Di panel navigasi sebelah kiri, klik Clusters.

2. Pada halaman Clusters, temukan kluster target dan klik namanya. Di panel sebelah kiri, pilih Workloads > Pods.

3. Pada halaman Pods, temukan websockets-client dan klik Terminal di kolom Actions. Lalu, klik websockets-client.

Opsi B: kubectl

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

Ganti <namespace> dengan namespace tempat klien diterapkan (misalnya, default).

Uji koneksi WebSocket

Hubungkan ke server WebSocket:

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

Output yang diharapkan:

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

Ketik hello dan world untuk memverifikasi bahwa server echo mengembalikan setiap pesan:

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

Verifikasi log proxy sidecar

Periksa log kedua proxy sidecar untuk memastikan koneksi WebSocket menggunakan HTTP/1.1.

Log proxy sidecar sisi klien:

1. Pada halaman Pods, klik nama pod klien WebSocket.

2. Klik tab Logs dan pilih istio-proxy dari daftar drop-down Container.

Log berisi entri dengan protocol: HTTP/1.1:

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

Log proxy sidecar sisi server:

1. Pada halaman Pods, klik nama pod server WebSocket.

2. Klik tab Logs dan pilih istio-proxy dari daftar drop-down Container.

Log juga menampilkan protocol: HTTP/1.1:

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

Buat aturan tujuan

1. Masuk ke Konsol ASM.

2. Di panel navigasi sebelah kiri, pilih Service Mesh > Mesh Management.

3. Pada halaman Mesh Management, temukan instans ASM target. Klik nama instans atau klik Manage di kolom Actions.

4. Di panel navigasi sebelah kiri halaman detail, pilih Traffic Management Center > DestinationRule. Pada halaman yang muncul, klik Create from YAML.

5. Pilih default dari daftar drop-down Namespace, tempel YAML berikut ke editor kode, lalu klik Create: Mengatur h2UpgradePolicy ke UPGRADE mengaktifkan HTTP/2 untuk koneksi ke server WebSocket.

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

Buat Envoy filter

Secara default, WebSocket tidak berfungsi dengan protokol HTTP/2. Namun, Envoy mendukung tunneling WebSocket melalui HTTP/2. Atur parameter allow_connect ke true pada sidecar sisi server agar koneksi HTTP/2 didukung oleh server WebSocket.

1. Masuk ke Konsol ASM.

2. Di panel navigasi sebelah kiri, pilih Service Mesh > Mesh Management.

3. Pada halaman Mesh Management, temukan instans ASM target. Klik nama instans atau klik Manage di kolom Actions.

4. Di panel navigasi sebelah kiri halaman detail, pilih Plugin Extension Center > Market Place.

5. Pada halaman Market Place, klik Template that sets the allow_connect parameter to true to allow updated protocol connections.

6. Pada halaman Plugin Detail, klik tab Plugin Config. Di bagian Plugin Effective scope, pilih Workload Scope, lalu klik Add workloads to effective scope.

7. Pada kotak dialog Add workloads to effective scope, atur parameter sebagai berikut:

   • Namespace: default

   • Workload Type: Deployment

   • Di bagian Select workloads, pilih websockets-server, klik ikon untuk memindahkannya ke bagian selected, lalu klik OK.

8. Di editor kode YAML bagian Plugin Config, masukkan patch_context: SIDECAR_INBOUND, aktifkan Plugin Switch, lalu tunggu hingga plug-in diaktifkan.

Setelah plug-in diaktifkan, ASM secara otomatis membuat Envoy filter. YAML yang dihasilkan mirip dengan berikut:

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

Uji koneksi WebSocket melalui HTTP/2

Jalankan perintah berikut dari pod klien:

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

Output yang diharapkan:

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

Ketik hello dan world untuk memverifikasi respons echo:

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

Verifikasi upgrade protokol dalam log proxy sidecar

Log proxy sidecar sisi klien:

1. Pada halaman Pods, klik nama pod klien WebSocket.

2. Klik tab Logs dan pilih istio-proxy dari daftar drop-down Container.

Log sisi klien menampilkan protocol: HTTP/1.1 karena klien menginisiasi permintaan sebagai HTTP/1.1:

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

Log proxy sidecar sisi server:

1. Pada halaman Pods, klik nama pod server WebSocket.

2. Klik tab Logs dan pilih istio-proxy dari daftar drop-down Container.

Log sisi server menampilkan protocol: HTTP/2, yang mengonfirmasi bahwa sidecar telah meningkatkan koneksi tersebut:

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