Spring MVC中怎么利用webSocket保持長連接

本篇文章給大家分享的是有關(guān)Spring MVC中怎么利用webSocket保持長連接，小編覺得挺實用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

配置

• 在pom.xml中加入包依賴

<!-- webSocket start Add by zhangxueliang on 2018-02-22 -->
        <dependency>
            <groupId>javax</groupId>
            <artifactId>javaee-api</artifactId>
            <version>7.0</version>
            <scope>provided</scope>
        </dependency>
    
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-websocket</artifactId>
            <version>4.3.13.RELEASE</version>
        </dependency>
        <!-- webSocket end -->

• Java后臺實現(xiàn)代碼

package com.netcar.tien.mobile;

import java.io.IOException;

import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

import org.springframework.web.socket.server.standard.SpringConfigurator;

import com.netcar.tien.core.log.LogFactory;
import com.netcar.tien.core.log.OnlineLog;


/**
 * 保持socket連接
 * @author JoyoDuan
 * Add by JoyoDuan on 2018-02-22
 * 
 * @ServerEndpoint 注解是一個類層次的注解，它的功能主要是將目前的類定義成一個websocket服務(wù)器端,
 * 注解的值將被用于監(jiān)聽用戶連接的終端訪問URL地址,客戶端可以通過這個URL來連接到WebSocket服務(wù)器端
 */
@ServerEndpoint(value="/app/webSocket", configurator = SpringConfigurator.class)
public class WebSocket {
    
    private OnlineLog logger = LogFactory.getOnlineLog(WebSocket.class);
    
    
    //socket連接會話，用于發(fā)送消息給客戶端
    private Session session;

    
    
    /**
     * 客戶端連接成功
     * @param session
     * @throws IOException
     */
    @OnOpen
    public void onOpen(Session session) throws IOException 
    {
        this.session = session;
//      System.out.println("WebSocket連接成功");
        logger.info("WebSocket - 連接成功");
    }
    
     
    /**
     * 收到消息時執(zhí)行
     * @param message
     * @param session
     * @throws IOException
     */
    @OnMessage 
    public void onMessage(String message, Session session) throws IOException 
    { 
        this.sendMessage("success");
    }
    
    
    /**
     * 關(guān)閉時執(zhí)行
     */
    @OnClose
    public void onClose() 
    { 
        logger.info("webSocket - 連接關(guān)閉");
//      System.out.println("webSocket連接關(guān)閉");
    }
    
    
    /**
     * 連接錯誤時執(zhí)行
     * @param session
     * @param error
     */
    @OnError 
    public void onError(Session session, Throwable error) 
    {
        logger.error("webSocket - 出錯：" + error.getMessage());
//      System.out.println("webSocket出錯" + error);
    }
    
    
    /**
     * 發(fā)送消息給客戶端
     * @param message
     * @throws IOException
     */
    public void sendMessage(String message) throws IOException 
    {
        this.session.getBasicRemote().sendText(message);
    }
}

• 前端使用webSocket代碼

/**
   * 與服務(wù)器保持長連接
   * @param {boolean} [isReconnect]
   * @returns
   * @memberof HomePage
   */
  connectWebSocket(isReconnect?: boolean)
  {
    let webSocket = new WebSocket(this.urlService.getWebSocketURL());   ///webSocket
    this.globalData.isLog && console.log('WebSocket:', 'WebSocket' in window);

    //上傳經(jīng)緯度的定時器
    let uploadLngLatTimer: number = null;

    if (!isReconnect && !('WebSocket' in window))
    {
      // this.nativeService.alert('您的手機不支持位置上傳');
      return;
    }

    //監(jiān)測網(wǎng)絡(luò)斷開
    this.nativeService.monitorNetworkDisconnect(() => {
      this.nativeService.toast('親，網(wǎng)絡(luò)連接中斷了');

      //遞歸，重新連接
      this.connectWebSocket(true);
      return;
    });

    //初始化webSocket
    webSocket.onopen = (event) => {
      this.globalData.isLog && !isReconnect && console.log('webSocket - 連接服務(wù)器成功!', event);

      this.globalData.isLog && isReconnect && console.log('webSocket - 重新連接服務(wù)器!', event);

      //每隔10秒上傳一次經(jīng)緯度
      uploadLngLatTimer = setInterval(() => {
        //上傳經(jīng)緯度時定位當前位置
        this.getAMapLocationByJS(true, () => {
          // webSocket.send('JoyoDuan' + new Date().getTime());

          let params = {
            strokeNo: this.trip.strokeNo,
            strokeStatus: this.trip.strokeStatus,
            strokeLongitude: this.position.currentPosition.lngLat.lng,
            strokeLatitude: this.position.currentPosition.lngLat.lat,
            routeId: this.trip.routeId,
            carTypeId: this.trip.carTypeId || ''
          };

          //發(fā)送經(jīng)緯度到服務(wù)器
          webSocket.send(
              Secret.encodeBase64String(JSON.stringify(params))
          );

          this.globalData.isLog && console.log('webSocket - 實時上傳經(jīng)緯度發(fā)送參數(shù)：', JSON.stringify(params));
        });

      }, TIMEOUT.UPLOAD_LNGLAT_TIMEOUT);
    };

    //連接關(guān)閉時執(zhí)行
    webSocket.onclose = () => {
      this.globalData.isLog && console.log('webSocket - 連接服務(wù)器關(guān)閉!', event);
      //清除計時器，停止發(fā)送
      clearInterval(uploadLngLatTimer);
    };

    //連接出現(xiàn)錯誤時執(zhí)行
    webSocket.onerror = (event) => {
      this.globalData.isLog && console.log('webSocket - 連接服務(wù)器錯誤!', event);

      //10秒重連一次
      setTimeout(() => {
        this.connectWebSocket(true);
      }, TIMEOUT.RECONNECT_WEB_SOCKET);
    };

    //收到服務(wù)器消息時執(zhí)行
    webSocket.onmessage = (event) => {
      this.globalData.isLog && console.log('webSocket - 服務(wù)器發(fā)送的消息！', event);
    }
  }

以上就是Spring MVC中怎么利用webSocket保持長連接，小編相信有部分知識點可能是我們?nèi)粘９ぷ鲿姷交蛴玫降摹ＯＭ隳芡ㄟ^這篇文章學(xué)到更多知識。更多詳情敬請關(guān)注億速云行業(yè)資訊頻道。