消息推送的常见方式

轮询

浏览器以指定的时间间隔，向服务器发送HTTP请求，服务器将会实时地返回数据给浏览器。
例如，浏览器端可以定时每秒钟一次给后端发HTTP请求，服务端若有数据会实时返回给浏览器，浏览器通过前端展示出来。假设服务器端没有数据更新，则依然会返回一个空的数据。

轮询的弊端：

1. 易造成浏览器端数据更新的延迟
2. 服务器需要不停地处理浏览器发过来的请求，即使没有数据更新也需要定时发送空数据，给服务器造成较大负担

长轮询

长轮询时浏览器会发出ajax请求（异步的javascript和xml请求），服务器端接收到请求后，会阻塞请求，直到有数据更新或者超时，才会返回。HTTP/1.1采用的长链接就是这种方式。
与轮询的区别就在于：若服务器端无数据更新，轮询会返回空数据，长轮询则会阻塞住，直到超时或数据更新，减少了返回的次数，也减轻了服务器的压力。

SSE（server-sent event）：服务器发送事件

SSE会在服务器和客户端之间打开一个单向通道（服务器向浏览器传输），服务器响应的不再是一次性的数据包，而是text/event-stream类型的数据流信息，当服务器有数据变更时，将数据流式地传输到客户端。
例如浏览器请求下载一个大文件时，就会以流式传输源源不断下载数据到客户端。

浏览器先发出请求，服务器响应并在二者之间打开一个单向通道，然后服务器开始向浏览器源源不断地传输流式数据，直到连接关闭。

WebSocket

WebSocket简介

WebSocket是一种基于TCP连接上进行全双工通信的协议。
（附HTTP协议工作模式：
http1.0：单工。因为是短连接，客户端发起请求之后，服务端处理完请求并收到客户端的响应后即断开连接
http1.1：半双工。默认开启长连接keep-alive，开启一个连接可发送多个请求
http2.0：全双工，允许服务端主动向客户端发送数据）

客户端先发送HTTP请求，请求中包含一个upgrade:websocket字段，即请求将HTTP协议升级为websocket协议，服务端响应头状态为101，表示同意将HTTP协议升级成websocket协议。

切换为websocket协议后，就可以实现全双工通信了。服务器可以主动发数据给客户端，二者之间也可以同时互相发送消息。

WebSocket API

客户端API
现在HTML5已经支持websocket协议。

1. 创建websocket对象：let ws = new WebSocket(URL);
2. websocket对象相关事件：
   open 连接建立时触发：ws.open
   message 客户端接收到服务器发送的数据时触发 ws.onmessage
   close 连接关闭时触发 ws.onclose
3. websocket对象提供的方法
   send()方法：通过websocket对象调用send()方法发送数据给服务端，参数即为要发送的数据

<script>
	let ws = new WebSocket("ws://localhost/chat");
	ws.open = function(){
	
	};
	es.onmessage = function(evt){
		//通过evt.data可以获取服务器发送的数据
	};
	ws.onclose = function(){
	};
</script>

服务端API
Tomcat从7.0.5开始支持WebSocket，并实现了Java WebSocket规范。
Java WebSocket应用由一系列的Endpoint组成。Endpoint是一个Java对象，代表了WebSocket链接的一端。
（例如，某用户用浏览器和服务端建立了websocket连接之后，服务器就会为该用户创建一个自己的Endpoint。即服务端会有和每个客户端一一对应的Endpoint）
所以，对于服务端来说，Endpoint可以视为是处理客户端具体websocket消息的一个接口，专门和某一个浏览器建立一对一的关系，处理其发送的消息，并返回消息等。

Endpoint对象在Websocket握手时创建，并在客户端与服务端链接过程中有效，最后在链接关闭时结束。

通常用注解式方式实现Endpoint，即定义一个POJO，并添加@ServerEndpoint相关注解。
在Endpoint接口中定义了与其生命周期相关的方法，注解式实现如下：

1. @OnOpen：当开启一个新的会话时调用，该方法是客户端与服务端握手成功后调用的方法
2. @OnClose：当会话关闭时调用
3. @OnError：当连接过程异常时调用

了解了Endpoint生命周期，接下来要开始数据传输了！
服务端接收客户端发送的数据：
定义Endpoint时，用@OnMessage注解指定接收消息的方法，收到消息后会自动执行；
服务端推送数据给客户端：
发送消息由RemoteEndpoint完成，其实例由Session维护。
发送消息有同步和异步两种方式：
同步：通过session,getBasicRemote获取同步消息发送的实例，然后调用其sendXxx()方法发送消息
异步：通过session,getAsyncRemote获取异步消息发送实例，然后调用其sendXxx()方法发送消息
（注：如sendText()就是发送文本数据）

@ServerEndpoint("/chat")
@Component
public class ChatEndpoint{
	
	@OnOpen
	//连接建立时被调用
	public void onOpen(Session session, EndpointConfig config){
	
	}
	
	@OnMessage
	//接收客户端发送的数据时被调用
	public void Message(String message){
	
	}
	
	@OnClose
	//连接关闭时调用
	public void onClose(Session session){

	}
}

Web浏览器和服务器建立websocket连接之后，OnOpen事件就会触发，onOpen方法就会自动执行。Tomcat会解析这些注解，然后传递onOpen方法中的参数。

实现小小聊天室

实现流程

1. ws client：为客户端组件，即浏览器；login页面输入用户名密码登录后，会请求UserController里的方法；登录成功后，浏览器会向服务端发送websocket请求，触发OnOpen事件；在发送消息时，将消息推送到服务器端，触发OnMessage事件；当关闭连接时，触发OnClose事件；
2. UserController：用于登录请求的接收，校验用户名密码是否正确；用户名不为空即可，密码要求为123；登录成功后跳转到聊天室页面；
3. @OnOpen：OnOpen事件被触发后，在该方法中要记录session和httpsession，并广播消息；因为登录并建立会话之后，需要通知其他用户我已登录，并把最新的用户列表推送给所有的客户端；
4. @OnMessage：OnMessage事件被触发后，需要解析消息，并判断收消息的人是谁，最后把消息推送给指定的人；
5. @OnClose：Onclose事件被触发后，断开与客户端的连接。

消息格式

消息均为Json格式，分为客户端推送给服务端的消息，以及服务端返回客户端的消息。服务端发往客户端的消息又分两种：一种是系统消息，如显示所有好友信息；另一种是推送给用户的消息，即聊天消息。

客户端–>服务端

消息格式：{“toName”:“刘能”, “message”:“你好”}

服务端–>客户端

1. 系统消息格式：{“system”:true, “fromName”:null, “message”:[“好友1”,“好友2”]}
2. 推送给某一个用户的消息格式：{“system”:false, “fromName”:刘能, “message”:“你好”}