https://www.techempower.com/benchmarks/#section=data-r16&hw=ph&test=json&l=hr9zpb

Embora o tópico de programação assíncrona não seja novo, em particular, nos artigos do ano passado foram mencionadas algumas implementações escritas em PHP ( Ratchet , Workerman ), acho que o mundo do PHP tem algo para se gabar no último ano

Eu quero apresentar a comunidade ao Swoole  – estrutura assíncrona de código aberto para PHP, escrita em C e fornecida como extensão pecl.

Você pode ver o aplicativo resultante (bate-papo) aqui e os códigos fontes no Github

Porque swoole?

Certamente existem pessoas que serão contra o uso do PHP para tais fins, mas em favor do PHP muitas vezes podem jogar:

  • Relutância em criar um zoológico de diferentes linguagens de programação no projeto
  • A capacidade de usar a base de código existente (se o projeto estiver em PHP).

No entanto, mesmo comparando com node.js / go / erlang e outras linguagens que nativamente oferecem um modelo assíncrono, uma estrutura Swoole escrita em C e combinando um limite de entrada baixo e funcionalidade poderosa pode ser um bom candidato.

Сapabilities:

  • Programação Assíncrona Orientada a Eventos para PHP
  • API do cliente / servidor TCP / UDP / HTTP / Websocket / HTTP2 assíncrono
  • Suporte a IPv4 / IPv6 / Unix socket / TCP / UDP e SSL / TLS
  • Serializador rápido / desserializador
  • Alto desempenho , escalável, suporte C1000K
  • Agendador de tarefas de milissegundos
  • Código aberto

Casos de uso:

  • Servidor de API para dispositivos móveis
  • Internet das Coisas
  • Micro serviços
  • API ou aplicativos da Web
  • Servidores de jogos
  • Sistemas de bate-papo ao vivo

Exemplos de código que você pode ver no site oficial . Na seção docs, você pode encontrar informações mais detalhadas sobre todas as funcionalidades do framework.

Vamos começar!

Abaixo, descreverei o processo de escrever um servidor Websocket simples para bate-papo on-line e a solução de possíveis dificuldades.

Antes de começar: Você pode aprender mais sobre as classes Swoole \ Websocket \ Server e Swoole \ Server (a Segunda classe é herdada da primeira). 
Fontes do chat .

Instalação:

Usuários Linux:

Usuários de Mac:

Para usar o preenchimento automático no IDE, é proposto usar o ide-helper

Modelo básico do servidor Websocket

$ fd é o identificador de conexão;

Quadros ($ frame) contêm todos os dados enviados. Aqui está um exemplo do objeto que veio para o retorno de chamada on (‘message’):

Os dados são enviados para o cliente por função

Você pode aprender um pouco mais sobre o protocolo WS e a implementação do lado do cliente (JS) aqui

Como salvar os dados que chegaram ao servidor?

Swoole fornece funcionalidade para o trabalho assíncrona com MySQL , Redisarquivo de I / O .

Também baseado em armazenamentos de memória compartilhada: swoole_buffer , swoole_channel , swoole_table .

As diferenças estão bem descritas na documentação. Para armazenar os nomes dos usuários, escolho swoole_table e as mensagens são armazenadas no MySQL.

Então, inicialize uma tabela de nomes de usuários:

Arquivar os dados é o seguinte:

Para trabalhar com o MySQL, decidi não usar o modelo assíncrono ainda e acessar o banco de dados diretamente dos workers via PDO:

Servidor Websocket que eu formalizo como uma classe e coloco a inicialização em __construct ().

Manipulando сallbacks (Open connection, new message, closed connection, worker start ), decidi implementar como métodos de classe:

Problemas encontrados:

  • O usuário conectado ao websocket é encerrado após 60 segundos se não houver troca de pacotes (ou seja, o usuário não enviou e não recebeu nada).
  • O servidor web perde a conexão com o MySQL se nenhuma interação ocorrer por um longo tempo

Uma solução em ambos os casos – implemente uma função “ping” que fará o ping constante do cliente a cada “n” segundos no primeiro caso, e o servidor MySQL no segundo.

Como ambas as funções devem ser executadas de forma assíncrona, elas devem ser chamadas nos processos filhos do servidor.

Para fazer isso, eles devem ser inicializados após o evento “workerStart”. Nós já o definimos no construtor, e o método $ this-> onWorkerStart já é chamado neste evento: 
O protocolo Websocket suporta ping-pong fora da caixa. Abaixo você pode ver a implementação no Swoole.

onWorkerStart:

Em seguida, implementei uma função simples para executar ping no servidor MySQL após cada período de tempo usando o Swoole \ Timer:

A parte principal do trabalho foi escrever lógica para adicionar, salvar, enviar mensagens (não mais complicado do que o habitual CRUD) e, em seguida, um enorme espaço para melhorias.

Até agora, eu trouxe meu código para um formato mais legível e estilo orientado a objeto, implementado algumas funcionalidades:

  • Login por nome
  • Verifique se o nome não foi obtido por outro usuário:
  • Solicitar limitador para proteção contra spam:

O Frontend do chat é um pouco feio, porque fiquei mais atraído pelo backend, mas quando tenho mais tempo vou tentar torná-lo mais agradável.

Onde obter informações, aprender notícias sobre o framework?

  • Site oficial
  • Grupo do slack
  • Twitter – notícias reais, artigos interessantes
  • Issue tracker (Github) – bugs, perguntas, comunicação com os criadores do framework. Responda muito rapidamente.
  • Testes – quase todos os módulos da documentação possuem testes escritos em PHP, mostrando os casos de uso
  • Wiki chinês – todas as informações que estão em inglês, mas muito mais comentários de usuários (usei o google translator para ler).
  • Documentação da API – descrição de algumas classes e funções da estrutura em uma forma bastante conveniente.

Na conclusão

Parece-me que o Swoole tem se desenvolvido muito ativamente no ano passado, saiu do estágio em que poderia ser chamado de “raw”, e agora está competindo com o uso de node.js / go / etc. em termos de programação assíncrona e implementação de protocolos de rede.

Terei todo o prazer em ouvir opiniões e opiniões diferentes de quem já tem experiência em usar o Swoole

Se você tiver alguma dúvida ou feedback para mim, vamos nos conectar no Twitter, Telegram .

Para se comunicar no chat descrito, por favor siga o link
O código fonte está disponível no Github .

Artigo Original AQUI

Autor: Evgeniy Romashkan

%d blogueiros gostam disto: