<dependency>
			<groupId>org.eclipse.jetty</groupId>
			<artifactId>jetty-webapp</artifactId>
			<version>8.1.2.v20120308</version>
		</dependency>
		<dependency>
        	<groupId>org.eclipse.jetty</groupId>
        	<artifactId>jetty-websocket</artifactId>
        	<version>8.1.2.v20120308</version>
    	</dependency>

package kzg.html5.websocket;

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import javax.servlet.http.HttpServletRequest;

import net.sf.json.JSONObject;

import org.eclipse.jetty.websocket.WebSocket;
import org.eclipse.jetty.websocket.WebSocketServlet;

@SuppressWarnings("serial")
public class DebugLogWsSocket extends WebSocketServlet
{

	@Override
	public WebSocket doWebSocketConnect(HttpServletRequest request, String protocol)
	{
		LogService.debug("websocket request protocol:" + protocol);

		return new TestSocket();
	}

	private static class TestSocket implements WebSocket.OnTextMessage
	{
		ExecutorService service;
		Connection conn;

		private boolean clientStop = false;

		@Override
		public void onClose(int code, String message)
		{
			LogService.debug("websocket close:" + code + ":" + message);
			setClientStop(true);
			if (null != service)
			{
				service.shutdown();
			}
		}

		private void sendData(Object data)
		{
			JSONObject respj = new JSONObject();
			respj.put("status", "ok");
			respj.put("data", data);
			if (null == conn || !conn.isOpen())
			{
				return;
			}
			try
			{
				conn.sendMessage(respj.toString());
			}
			catch (IOException e)
			{
				LogService.error("websocket send data error:", e);
			}
		}

		@Override
		public void onOpen(final Connection aconn)
		{
			this.conn = aconn;
			LogService.debug("websocket open:" + conn.getProtocol());

			service = Executors.newSingleThreadExecutor();
			service.execute(new Runnable() {

				@Override
				public void run()
				{

					while (!isClientStop())
					{
						sendData(System.currentTimeMillis());
						try
						{
							TimeUnit.SECONDS.sleep(1);
						}
						catch (InterruptedException e)
						{
							return;
						}
					}
				}
			});
		}

		@Override
		public void onMessage(final String message)
		{
			LogService.debug("websocket incomming message:" + message);
			sendData("server got message:" + message);
		}

		public synchronized boolean isClientStop()
		{
			return clientStop;
		}

		public synchronized void setClientStop(boolean clientStop)
		{
			this.clientStop = clientStop;
		}

	}

}

<!DOCTYPE web-app PUBLIC
	 "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
	 "http://java.sun.com/dtd/web-app_2_3.dtd" >

<web-app>
	
  <servlet>
    <servlet-name>DebugLogServlet</servlet-name>
    <servlet-class>kzg.html5.websocket.DebugLogWsSocket</servlet-class>
  </servlet>

  <servlet-mapping>
    <servlet-name>DebugLogServlet</servlet-name>
    <url-pattern>/dlog/</url-pattern>
  </servlet-mapping>	
</web-app>

function strat_socket() {
		var error_count = 0;
		var url = 'ws://' + document.location.host + '/dlog/';
		ws = new WebSocket(url);
		ws.onopen = function() {
			log('ws open');
		};
		ws.onerror = function(e) {
			log('ws error');
		};
		ws.onclose = function() {
			log('ws close');
		};
		ws.onmessage = function(msg) {
			log('ws message:');
			log(msg);
			var d = $.parseJSON(msg.data);
			if (!d || 'error' == d.status) {
				error_count++;

				if (error_count > 3) {
					alert('poll error many times.');

					return;
				}

				return;
			}

			process_log(d.data,true);
		};
	}

data
	"{"status":"ok","data":1334634452781}"
	
defaultPrevented
	false
	
lastEventId
	""
	
origin
	"ws://localhost:20090"
	
source
	null
	
initMessageEvent
	initMessageEvent()
	
stopImmediatePropagation
	stopImmediatePropagation()
	
bubbles
	false
	
cancelable
	false
	
constructor
	MessageEvent {}
	
currentTarget
	WebSocket { url="ws://localhost:20090/dlog/", readyState=3, bufferedAmount=0, more...}
	
eventPhase
	2
	
explicitOriginalTarget
	WebSocket { url="ws://localhost:20090/dlog/", readyState=3, bufferedAmount=0, more...}
	
isTrusted
	true
	
originalTarget
	WebSocket { url="ws://localhost:20090/dlog/", readyState=3, bufferedAmount=0, more...}
	
target
	WebSocket { url="ws://localhost:20090/dlog/", readyState=3, bufferedAmount=0, more...}
	
timeStamp
	1334634452921000
	
type
	"message"

//1000 or 3000-4999
ws.close(3001,'my close');

ws.send('hello');