1

Estou estudando para certificação web, e me deparei com um problema ao tentar fazer um chat usando long pooling, mas precisamente no artigo:

http://blog.caelum.com.br/javaee-6-contexto-assincrono-das-servlets-para-o-ajax-push/

Notei que meu cliente não obtinha a escrita, desta forma escrevi um exemplo básico para ver se a resposta era escrita sem a a chamada de oncomplete() no contexto assíncrono, mas observei que não funcionou no Chrome, travando o browser, mas no firefox e IE funcionou, então a pergunta é:

Neste código abaixo o cliente deveria obter a resposta ou existe algum erro da minha parte?

package br.com.claudemir.livroCert;
import java.io.IOException;

import javax.servlet.AsyncContext;
import javax.servlet.GenericServlet;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebServlet;
@WebServlet(asyncSupported=true,urlPatterns={"/MyServlet"})
public class MyServlet extends GenericServlet {
    private static final long serialVersionUID = 1L;
    public MyServlet() {
        super();
    }
    @Override
    public void service(ServletRequest req, ServletResponse resp)
            throws ServletException, IOException {
        AsyncContext ac = req.startAsync();
        ac.setTimeout(0);
        MyAsincTask t = new MyAsincTask(ac);
        ac.start(t);
    }

}

Task

package br.com.claudemir.livroCert;

import java.io.IOException;

public class MyAsincTask implements Runnable {
    private javax.servlet.AsyncContext context;
    public MyAsincTask(javax.servlet.AsyncContext context) {
        this.context = context;
    }

    @Override
    public void run() {
        try {
            Thread.sleep(3000);
            javax.servlet.ServletResponse resp = context.getResponse();
            resp.getWriter().println("oim");
            resp.getWriter().flush();
        } catch (InterruptedException | IOException e) {
            e.printStackTrace();
        }
    }

}

Meu codigo é o seguinte:

<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    <html>
    <head>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
    <title>Insert title here</title>
    <script type="text/javascript" src="jquery-2.1.3.js"></script>
    <script type="text/javascript" src="jquery.tmpl.min.js"></script>
    <script type="text/javascript">
    $(document).ready(function(){
        $("#btn_enviar").click(function(event) {
            event.preventDefault();
        $.ajax({

            url: 'subscribe',
            data: '{}',
            type: 'GET',
            success: function(data){
                alert("resposta server");
            }
        });     
    });
        $("#btn_postar").click(function(event) {
            event.preventDefault();
        $.ajax({

            url: 'subscribe',
            data: '{}',
            type: 'POST',

            success: function(data){
                alert("post mensagem");
            }
        });     
    });

    });
    </script>
    </head>
    <body>
    <form>
    Entrar no Chat:<br />
    <input type="button" id="btn_enviar" value="entrar" /></br>
    <input type="button" id="btn_postar" value="postar" /></br>
    <input type="button" id="btn_postar_simples" value="postar simples" /></br>

    </form>
    </body>
    </html>

Servlet:

package br.com.claudemir;

import java.io.IOException; 
import java.io.PrintWriter;
import java.util.Queue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentLinkedQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.atomic.AtomicInteger;

import javax.servlet.AsyncContext;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(urlPatterns = { "/subscribe" }, asyncSupported = true, loadOnStartup = 1)
public class ChatServlet extends HttpServlet {

    private Queue<AsyncContext> clients = new ConcurrentLinkedQueue<AsyncContext>();
    private BlockingQueue<String> messages = new LinkedBlockingQueue<String>();
    private AtomicInteger contador = new AtomicInteger();
    private AtomicInteger clientes = new AtomicInteger();

    @Override
    public void init() throws ServletException {
        final ExecutorService executors = Executors.newCachedThreadPool();
        Executors.newSingleThreadExecutor().execute(new Runnable() {
            public void run() {
                while (true) {
                    try {
                        final String message = messages.take();

                        for (final AsyncContext ctx : clients) {
                            executors.execute(new Runnable() {
                                public void run() {
                                    try {
                                        PrintWriter writer = ctx.getResponse()
                                                .getWriter();
                                        System.out.println(message);
                                        writer.println(message);
                                        writer.flush();
                                        //ctx.complete();
                                    } catch (IOException e) {
                                        e.printStackTrace();
                                    }
                                }

                            });
                        }
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }

        });
    }

    @Override
    protected void doGet(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        resp.setContentType("text/html");
     // Set to expire far in the past.
        resp.setHeader("Expires", "Sat, 6 May 1995 12:00:00 GMT");

        // Set standard HTTP/1.1 no-cache headers.
        resp.setHeader("Cache-Control", "no-store, no-cache, must-revalidate");

        // Set IE extended HTTP/1.1 no-cache headers (use addHeader).
        resp.addHeader("Cache-Control", "post-check=0, pre-check=0");

        // Set standard HTTP/1.0 no-cache header.
        resp.setHeader("Pragma", "no-cache");
        AsyncContext ctx = req.startAsync();
        ctx.setTimeout(3000000);
        clients.add(ctx);
        System.out.println("novo cliente. id: " + clientes.incrementAndGet());
    }

    @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp)
            throws ServletException, IOException {
        resp.setContentType("text/html");
        System.out.println("enviando mensagem para   " + clientes + " clientes");
        messages.add(String.format("mensagem número %d %n", contador.incrementAndGet()));
    }
}
insira o código aqui

Esse cliente foi feito para testar o flush, se eu fizer ctx.complete, a escrita acontece em todos aqueles que fizeram get, mas somente se eu der um complete, mas desta forma eu desconecto o cliente, e ai teria que fazer um novo get.

No primeiro codigo não tem a implementação de lista de clientes, no caso da primeira dúvida funcionou após setar

resp.setContentType("text/html");

Mas agora, no código que estou mesmo implementando do chat, estou com esse problema, talvez tenha mesmo que dar o ctx.complete(), mas acho estranho ter que entrar novamente no chat toda vez e no fonte do Git não tem o complete.

1
  • Claudemir, bem-vindo ao Stack Overflow em Português! Não parece haver problema com a sua implementação. Poderia postar o código cliente que roda no navegador?
    – utluiz
    7/04/2015 às 15:48

0

Você deve fazer log-in para responder a esta pergunta.

Pesquise outras perguntas com a tag .