Alibaba Cloud Service Mesh:Acesse serviços usando o protocolo WebSocket no ASM

Conectar-se ao cluster ACK

Conecte-se ao cluster ACK usando kubectl. Para mais informações, consulte Obter o arquivo kubeconfig de um cluster e usar kubectl para conectar-se ao cluster.

Implantar o servidor WebSocket

Este exemplo utiliza o servidor WebSocket em Python da comunidade WebSocket. Para mais detalhes sobre como personalizar a implantação do servidor, consulte Implantar no Kubernetes.

1. Crie um arquivo chamado websockets-server.yaml com o seguinte conteúdo:

   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. Aplique o manifesto no namespace default:

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

Implantar o cliente WebSocket

A imagem do cliente WebSocket é construída a partir do seguinte Dockerfile:

FROM python:3.9-alpine
RUN pip3 install websockets

1. Crie um arquivo chamado websockets-client.yaml com o seguinte conteúdo:

   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. Aplique o manifesto no namespace default:

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

Abrir um shell no pod do cliente

Utilize um dos métodos a seguir:

Opção A: Console do ACK

1. Faça login no console do ACK. No painel de navegação à esquerda, clique em Clusters.

2. Na página Clusters, localize o cluster desejado e clique no nome dele. No painel à esquerda, escolha Workloads > Pods.

3. Na página Pods, encontre websockets-client e clique em Terminal na coluna Actions. Em seguida, clique em websockets-client.

Opção B: kubectl

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

Substitua <namespace> pelo namespace onde o cliente foi implantado (por exemplo, default).

Testar a conexão WebSocket

Conecte-se ao servidor WebSocket:

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

Saída esperada:

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

Digite hello e world para verificar se o servidor de eco retorna cada mensagem:

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

Verificar os logs do proxy sidecar

Consulte os logs de ambos os proxies sidecar para confirmar que a conexão WebSocket utilizou HTTP/1,1.

Logs do proxy sidecar no lado do cliente:

1. Na página Pods, clique no nome do pod do cliente WebSocket.

2. Clique na aba Logs e selecione istio-proxy na lista suspensa Container.

O log contém uma entrada com protocol: HTTP/1.1:

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

Logs do proxy sidecar no lado do servidor:

1. Na página Pods, clique no nome do pod do servidor WebSocket.

2. Clique na aba Logs e selecione istio-proxy na lista suspensa Container.

O log também exibe protocol: HTTP/1.1:

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

Client (HTTP/1.1 Upgrade) --> Client sidecar --> HTTP/2 CONNECT --> Server sidecar --> HTTP/1.1 Upgrade --> Server

Criar uma regra de destino

1. Faça login no console do ASM.

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

3. Na página Mesh Management, localize a instância do ASM desejada. Clique no nome da instância ou em Manage na coluna Actions.

4. No painel de navegação à esquerda da página de detalhes, escolha Traffic Management Center > DestinationRule. Na página exibida, clique em Create from YAML.

5. Selecione default na lista suspensa Namespace, cole o YAML a seguir no editor de código e clique em Create: Definir h2UpgradePolicy como UPGRADE habilita HTTP/2 para conexões com o servidor WebSocket.

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

Criar um filtro Envoy

Por padrão, o WebSocket não funciona com o protocolo HTTP/2. No entanto, o Envoy suporta tunelamento de WebSocket sobre HTTP/2. Defina o parâmetro allow_connect como true no sidecar do servidor para que conexões HTTP/2 sejam suportadas pelo servidor WebSocket.

1. Faça login no console do ASM.

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

3. Na página Mesh Management, localize a instância do ASM desejada. Clique no nome da instância ou em Manage na coluna Actions.

4. No painel de navegação à esquerda da página de detalhes, escolha Plugin Extension Center > Market Place.

5. Na página Market Place, clique em Template that sets the allow_connect parameter to true to allow updated protocol connections.

6. Na página Plugin Detail, clique na aba Plugin Config. Na seção Plugin Effective scope, selecione Workload Scope e clique em Add workloads to effective scope.

7. Na caixa de diálogo Add workloads to effective scope, configure os parâmetros conforme descrito a seguir:

   • Namespace: default

   • Workload Type: Deployment

   • Na seção Select workloads, selecione websockets-server, clique no ícone para movê-lo para a seção selected e clique em OK.

8. No editor de código YAML da seção Plugin Config, insira patch_context: SIDECAR_INBOUND, ative a opção Plugin Switch e aguarde até que o plug-in seja habilitado.

Após a ativação do plug-in, o ASM cria automaticamente um filtro Envoy. O YAML gerado é semelhante ao seguinte:

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

Testar a conexão WebSocket sobre HTTP/2

Execute o comando a partir do pod do cliente:

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

Saída esperada:

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

Digite hello e world para verificar a resposta de eco:

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

Verificar o upgrade de protocolo nos logs do proxy sidecar

Logs do proxy sidecar no lado do cliente:

1. Na página Pods, clique no nome do pod do cliente WebSocket.

2. Clique na aba Logs e selecione istio-proxy na lista suspensa Container.

O log do lado do cliente mostra protocol: HTTP/1.1 porque o cliente origina a requisição como HTTP/1,1:

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

Logs do proxy sidecar no lado do servidor:

1. Na página Pods, clique no nome do pod do servidor WebSocket.

2. Clique na aba Logs e selecione istio-proxy na lista suspensa Container.

O log do lado do servidor exibe protocol: HTTP/2, confirmando que o sidecar fez o upgrade da conexão:

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