消息推送二之webSocket

阿新 • • 發佈：2017-05-06

還需由於 else har 頁面 try window class logs

友情提示：消息推送的介紹可以參考http://www.cnblogs.com/dahuandan/p/6816173.html

什麽是webSocket

webSocket是為解決客戶端與服務端實時通信而產生的技術，其本質是使用一個TCP連接進行雙向通訊，可以用來Web服務端的消息推送，被IETF定義為標準協議。

優點

相對於傳統的HTTP輪詢技術而言，webSocket是建立一次TCP連接進行客戶端與服務端的雙向通訊，減少了傳統輪詢技術頻繁地向服務器發起請求，另外webSocket的Header相比HTTP的非常小。

helloWord

環境準備

Spring4.0版本以上

tomcat8

Constants.java

package demo;


/**
 * webSocket常量
 */
public class Constants {

    /**
     * http session 中 用戶名的key值
     */
    public static String SESSION_USERNAME = "session_username";
    
    /**
     * websocket session 中 用戶名的key值
     */
    public static String WEBSOCKET_USERNAME = "websocket_username";
}

View Code

WebSocketConfig.java

package demo;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.EnableWebMvc;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
 
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.config.annotation.EnableWebSocket;
import org.springframework.web.socket.config.annotation.WebSocketConfigurer;
import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry;


/**
 * 註冊websocket
 */
@Configuration
@EnableWebMvc
@EnableWebSocket
public class WebSocketConfig extends WebMvcConfigurerAdapter implements WebSocketConfigurer{

    public void registerWebSocketHandlers(WebSocketHandlerRegistry reg) {
        String websocket_url = "/webSocketServer";                     //設置websocket的地址
        reg.addHandler(systemWebSocketHandler(), websocket_url)        //註冊到Handler
           .addInterceptors(new WebSocketInterceptor());               //註冊到Interceptor
        
        //提供SockJS支持(主要是兼容ie8)
        String sockjs_url    = "/sockjs/webSocketServer";           //設置sockjs的地址
        reg.addHandler(systemWebSocketHandler(),sockjs_url )        //註冊到Handler
           .addInterceptors(new WebSocketInterceptor())                //註冊到Interceptor
           .withSockJS();                                              //支持sockjs協議 
        
    }
    
    @Bean
    public WebSocketHandler systemWebSocketHandler(){
        return new MyWebSocketHandler();
    }

}

View Code

WebSocketInterceptor.java

package demo;
import java.util.Map;

import org.springframework.http.server.ServerHttpRequest;
import org.springframework.http.server.ServerHttpResponse;
import org.springframework.http.server.ServletServerHttpRequest;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.server.HandshakeInterceptor;

/**
 * WebSocket握手攔截器
 */
public class WebSocketInterceptor implements HandshakeInterceptor {

    //握手前
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler handler,
            Map<String, Object> attr) throws Exception {
        
        if (request instanceof ServletServerHttpRequest) {
            
            ServletServerHttpRequest servletRequest = (ServletServerHttpRequest) request;
            
            String user = servletRequest.getServletRequest().getParameter("user");
            attr.put(Constants.WEBSOCKET_USERNAME, user);
        }
        return true;
    }
    
    //握手後
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response,
            WebSocketHandler handler, Exception e) {
    }
}

View Code

MyWebSocketHandler.java

package demo;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.WebSocketMessage;
import org.springframework.web.socket.WebSocketSession;

/**
 * WebSocket處理器
 */
public class MyWebSocketHandler implements WebSocketHandler {
    
    /**
     * WebSocketSession容器
     */
    private static final List<WebSocketSession> users = new ArrayList<WebSocketSession>();


    //建立連接後的函數
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        users.add(session);
    }
    
    //消息處理
    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> ws_msg) throws Exception {
//        String user = (String)session.getAttributes().get(Constants.WEBSOCKET_USERNAME);
        
        sendMessageToUsers(new TextMessage("received at server: " + ws_msg.getPayload()));
    }
    
    //關閉連接後的函數
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        users.remove(session);
    }

    
    //異常處理
    @Override
    public void handleTransportError(WebSocketSession session, Throwable e) throws Exception {
        
        if(session.isOpen()) 
            session.close();
        
        users.remove(session);
    }
    
    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
    
    
    /**
     * 給所有在線用戶發送消息
     * @param message
     * @throws IOException 
     */
    public void sendMessageToUsers(TextMessage message) throws IOException {
        for (WebSocketSession user : users) {
            if (user.isOpen()) 
                user.sendMessage(message);
        }
    }
    
    
    /**
     * 給某個用戶發送消息
     * @param userName
     * @param message
     * @throws IOException 
     */
    public void sendMessageToUser(String userName, TextMessage message) throws IOException {
        for (WebSocketSession user : users) {
            if (user.getAttributes().get(Constants.WEBSOCKET_USERNAME).equals(userName)) {
               if (user.isOpen()) {
                   user.sendMessage(message);
               }
            }
        }
    }

}

View Code

index.jsp

<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>websocket</title>

<script src="jquery-1.10.2.js"></script>
<script src="sockjs-0.3.min.js"></script>
<script>

$(function(){
    var webSocket = newWebSocket();
    
    sendMessage(webSocket);
});


/**
 * 創建webSocket
 */
function newWebSocket(){
    var webSocket;
    
    if (‘WebSocket‘ in window) 
        webSocket = new WebSocket("ws://localhost:8080/websocket/webSocketServer?user=123");
    
    else if (‘MozWebSocket‘ in window) 
        webSocket = new MozWebSocket("ws://localhost:8080/websocket/webSocketServer");
    
    else 
        webSocket = new SockJS("http://localhost:8080/websocket/sockjs/webSocketServer");
    
     
    //打開webSocket連接
    webSocket.onopen = function (evnt) {
    };
    
    //接收信息
    webSocket.onmessage = function (evnt) {
        $("#console").append("(<font color=‘red‘>"+evnt.data+"</font>)</br>")
    };
    
    //錯誤處理
    webSocket.onerror = function (evnt) {
    };
    
    //關閉webSocket
    webSocket.onclose = function (evnt) {
    }
    
    return webSocket;
}


/**
 * 發送信息
 */
function sendMessage(webSocket){
    
    $("#send").click(function(){
        webSocket.send($("#message").val());
    });
}
</script>
</head>


<body>
    <div>
        <textarea id="message" style="width: 350px">send message!</textarea>
    </div>
    
    </br>
    
    <div>
        <button id="send">send</button>
    </div>
    
    <div id="console"></div>
</body>
</html>

View Code

spring.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
         http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
         http://www.springframework.org/schema/context
         http://www.springframework.org/schema/context/spring-context-4.1.xsd">
        
      <context:annotation-config /> 
</beans>

View Code

springmvc.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
       xmlns:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
           http://www.springframework.org/schema/beans/spring-beans-4.1.xsd
        http://www.springframework.org/schema/context 
        http://www.springframework.org/schema/context/spring-context-4.1.xsd
        http://www.springframework.org/schema/mvc 
        http://www.springframework.org/schema/mvc/spring-mvc-4.1.xsd">
        
    <mvc:annotation-driven/>
    <context:component-scan base-package="demo*"/>
    
    <!-- 靜態資源解析 包括 ：js、css、img、..
         location： 資源所在的本地路徑，建議不要放在webInf下
         mapping ：url的訪問路徑， **代表包含resource/路徑後的所有子目錄
     -->
     <mvc:resources location="/" mapping="/**"/>
</beans>

View Code

web.xml

<?xml version="1.0" encoding="UTF-8"?>
<web-app version="3.0" 
    xmlns="http://java.sun.com/xml/ns/javaee" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
    xsi:schemaLocation="http://java.sun.com/xml/ns/javaee 
    http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd">
    
    <display-name>websocketDemo</display-name>    


    <!-- 加載spring容器 -->
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>/WEB-INF/classes/spring/spring.xml</param-value>
    </context-param>
    
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>

    
    <!-- springmvc前端控制器，rest配置 -->
    <servlet>
        <servlet-name>springmvc_rest</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <!-- contextConfigLocation配置springmvc加載的配置文件（配置處理器映射器、適配器等等） 如果不配置contextConfigLocation，默認加載的是/WEB-INF/servlet名稱-serlvet.xml（springmvc-servlet.xml） -->
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:spring/springmvc.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    
    <servlet-mapping>
        <servlet-name>springmvc_rest</servlet-name>
        <!-- 第一種：*.action，訪問以.action結尾 由DispatcherServlet進行解析 
               第二種：/，所以訪問的地址都由DispatcherServlet進行解析， 使用此種方式可以實現 RESTful風格的url(對於靜態文件的解析需要配置不讓DispatcherServlet進行解析)
               第三種：/*，這樣配置不對，使用這種配置，最終要轉發到一個jsp頁面時， 仍然會由DispatcherServlet解析jsp地址，不能根據jsp頁面找到handler，會報錯。 -->
        <url-pattern>/</url-pattern>
    </servlet-mapping>
    


    <!-- post亂碼過慮器 -->
    <!-- 除了加過濾器，由於tomcat默認編碼ISO-8859-1，還需要修改 %tomcat%/conf/server.xml Connector 標簽加屬性 URIEncoding="UTF-8" -->
    <filter>
        <filter-name>CharacterEncodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>utf-8</param-value>
        </init-param>
    </filter>
    
    <filter-mapping>
        <filter-name>CharacterEncodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>
    
</web-app>

View Code

測試

打開多個窗口，分別輸入http://localhost:8080/websocket/index.jsp，然後在某一窗口發送消息的時候，其他窗口都能接收到：

技術分享

消息推送二之webSocket

還需由於 else har 頁面 try window class logs 友情提示：消息推送的介紹可以參考http://www.cnblogs.com/dahuandan/p/6816173.html 什麽是webSocket webSocket是為解決客

Android 基於Netty的消息推送方案之概念和工作原理(二)

img b2c 決定 watermark net nios 通道感覺 art 上一篇文章中我講述了關於消息推送的方案以及一個基於Netty實現的一個簡單的Hello World。為了更好的理解Hello World中的代碼，今天我來解說一下關於Netty中一些概念和工

WebSocket消息推送

parse 才會拆分創建 max win event its 數據 WebSocket協議是基於TCP的一種新的網絡協議，應用層，是TCP/IP協議的子集。它實現了瀏覽器與服務器全雙工（full-duplex）通信，客戶端和服務器都可以向對方主動發送和接收數據。在JS

WebSocket與消息推送

加密 sin exp 安裝flash throwable tin pat 允許被調用轉自張果原文 WebSocket與消息推送 B/S結構的軟件項目中有時客戶端需要實時的獲得服務器消息，但默認HTTP協議只支持請求響應模式，這樣做可以簡化Web服務器，減少服

springboot實現服務器端消息推送（websocket + sockjs + stomp）

client rem queue rip rsa socket gin enabled lis 　　服務器端推送技術在web開發中比較常用，可能早期很多人的解決方案是采用ajax向服務器輪詢消息，這種方式的輪詢頻率不好控制，所以大大增加了服務器的壓力，後來有了下面的方案

PWA之消息推送——Notification

更新 grant sticky cat alert gecko per tag 授權原文　　簡書原文：https://www.jianshu.com/p/69042b92cae1 大綱　　1、推送通知的概念　　2、消息推送的知識點　　3、實例 1、推送通知的概念　　

spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解

退出 rec oid -name 返回 classes sockets 們的 tomcat7.0 spring websocket 和socketjs實現單聊群聊,廣播的消息推送詳解 WebSocket簡單介紹　　隨著互聯網的發展，傳統的HTTP協議已經很難滿足Web應用

微信小程序之模板消息推送

默認 .json 定時刷新 lec pla 跳轉頁面 -a scp pscp 最近在用sanic框架寫微信小程序，其中寫了一個微信消息推送，還挺有意思的，寫了個小demo 具體見官方文檔：https://developers.weixin.qq.com/miniprogra

C# 之小程序 webapi 認證微信小程序CheckSignature 消息推送

return 程序登錄 apps 平臺 ger file app bubuko 微信小程序想實現模板消息推送的話 1.登錄到微信公眾平臺 - 小程序 - 開發 - 開發設置。找到消息推送 2.驗證消息的確來自微信服務器微信只提供了ph

GoBelieve IM 消息推送的方案

apn dem 所有消息做的 pan 切換賬戶 mic 消息推送設計方案如下：所有接入im SDK的deviceTOken都會存儲到IM服務器。就可以 IM服務器來根據你們服務器指定的useId來下發消息。判斷客戶端在線，並且APP在前臺。就是socket下發，IM

iOS開發——遠程消息推送的實現

ice 分享 mit load con targe you 取消 tex 在我們使用App的過程中。總是會收到非常多的消息推送。今天我們就要來實現這個功能。首先消息推送分為本地消息推送和遠程消息推送。而當中又以遠程消息最為經常使用。可是在推送遠程消息之前。

細說 iOS 消息推送

not 個數 text payload 自己是否 coffee reserve use APNS的推送機制與Android上我們自己實現的推送服務不一樣，Apple對設備的控制很嚴格。消息推送的流程必需要經過APNs：這裏 Provider 是指某個應用的

asp.net web 通過IHttpAsyncHandler接口進行消息推送

authent div reg ret back sig sts content validate 1.創建Comet_by_ASP.NET web項目 2.handler類和result類 namespace Handle { /// <summary&g

SignalR Self Host+MVC等多端消息推送服務(2)

寫到後端 local -1 顯示 rgs 代碼發送登錄一、概述上次的文章中我們簡單的實現了SignalR自托管的服務端，今天我們來實現控制臺程序調用SignalR服務端來實現推送信息，由於之前我們是打算做審批消息推送，所以我們的demo方向是做指定人發送信息，至

vue js 和signalr 結合實現消息推送1

ack all client aspnet 由於 user startup man logs 由於signalr2.2.0 依賴於jQuery,雖然在vuejs 略顯臃腫，但是對於目前剛接觸 vuejs 和想實現前後分離的我來說這已經很好了。目前先實現功能，然後如果

MQTT是IBM開發的一個即時通訊協議，構建於TCP/IP協議上，是物聯網IoT的訂閱協議，借助消息推送功能，可以更好地實現遠程控制

集合 cap 消息處理簡易遠程控制 mes ogr 設計思想成本最近一直做物聯網方面的開發，以下內容關於使用MQTT過程中遇到問題的記錄以及需要掌握的機制原理,主要講解理論。背景 MQTT是IBM開發的一個即時通訊協議。MQTT構建於TCP/IP協議上

互聯網產品消息推送設計策略（轉）

做出可能依然應用存在第一次時間段時間保持在移動互聯時代，消息推送越來越受到各個APP的重視，本文就以互金產品為例闡述消息推送的幾個類別以及應用的場景方式、運營策略，希望對你有益。在之前一文中，筆者概括性的介紹了通知功能是互金理財平臺的一個基礎但重要

errcode 4103 invalid page hint 小程序模板消息推送遇到的坑

val 推送技術 pid 遇到小程序微信 err 成功 invalid page hint一直提示這個坑爹的就是，我的小程序沒發布之前，也就是測試版本用這個格式是可以的 /pages/myGroup/myGroup?groupid=22***但是發布成功以後，線上

apollo實現c#與android消息推送(三)

class net names oid urn 服務 mbo target parse 3 實現c#消息推送服務 c#實現消息推送必須引入M2Mqtt.dll，源碼 a 連接apache apollo代理服務器的代碼。需要引入using uPLibrar

IM系統：消息推送及離線存儲

target 做到 targe 用戶 mda fontsize 部分 watermark 維護一、服務端維護每條消息對用戶的送達狀態二、利用標號標記最新已讀消息說明： 1、消息離線存儲與拉取部分，有贊客服系統現有實現采用第二種方式 2、文章參考了沈

消息推送二 之webSocket

什麽是webSocket

優點

helloWord

環境準備

Constants.java

WebSocketConfig.java

WebSocketInterceptor.java

MyWebSocketHandler.java

index.jsp

spring.xml

springmvc.xml

web.xml

測試

相關推薦

消息推送二之webSocket