基于websocket和java的多人聊天室

《基于websocket和java的多人聊天室》由会员分享，可在线阅读，更多相关《基于websocket和java的多人聊天室（11页珍藏版）》请在装配图网上搜索。

1、最新基于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;i

2、mport 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;

3、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 f

4、inal 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.getAndI

5、ncrement(); 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 disconnec

6、ted.); 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

7、: + 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.

8、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

9、 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 */ publi

10、c 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.a

11、ppend(>); 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;

12、 ); Chat.initialize(); document.addEventListener(DOMContentLoaded, function() / Remove elements with noscript class - is not allowed in XHTML var noscripts = document.getElementsByClassName(noscript); for (var i = 0; i Seems your browser doesnt support Javascript! Websockets rely on Javascript being enabled. Please enable Javascript and reload this page! 亲自测试：如果按照以上环节部署项目，保证能顺利运营。