ApsaraMQ for RabbitMQ:Conexões e canais

Utilize conexões persistentes

Abra as conexões na inicialização da aplicação e mantenha-as durante todo o ciclo de vida dela. Não abra e feche conexões para cada operação de publicação ou consumo.

Se sua carga de trabalho exigir criação frequente de canais, reutilize um conjunto estável de conexões e crie múltiplos canais dentro delas. Para verificar os limites nas taxas de abertura de conexões e canais, consulte Limites.

Separe as conexões de produtores e consumidores

Use pelo menos uma conexão para produzir mensagens e outra distinta para consumir. O ApsaraMQ for RabbitMQ aplica controle de fluxo (back pressure) às conexões que publicam mais rápido do que a instância consegue processar. Se produtores e consumidores compartilharem a mesma conexão, o controle de fluxo no lado da publicação pode atrasar os acknowledgments do consumidor e degradar o throughput de consumo.

Use um canal por thread

Várias threads podem compartilhar uma conexão. No entanto, os canais não são thread-safe na maioria das bibliotecas cliente. Atribua um canal exclusivo a cada thread em vez de compartilhar um canal entre várias threads.

// Anti-pattern: sharing a channel across threads
Channel shared = connection.createChannel(); // Not thread-safe

// Recommended: one channel per thread
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 4; i++) {
    executor.submit(() -> {
        Channel ch = connection.createChannel();
        // Use ch for this thread's publish/consume operations
    });
}

Quando vários processos compartilham uma conexão, evite abri-la e fechá-la frequentemente. Caso contrário, pode ocorrer um erro ChannelNotFind.

Evite desbalanceamento no consumo

Quando apenas algumas conexões lidam com um grande volume de mensagens, o consumo pode ficar distribuído de forma desigual entre os consumidores. Para evitar isso:

• Aumente o número de conexões por consumidor ou adicione mais consumidores.

• Garanta que cada consumidor estabeleça o mesmo número de conexões.

• Mantenha pelo menos 30 conexões totais de consumidores como diretriz geral.