1.認識WebSocket端點的4個生命週期

• 開啟事件：此事件發生在端點上建立新連線時並且在任何其他事件發生之前
• 訊息事件：此事件接收WebSocket對話中另一個端傳送的訊息。它可以發生在WebSocket端點接收了開啟事件之後並且在接收關閉事件關閉連線之前的任意時刻。
• 錯誤事件：此事件在WebSocket連線或者端點發送錯誤時產生（注：若錯誤是致命錯誤，則該連線會被關閉）
• 關閉事件：此事件表示WebSocket端點的連線目前正在部分地關閉，它可以由參與連線的任意一個端點發出。

2.註解式端點事件處理

對於註解式端點來說，為了攔截不同的生命週期事件，我們需要以下方法級註解：@OnOpen @OnMessage @OnError @OnClose

• @OnOpen

該註解對應攔截開啟事件。開啟事件伴隨著三部分資訊：WebSocket Session物件，用於表示已經建立好的連線；配置物件（EndpointConfig的例項），包含了用來配置端點的資訊；一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑引數。 例子：

	/**
	 * 使用@OnOpen註解的方法是沒有任何返回值的公有方法，
	 * 這些方法有一個可選的Session引數，一個可選的EndpointConfig引數，以及任意數量的被@PathParam註解的String引數。
	 * 另外，這些引數的順序可以任意排列。
	 * @param session 用於表示已經建立好的連線
	 * @param config 配置物件
	 */
	@OnOpen
	public void init(Session session, EndpointConfig config) {
		// initialization code
	}
 

• @OnMessage

該註解對應攔截訊息事件。訊息事件伴隨著四部分資訊：WebSocket Session物件，用於表示已經建立好的連線；配置物件（EndpointConfig的例項），包含了用來配置端點的資訊；一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑引數；訊息本身。
連線上的訊息將以3種基本形式抵達：文字訊息、二進位制訊息或Pong訊息。JavaWebSocket API提供了一系列的選項使得能夠以這些形式接收訊息。最基本的形式是選擇使用帶String引數的方法來處理文字訊息；使用帶ByteBuffer或者是byte[]引數的方法來處理二進位制訊息；若你的訊息將僅僅處理Pong訊息，則可以使用JavaWebSocket API中的PongMessage介面的一個例項。 例子：

	/**
	 * 註解@OnMessage是方法級別註解，該註解指定了被註解的方法處理入站訊息
	 * 這些方法有一個可選的Session引數，一個可選的EndpointConfig引數，任意數量的被@PathParam註解的String引數,以及訊息本身。
	 * @param incomingMessage 入站訊息
	 * @return String 伺服器端返回的資料
	 */
	@OnMessage
	public String reply(String incomingMessage) {
		return "The server has received message:" + incomingMessage;
	}
 

或者：

	@OnMessage
	public void reply(byte[] messageData, Session session) {
        //process binarry data
	}

對於文字和二進位制訊息來說有一些更加高階的選項。例如：你可以選擇當訊息到來時分批地接收文字或者二進位制訊息。若如此，可以使用一對引數來表示到來的訊息分片（partial message）。對文字訊息分片來說是String和boolean，其中String引數表示文字訊息分片，boolean引數表示該分片是否是序列中的最後一個訊息分片；對二進位制訊息分片來說，可以選擇一對引數ByteBuffer（或者byte[])和boolean，其中ByteBuffer（或者byte[])表示二進位制訊息分片，boolean引數表示該分片是否是序列中的最後一個訊息分片。

	@OnMessage
	public void reply(String incomingMessage, boolean isLast) {
		//pass on to feed elsewhere
	}

	@OnMessage
	public void reply(ByteBuffer partialData, boolean isLast) {
		if (!isLast) {
			//there is more to come !
		} else {
			//now we have the whole message !
		}
	}

使用@OnMessage註解來處理輸入訊息的另一個選項是選擇使用Java I/O流（java.io.Reader，java.io.InputStream）。 WebSocket應用一般是非同步的雙向訊息。一般情況下的WebSocket應用並不總是立即響應入站訊息。如果想要立刻響應入站訊息，可以通過將@OnMessage註解的方法的返回型別設定為有返回型別，那麼WebSocket實現立即將返回值作為訊息返回給剛剛在方法中處理的訊息的傳送者。

• @OnError

該註解對應攔截錯誤事件。開啟事件伴隨著三部分資訊：錯誤資訊、傳送錯誤的會話、一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑引數。

	/**註解@OnError是方法級別註解，該註解指定了被註解的方法處理錯誤事件
	 * 這些方法的引數有可選的錯誤資訊、可選的傳送錯誤的會話、可選的一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑
	 * @param t 錯誤資訊
	 */
	@OnError
	public void errorHandler(Throwable t) {
		//log error here
	}

處理入站訊息時，可能會發生3種基本的錯誤型別。

• SessionException ：如果該WebSocket端點的入站訊息是非正常的。
• DecodeException ：當WebSocket實現檢視將入站訊息解碼成開發人員所要求的某個物件時傳送錯誤。
• 其他 ：由WebSocket端點的其他方法產生的執行時錯誤。

如果不選擇在應用中包含錯誤處理方法，那麼WebSocket實現將記錄WebSocket端點操作過程中產生的任何錯誤。

• @OnClose

該註解對應攔截關閉事件。開啟事件伴隨著三部分資訊：關閉資訊、一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑引數、一些描述連線關閉原因的資訊

	/**註解@OnClose是方法級別註解，該註解指定了被註解的方法處理關閉事件
	 * 這些方法的引數有可選的關閉資訊、可選的一組路徑引數，用於開啟階段握手時WebSocket端點匹配入站URI過程中獲取的路徑引數
	 * @param reason 關閉原因
	 */
	@OnError
	public void closeConnection(CloseReason reason) {
		//log the reason for posterity
		//close database connection
	}

參考書籍：

 《Java WebSocket程式設計 開發、部署和保護動態Web應用》/（美）科沃德（Coward, D.） 著；劉建、夏先波 譯. ——北京：清華大學出版社，2015