解决浏览器不兼容websocket

2018-02-04 667 收藏

解决浏览器不兼容websocke原文地址thttp://www.bieryun.com/935.html

本例使用tomcat 7.0的websocket做为例子。

1.新建web project。
2.找到tomcat 7.0 lib 下的 catalina.jar,tomcat-coyote.jar添加到项目中.
3.如下是我的目录结构

web.xml的配置.

[html] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>
2. <web-app version="2.5" xmlns="http://java.sun.com/xml/ns/javaee"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd">
5.     <display-name>Archetype Created Web Application</display-name>
6.     <servlet>
7.         <servlet-name>serverSocket</servlet-name>
8.         <servlet-class>com.sun.websocket.server.ServerSocket</servlet-class>
9.     </servlet>
10.     <servlet-mapping>
11.         <servlet-name>serverSocket</servlet-name>
12.         <url-pattern>/serverSocket</url-pattern>
13.     </servlet-mapping>
15.       <welcome-file-list>
16.         <welcome-file>index.jsp</welcome-file>
17.       </welcome-file-list>
18. </web-app>

ServerSocket.java的源码.

[java] view plain copy

1. package com.sun.websocket.server;
3. import java.io.IOException;
5. import java.nio.ByteBuffer;
6. import java.nio.CharBuffer;
7. import java.util.ArrayList;
8. import java.util.HashMap;
9. import java.util.List;
10. import java.util.Map;
11. import java.util.UUID;
12. import java.util.concurrent.ConcurrentHashMap;
14. import javax.servlet.http.HttpServletRequest;
16. import org.apache.catalina.websocket.MessageInbound;
17. import org.apache.catalina.websocket.StreamInbound;
18. import org.apache.catalina.websocket.WebSocketServlet;
19. import org.apache.catalina.websocket.WsOutbound;
21. public class ServerSocket extends WebSocketServlet {
23.     private static final long serialVersionUID = -4853540828121130946L;
24.     private static Map< String , MyMessageInbound> mmiList = new ConcurrentHashMap< String , MyMessageInbound >();
25.     private String message_to ;
26.     private String message_me ;
28.     @Override
29.     protected StreamInbound createWebSocketInbound(String arg0, HttpServletRequest request) {
30.         message_me = request.getParameter( "message_me" );
31.         message_to = request.getParameter( "message_to" );
32.         return new MyMessageInbound();
33.     }
35.     private class MyMessageInbound extends MessageInbound  {
36.         WsOutbound myoutbound;
37.         private String me = message_me ;
38.         private String to = message_to ;
40.         @Override
41.         public void onOpen(WsOutbound outbound) {
42.             try {
43.                 System.out.println("Open " + me + " to " + to);
44.                 this.myoutbound = outbound;
45.                 mmiList.put( me , this );
46.                 outbound.writeTextMessage(CharBuffer.wrap("Hello!"));
47.             } catch (IOException e) {
48.                 e.printStackTrace();
49.             }
50.         }
52.         @Override
53.         public void onTextMessage(CharBuffer cb) throws IOException {
54.             System.out.println("Accept Message : " + cb);
55.             for ( String mmib : mmiList.keySet() ) {
56.                 if ( !to.equals(mmib) )
57.                     continue;
58.                 try
59.                 {
60.                     CharBuffer buffer = CharBuffer.wrap(cb);
61.                     mmiList.get(mmib).myoutbound.writeTextMessage(buffer);
62.                     mmiList.get(mmib).myoutbound.flush();
63.                 }
64.                 catch (Exception e) {
65.                     continue;
66.                 }
67.                 break;
68.             }
69.         }
71.         @Override
72.         public void onClose(int status) {
73.             if( status == 1002 || status == 1000)
74.             {
75.                 System.out.println("Close " + me + " to " + to);
76.                 mmiList.remove(this);
77.             }
78.         }
80.         @Override
81.         public void onBinaryMessage(ByteBuffer bb) throws IOException {
82.         }
84.     }
85. }

接下来编写index.jsp

[html] view plain copy

1. <%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
2. <%
3. String path = request.getContextPath();
4. String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
5. %>
7. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
8. <html>
9.   <head>
10.     <base href="<%=basePath%>">
12.     <title>My JSP 'index.jsp' starting page</title>
13.     <meta http-equiv="pragma" content="no-cache">
14.     <meta http-equiv="cache-control" content="no-cache">
15.     <meta http-equiv="expires" content="0">
16.     <meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
17.     <meta http-equiv="description" content="This is my page">
19.     <script type="text/javascript" src="scripts/swfobject.js"></script>
20.     <script type="text/javascript" src="scripts/jquery.js"></script>
21.     <script type="text/javascript" src="scripts/web_socket.js"></script>
22.     <script type="text/javascript" src="scripts/jquery.WebSocket.js"></script>
23.     <%
24.         String message_to = request.getParameter( "message_to" );
25.         String message_me = request.getParameter( "message_me" );
26.         request.setAttribute( "message_to" , message_to );
27.         request.setAttribute( "message_me" , message_me );
28.     %>
29. <script>
30.     $(function ()
31.     {
32.         window.onbeforeunload = onbeforeunload_handler;
33.         window.onunload = onunload_handler;
34.         function onbeforeunload_handler(){
35.             //ws.close();
36.             return warning;
37.         }
38.         function onunload_handler()
39.         {
40.             //alert(1);
41.             ws = null;
42.         }
43.     });
44.     var message_to = "${message_to}";
45.     var message_me = "${message_me}";
46.     //var ws = new WebSocket("ws://192.168.202.56:8080/websocket_msg/serverSocket?message_to="+message_to+"&message_me="+message_me);
47.     var url = "websocket_msg/serverSocket?message_to="+message_to+"&message_me="+message_me;
48.     var ws = new $.websocket({
49.         protocol : "websocket_msg/serverSocket?message_to="+message_to+"&message_me="+message_me,
50.         domain : "192.168.1.120",
51.         port : "8080",
52.         onOpen:function(event){
53.             showMessage("已成功登录");
54.         },
55.         onError:function(event){
56.              alert("error:"+ event)
57.         },
58.         onMessage:function(result){
59.             receiveMessage(result);
60.         },
61.         onClose:function(event){
62.             ws = null;
63.         }
64.     });
66.     function send(){
67.         if(!ws){
68.             alert("已经断开聊天室");
69.             return;
70.         }
71.          var msg=$.trim($("#msg").val());
72.          if(msg==""){return;}
73.          ws.send(msg);
74.          $("#messageInput").val("").focus();;
75.     }
77.     function receiveMessage(result){
78.         showMessage(result);
79.     }
81.     function showMessage(msg){
82.         document.getElementById("chatlog").textContent += msg + "\n";
83.     }
84. </script>
85.   </head>
87.   <body>
88.     <body>
89.         <textarea id="chatlog" readonly style="width:500px;height:500px;"></textarea><br/>
90.         <input id="msg" type="text" />
91.         <button type="submit" id="sendButton" onClick="send()">Send!</button>
92.         <button type="submit" id="sendButton" onClick="closeConnect()">End</button>
93.     </body>
94.   </body>
95. </html>

编写完成后，访问index.jsp时需要URL给出两个参数。一个代表发送者，一个代表接收者。

[html] view plain copy

1. 例如 ?message_to=1&message_me=2"

上一篇 下一篇

微信关注我们

原文链接：https://yq.aliyun.com/articles/433514

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

pdf.js远程加载

pdf.js一个基于Html的工具类，熟悉pdf.js的朋友们很清楚，pdf.js帮助我们做了很多事。尤其金融类网站会产生很多的报表。需要在线预览。pdf.js绝对是我们的首选 本地预览 在pdf.js的官网上下载的demo中我们就可以直接进行预览。官网的案列在web文件夹下的view.html。这里我整理了一个pdf.js精简版的。 这两个demo里面加载的是本地文件。这里没什么说的。其中demo2的效果如下。代码也很简单： pdfjs 为我们做了其他的操作，。我们通过pdfjs只需要将本地文件当做参数传递给viewer.html就可以了。 远程加载(跨域) 通过上面我们很轻松在实际项目中实现pdf的预览。但是这样的预览存在一个问题。我们分布式项目中往往资源服务和业务服务不在同一台服务器上。这个时候我们在对文件进行预览就时跨域操作了。遇到这个问题我想当然的将上面的a.pdf 换成了我们远程pdf地址了。 首先看看我们的远程文件是否正常 然后再看看我们的代码修改是否正常 所有的就绪后，我很高兴的刷新了demo2的页面并进行了操作。但是令人很失望。报错了 报错大概的意思就是文件没找到。为...

2018-02-05

655

上一篇

JSP第二篇【内置对象的介绍、4种属性范围、应用场景】

什么是JSP内置对象 JSP引擎在调用JSP对应的jspServlet时，会传递或创建9个与web开发相关的对象供jspServlet使用。JSP技术的设计者为便于开发人员在编写JSP页面时获得这些web对象的引用，特意定义了9个相应的变量，开发人员在JSP页面中通过这些变量就可以快速获得这9大对象的引用 细心的朋友会发现，我们没有在JSP页面上定义过out对象，却可以直接使用！其实out对象就是JSP内置对象之一。 九个内置对象： pageContext page config request response session application exception out out对象 out对象的API int getBufferSize()【得到缓存大小】 int getRemaining()【得到未使用缓存的大小】 boolean isAutoFlush() void println() void flush() void close() void clearBuffer() void clear() out对象用于向浏览器输出数据，与之对应的是Servlet的PrintW...

2018-02-05

513

下一篇

相关文章

发表评论

发表

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

时间: 2025-12-03 大小: 4.36MB 下载: 23次

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称，一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集，帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

时间: 2025-12-13 大小: 189MB 下载: 0次

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

时间: 2025-12-13 大小: 5MB 下载: 0次

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。

时间: 2025-12-13 大小: 1.42GB 下载: 0次