Skip to main content
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
[kura-dev] Web Sockets using embedded Jetty
Dear all,

for our product we’d like to have real-time data updates pushed from the device over HTTP. To this end I’ve been trying out different solutions for server-sent data. The first was a Socket.IO server sitting on Netty [1], which always timed out without sending data. I switched to Atmosphere[2], which provides Websocket based communication with a fallback to HTTP long polling directly over the Servlet container.

Unfortunately this too doesn’t want to work correctly. The websocket upgrade never completes, leaving the client hanging. Here is the code I use to register with HTTPService:

mAtmoServlet = new AtmosphereDSServlet(mDataStore);
mHttpService.registerServlet("/chat", mAtmoServlet, null, null);
mAtmoServlet.init();

The servlet itself is just a thin wrapper registering handlers with the Atmosphere framework and setting the correct Websocket support:

public class AtmosphereDSServlet extends AtmosphereServlet {


private Datastore mDatastore;


protected static final Logger s_logger = LoggerFactory
.getLogger(AtmosphereDSServlet.class);

public AtmosphereDSServlet(final Datastore datastore) throws ServletException {
super();
mDatastore = datastore;
}


public void init() {
framework.addAtmosphereHandler("/chat", new ChatRoom());
framework.setAsyncSupport(new JettyServlet30AsyncSupportWithWebSocket(framework.getAtmosphereConfig()));
}
}

When the demo application wants to connect, it can load all the necessary JS from the HTTPService resources, but it can never complete the Websocket handshake. Debug log gives me this:

:37:37,841 [qtp809674942-24 - /app/js/index.js] DEBUG ContextHandler:993  - context=||/app/js/index.js @ o.e.j.s.ServletContextHandler{/,null}
15:37:37,844 [qtp809674942-24 - /app/js/index.js] DEBUG session:275  - Got Session ID 1h35mxzrwp74s1bk2nsh58qtp8 from cookie
15:37:37,844 [qtp809674942-24 - /app/js/index.js] DEBUG session:186  - sessionManager=org.eclipse.jetty.server.session.HashSessionManager@4335ed52
15:37:37,844 [qtp809674942-24 - /app/js/index.js] DEBUG session:187  - session=null
15:37:37,844 [qtp809674942-24 - /app/js/index.js] DEBUG ServletHandler:399  - servlet ||/app/js/index.js -> org.eclipse.equinox.http.jetty.internal.HttpServerManager$InternalHttpServiceServlet-2054775530
15:37:37,844 [qtp809674942-24 - /app/js/index.js] DEBUG ServletHandler:461  - chain=null
15:37:37,847 [qtp809674942-24 - /app/js/index.js] INFO  BasicHttpContext:28  - security path null
15:37:37,847 [qtp809674942-24 - /app/js/index.js] INFO  BasicHttpContext:35  - resource path static/js/index.js
15:37:37,848 [qtp809674942-24 - /app/js/index.js] DEBUG Server:347  - RESPONSE /app/js/index.js  304
15:37:37,849 [qtp809674942-24] DEBUG AsyncHttpConnection:206  - Enabled read interest SCEP@1358f1fa{l(/0:0:0:0:0:0:0:1:58697)<->r(/0:0:0:0:0:0:0:1:8080),d=true,open=true,ishut=false,oshut=false,rb=false,wb=false,w=true,i=1r}-{AsyncHttpConnection@4715f036,g=HttpGenerator{s=4,h=0,b=-1,c=-1},p=HttpParser{s=0,l=29,c=0},r=1}
15:37:37,851 [qtp809674942-24] DEBUG HttpParser:276  - filled 0/0
15:37:37,903 [qtp809674942-18 Selector0] DEBUG nio:837  - created SCEP@580930a4{l(/0:0:0:0:0:0:0:1:58703)<->r(/0:0:0:0:0:0:0:1:8080),d=false,open=true,ishut=false,oshut=false,rb=false,wb=false,w=true,i=0}-{AsyncHttpConnection@43588c23,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpParser{s=-14,l=0,c=0},r=0}
15:37:37,904 [qtp809674942-21] DEBUG HttpParser:276  - filled 795/795
15:37:37,904 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG Server:345  - REQUEST /chat/ on AsyncHttpConnection@43588c23,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpParser{s=-5,l=42,c=0},r=1
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG ContextHandler:921  - scope null||/chat/ @ o.e.j.s.ServletContextHandler{/,null}
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG ContextHandler:993  - context=||/chat/ @ o.e.j.s.ServletContextHandler{/,null}
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG session:275  - Got Session ID 1h35mxzrwp74s1bk2nsh58qtp8 from cookie
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG session:186  - sessionManager=org.eclipse.jetty.server.session.HashSessionManager@4335ed52
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG session:187  - session=null
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG ServletHandler:399  - servlet ||/chat/ -> org.eclipse.equinox.http.jetty.internal.HttpServerManager$InternalHttpServiceServlet-2054775530
15:37:37,905 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG ServletHandler:461  - chain=null
15:37:37,920 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG WebSocketFactory:395  - extensions=[]
15:37:37,946 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG WebSocketFactory:296  - Websocket upgrade /chat/ 13 null WebSocketServletConnectionRFC6455 p=WebSocketParserRFC6455@4b14cf96 state=START buffer=null g=WebSocketGeneratorRFC6455@4348a75c closed=false buffer=-1
15:37:37,946 [qtp809674942-21 - /chat/?X-Atmosphere-tracking-id=0&X-Atmosphere-Framework=2.2.6-_javascript_&X-Atmosphere-Transport=websocket&X-Atmosphere-TrackMessageSize=true&Content-Type=application/json&X-atmo-protocol=true] DEBUG Server:347  - RESPONSE /chat/  101
15:37:37,947 [qtp809674942-21] DEBUG AsyncHttpConnection:206  - Enabled read interest SCEP@580930a4{l(/0:0:0:0:0:0:0:1:58703)<->r(/0:0:0:0:0:0:0:1:8080),d=true,open=true,ishut=false,oshut=false,rb=false,wb=false,w=true,i=0r}-{AsyncHttpConnection@43588c23,g=HttpGenerator{s=4,h=0,b=-1,c=-1},p=HttpParser{s=0,l=42,c=0},r=1}
15:37:37,948 [qtp809674942-21] DEBUG nio:609  - WebSocketServletConnectionRFC6455 p=WebSocketParserRFC6455@4b14cf96 state=START buffer=null g=WebSocketGeneratorRFC6455@4348a75c closed=false buffer=-1 replaced AsyncHttpConnection@43588c23,g=HttpGenerator{s=0,h=-1,b=-1,c=-1},p=HttpParser{s=-14,l=0,c=-3},r=1
15:37:37,993 [qtp809674942-24] DEBUG HttpParser:276  - filled 395/395

I tried getting support from the Atmosphere guys but they could not give me any pointers. I found no related issues on the issue tracker and Jetty 8.1 seems well supported. I’d be glad for any pointers.

Thanks and all the best,
Kevin

Back to the top