websocket

packagecom.byteslounge.websockets;

importjava.io.IOException;

importjavax.websocket.OnClose;

importjavax.websocket.OnMessage;

importjavax.websocket.OnOpen;

importjavax.websocket.Session;

importjavax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")

publicclassWebSocketTest{

@OnMessage

publicvoidonMessage(Stringmessage,Sessionsession)

throwsIOException,InterruptedException{

//Printtheclientmessagefortestingpurposes

System.out.println("Received:"+message);

//Sendthefirstmessagetotheclient

session.getBasicRemote().sendText("Thisisthefirstservermessage");

//Send3messagestotheclientevery5seconds

intsentMessages=0;

while(sentMessages<3){

Thread.sleep(5000);

session.getBasicRemote().

sendText("Thisisanintermediateservermessage.Count:"

+sentMessages);

sentMessages++;

}

//Sendafinalmessagetotheclient

session.getBasicRemote().sendText("Thisisthelastservermessage");

}

@OnOpen

publicvoidonOpen(){

System.out.println("Clientconnected");

}

@OnClose

publicvoidonClose(){

System.out.println("Connectionclosed");

}

}

varwebSocket=

newWebSocket('ws://localhost:8080/byteslounge/websocket');

webSocket.onerror=function(event){

onError(event)

};

webSocket.onopen=function(event){

onOpen(event)

};

webSocket.onmessage=function(event){

onMessage(event)

};

functiononMessage(event){

document.getElementById('messages').innerHTML

+='<br/>'+event.data;

}

functiononOpen(event){

document.getElementById('messages').innerHTML

='Connectionestablished';

}

functiononError(event){

alert(event.data);

}

functionstart(){

webSocket.send('hello');

returnfalse;

}