基于Tomcat的WebSocket的推送式聊天程序

原创
2012/04/22 18:28
阅读数 1.5W
在开始学习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/SocketTest/action/SocketServlet.do";
        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..");
        };
    }
</script>
</head>

<body onload="startServer()">

</body>
</html>
src
package action;

import org.apache.catalina.websocket.StreamInbound;

import socket.MyWebSocket;

public class WebSocketServlet extends
        org.apache.catalina.websocket.WebSocketServlet {

    @Override
    protected StreamInbound createWebSocketInbound(String subProtocol) {
        // TODO Auto-generated method stub
        return new MyWebSocket();
    }

}


package socket;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.CharBuffer;

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

public class MyWebSocket extends MessageInbound {

    @Override
    protected void onOpen(WsOutbound outbound) {
        System.out.println("connect....");
        CharBuffer buffer = CharBuffer.wrap("hello,welcome to connect!");
        try {
            this.getWsOutbound().writeTextMessage(buffer);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    @Override
    protected void onClose(int status) {
        System.out.println("close.....");
    }

    @Override
    protected void onBinaryMessage(ByteBuffer arg0) throws IOException {
        // TODO Auto-generated method stub

    }

    @Override
    protected void onTextMessage(CharBuffer arg0) throws IOException {
        // TODO Auto-generated method stub

    }

}

需要说明的是,在开发的时候必须在tomcat的lib目录下拷贝两个JAR包:catalina.jar  tomcat-coyote.jar
但当你运行的时候必须将这两个包删除,否则,会与tomcat的包冲突!!!!!
他们类的关系,也有一定的理解,今天暂时写到这里吧!!
展开阅读全文
打赏
0
11 收藏
分享
加载中
我觉得这种东西自己开发太麻烦了,就别自己捣鼓了,找个第三方,方便,GoEasy就挺不错的,我昨天试了一下,代码简洁易懂,几分钟我就洗了一个自己的实时推送功能;官网: http://goeasy.io/
2017/06/12 16:06
回复
举报

引用来自“tianpeng91”的评论

引用来自“yangf2008”的评论

确实是Tomcat 实现问题,Tomcat 7.0.28 修复了这个bug
53074: Switch to an infinite socket timeout by default for WebSocket connections. (markt)

其实Jetty也有一个默认的超时,但是正常的,tomcat就几秒就断,问题比较大。不知道怎么样了,现在我用Jetty开发了一个IM程序,想哪天上传共享
tomcat有自己的socket time out,在配置connector的地方改大一些就好了。
2015/03/25 17:27
回复
举报
tianpeng91博主

引用来自“yangf2008”的评论

确实是Tomcat 实现问题,Tomcat 7.0.28 修复了这个bug
53074: Switch to an infinite socket timeout by default for WebSocket connections. (markt)

其实Jetty也有一个默认的超时,但是正常的,tomcat就几秒就断,问题比较大。不知道怎么样了,现在我用Jetty开发了一个IM程序,想哪天上传共享
2012/10/20 09:02
回复
举报
确实是Tomcat 实现问题,Tomcat 7.0.28 修复了这个bug
53074: Switch to an infinite socket timeout by default for WebSocket connections. (markt)
2012/10/19 11:17
回复
举报
tianpeng91博主

引用来自“浮生如斯”的评论

看HTML5的WebSocket的时候在Tomcat7.0.27上写WebSocket遇到了一个超时的问题,当时调试了一下Tomcat的源码,确认是底层使用的Socket设置了读超时的问题,只好放着不管,用Node.js搞了一个测试过去。
----------------------------------------------------------
在网上看到这样一段话,是这个原因吧,楼主

恩,,,源码也只看了一部分,后来各种原因没时间看下去了,不过确定是tomcat的实现问题。具体原因不太确定,最近又在实习,也没时间读源码,如果你找到原因了,麻烦告诉下哈!!!
2012/09/04 16:31
回复
举报
看HTML5的WebSocket的时候在Tomcat7.0.27上写WebSocket遇到了一个超时的问题,当时调试了一下Tomcat的源码,确认是底层使用的Socket设置了读超时的问题,只好放着不管,用Node.js搞了一个测试过去。
----------------------------------------------------------
在网上看到这样一段话,是这个原因吧,楼主
2012/09/04 15:30
回复
举报
tianpeng91博主
对啦,最近有人说参考我的代码会发生无法连接的状况,当然我上面的代码也只是测试代码,我测试是完全通过的,那么如果发生无法连接的状态。我希望大家确认两点:一、使用的浏览器是Chrome或者Firefox较新的版本;二、确认使用的Tomcat 版本是 7.0.27及以上版本,低于该版本无法运行。
2012/07/09 19:13
回复
举报
tianpeng91博主

引用来自“adonis0147”的评论

有个问题,我想请教下,为什么我在tomcat上启动后,在浏览器上输入对应的地址,然后返回了 close connect ????

我想问下你使用的是什么浏览器??需要注意的是,目前只支持Chrome 、Firefox浏览器较新的版本,IE9+我没有测试过,所以不确定。还有一点需要注意的是,目前Tomcat有一个BUG,就算你输入地址后,显示连接成功,但过了大概几分钟后会自动断开,问题出
@Override
protected void onClose(int status) {
System.out.println("close.....");
}
上面,还在研究,需要重写方法。
2012/07/03 16:07
回复
举报
tianpeng91博主
我想问下你使用的是什么浏览器??需要注意的是,目前只支持Chrome 、Firefox浏览器较新的版本,IE9+我没有测试过,所以不确定。还有一点需要注意的是,目前Tomcat有一个BUG,就算你输入地址后,显示连接成功,但过了大概几分钟后会自动断开,问题出
@Override
protected void onClose(int status) {
System.out.println("close.....");
}
上面,还在研究,需要重写方法。
2012/07/03 15:46
回复
举报
有个问题,我想请教下,为什么我在tomcat上启动后,在浏览器上输入对应的地址,然后返回了 close connect ????
2012/07/03 00:39
回复
举报
更多评论
打赏
10 评论
11 收藏
0
分享
返回顶部
顶部