<!-- webSocket 秒杀通知--><dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-websocket</artifactId></dependency>

WebSocketConfig 配置：

/**   * WebSocket配置   * 创建者  爪哇笔记   * 创建时间    2018年5月29日   */@ConfigurationpublicclassWebSocketConfig{      @Beanpublic ServerEndpointExporter serverEndpointExporter(){              returnnew ServerEndpointExporter();          }  }

WebSocketServer 配置：

@ServerEndpoint("/websocket/{userId}")@ComponentpublicclassWebSocketServer{    privatefinalstatic Logger log = LoggerFactory.getLogger(WebSocketServer.class);    //静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。privatestaticint onlineCount = 0;    //concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。privatestatic CopyOnWriteArraySet<WebSocketServer> webSocketSet = new CopyOnWriteArraySet<WebSocketServer>();    //与某个客户端的连接会话，需要通过它来给客户端发送数据private Session session;    //接收userIdprivate String userId="";    /**     * 连接建立成功调用的方法*/@OnOpenpublicvoidonOpen(Session session,@PathParam("userId") String userId) {        this.session = session;        webSocketSet.add(this);     //加入set中        addOnlineCount();           //在线数加1        log.info("有新窗口开始监听:"+userId+",当前在线人数为" + getOnlineCount());        this.userId=userId;        try {             sendMessage("连接成功");        } catch (IOException e) {            log.error("websocket IO异常");        }    }    /**     * 连接关闭调用的方法     */@OnClosepublicvoidonClose(){        webSocketSet.remove(this);  //从set中删除        subOnlineCount();           //在线数减1        log.info("有一连接关闭！当前在线人数为" + getOnlineCount());    }    /**     * 收到客户端消息后调用的方法     * @param message 客户端发送过来的消息   */@OnMessagepublicvoidonMessage(String message, Session session){        log.info("收到来自窗口"+userId+"的信息:"+message);        //群发消息for (WebSocketServer item : webSocketSet) {            try {                item.sendMessage(message);            } catch (IOException e) {                e.printStackTrace();            }        }    }    /**     * @param session     * @param error     */@OnErrorpublicvoidonError(Session session, Throwable error){        log.error("发生错误");        error.printStackTrace();    }    /**     * 实现服务器主动推送     */publicvoidsendMessage(String message)throws IOException {        this.session.getBasicRemote().sendText(message);    }    /**     * 群发自定义消息     * */publicstaticvoidsendInfo(String message,@PathParam("userId") String userId){        log.info("推送消息到窗口"+userId+"，推送内容:"+message);        for (WebSocketServer item : webSocketSet) {            try {                //这里可以设定只推送给这个userId的，为null则全部推送if(userId==null) {                    item.sendMessage(message);                }elseif(item.userId.equals(userId)){                    item.sendMessage(message);                }            } catch (IOException e) {                continue;            }        }    }    publicstaticsynchronizedintgetOnlineCount(){        return onlineCount;    }    publicstaticsynchronizedvoidaddOnlineCount(){        WebSocketServer.onlineCount++;    }    publicstaticsynchronizedvoidsubOnlineCount(){        WebSocketServer.onlineCount--;    }}

KafkaConsumer 消费配置，通知用户是否秒杀成功：

/** * 消费者 spring-kafka 2.0 + 依赖JDK8 * @author  By https://blog.52itstyle.com */@ComponentpublicclassKafkaConsumer{    @Autowiredprivate ISeckillService seckillService;        privatestatic RedisUtil redisUtil = new RedisUtil();    /**     * 监听seckill主题,有消息就读取     * @param message     */@KafkaListener(topics = {"seckill"})    publicvoidreceiveMessage(String message){        //收到通道的消息之后执行秒杀操作        String[] array = message.split(";");         if(redisUtil.getValue(array[0])!=null){//control层已经判断了，其实这里不需要再判断了            Result result = seckillService.startSeckil(Long.parseLong(array[0]), Long.parseLong(array[1]));            if(result.equals(Result.ok())){                WebSocketServer.sendInfo(array[0].toString(), "秒杀成功");//推送给前台            }else{                WebSocketServer.sendInfo(array[0].toString(), "秒杀失败");//推送给前台                redisUtil.cacheValue(array[0], "ok");//秒杀结束            }        }else{            WebSocketServer.sendInfo(array[0].toString(), "秒杀失败");//推送给前台        }    }}

webSocket.js 前台通知逻辑：

$(function(){    socket.init();});var basePath = "ws://localhost:8080/seckill/";socket = {    webSocket : "",    init : function() {        //userId：自行追加if ('WebSocket'inwindow) {            webSocket = new WebSocket(basePath+'websocket/1');         }         elseif ('MozWebSocket'inwindow) {            webSocket = new MozWebSocket(basePath+"websocket/1");        }         else {            webSocket = new SockJS(basePath+"sockjs/websocket");        }        webSocket.onerror = function(event) {            alert("websockt连接发生错误，请刷新页面重试!")        };        webSocket.onopen = function(event) {                    };        webSocket.onmessage = function(event) {            var message = event.data;            alert(message)//判断秒杀是否成功、自行处理逻辑        };    }}

客户端API

客户端与服务器通信

send() 向远程服务器发送数据
close() 关闭该websocket链接

监听函数　

onopen 当网络连接建立时触发该事件
onerror 当网络发生错误时触发该事件
onclose 当websocket被关闭时触发该事件
onmessage 当websocket接收到服务器发来的消息的时触发的事件，也是通信中最重要的一个监听事件。msg.data

readyState属性

这个属性可以返回websocket所处的状态。

CONNECTING(0) websocket正尝试与服务器建立连接
OPEN(1) websocket与服务器已经建立连接
CLOSING(2) websocket正在关闭与服务器的连接
CLOSED(3) websocket已经关闭了与服务器的连接

开源方案

goeasy

GoEasy实时Web推送，支持后台推送和前台推送两种：后台推送可以选择Java SDK、 Restful API支持所有开发语言；前台推送：JS推送。无论选择哪种方式推送代码都十分简单（10分钟可搞定）。由于它支持websocket 和polling两种连接方式所以兼顾大多数主流浏览器，低版本的IE浏览器也是支持的。

地址：http://goeasy.io/