基于websocket和java的多人聊天室

最新基于最新基于 websocketwebsocket 与与 javajava 的多人聊天室的多人聊天室 实现架构实现架构 html5+websocket+javaEE7+tomcat8html5+websocket+javaEE7+tomcat8 JavaEE7JavaEE7 最新的最新的 websocket1.0websocket1.0 APIAPI Tomcat8Tomcat8 开始支持开始支持 websocket1.0websocket1.0 APIAPI 【Tomcat【Tomcat implementsimplements thethe JavaJava WebSocketWebSocket 1.01.0 APIAPI defineddefined byby JSR-356】JSR-356】 在编写代码之前你要导入在编写代码之前你要导入 javaEE7javaEE7 的的 jarjar 包以便使用包以便使用 websocketwebsocket APIAPI，将此，将此 项目部署到项目部署到 tomcat8tomcat8 里面。里面。 具体代码如下：具体代码如下： JavaJava 端：端： ChatAnnotationChatAnnotation 类；类； 使用的是注解的方式。使用的是注解的方式。 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); 3 / 8 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.jarjuli.jar 包可以百度一下自行包可以百度一下自行 下载。下载。 util.HTMLFilterutil.HTMLFilter 类如下：类如下： HTMLFilterHTMLFilter 类。类。 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(); 5 / 8 message.getChars(0, message.length(), content, 0); StringBuilder result = new StringBuilder(content.length + 50); for (int i = 0; i : result.append(“); break; case “); break; case “: result.append(“); break; default: result.append(contenti); return (result.toString(); 接下来是接下来是 webweb 端：端： Chat.xhtmlChat.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 (v