On 1/25/12 4:15 PM, Ryan Lubke wrote:
> Sorry for the delay, I'll be following up with a more complete answer
> soon.
Identified the issue. Will follow up once we have a change integrated.
>
> On 1/24/12 5:37 AM, forums_at_java.net wrote:
>> Hi,
>>
>> i try so timplement a simple chat application using glassfish version
>> 3.1.2-b18 (build 18).
>>
>> If two clients connect, they can write a message and the other client
>> will
>> get the message. The getWebSockets() -Method returns 2. So far, so good.
>>
>> But if one client disconnect, the getWebSockets()-method still
>> returns 2. If
>> the disconnected client connect again, the getWebSockets()-method
>> will return
>> 3 and the clients can not send any messages. I do not know how to
>> handle this
>> behavior. Only a restart of the server solve this problem and everything
>> works fine until the a client disconnect.
>>
>> The following approach produces the behaviour:
>>
>> 1. C1 connect
>>
>> 2. C1 send text --> retrieve 1 (from getWebSockets()) (Client can send
>> message as he like to)
>>
>> 3. C1 disconnect
>>
>> 4. C1 connect
>>
>> 5. C1 send text --> retrieve 2 (from getWebSockets())
>>
>> 6. C1 cannot send messages after that
>>
>> This is my implementation:
>>
>> *Client *(with weberknecht-websockets)
>>
>> package de.wsclient;
>> import java.io.BufferedReader;
>> import java.io.IOException;
>> import java.io.InputStreamReader;
>> import java.net.URI;
>> import java.net.URISyntaxException;
>> import de.roderick.weberknecht.WebSocket;
>> import de.roderick.weberknecht.WebSocketConnection;
>> import de.roderick.weberknecht.WebSocketEventHandler;
>> import de.roderick.weberknecht.WebSocketException;
>> import de.roderick.weberknecht.WebSocketMessage;
>> public class Client {
>>
>> static boolean open = true;
>> /**
>> * @param args
>> */
>> public static void main(String[] args) {
>> // TODO Auto-generated method stub
>>
>> try {
>> // jetty url
>> //URI url = new
>> URI("ws://172.30.17.100:8080/WSTest/WebServletTest");
>>
>> // glassfish url
>> URI url = new
>> URI("ws://172.30.17.100:8080/GlassfishWebSocket/WebSocketServlet");
>>
>>
>> WebSocket socket = new WebSocketConnection(url);
>>
>> socket.setEventHandler(new WebSocketEventHandler() {
>>
>> @Override
>> public void onOpen() {
>> System.out.println("Websocket opened");
>>
>> }
>>
>> @Override
>> public void onMessage(WebSocketMessage arg0) {
>> System.out.println("\tServer: " +
>> arg0.getText());
>> open = false;
>>
>> }
>>
>> @Override
>> public void onClose() {
>> System.out.println("Websocket closed!");
>>
>> }
>> });
>>
>> socket.connect();
>>
>> BufferedReader buf = new BufferedReader(new
>> InputStreamReader(System.in));
>> String input = "";
>>
>> while(!input.equals("stop")){
>> try {
>> input = buf.readLine();
>> } catch (IOException e1) {
>> // TODO Auto-generated catch block
>> e1.printStackTrace();
>> }
>>
>> socket.send(input);
>> }
>> socket.close();
>>
>> } catch (URISyntaxException e) {
>> // TODO Auto-generated catch block
>> e.printStackTrace();
>> }catch (WebSocketException e) {
>> // TODO Auto-generated catch block
>> e.printStackTrace();
>> }
>> }
>> }
>>
>>
>> *Servlet* (set loadOnStartup=1 or
>> <load-on-startup>1</load-on-startup> in
>> web.xml)
>>
>> package de.gfwebsocket;
>> import java.io.IOException;
>> import java.io.PrintWriter;
>> import java.text.SimpleDateFormat;
>> import java.util.Date;
>> import javax.servlet.ServletConfig;
>> import javax.servlet.ServletException;
>> import javax.servlet.http.HttpServlet;
>> import javax.servlet.http.HttpServletRequest;
>> import javax.servlet.http.HttpServletResponse;
>> import com.sun.grizzly.websockets.WebSocketEngine;
>> public class WebSocketServlet extends HttpServlet {
>> private static final long serialVersionUID = 1L;
>>
>> private final WebSocketConnection conn = new WebSocketConnection();
>>
>> public WebSocketServlet() {
>> super();
>> // TODO Auto-generated constructor stub
>> }
>>
>> public void init(ServletConfig config) throws ServletException {
>> // TODO Auto-generated method stub
>> WebSocketEngine.getEngine().register(conn);
>> }
>>
>> protected void doGet(HttpServletRequest request, HttpServletResponse
>> response) throws ServletException, IOException {
>> SimpleDateFormat format = new SimpleDateFormat("dd.MM.yyyy
>> HH:mm:ss");
>> PrintWriter writer = response.getWriter();
>> writer.println("<html>");
>> writer.println("<head><title>Hello World
>> Servlet</title></head>");
>> writer.println("<body>");
>> writer.println("<h1>Es ist " + format.format(new Date()) + "
>> Uhr</h1>");
>> writer.println("<body>");
>> writer.println("</html>");
>> writer.flush();
>> writer.close();
>> }
>> protected void doPost(HttpServletRequest request,
>> HttpServletResponse
>> response) throws ServletException, IOException {
>> // TODO Auto-generated method stub
>> }
>> }
>>
>>
>>
>> *WebSocketConnection*
>>
>> package de.gfwebsocket;
>> import com.sun.grizzly.tcp.Request;
>> import com.sun.grizzly.websockets.DataFrame;
>> import com.sun.grizzly.websockets.ProtocolHandler;
>> import com.sun.grizzly.websockets.WebSocket;
>> import com.sun.grizzly.websockets.WebSocketApplication;
>> import com.sun.grizzly.websockets.WebSocketListener;
>> public class WebSocketConnection extends WebSocketApplication{
>>
>>
>> @Override
>> public WebSocket createWebSocket(ProtocolHandler protocolHandler,
>> WebSocketListener... listeners) {
>> // TODO Auto-generated method stub
>> //return super.createWebSocket(protocolHandler, listeners);
>> return new WebSocketDataProcess(protocolHandler, listeners);
>> }
>>
>> @Override
>> public void onClose(WebSocket socket, DataFrame frame) {
>> // TODO Auto-generated method stub
>> socket.close();
>> super.onClose(socket, frame);
>> }
>> @Override
>> public void onConnect(WebSocket socket) {
>> // TODO Auto-generated method stub
>> super.onConnect(socket);
>> }
>> @Override
>> public void onMessage(WebSocket socket, String text) {
>>
>>
>>
>>
>> for(final WebSocket sock : getWebSockets()){
>> //if(!(sock.equals(socket))){
>> //sock.send(text);
>>
>> sock.send(String.valueOf(getWebSockets().size()));
>> //}
>> }
>>
>> //super.onMessage(socket, text);
>> }
>>
>> // return true if you want to communicate over websocket otherwise
>> return false
>> @Override
>> public boolean isApplicationRequest(Request arg0) {
>> // TODO Auto-generated method stub
>> return true;
>> }
>>
>> }
>>
>> *WebSocketProcess*
>>
>> package de.gfwebsocket;
>> import com.sun.grizzly.websockets.ProtocolHandler;
>> import com.sun.grizzly.websockets.DefaultWebSocket;
>> import com.sun.grizzly.websockets.WebSocketListener;
>> //public class WebSocketDataProcess extends BaseServerWebSocket{
>> public class WebSocketDataProcess extends DefaultWebSocket{
>>
>>
>> public WebSocketDataProcess(ProtocolHandler handler,
>> WebSocketListener... listeners) {
>> // TODO Auto-generated constructor stub
>> super(handler, listeners);
>> }
>> }
>>
>> How can i fix this problem? The servers seems not to delete or close the
>> server-side websocket or close the connection.
>>
>> Thank your for your help in advance!
>>
>> best regards
>>
>> hsch
>>
>>
>>
>> --
>>
>> [Message sent by forum member 'hsch']
>>
>> View Post: http://forums.java.net/node/882964
>>
>>
>