之前大概的看过WebSocket,当时Tomcat还不支持WebSocket,所以当时写了一篇基于Jetty的WebSocket实现,地址如下:
http://redstarofsleep.iteye.com/blog/1307608
现在Tomcat7.0.27发布了,从这个版本开始Tomcat就支持WebSocket了。
Tomcat的WebSocket和Jetty的大致上差不多,大同小异,这里就简单的贴两个类吧(此例子未考虑多线程的情况):
第一个类,这个和Jetty一样,需要一个Servlet来处理WebSocket请求:
- package lhc.websocket;
- import org.apache.catalina.websocket.StreamInbound;
- import org.apache.catalina.websocket.WebSocketServlet;
- public class MyWebSocketServlet extends WebSocketServlet {
- private static final long serialVersionUID = -7178893327801338294L;
- @Override
- protected StreamInbound createWebSocketInbound(String arg0) {
- System.out.println("##########");
- return new MyMessageInbound();
- }
- }
这个Servlet继承自WebSocketServlet,实现createWebSocketInbound方法。该方法返回第二个类的实例。
第二个类,处理每一次具体的WebSocket任务:
- package lhc.websocket;
- import java.io.IOException;
- import java.nio.ByteBuffer;
- import java.nio.CharBuffer;
- import lhc.init.InitServlet;
- import org.apache.catalina.websocket.MessageInbound;
- import org.apache.catalina.websocket.WsOutbound;
- public class MyMessageInbound extends MessageInbound {
- @Override
- protected void onBinaryMessage(ByteBuffer arg0) throws IOException {
- // TODO Auto-generated method stub
- }
- @Override
- protected void onTextMessage(CharBuffer msg) throws IOException {
- for (MessageInbound messageInbound : InitServlet.getSocketList()) {
- CharBuffer buffer = CharBuffer.wrap(msg);
- WsOutbound outbound = messageInbound.getWsOutbound();
- outbound.writeTextMessage(buffer);
- outbound.flush();
- }
- }
- @Override
- protected void onClose(int status) {
- InitServlet.getSocketList().remove(this);
- super.onClose(status);
- }
- @Override
- protected void onOpen(WsOutbound outbound) {
- super.onOpen(outbound);
- InitServlet.getSocketList().add(this);
- }
- }
这个类继承自MessageInbound类,必须实现onBinaryMessage和onTextMessage方法。Jetty中只有一个onMessage方法,而Tomcat细化成了2个方法。
还要一个初始化的Servlet
- package lhc.init;
- import java.util.ArrayList;
- import java.util.List;
- import javax.servlet.ServletConfig;
- import javax.servlet.ServletException;
- import javax.servlet.http.HttpServlet;
- import org.apache.catalina.websocket.MessageInbound;
- public class InitServlet extends HttpServlet {
- private static final long serialVersionUID = -3163557381361759907L;
- private static List<MessageInbound> socketList;
- public void init(ServletConfig config) throws ServletException {
- InitServlet.socketList = new ArrayList<MessageInbound>();
- super.init(config);
- System.out.println("Server start============");
- }
- public static List<MessageInbound> getSocketList() {
- return InitServlet.socketList;
- }
- }
最后,web.xml中进行一下Servlet的配置。
- <?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_3_0.xsd" id="WebApp_ID" version="3.0">
- <display-name>wsoc</display-name>
- <welcome-file-list>
- <welcome-file>index.jsp</welcome-file>
- </welcome-file-list>
- <servlet>
- <servlet-name>mywebsocket</servlet-name>
- <servlet-class>lhc.websocket.MyWebSocketServlet</servlet-class>
- </servlet>
- <servlet-mapping>
- <servlet-name>mywebsocket</servlet-name>
- <url-pattern>*.do</url-pattern>
- </servlet-mapping>
- <servlet>
- <servlet-name>initServlet</servlet-name>
- <servlet-class>lhc.init.InitServlet</servlet-class>
- <load-on-startup>1</load-on-startup>
- </servlet>
- </web-app>
页面的话,就是标准的HTML5的websocket,这个和服务器是否是Tomcat或者Jetty是无关的:
- <%@ page language="java" contentType="text/html; charset=UTF-8"
- pageEncoding="UTF-8"%>
- <!DOCTYPE html>
- <html>
- <head>
- <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
- <title>Index</title>
- <script type="text/javascript">
- var ws = null;
- function startWebSocket() {
- if ('WebSocket' in window)
- ws = new WebSocket("ws://localhost:8080/wsoc/mywebsocket.do");
- else if ('MozWebSocket' in window)
- ws = new MozWebSocket("ws://localhost:8080/wsoc/mywebsocket.do");
- else
- alert("not support");
- ws.onmessage = function(evt) {
- alert(evt.data);
- };
- ws.onclose = function(evt) {
- alert("close");
- };
- ws.onopen = function(evt) {
- alert("open");
- };
- }
- function sendMsg() {
- ws.send(document.getElementById('writeMsg').value);
- }
- </script>
- </head>
- <body onload="startWebSocket();">
- <input type="text" id="writeMsg"></input>
- <input type="button" value="send" onclick="sendMsg()"></input>
- </body>
- </html>
相关推荐
Tomcat利用webSocket建立常连接 jar包
java tomcat 7.0.42 websocket可使用java tomcat 7.0.42 websocket可使用java tomcat 7.0.42 websocket可使用java tomcat 7.0.42 websocket可使用
要求tomcat7.0.47以上
基于Tomcat实现HTML5的WebSocket 使用工程前先阅读使用说明!
tomcat8真正支持jsr-356(包含对websocket的支持), tomcat7部分版本的websocket实现不兼容jsr-356。 需要注意websocket与浏览器的兼容问题,有些早期版本的浏览器支持旧版本的websocket协议,可能会与新版本的...
项目可以直接导入,一个基于Tomcat7、Java、Ext、WebSocket的聊天室,分数是3分,目的不是为了赚分,是为了大家能够评论,提出意见。
tomcat实现websocket.rar所需jar包。
基于Springboot websocket + js实现的即时聊天系统 基于Springboot websocket + js实现的即时聊天系统 基于Springboot websocket + js实现的即时聊天系统 基于Springboot websocket + js实现的即时聊天系统 基于...
基于Springboot+Websocket的简单聊天室 基于Springboot+Websocket的简单聊天室 基于Springboot+Websocket的简单聊天室 基于Springboot+Websocket的简单聊天室 基于Springboot+Websocket的简单聊天室 基于Springboot+...
websocket+tomcat+jetty+netty
支持websocket的tomcat
tomcat7-websocket.jar
一个可以正常运行的websocket案例,初学者学习用吧, 由于websocket是在Tomcat7.0.27版本添加的,所以打包在tomcat中运行的时候,注意要删除tomcat中包含的自身jar包才能正常运行
使用JSR356在Java中构建WebSocket应用,详细介绍,包括1.服务器推送给客户端和2.客户端发送给服务器
tomcat-embed-websocket7 jar包
基于java Websocket开发的网页聊天工具,曾用于本人课程设计,在此放出造福大家
直接将该下载包解压到tomcat 7.0.42 lib 包下替换即可