WebSocket em Java: aplicações avançadas em tempo real

WebSocket em Java: Técnicas avançadas para aplicações em tempo real

WebSocket é um protocolo de comunicação full-duplex que permite estabelecer uma conexão persistente entre cliente e servidor. Diferente do HTTP, onde cada requisição cria uma nova conexão, o WebSocket possibilita a troca contínua de dados em tempo real. Em Java, este protocolo é implementado através do JSR 356 (Java API for WebSocket) e frameworks poderosos como Spring WebSocket. Neste artigo, abordaremos aspectos avançados do desenvolvimento de aplicações em tempo real em Java: escalabilidade, clusterização, integração com Spring e tratamento de cenários complexos.

Arquitetura e escalabilidade de aplicações WebSocket em Java

Ao desenvolver sistemas em tempo real em Java, é importante entender que as conexões WebSocket são conexões de longa duração e stateful (que mantêm estado). Isso cria problemas de escalabilidade: se a aplicação roda em vários servidores, como garantir que uma mensagem enviada a um servidor chegue a um cliente conectado a outro?

Solução: uso de um broker de mensagens. Soluções populares são Redis Pub/Sub ou RabbitMQ. Eles atuam como um "barramento" central através do qual todos os servidores trocam dados. Quando um servidor recebe uma mensagem de um cliente, ele a publica no broker, e todos os outros servidores se inscrevem nesse canal e enviam a mensagem para seus clientes conectados.

Exemplo de integração com Redis Pub/Sub no Spring:

@Component\npublic class RedisMessagePublisher implements MessagePublisher {\n    @Autowired\n    private StringRedisTemplate stringRedisTemplate;\n\n    public void publish(String channel, String message) {\n        stringRedisTemplate.convertAndSend(channel, message);\n    }\n}\n\n@Service\npublic class WebSocketRedisSubscriber implements MessageListener {\n    @Autowired\n    private SimpMessagingTemplate messagingTemplate;\n\n    @Override\n    public void onMessage(Message message, byte[] pattern) {\n        String payload = new String(message.getBody());\n        // Envia para todos os assinantes do WebSocket\n        messagingTemplate.convertAndSend("/topic/public", payload);\n    }\n}

Além disso, para escalabilidade, é necessário gerenciar as sessões corretamente. Em vez de armazenar sessões na memória de um único servidor (HashMap), utilize um armazenamento distribuído, como Hazelcast ou Redis. Isso permitirá que qualquer servidor no cluster acesse qualquer sessão.

Trabalho avançado com Spring WebSocket e STOMP

Spring WebSocket fornece uma abstração de alto nível sobre o JSR 356. O uso do protocolo STOMP (Simple Text Oriented Messaging Protocol) sobre WebSocket simplifica o roteamento de mensagens e o gerenciamento de inscrições.

Configuração avançada:

@Configuration\n@EnableWebSocketMessageBroker\npublic class WebSocketConfig implements WebSocketMessageBrokerConfigurer {\n\n    @Override\n    public void configureMessageBroker(MessageBrokerRegistry config) {\n        // Broker embutido para cenários simples\n        config.enableSimpleBroker("/topic", "/queue");\n        // Prefixos para mensagens do cliente para o servidor\n        config.setApplicationDestinationPrefixes("/app");\n        // Uso de broker externo (ex.: RabbitMQ)\n        config.enableStompBrokerRelay("/topic", "/queue")\n              .setRelayHost("localhost")\n              .setRelayPort(61613)\n              .setClientLogin("guest")\n              .setClientPasscode("guest");\n    }\n\n    @Override\n    public void registerStompEndpoints(StompEndpointRegistry registry) {\n        registry.addEndpoint("/ws")\n                .setAllowedOrigins("*")\n                .withSockJS(); // Fallback para navegadores antigos\n    }\n}

Tratamento de cenários complexos com anotações:

\n
• @MessageMapping — tratamento de mensagens do cliente.
\n