现在的位置: 首页 > 综合 > 正文

Jetty9 搭建WebSocket简单例子

2014年08月11日 ⁄ 综合 ⁄ 共 1765字 ⁄ 字号 评论关闭

下载

最新的下载的地址已经移动到eclipse上:http://www.eclipse.org/jetty/downloads.php

目前的版本为9.0.0.M3

JDK版本要求7

所需要的类库

下载下来后,JETTY带了非常多的类库,经过测试发现,最简答的例子仅仅需要

javax.websocket-api-0.0.006.draft.jar
jetty-http-9.0.0.M3.jar
jetty-io-9.0.0.M3.jar
jetty-security-9.0.0.M3.jar
jetty-server-9.0.0.M3.jar
jetty-servlet-9.0.0.M3.jar
jetty-util-9.0.0.M3.jar
servlet-api-3.0.jar
websocket-api-9.0.0.M3.jar
websocket-common-9.0.0.M3.jar
websocket-server-9.0.0.M3.jar
websocket-servlet-9.0.0.M3.jar

创建最简单的WEB服务

建立Eclipse后,先建立一个启动类

Server server = new Server(8080);
try {
	server.start();
	server.join();
} catch (Exception e) {

	e.printStackTrace();
}

这样一个最简单对外提供WEB服务,默认都返回404

创建一个WebSocketServlet

从官网查看例子,MyEchoSocket和MyEchoServlet,BAIDU一下也有很多转载
唯一的变化是在接受请求连接的时候,向客户端发送一个包
	@Override
	public void onWebSocketConnect(WebSocketConnection connection) {
		this.outbound = connection;
		try {
			outbound.write("ok");
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
加入到Server中
		Server server = new Server(8080);
		try {
			HandlerList handlerList = new HandlerList();
			ServletContextHandler context = new ServletContextHandler(
					ServletContextHandler.SESSIONS);
			context.setContextPath("/");
			context.addServlet(new ServletHolder(new MonitorStatusServlet()),
					"/monitor");
			context.addServlet(new ServletHolder(new MyEchoServlet()), "/echo");
			handlerList.addHandler(context);
			handlerList.addHandler(new DefaultHandler());
			server.setHandler(handlerList);

			server.start();
			server.join();
		} catch (Exception e) {

			e.printStackTrace();
		}

	}

其中MonitorStatusServlet是返回当前的状态,DefualtHandler用于实现其它任何请求都返回FORBIDDEN

/echo则调用WebSocket


编写客户端测试

<script type="text/javascript">
	var url = "ws://192.168.1.200:8080/echo";
	
	
	if(window.MozWebSocket) {
		this.connection = new MozWebSocket(url);
	} else {
		this.connection = new WebSocket(url);
	}

	 this.connection.onmessage = function(e) {
		alert(e.data);
	};

	this.connection.onopen = function(e) {
		this.connection.send("123456");
	};

	


            
</script>

抱歉!评论已关闭.