Não é possível transmitir para uma conexão única usando o tempo de execução do Atmosphere
Estou usando o Atmosphere runtime 0.6 Snapshot. O Tomcat 7 está registrando corretamente que estou usando o conector Http11 Nio e não há aviso de que o BlockingIO será usado.
Estou tentando enviar mensagens para três tipos de canais.
Global Broadcaster - transmita para todos os recursos suspensos. (Tudo)Transmitir para um recurso específico (por exemplo, parceiro)Transmitir para o recurso atual (Próprio)Quando ocorre uma ação de login, o que tenho para armazenar em sessão para obter esse tipo de transmissão?
Alguns detalhes do meu código são os seguintes:
Meu manipulador implementa AtmosphereHandlerNo construtor, instanciamos o globalBroadcaster da seguinte maneira:
globalBroadcaster = new DefaultBroadcaster();
No login,
resource.getAtmosphereConfig().getServletContext().setAttribute(name, selfBroadcaster); onde name é o nome de usuário do parâmetro request e selfBroadcaster é uma nova instância do DefaultBroadcaster.
Aqui está o código para sendMessageToPartner,
private synchronized void sendMessageToPartner(Broadcaster selfBroadcaster, AtmosphereResource<HttpServletRequest, HttpServletResponse> resource,String name, String message) {<br>// this gives the partner's name<br>String partner= (String) resource.getAtmosphereConfig().getServletContext().getAttribute(name + PARTNER_NAME_TOKEN);<br>// get partner's broadcaster<br>Broadcaster outsiderBroadcaster = (Broadcaster) resource<br>.getAtmosphereConfig().getServletContext()<br>.getAttribute(partner);<br>if (outsiderBroadcaster == null) {<br>sendMessage(selfBroadcaster, "Invalid user " + partner);<br>return;<br>}<br>// broadcast to partner<br>outsiderBroadcaster.broadcast(" **" + message);
Espero ter fornecido todas as informações necessárias. Posso fornecer mais informações, se necessário.
O problema é que a mensagem global é enviada. Quando a mensagem para o parceiro é enviada, às vezes é bloqueada, a mensagem não é recebida no cliente. Isso acontece de maneira consistente após 3-4 mensagens.
Existe algum problema de segmentação? O que estou fazendo errado?
Espero que alguém me ajude com isso.