websocket兼容IE678

package com.server; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.servlet.http.HttpServletRequest; import org.apache.catalina.websocket.MessageInbound; import org.apache.catalina.websocket.StreamInbound; import org.apache.catalina.websocket.WebSocketServlet; import org.apache.catalina.websocket.WsOutbound; import com.talk.TalkManager; public class ServerSocket extends WebSocketServlet { private static final long serialVersionUID = -4853540828121130946L; public static Map<String, List<MyMessageInbound>> clients = new ConcurrentHashMap<String, List<MyMessageInbound>>(); private String user_id ; @Override protected StreamInbound createWebSocketInbound(String arg0, HttpServletRequest request) { user_id = request.getParameter( "user_id" ); return new MyMessageInbound(); } public class MyMessageInbound extends MessageInbound { public WsOutbound myoutbound; public String userId = user_id ; @Override public void onOpen(WsOutbound outbound) { try { System.out.println("Open>>>>>>用户ID为" + userId + "建立连接" ); this.myoutbound = outbound; if (clients.containsKey(userId)){ List<MyMessageInbound> list = clients.get(userId); list.add(this); clients.put(userId, list); }else{ List<MyMessageInbound> list = new ArrayList<MyMessageInbound>(); list.add(this); clients.put(userId, list); } outbound.writeTextMessage(CharBuffer.wrap("Hello!")); } catch (IOException e) { e.printStackTrace(); } } @Override public void onTextMessage(CharBuffer cb) throws IOException { System.out.println("服务器收到消息 : " + cb); TalkManager.broadcast(cb.toString()); } @Override public void onClose(int status) { if( status == 1002 || status == 1000) { System.out.println("Close>>>>>>用户ID为" + userId + "断开连接" ); List<MyMessageInbound> list = clients.get(userId); list.remove(this); } } @Override public void onBinaryMessage(ByteBuffer bb) throws IOException { } } }