Jetty websocket
使用jetty版本：jetty-websocket-8.0.4.v20111024.jar使用servletapi版本：3.0
服务器端servlet继承 WebSocketServlet 实现websocket连接。如下代码：
public class Communicate extends WebSocketServlet {private static final long serialVersionUID = 5933410218860858657L;private static List<WSocket> clients = new ArrayList<WSocket>();
@Overridepublic WebSocket doWebSocketConnect(HttpServletRequest arg0, String arg1) {WSocket wsClinet = new WSocket();clients.add(wsClinet);
return wsClinet;}
public static List<WSocket> getClients() {return clients;}
public static void setClients(List<WSocket> clients) {Communicate.clients = clients;}}
使用自定义的文本消息的websocket：
public class WSocket implements OnTextMessage {private Connection connection;
@Overridepublic void onClose(int arg0, String arg1) {System.out.println("*** close:" + arg1);}
@Overridepublic void onOpen(Connection arg0) {System.out.println("*** open:" + arg0.getProtocol());connection = arg0;}
@Overridepublic void onMessage(String arg0) {List<WSocket> clients = Communicate.getClients();if (null == clients) {return;}
for (WSocket ws: clients) {try {Connection ct = ws.getConnection();if(null!= ct && ct.isOpen()) {ct.sendMessage(arg0);}} catch (IOException e) {System.out.println("*** send message exception.");e.printStackTrace();}}}
public Connection getConnection() {return connection;}}
实现逻辑：当接收到消息的时候，给各个客户端轮发。
web.xml配一个servlet：
<servlet>
<servlet-name>communicate</servlet-name>
<servlet-class>com.websocket.service.Communicate</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>communicate</servlet-name>
<url-pattern>communicate.htm</url-pattern>
</servlet-mapping>
页面代码：
<script>
if(!window.WebSocket) {alert("not support websocket.");}
var socket = new WebSocket("ws://localhost:8080/WebSocketDemo/communicate.htm");socket.onmessage = function(evt) {alert(evt.data);}
socket.onclose = function() {alert("close.");}
socket.onopen = function() {alert("open connection.");}
function sendMsg() {socket.send('data');}</script>
页:
[1]