`
longgangbai
  • 浏览: 7238486 次
  • 性别: Icon_minigender_1
  • 来自: 上海
社区版块
存档分类
最新评论
阅读更多

             在开始学习GUI的SOCKET编程时,就一直有一个梦想,希望有一天能将这种聊天程序在WEB上实现,虽然QQ和许多其它的聊天程序已经实现,但是他们的实现都使用的是AJAX,无非是对AJAX进行改进,或者使用FLEX,个人认为那样实现太复杂,没有研究!!几个星期前终天有时间研究了,使用jetty来编写聊天程序,后来聊天都实现了,但是jetty服务器没有使用过,中间配服务器差不多用了一个星期,让我很纠结,最后在实验室的电脑可以成功运行!!!不过可悲的是当我移植到我的笔记本时,却出现在了各种怪错!!于是,我又纠结了,今天晚上,奇迹的发现tomcat竟然也支持了,所以果然的下载了tomcat7.0.27来测试,惊人的发现与jetty实现相似,所以写了一个小测试程序,测试成功!!下面贴上我的代码,有兴趣的童鞋可以一起学习哦!!!! 
index.jsp 

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%> 
<% 
    String path = request.getContextPath(); 
    String basePath = request.getScheme() + "://" 
            + request.getServerName() + ":" + request.getServerPort() 
            + path + "/"; 
%> 

<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN"> 
<html> 
<head> 
<base href="<%=basePath%>"> 

<title>My JSP 'index.jsp' starting page</title> 
<meta http-equiv="pragma" content="no-cache"> 
<meta http-equiv="cache-control" content="no-cache"> 
<meta http-equiv="expires" content="0"> 
<meta http-equiv="keywords" content="keyword1,keyword2,keyword3"> 
<meta http-equiv="description" content="This is my page"> 
<script type="text/javascript"> 
    var ws = null; 
    function startServer() { 
        var url = "ws:localhost:8080/WebSocketAnnonationTomcat7/echo.ws"; 
        if ('WebSocket' in window) { 
            ws = new WebSocket(url); 
        } else if ('MozWebSocket' in window) { 
            ws = new MozWebSocket(url); 
        } else { 
            alert('WebSocket is not supported by this browser.'); 
            return; 
        } 
        ws.onopen = function() { 
            alert("connect success!"); 
        }; 
        ws.onmessage = function(event) { 
            alert("revice mess:" + event.data); 
        }; 
        ws.onclose = function() { 
            alert("close connect.."); 
        }; 
    } 
    function sendMessage(){
         var txtMsg=document.getElementById("msg").value;
         if(ws!=null && txtMsg!=''){
             ws.send(txtMsg);
         }
         
        }
</script> 
</head> 

<body onload="startServer()"> 
  <input type="text" id="msg" value="" size="20" />
  <input type="button" onclick="sendMessage();" value="发送" />
</body> 
</html> 

 

servlet具体实现:

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;
import java.util.logging.Logger;

import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServletRequest;

import org.apache.catalina.websocket.MessageInbound;
import org.apache.catalina.websocket.StreamInbound;
import org.apache.catalina.websocket.WsOutbound;

/**
 * Tomcat7 WebSocket的簡單應用, WebSocket的servlet接口集成自webSocketServlet,实质为Serlet
 * <p>功能描述,该部分必须以中文句号结尾。<p>
 *
 * 创建日期  2013-7-21<br>
 * @author  longgangbai <br>
 * @version $Revision$ $Date$
 * @since   3.0.0
 */
public class WebSocketExtServlet extends 
        org.apache.catalina.websocket.WebSocketServlet { 
    //
    private Logger logger=Logger.getLogger(WebSocketExtServlet.class.getSimpleName());
    
    private static final long serialVersionUID = 1L;

    
    @Override
    protected StreamInbound createWebSocketInbound(String subProtocol, HttpServletRequest arg1) {
        logger.info(";request ws servelt");
        
        return  new MessageInbound(){
            @Override
            protected void onClose(int status){
                logger.info(";web socket closed :"+status);
            }
            @Override
            protected void onOpen(WsOutbound outbound){
                logger.info(";web socket onOpen !");
            }
            @Override
            protected void onBinaryMessage(ByteBuffer buff) throws IOException {
                // TODO Auto-generated method stub
                logger.info(";web socket Received : !"+buff.remaining());
            }

            @Override
            protected void onTextMessage(CharBuffer buff) throws IOException {
                logger.info(";web socket Received : !"+buff.remaining());
                //getWsOutbound可以返回当前的WsOutbound,通过他向客户端返回数据,这里采用nio的CharBuffer
                for (int j = 0; j < 50; j++) {
                    try {
                        Thread.sleep(2000);
                        this.getWsOutbound().writeTextMessage(CharBuffer.wrap(String.valueOf(j)));
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                
            }
            
        }; 
    } 

} 

 

 

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xmlns:web="http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
  <display-name>WebSocketTomcat7</display-name>
  <servlet>
   <servlet-name>websocket</servlet-name>
   <servlet-class>com.easyway.websocket.WebSocketExtServlet</servlet-class>
  </servlet>
  <servlet-mapping>
     <servlet-name>websocket</servlet-name>
     <url-pattern>/echo.ws</url-pattern>
  </servlet-mapping>
  <welcome-file-list>
    <welcome-file>index.html</welcome-file>
    <welcome-file>index.htm</welcome-file>
    <welcome-file>index.jsp</welcome-file>
    <welcome-file>default.html</welcome-file>
    <welcome-file>default.htm</welcome-file>
    <welcome-file>default.jsp</welcome-file>
  </welcome-file-list>
</web-app>

 
需要说明的是,在开发的时候必须在tomcat的lib目录下拷贝两个JAR包:catalina.jar  tomcat-coyote.jar 
但当你运行的时候必须将这两个包删除,否则,会与tomcat的包冲突!!!!! 
他们类的关系,也有一定的理解,今天暂时写到这里吧!! 

分享到:
评论
1 楼 郭燕永 2015-09-10  
 

相关推荐

    基于tomcat的websocket开发示例源码

    要求tomcat7.0.47以上

    物联网示例,WEBSOCKET丰富案例

    1. Websocket 编程,包括基于Tomcat8的文本和二进制读写,和浏览器端的编程 2. 提供贪吃蛇案例,包括服务端程序和网页端,服务端是控制蛇运动方向的 3. 提供嵌入式端能过Websocket控制灯亮度,嵌入式代码另外上传

    tomcat6、7、8、9, maven3.5

    的Apache Tomcat 7.x的建立在Tomcat中6.0.x的改进和实现的Servlet 3.0, JSP 2.2,EL 2.2和 WebSocket的1.1规格。除此之外,它还包括以下改进: Web应用程序内存泄漏检测和预防 提高了Manager和Host Manager应用...

    apache-tomcat-7.0.82.rar

    Apache Tomcat是一款基于Java的Web应用程序服务器,用于处理Java Servlet和JavaServer Pages(JSP)等动态Web内容的请求和响应。在Java Web开发中,Tomcat是广泛应用的Web容器之一。 Apache Tomcat 7.0.82是Tomcat ...

    基于websocket和SSM框架简单网页聊天管理系统设计

    ## 功能实现: 用户角色包含以下功能:用户登录,弹出其他用户上线提醒,用户互相聊天,发送广播等功能。 用了技术框架: HTML+CSS+JavaScript+WebSocket+Spring+mybatis+jsp+mysql ...## tomcat环境: Tomcat8.x/9.x

    WebSocket部署服务器但外网无法连接的解决方法

    WebSocket是html5新增加的一种通信协议,目前流行的浏览器都支持这个协议,例如Chrome,Safari,Firefox,Opera,IE等等,下面这篇文章主要给大家介绍了关于WebSocket部署服务器但外网无法连接的解决方法,需要的朋友可以...

    基于springboot+微信小程序的疫苗预约接种系统.zip

    该项目都是测试过了的,真实可靠,请放心使用...Spring Boot 提供了 spring-boot-starter-websocket 来快速实现消息推送,同时也可以整合流行的 RPC 框架,提供 RPC 服务接口(只要简单加入对应的 starter 组件即可)。

    基于springboot+微信小程序的企业微信点餐系统.zip

    该项目都是测试过了的,真实可靠,请放心使用...Spring Boot 提供了 spring-boot-starter-websocket 来快速实现消息推送,同时也可以整合流行的 RPC 框架,提供 RPC 服务接口(只要简单加入对应的 starter 组件即可)。

    java开源包1

    SpeechLion 是一个语音识别程序,主要用来处理桌面命令,基于 Sphinx-4 语音识别引擎开发。用户可以通过该软件来控制 Linux 桌面,例如打开google搜索、鼠标点击、下一窗口、打开帮助、静音等操作。 Java发送短信包...

    基于springboot+uniapp微信小程序实现的学生互动课堂,采用前后端分离开发模式.zip

    该项目都是测试过了的,真实可靠,请放心使用...Spring Boot 提供了 spring-boot-starter-websocket 来快速实现消息推送,同时也可以整合流行的 RPC 框架,提供 RPC 服务接口(只要简单加入对应的 starter 组件即可)。

    基于springboot+Mysql+微信小程序的图书捐赠管理系统-1.zip

    该项目都是测试过了的,真实可靠,请放心使用...Spring Boot 提供了 spring-boot-starter-websocket 来快速实现消息推送,同时也可以整合流行的 RPC 框架,提供 RPC 服务接口(只要简单加入对应的 starter 组件即可)。

    基于springboot的商城后台管理系统+H5端+小程序端+api后端接口.zip

    该项目都是测试过了的,真实可靠,请放心使用...Spring Boot 提供了 spring-boot-starter-websocket 来快速实现消息推送,同时也可以整合流行的 RPC 框架,提供 RPC 服务接口(只要简单加入对应的 starter 组件即可)。

    java开源包7

    SpeechLion 是一个语音识别程序,主要用来处理桌面命令,基于 Sphinx-4 语音识别引擎开发。用户可以通过该软件来控制 Linux 桌面,例如打开google搜索、鼠标点击、下一窗口、打开帮助、静音等操作。 Java发送短信包...

    moco:简易安装存根服务器

    在过去,我们只是将另一个WAR部署到应用程序服务器,例如Jetty或Tomcat等。众所周知,即使使用嵌入式服务器,开发WAR并将其部署到任何应用程序服务器也很无聊。 而且,即使我们只想稍作更改,也需要重新组装WAR。...

    java7源码-ALLGO:一个可以组织活动的app,基于android(客户端)和servlet(服务器),学习编程之用

    用户登录WebSocket实时接收消息(如活动评论,活动被删除),程序关闭后台Http轮询接收消息 ##软件展示 查看完整客户端截图 ##客户端使用的开源库 ActionBar-PullToRefresh: ListViewAnimations: xUtils: ...

    JAVA上百实例源码以及开源项目

     基于JAVA的UDP服务器模型源代码,内含UDP服务器端模型和UDP客户端模型两个小程序,向JAVA初学者演示UDP C/S结构的原理。 简单聊天软件CS模式 2个目标文件 一个简单的CS模式的聊天软件,用socket实现,比较简单。 ...

    JAVA上百实例源码以及开源项目源代码

     基于JAVA的UDP服务器模型源代码,内含UDP服务器端模型和UDP客户端模型两个小程序,向JAVA初学者演示UDP C/S结构的原理。 简单聊天软件CS模式 2个目标文件 一个简单的CS模式的聊天软件,用socket实现,比较简单。 ...

    java开源包11

    SpeechLion 是一个语音识别程序,主要用来处理桌面命令,基于 Sphinx-4 语音识别引擎开发。用户可以通过该软件来控制 Linux 桌面,例如打开google搜索、鼠标点击、下一窗口、打开帮助、静音等操作。 Java发送短信包...

    java开源包2

    SpeechLion 是一个语音识别程序,主要用来处理桌面命令,基于 Sphinx-4 语音识别引擎开发。用户可以通过该软件来控制 Linux 桌面,例如打开google搜索、鼠标点击、下一窗口、打开帮助、静音等操作。 Java发送短信包...

Global site tag (gtag.js) - Google Analytics