package websocket;import java.io.IOException;import javax.servlet.ServletException;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import org.apache.catalina.websocket.WebSocketServlet; import org.apache.catalina.websocket.StreamInbound;public class WebSocketMessageServlet extends WebSocketServlet{ /** * */ private static final long serialVersionUID = 1L; private String username; @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { this.username = (String)req.getSession().getAttribute("user_nickname"); super.doGet(req, resp); } @Override protected StreamInbound createWebSocketInbound(String arg0, HttpServletRequest arg1) { // TODO Auto-generated method stub return new WebSocketMessageInboundPool(this.username); } }
package websocket;import java.io.IOException;import java.nio.CharBuffer;import java.nio.ByteBuffer;import java.util.HashMap;import java.util.Map;import org.apache.catalina.websocket.MessageInbound;import org.apache.catalina.websocket.WsOutbound;public class WebSocketMessageInboundPool extends MessageInbound{ private final String user_nickname; private static final Map<String,WebSocketMessageInboundPool > Connections = new HashMap<String,WebSocketMessageInboundPool>(); public WebSocketMessageInboundPool(String username){ this.user_nickname=username; } protected void onOpen(WsOutbound outbound) { // TODO Auto-generated method stub addMessageInbound(this); super.onOpen(outbound); } protected void onBinaryMessage(ByteBuffer arg0) throws IOException { // TODO Auto-generated method stub // 向所有已连接的客户端发送文本消息 try { //向特定的用户发送数据 WebSocketMessageInboundPool inbound = Connections.get(user_nickname); if(inbound != null){ ByteBuffer bb = ByteBuffer.wrap(arg0.array()); WsOutbound wb = inbound.getWsOutbound(); wb.writeBinaryMessage(bb); wb.flush(); } } catch (IOException e) { e.printStackTrace(); } } protected void onTextMessage(CharBuffer arg0) throws IOException { // TODO Auto-generated method stub try { //向特定的用户发送数据 WebSocketMessageInboundPool inbound = Connections.get(user_nickname); if(inbound != null){ CharBuffer cb = CharBuffer.wrap(arg0); WsOutbound wb = inbound.getWsOutbound(); wb.writeTextMessage(cb); wb.flush(); } } catch (IOException e) { e.printStackTrace(); } } protected void onClose(int status) { // TODO Auto-generated method stub removeMessageInbound(this); super.onClose(status); } //向连接池中添加连接 public static void addMessageInbound(WebSocketMessageInboundPool inbound){ //添加连接 Connections.put(inbound.user_nickname, inbound); } public static void removeMessageInbound(WebSocketMessageInboundPool inbound){ //移除连接 Connections.remove(inbound.user_nickname); }}
我的握手链接是ws = new WebSocket("ws://localhost:8080/websocket/web"); // 本地
xml配置:
<?xml version="1.0" encoding="UTF-8"?><web-app version="3.0" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"> <display-name></display-name> <servlet> <servlet-name>WebSocketMessageServlet</servlet-name> <servlet-class>websocket.WebSocketMessageServlet</servlet-class> </servlet> <servlet-mapping> <servlet-name>WebSocketMessageServlet</servlet-name> <url-pattern>/web</url-pattern> </servlet-mapping> <welcome-file-list> <welcome-file>index.jsp</welcome-file> </welcome-file-list></web-app>
但是我本地tomcat测试了还是不行,
tomcat项目lib文件夹下的jar包全都要删掉吗?
回复讨论(解决方案)
up..........................
木有人会吗?
public class WebSocketMessageServlet extends WebSocketServlet{ protected StreamInbound createWebSocketInbound(String arg0) { System.out.println("$$$$$$$$"); return new WebSocketMessageInboundPool("1"); }
这样写就能握手,太奇怪了,明明要重载父类抽象方法才是正确的。
我在浏览器上F12看了一下,错误是这样说的
楼主你的xml配置有问题!

本文讨论了html&lt; datalist&gt;元素,通过提供自动完整建议,改善用户体验并减少错误来增强表格。Character计数:159

本文讨论了HTML&lt; Progress&gt;元素,其目的,样式和与&lt; meter&gt;元素。主要重点是使用&lt; progress&gt;为了完成任务和LT;仪表&gt;对于stati

本文讨论了HTML&lt; meter&gt;元素,用于在一个范围内显示标量或分数值及其在Web开发中的常见应用。它区分了&lt; meter&gt;从&lt; progress&gt;和前

本文讨论了视口元标签,这对于移动设备上的响应式Web设计至关重要。它解释了如何正确使用确保最佳的内容缩放和用户交互,而滥用可能会导致设计和可访问性问题。

本文讨论了&lt; iframe&gt;将外部内容嵌入网页,其常见用途,安全风险以及诸如对象标签和API等替代方案的目的。

本文解释了HTML5&lt; time&gt;语义日期/时间表示的元素。 它强调了DateTime属性对机器可读性(ISO 8601格式)的重要性,并在人类可读文本旁边,增强Accessibilit

本文讨论了使用HTML5表单验证属性,例如必需的,图案,最小,最大和长度限制,以直接在浏览器中验证用户输入。


热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

AI Hentai Generator
免费生成ai无尽的。

热门文章

热工具

Atom编辑器mac版下载
最流行的的开源编辑器

Dreamweaver Mac版
视觉化网页开发工具

VSCode Windows 64位 下载
微软推出的免费、功能强大的一款IDE编辑器

适用于 Eclipse 的 SAP NetWeaver 服务器适配器
将Eclipse与SAP NetWeaver应用服务器集成。

EditPlus 中文破解版
体积小,语法高亮,不支持代码提示功能