问题描述
- 学习JavaEE中，使用WebSocket的问题
- 最近刚刚学习了JSP／Servlet的知识，书上有讲WebSocket的技术，自己想实现一下，但总是有问题，如下图：
源代码如下：
/*页面脚本*/ <!DOCTYPE html><html><head><meta http-equiv=""Content-Type"" content=""text/html; charset=UTF-8"" /><title>使用WebSocket通信</title><script type=""text/javascript""> var webSocket=new WebSocket(""ws://127.0.0.1:8080/WebSocket/websocket/chat""); var sendMsg=function() { var inputElement=document.getElementById('msg'); //发送信息 webSocket.send(inputElement.value); //清空单行文本框 inputElement.value=""""; }; var send=function(event) { if(event.keyCode==13) { sendMsg(); } }; webSocket.onopen = funcntion() { alert(""hello webSocket!""); //为onmessage事件绑定监听器，接收消息 webSocket.onmessage = function(event) { var show = document.getElementById('show'); //接收并显示消息 show.innerHTML+= event.data + ""<br/>""; show.scrollTop = show.scrollHeight; } document.getElementById('msg').onkeydown = send; document.getElementById('sendBn').onclick = sendMsg; }; webSocket.onclose = function() { document.getElementById('msg').onkeydown = null; document.getElementById('sendBn').onclick = null; Console.log('WebSocket已经关闭。'); };</script></head><body> <div style=""width:600px; height:240px; overflow-y:auto;border:1px solid #333;"" id=""show""></div> <input type=""text"" size=""80"" id=""msg"" name=""msg"" placeholder=""输入聊天内容""/> <input type=""button"" value=""发送"" id=""sendBn"" name=""sendBn""/> </body></html>//实现的Java类 package com.xlf;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.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;@ServerEndpoint(value = ""/websocket/chat"")public class ChatEntpoint { private static final String GUEST_PREFIX = ""访客""; private static final AtomicInteger connectionIds = new AtomicInteger(0); // 定义一个集合，用于保存所有接入的WebSocket客户端 private static final Set<ChatEntpoint> clientSet = new CopyOnWriteArraySet<ChatEntpoint>(); private final String nickname; private Session session; public ChatEntpoint() { nickname = GUEST_PREFIX + connectionIds.getAndIncrement(); } // 当客户端连接进来时自动激发该方法 @OnOpen public void start(Session session) { this.session = session; clientSet.add(this); String message = String.format(""[%s %s]"" nickname加入了聊天室！""); broadcast(message); } // 当客户端断开连接时自动激发该方法 @OnClose public void end() { clientSet.remove(this); String message = String.format(""[%s %s]"" nickname离开了聊天室！""); broadcast(message); } // 每当收到客户端消息时自动激发该方法 @OnMessage public void incoming(String message) { String filterMessage = String .format(""%s %s"" nickname filter(message)); broadcast(filterMessage); } public static void broadcast(String msg) { for (ChatEntpoint client : clientSet) { try { synchronized (client) { //发送消息 client.session.getBasicRemote().sendText(msg); } } catch (IOException e) { System.out.println(""聊天错误，向客户端 ""+client+"" 发送消息出现错误。""); clientSet.remove(client); try { client.session.close(); } catch (IOException e1) {} String message=String.format(""[%s %s]"" client.nickname已经被断开了""); broadcast(message); } } } public static String filter(String message){ if(message==null) return null; char content[]=new char[message.length()]; message.getChars(0 message.length() content 0); StringBuilder result=new StringBuilder(content.length+50); for (int i = 0; i < content.length; i++) { switch (content[i]) { case '<': result.append(""<""); break; case '>': result.append("">""); break; case '&': result.append(""&""); break; case '""': result.append("""""); break; default: result.append(content[i]); break; } } return (result.toString()); }}新人，希望有大神指教！
解决方案
应该是function() 拼写错误吧？
时间： 2024-10-30 11:00:37