JSR356标准Java WebSocket

redstarofsleep

浏览: 439975 次
性别:
来自: 苏州

最近访客更多访客>>

mulingya

pch272215690

z3996821

sanrenxing_1

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

Web前端
Java
WebServer

文章搬至CSDN, 最新内容请访问: http://blog.csdn.net/redstarofsleep/article/details/45092125

之前几次写WebSocket的例子都是基于某个特定的容器(Tomcat,Jetty),而现在,Oracle发布了JSR356规范,WebSocket的Java API得到了统一,所以只要Web容器支持JSR356,那么我们写WebSocket时,代码都是一样的了.Tomcat从7.0.47开始支持JSR356.另外有一点要说明的是JDK的要求是7及以上

JSR356实现WebSocket有两种方式,一种是使用注解的,另一种是继承javax.websocket.Endpoint类,推荐方式是使用注解,我这里也就写的注解的例子:

@ServerEndpoint(value = "/websocket/{user}")
public class MyServerEndpoint {
	
	private Session session;
	private static final Logger sysLogger = Logger.getLogger("sysLog");
	
	@OnOpen
	public void open(Session session,  @PathParam(value = "user")String user) {
		this.session = session;
		
		sysLogger.info("*** WebSocket opened from sessionId " + session.getId());
	}
	
	@OnMessage
	public void inMessage(String message) {
		sysLogger.info("*** WebSocket Received from sessionId " + this.session.getId() + ": " + message);
	}
	
	@OnClose
	public void end() {
		sysLogger.info("*** WebSocket closed from sessionId " + this.session.getId());
	}
	

}

服务端的代码呢就这么多,没有其它的代码了.

首先给类加上@ServerEndpoint注解,标示出这是一个WebSocket的Server端,这个注解的一个属性value="xxx"是访问这个websocket的url,这个url还可以带参数,用过Spring3MVC的应该很熟悉,我现在的这个例子客户端访问这个websocket的url就是: ws://localhost:8080/webserver/websocket/user1,user1是参数,在下面的方法open,close等都可以直接访问这个参数.

然后是open方法上的注解onOpen,这个当一个客户端连上来时触发,每个客户端会被分配一个session,这个session可不是httpsession.open方法里有个参数user被加上了注解@PathParam(value = "user")String user,这个就是从url中获取user的方式.

另外两个onClose和onMessage也不用多解释了,一个是客户端断开时触发,一个是收到客户端发送的消息时触发.

最后要发送消息给客户端得调用session.getBasicRemote().sendText("msg").

恩,就这么多了.

这样一个最基本的WebSocket服务端就完成了.客户端的话原来的HTML5的可以直接连,这里也贴一下吧:

    <%@ 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>

另外JSR356也有客户端,也就是说,也可以用Java代码来写一个WebSocket客户端,具体的下回研究了再写吧..

转载请注明出处

9
顶

0
踩

分享到：

ubuntu下安装nginx | guacamole搭建,一个基于HTML5的VNC远程 ...

2013-11-14 11:16
浏览 15333
评论(13)
分类:企业架构
查看更多

13 楼 mdqy195905 2015-01-12

Java 代码:

package com.wing;

import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;

@ServerEndpoint("/webSocket")
public class WebSocketTest {

    @OnMessage
    public void resolveTextMessage(String message, Session session) {
        try {
            session.getBasicRemote().sendText("server get your message:" + message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

页面代码:
webSocket = new WebSocket("ws://localhost:8080/工程名/webSocket");

chrome报错：
WebSocket connection to 'ws://localhost:8080/工程名/webSocket' failed: Error during WebSocket handshake: Unexpected response code: 404

为什么，有人碰到过么.环境

server:tomcat8.0.15,
lib:javax.websocket-api-1.1.jar.
jdk:1.8.0_25-b18.

是不是还缺什么配置？？？？？

12 楼 A_T_Being 2014-07-26

A_T_Being 写道

是不是还有其他代码没有贴出来？我运行不对，总是说“ws://localhost:8080/wsoc/mywebsocket.do 服务器的连接”，是不是还需要写一个servlet配合的？求解

自己搞定了，是ws的请求路径不对，我直接复制楼主的，楼主的是错的，正确的应该是{项目路径}/websocket/{user}，而不是什么.do,不知道楼主为什么这样子写

11 楼 A_T_Being 2014-07-26

是不是还有其他代码没有贴出来？我运行不对，总是说“ws://localhost:8080/wsoc/mywebsocket.do 服务器的连接”，是不是还需要写一个servlet配合的？求解

10 楼 bridge_ca 2014-07-25

redstarofsleep 写道

bridge_ca 写道

为嘛直接弹出close,404 Not Found - http://localhost/websocket/

url写错了,没匹配上

恩，忘记写工程名了

9 楼 redstarofsleep 2014-07-25

bridge_ca 写道

为嘛直接弹出close,404 Not Found - http://localhost/websocket/

url写错了,没匹配上

8 楼 bridge_ca 2014-07-24

为嘛直接弹出close,404 Not Found - http://localhost/websocket/

7 楼白小仙_尖叫 2014-06-13

wang_anqi 写道

CUIT_TED 写道

楼主，我已经实现了你的例子，但是我想实现后台页面添加一项数据，然后将这个数据推送到客户端，该怎么处理？session在action中拿不到啊

能不能把代码共享一下啊，配置不会啊。

你可以放到 value = "/websocket/{user}" 这个user里面啊~

6 楼 redstarofsleep 2014-06-04

wang_anqi 写道

CUIT_TED 写道

楼主，我已经实现了你的例子，但是我想实现后台页面添加一项数据，然后将这个数据推送到客户端，该怎么处理？session在action中拿不到啊

能不能把代码共享一下啊，配置不会啊。

这个不需要其它配置了.

5 楼 wang_anqi 2014-06-03

CUIT_TED 写道

楼主，我已经实现了你的例子，但是我想实现后台页面添加一项数据，然后将这个数据推送到客户端，该怎么处理？session在action中拿不到啊

能不能把代码共享一下啊，配置不会啊。

4 楼白小仙_尖叫 2014-05-27

白小仙_尖叫写道

用JSR356接口怎么获得HandshakeRequest呀？

我谷歌到了，找了一天终于找到了 http://stackoverflow.com/questions/17936440/accessing-httpsession-from-httpservletrequest-in-a-web-socket-socketendpoint

3 楼白小仙_尖叫 2014-05-27

用JSR356接口怎么获得HandshakeRequest呀？

2 楼 redstarofsleep 2014-03-18

CUIT_TED 写道

楼主，我已经实现了你的例子，但是我想实现后台页面添加一项数据，然后将这个数据推送到客户端，该怎么处理？session在action中拿不到啊

private static final Set<MyServerEndpoint> connections = new CopyOnWriteArraySet<>();

open方法中加入:connections.add(this);

然后再加一个广播方法:
public static void broadcast(String msg) {
for (MyServerEndpoint client : connections) {
            try {
                client.session.getBasicRemote().sendText(msg);
            } catch (IOException e) {
                connections.remove(client);
                try {
                    client.session.close();
                } catch (IOException e1) {
                    e1.printStackTrace();
                }
            }
        }
    }

1 楼 CUIT_TED 2014-03-14

楼主，我已经实现了你的例子，但是我想实现后台页面添加一项数据，然后将这个数据推送到客户端，该怎么处理？session在action中拿不到啊

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论