消息實(shí)時(shí)推送可使得用戶(hù)及時(shí)獲取相關(guān)的信息，增加工作的處理效率精刷，獲得更好的交互體驗(yàn)乐疆。消息推送的應(yīng)用場(chǎng)景舉例
---新內(nèi)容提示——新文章，新視頻贬养，新留言
---任務(wù)列表提示——下午6點(diǎn)有視頻會(huì)議挤土，有兩個(gè)審批文件需要批復(fù)，下午4點(diǎn)巡邏A區(qū)
---操作狀態(tài)提示——你上傳的視頻已經(jīng)壓縮完畢误算，你發(fā)布的文章已被收錄
---指引性提示——數(shù)據(jù)文件已處理完畢仰美，請(qǐng)進(jìn)行下一步操作

比較一下兩種不同的瀏覽體驗(yàn)
1、點(diǎn)擊一篇文章儿礼，進(jìn)去閱讀（用戶(hù)主動(dòng)獲取信息）
2咖杂、界面蹦出一個(gè)界面，你的付款已成功（正常信息推送）蚊夫；正在瀏覽網(wǎng)頁(yè)時(shí)诉字，突然蹦出一個(gè)聯(lián)系客服的對(duì)話(huà)框等（不良信息推送）
在系統(tǒng)推送的消息中，有些是有益信息，有些是影響體驗(yàn)的信息壤圃，或者換句話(huà)說(shuō)陵霉，需要用戶(hù)去篩選和識(shí)別有用的信息。

用戶(hù)主動(dòng)獲取信息示意圖

服務(wù)器主動(dòng)推送信息示意圖

在設(shè)計(jì)過(guò)程中伍绳，要注意推送信息的形勢(shì)踊挠，不要讓用戶(hù)感覺(jué)突兀，或者推送太多不相關(guān)的影響使用體驗(yàn)的信息冲杀。

在具體工作中效床，如何去實(shí)現(xiàn)服務(wù)器推送呢？
信息推送的技術(shù)原理參考：http://88250.b3log.org/web-message-push

通過(guò)下方4步驟可輕松實(shí)現(xiàn)netty-socketio集成到spring中的實(shí)現(xiàn)過(guò)程（官網(wǎng)：https://socket.io/）权谁，
1剩檀、在pom.xml文件中添加依賴(lài)

<!-- 推送 -->
<dependency>
    <groupId>com.corundumstudio.socketio</groupId>
    <artifactId>netty-socketio</artifactId>
    <version>${netty-socketio.version}</version>
</dependency>

2、socketio服務(wù)端程序

package com.macrodata.socketio.service;

import java.util.Collection;
import java.util.HashMap;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;

import com.corundumstudio.socketio.AckRequest;
import com.corundumstudio.socketio.Configuration;
import com.corundumstudio.socketio.SocketIOClient;
import com.corundumstudio.socketio.SocketIOServer;
import com.corundumstudio.socketio.listener.ConnectListener;
import com.corundumstudio.socketio.listener.DataListener;
import com.corundumstudio.socketio.listener.DisconnectListener;
/**
 * 
 * @author JiaqianLi
 *
 */
@Service
public class SocketIoService {
    private Logger logger = LoggerFactory.getLogger(this.getClass());

    private static SocketIOServer server;
    private static Map<String, SocketIOClient> clientsMap = new HashMap<String, SocketIOClient>();

    public SocketIoService() {
        // 初始化時(shí)啟動(dòng)服務(wù)
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    startServer();
                    logger.info("SocketIOServer啟動(dòng)成功旺芽！");
                } catch (InterruptedException e) {
                    logger.error("SocketIOServer啟動(dòng)失敾铩！", e);
                }
            }
        }, "SocketIOServer啟動(dòng)線(xiàn)程").start();
    }

    public void startServer() throws InterruptedException {
        Configuration config = new Configuration();
        // 服務(wù)器主機(jī)ip
        config.setHostname("localhost");
        // 端口
        config.setPort(9092);
        config.setMaxFramePayloadLength(1024 * 1024);
        config.setMaxHttpContentLength(1024 * 1024);
        server = new SocketIOServer(config);
        // 監(jiān)聽(tīng)廣告推送事件甥绿，advert_info為事件名稱(chēng)字币，自定義
        server.addEventListener("advert_info", String.class, new DataListener<String>() {
            @Override
            public void onData(SocketIOClient client, String data, AckRequest ackRequest)
                    throws ClassNotFoundException {
                // 客戶(hù)端推送advert_info事件時(shí)则披，onData接受數(shù)據(jù)共缕，這里是string類(lèi)型的json數(shù)據(jù)，還可以為Byte[],object其他類(lèi)型

                String sa = client.getRemoteAddress().toString();
                String clientIp = sa.substring(1, sa.indexOf(":"));// 獲取客戶(hù)端連接的ip
                // Map params = client.getHandshakeData().getUrlParams();//
                // 獲取客戶(hù)端url參數(shù)

                System.out.println(clientIp + "：客戶(hù)端：************" + data);
                // client.sendEvent("advert_info", data+"你好……");
            }
        });
        // 監(jiān)聽(tīng)通知事件
        server.addEventListener("notice_info", String.class, new DataListener<String>() {
            @Override
            public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
                // 同上
            }
        });

        /**
         * 監(jiān)聽(tīng)其他事件
         */

        // 添加客戶(hù)端連接事件
        server.addConnectListener(new ConnectListener() {
            @Override
            public void onConnect(SocketIOClient client) {
                String sa = client.getRemoteAddress().toString();
                String clientIp = sa.substring(1, sa.indexOf(":"));// 獲取設(shè)備ip
                System.out.println(clientIp + "-------------------------" + "客戶(hù)端已連接");
                // Map params = client.getHandshakeData().getUrlParams();
                String uuid = client.getSessionId().toString();
                clientsMap.put(uuid, client);
                // 給客戶(hù)端發(fā)送消息
                client.sendEvent("advert_info", clientIp + "客戶(hù)端你好士复，我是服務(wù)端图谷，有什么能幫助你的？");
            }
        });
        // 添加客戶(hù)端斷開(kāi)連接事件
        server.addDisconnectListener(new DisconnectListener() {
            @Override
            public void onDisconnect(SocketIOClient client) {
                String sa = client.getRemoteAddress().toString();
                String clientIp = sa.substring(1, sa.indexOf(":"));// 獲取設(shè)備ip
                System.out.println(clientIp + "-------------------------" + "客戶(hù)端已斷開(kāi)連接");
                String uuid = client.getSessionId().toString();
                // 移除客戶(hù)端實(shí)例
                clientsMap.remove(uuid);
                // 給客戶(hù)端發(fā)送消息
                client.sendEvent("advert_info", clientIp + "客戶(hù)端你好阱洪，我是服務(wù)端便贵，期待下次和你見(jiàn)面");
            }
        });
        server.start();

        Thread.sleep(Integer.MAX_VALUE);

        server.stop();
    }

    public void stopServer() {
        if (server != null) {
            server.stop();
            server = null;
        }
    }

    /**
     * 給所有連接客戶(hù)端推送消息
     * 
     * @param eventType
     *            推送的事件類(lèi)型
     * @param message
     *            推送的內(nèi)容
     */
    public void sendMessageToAllClient(String eventType, String message) {
        Collection<SocketIOClient> clients = server.getAllClients();
        for (SocketIOClient client : clients) {
            client.sendEvent(eventType, message);
        }
    }

    /**
     * 給具體的客戶(hù)端推送消息
     * 
     * @param deviceId
     *            設(shè)備類(lèi)型
     * @param eventType推送事件類(lèi)型
     * @param message
     *            推送的消息內(nèi)容
     */
    public void sendMessageToOneClient(String uuid, String eventType, String message) {
        try {
            if (uuid != null && !"".equals(uuid)) {
                SocketIOClient client = (SocketIOClient) clientsMap.get(uuid);
                if (client != null) {
                    client.sendEvent(eventType, message);
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static SocketIOServer getServer() {
        return server;
    }

}

3、客戶(hù)端實(shí)現(xiàn)冗荸，編寫(xiě)socketio_client.js

var SocketioClient = {
        createNew:function(host,port){
            var client = {};
            //服務(wù)器域名/IP
            client.host = host;
            //socketio服務(wù)端口號(hào)
            client.port = port;
            client.socket = io('http://'+host+':'+port);
            client.socket.on('connect', () => {
              console.log(client.socket.id); // 'G5p5...'
            });
            client.socket.on('connect', () => {
                console.log("連接成功");
            });
            client.socket.on('connect_error', (error) => {
                console.error("連接錯(cuò)誤");
            });
            client.socket.on('connect_timeout', (timeout) => {
                console.log("連接超時(shí)");
            });
            client.socket.on('error', (error) => {
              // ...
            });
            client.socket.on('disconnect', (reason) => {
                console.log("關(guān)閉連接");
            });
            client.socket.on('reconnect', (attemptNumber) => {
                console.log("重新連接");
            });
            client.socket.on('reconnect_error', (error) => {
              // ...
            });
            client.socket.on('reconnect_failed', () => {
              // ...
            });
            client.socket.on('ping', () => {
                //console.log("向服務(wù)器端發(fā)送數(shù)據(jù)包");
            });
            client.socket.on('pong', (latency) => {
                //console.log("接收服務(wù)器數(shù)據(jù)包");
            });
            // 向服務(wù)端發(fā)送消息
            client.send = function(event,msg,callback){
                if(callback){
                    client.socket.emit(event, msg,(data) =>callback);
                }else{
                    client.socket.emit(event, msg);
                }
            }
            // 接收服務(wù)端消息
            client.receive = function(event,callback){
                client.socket.on(event,callback);
            }
            return client;
        }
}

4承璃、讓網(wǎng)頁(yè)支持消息推送

<!-- 引入官方的socket.io.js文件 -->
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/2.0.3/socket.io.js"></script>
<!-- 引入第三步創(chuàng)建的socketio_client.js文件 -->
<script src="/static/js/common/socketio_client.js"></script>
<script type="text/javascript">
//構(gòu)建客戶(hù)端實(shí)例
var client = SocketioClient.createNew('localhost',9092);
//接收消息處理
client.receive('advert_info',function(data){
    console.info(data);
        // 在此處更新頁(yè)面顯示（提示效果）
});
//向服務(wù)端發(fā)送消息
function sendMsg(){
    client.send('advert_info', 'jiaqianli.cn@gmail.com');
}
</script>