java+websocket使用

时间：2025-03-22 08:32:10

客户端

我们用HTML5页面来实现websocket的客户端。

websocket连接主要由ws:开头的连接信息来连接后台服务端，在需要发消息到后台的地方调用()方法即可发送消息到后台。

注：websocket由于网络原因可能会出现断掉的情况，我们可以设置断线重连，這里推荐一个开源的插件
/joewalnes/reconnecting-websocket/
只需要将连接改为ws = new ReconnectingWebSocket(‘ws://….’)即可。

 <script type="text/javascript">
  var websocket = null;

  //判断当前浏览器是否支持WebSocket
  if('WebSocket' in window){
      websocket = new WebSocket("ws://localhost:8080/websocket/index");
  }
  else{
      alert('Not support websocket');
  }

  //连接发生错误的回调方法
   = function(){
      ("error");
  };

  //连接成功建立的回调方法
   = function(event){
     alert("open");
  }

  //接收到消息的回调方法
   = function(){

  }

  //连接关闭的回调方法
   = function(){
      ("close");
  }

  //监听窗口关闭事件，当窗口关闭时，主动去关闭websocket连接，防止连接还没断开就关闭窗口，server端会抛异常。
   = function(){
      ();
  }
  </script>

服务端

我们用java代码实现webscoket的服务端。
在JavaEE 7中出了JSR-356规范之前，很多web容器都有自己的实现，使用的方法也不太一样，笔者所知道的就有两种，暂时列出来一个链接：
（1）引入org.java_websocket.*包，主要实现方式是继承WebSocketServer和
WebSocketClient来实现客户端服务器的即时通讯

具体demo例子：
/blog/2011985

（2）引入包，是apache实现的websocket规范，主要依靠继承WebSocketServlet类和实现MessageInbound来通讯

具体demo例子：
/jiangcs520/article/details/9749867

（3）这里主要介绍JSR-356的websocket代码。
具体tomcat版本有要求，亲测在tomcat8上可以实现，tomcat7.0.40出错，网上据说是要Tomcat7.0.47以上才能运行，主要通过@ServerEndpoint注解路径，@OnOpen，@OnClose等注解注释方法来实现。

package ;

import ;
import ;
import ;
import ;
import ;
import ;

import ;

/**
 * websocket demo
 * @author 
 */
//该注解用来指定一个URI，客户端可以通过这个URI来连接到WebSocket。
@ServerEndpoint("/index")
public class MyWebSocket {


    //与某个客户端的连接会话，需要通过它来给客户端发送数据
    private Session session;

    /**
     * 连接建立成功调用的方法
     * @param session  可选的参数。session为与某个客户端的连接会话，需要通过它来给客户端发送数据
     */
    @OnOpen
    public void onOpen(Session session,){
         = session;

        ("open");
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose(){

        ("close");
    }

    /**
     * 收到客户端消息后调用的方法
     * @param message 客户端发送过来的消息
     * @param session 可选的参数
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        ("来自客户端的消息:" + message);  
        String reply = "你好";
        //通过这个方法可以给客户端发送消息
        ().sendText(message)
    }

    /**
     * 发生错误时调用
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error){
        ("发生错误");
        ();
    }


}

相关文章