基于websocket和java的多人聊天室.docx

最新基于websocket与java的多人聊天室实现架构 html5+websocket+javaEE7+tomcat8JavaEE7 最新的websocket1.0 APITomcat8开始支持websocket1.0 API【Tomcat implements the Java WebSocket 1.0 API defined by JSR-356】在编写代码之前你要导入javaEE7的jar包以便使用websocket API，将此项目部署到tomcat8里面。具体代码如下：Java端：ChatAnnotation类；使用的是注解的方式。package websocket.chat;import java.io.IOException;import java.util.Set;import java.util.concurrent.CopyOnWriteArraySet;import java.util.concurrent.atomic.AtomicInteger;import javax.websocket.OnClose;import javax.websocket.OnError;import javax.websocket.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;import org.apache.juli.logging.Log;import org.apache.juli.logging.LogFactory;import util.HTMLFilter;ServerEndpoint(value = /websocket/chat)public class ChatAnnotation private static final Log log = LogFactory.getLog(ChatAnnotation.class); private static final String GUEST_PREFIX = Guest; private static final AtomicInteger connectionIds = new AtomicInteger(0); private static final Set connections = new CopyOnWriteArraySet(); private final String nickname; private Session session; public ChatAnnotation() nickname = GUEST_PREFIX + connectionIds.getAndIncrement(); OnOpen public void start(Session session) this.session = session; connections.add(this); String message = String.format(* %s %s, nickname, has joined.); broadcast(message); OnClose public void end() connections.remove(this); String message = String.format(* %s %s, nickname, has disconnected.); broadcast(message); OnMessage public void incoming(String message) / Never trust the client String filteredMessage = String.format(%s: %s, nickname, HTMLFilter.filter(message.toString(); broadcast(filteredMessage); OnError public void onError(Throwable t) throws Throwable log.error(Chat Error: + t.toString(), t); private static void broadcast(String msg) for (ChatAnnotation client : connections) try synchronized (client) client.session.getBasicRemote().sendText(msg); catch (IOException e) log.debug(Chat Error: Failed to send message to client, e); connections.remove(client); try client.session.close(); catch (IOException e1) / Ignore String message = String.format(* %s %s, client.nickname, has been disconnected.); broadcast(message); 里面的juli.jar包可以百度一下自行下载。util.HTMLFilter类如下：HTMLFilter类。package util;/* * HTML filter utility. * * author Craig R. McClanahan * author Tim Tye */public final class HTMLFilter /* * Filter the specified message string for characters that are sensitive * in HTML. This avoids potential attacks caused by including JavaScript * codes in the request URL that is often reported in error messages. * * param message The message string to be filtered */ public static String filter(String message) if (message = null) return (null); char content = new charmessage.length(); message.getChars(0, message.length(), content, 0); StringBuilder result = new StringBuilder(content.length + 50); for (int i = 0; i content.length; i+) switch (contenti) case : result.append(>); break; case &: result.append(&); break; case : result.append("); break; default: result.append(contenti); return (result.toString(); 接下来是web端：Chat.xhtml Apache Tomcat WebSocket Examples: Chat 25) console.removeChild(console.firstChild); console.scrollTop = console.scrollHeight; ); Chat.initialize(); document.addEventListener(DOMContentLoaded, function() / Remove elements with noscript class - is not allowed in XHTML var noscripts = document.getElementsByClassName(noscript); for