SQL標準定義了4類隔離級別，包括了一些具體規則，用來限定事務內外的哪些改變是可見的，哪些是不可見的。低級別的隔離級一般支持更高的并發處理，并擁有更低的系統開銷。
Read Uncommitted（讀取未提交內容）

       在該隔離級別，所有事務都可以看到其他未提交事務的執行結果。本隔離級別很少用于實際應用，因為它的性能也不比其他級別好多少。讀取未提交的數據，也被稱之為臟讀（Dirty Read）。
Read Committed（讀取提交內容）

       這是大多數數據庫系統的默認隔離級別（但不是MySQL默認的）。它滿足了隔離的簡單定義：一個事務只能看見已經提交事務所做的改變。這種隔離級別 也支持所謂的不可重復讀（Nonrepeatable Read），因為同一事務的其他實例在該實例處理其間可能會有新的commit，所以同一select可能返回不同結果。
Repeatable Read（可重讀）

       這是MySQL的默認事務隔離級別，它確保同一事務的多個實例在并發讀取數據時，會看到同樣的數據行。不過理論上，這會導致另一個棘手的問題：幻讀 （Phantom Read）。簡單的說，幻讀指當用戶讀取某一范圍的數據行時，另一個事務又在該范圍內插入了新行，當用戶再讀取該范圍的數據行時，會發現有新的“幻影” 行。InnoDB和Falcon存儲引擎通過多版本并發控制（MVCC，Multiversion Concurrency Control）機制解決了該問題。

Serializable（可串行化） 
       這是最高的隔離級別，它通過強制事務排序，使之不可能相互沖突，從而解決幻讀問題。簡言之，它是在每個讀的數據行上加上共享鎖。在這個級別，可能導致大量的超時現象和鎖競爭。

         這四種隔離級別采取不同的鎖類型來實現，若讀取的是同一個數據的話，就容易發生問題。例如：

         臟讀(Drity Read)：某個事務已更新一份數據，另一個事務在此時讀取了同一份數據，由于某些原因，前一個RollBack了操作，則后一個事務所讀取的數據就會是不正確的。

         不可重復讀(Non-repeatable read):在一個事務的兩次查詢之中數據不一致，這可能是兩次查詢過程中間插入了一個事務更新的原有的數據。

         幻讀(Phantom Read):在一個事務的兩次查詢中數據筆數不一致，例如有一個事務查詢了幾列(Row)數據，而另一個事務卻在此時插入了新的幾列數據，先前的事務在接下來的查詢中，就會發現有幾列數據是它先前所沒有的。

         在MySQL中，實現了這四種隔離級別，分別有可能產生問題如下所示：

下面，將利用MySQL的客戶端程序，分別測試幾種隔離級別。測試數據庫為test，表為tx；表結構：

兩個命令行客戶端分別為A，B；不斷改變A的隔離級別，在B端修改數據。

（一）、將A的隔離級別設置為read uncommitted(未提交讀)

 在B未更新數據之前：

客戶端A：

B更新數據：

客戶端B：

客戶端A：

        經過上面的實驗可以得出結論，事務B更新了一條記錄，但是沒有提交，此時事務A可以查詢出未提交記錄。造成臟讀現象。未提交讀是最低的隔離級別。

（二）、將客戶端A的事務隔離級別設置為read committed(已提交讀)

 在B未更新數據之前：

B更新數據：

客戶端B：

客戶端A：

       經過上面的實驗可以得出結論，已提交讀隔離級別解決了臟讀的問題，但是出現了不可重復讀的問題，即事務A在兩次查詢的數據不一致，因為在兩次查詢之間事務B更新了一條數據。已提交讀只允許讀取已提交的記錄，但不要求可重復讀。

(三)、將A的隔離級別設置為repeatable read(可重復讀)

 在B未更新數據之前：

B更新數據：

客戶端B：

客戶端A：

B插入數據：

客戶端B：

客戶端A：

       由以上的實驗可以得出結論，可重復讀隔離級別只允許讀取已提交記錄，而且在一個事務兩次讀取一個記錄期間，其他事務部的更新該記錄。但該事務不要求與其他事務可串行化。例如，當一個事務可以找到由一個已提交事務更新的記錄，但是可能產生幻讀問題(注意是可能，因為數據庫對隔離級別的實現有所差別)。像以上的實驗，就沒有出現數據幻讀的問題。

(四)、將A的隔離級別設置為 可串行化 (Serializable)

A端打開事務，B端插入一條記錄

事務A端：

事務B端：

因為此時事務A的隔離級別設置為serializable，開始事務后，并沒有提交，所以事務B只能等待。

事務A提交事務：

事務A端

事務B端

      
 serializable完全鎖定字段，若一個事務來查詢同一份數據就必須等待，直到前一個事務完成并解除鎖定為止 。是完整的隔離級別，會鎖定對應的數據表格，因而會有效率的問題。

一、rsync的概述

rsync是類unix系統下的數據鏡像備份工具，從軟件的命名上就可以看出來了——remote sync。rsync是Linux系統下的文件同步和數據傳輸工具，它采用“rsync”算法，可以將一個客戶機和遠程文件服務器之間的文件同步，也可以 在本地系統中將數據從一個分區備份到另一個分區上。如果rsync在備份過程中出現了數據傳輸中斷，恢復后可以繼續傳輸不一致的部分。rsync可以執行 完整備份或增量備份。它的主要特點有：

1.可以鏡像保存整個目錄樹和文件系統；

2.可以很容易做到保持原來文件的權限、時間、軟硬鏈接；無須特殊權限即可安裝；

3.可以增量同步數據，文件傳輸效率高，因而同步時間短；

4.可以使用rcp、ssh等方式來傳輸文件，當然也可以通過直接的socket連接；

5.支持匿名傳輸，以方便進行網站鏡象等；

6.加密傳輸數據，保證了數據的安全性；

二、鏡像目錄與內容

rsync -av duying  /tmp/test

查看/tmp/test目錄，我們可以看到此命令是把duying這個文件夾目錄連同內容全部考到當前目錄下了

rsync  -av duying/ /tmp/test         注意：比上一條命令多了符號“/” 

再次查看/tmp/test目錄，我們發現沒有duying這個目錄，只是看到了目錄中的內容

三、增量備份本地文件

rsync -avzrtopgL  --progress /src /dst

-v是“--verbose”,即詳細模式輸出； -z表示“--compress”，即傳輸時對數據進行壓縮處理；

-r表示“--recursive”，即對子目錄以遞歸的模式處理；-t是“--time”，即保持文件時間信息；

-o表示“owner”，用來保持文件屬主信息；-p是“perms”，用來保持文件權限；

-g是“group”，用來保持文件的屬組信息；

--progress用于顯示數據鏡像同步的過程；

四、鏡像同步備份文件

rsync -avzrtopg --progress --delete /src  /dst

--delete選項指定以rsync服務器端為基礎進行數據鏡像同步，也就是要保持rsync服務器端目錄與客戶端目錄的完全一致；

--exclude選項用于排除不需要傳輸的文件類型；

五、設置定時備份策略

crontab -e

30 3 * * * rsync -avzrtopg  --progress  --delete  --exclude "*access*"

--exclude "*debug*"  /src /dst

如果文件比較大，可使用nohup將進程放到后臺執行。

nohup rsync -avzrtopgL  --progress /data/opt /data2/  >/var/log/$(date +%Y%m%d).mail.log & 

六、rsync的優點與不足

與傳統的cp、tar備份方式對比，rsync具有安全性高、備份迅速、支持增量備份等優點，通過rsync可以解決對實時性要求不高的數據備份需求，例如，定期地備份文件服務器數據到遠端服務器，對本地磁盤定期進行數據鏡像等。

但是隨著系統規模的不斷擴大，rsync的缺點逐漸被暴露了出來。首先，rsync做數據同步時，需要掃描所有文件后進行對比，然后進行差量傳輸。如果文 件很大，掃面文件是非常耗時的，而且發生變化的文件往往是很少一部分，因此rsync是非常低效的方式。其次，rsync不能實時監測、同步數據，雖然它 可以通過Linux守護進程的方式觸發同步，但是兩次觸發動作一定會有時間差，可能導致服務器端和客戶端數據出現不一致。

轉自：http://blog.sina.com.cn/s/blog_6954b9a901011esn.html

     Linux下如何查看版本信息， 包括位數、版本信息以及CPU內核信息、CPU具體型號等等，整個CPU信息一目了然。

1. 在項目上右鍵進入Properties,選擇Deployment Assembly，再點擊Add...,如下圖所示：
   
   ２.然后在彈出的窗口中，選擇Java Build Path Entries，點擊Next,如下圖所示：
   
   
   
   3.選擇你要你引入的UserLibrary，點擊Finish即可
   
   注意：如果在Java Web Project引入了其它Java Project,默認引用的Java　Project的編譯后字節碼是不會部署到WEB-INF/class下的，此時需要使用上面的Project進行導出．

原文：http://hg.rabbitmq.com/rabbitmq-management/raw-file/3646dee55e02/priv/www-api/help.html

介紹

除了幫助頁面，所有URIs只會服務application/json類型的資源，并且需要HTTP基礎認證(使用標準RabbitMQ用戶數據庫). 默認用戶是guest/guest.

大多數URIs需要虛擬主機名稱作為其路徑的一部分, 因為名稱是虛擬主機的唯一標識符對象. 默認虛擬主機稱為"/", 它需要編碼為"%2f".

PUT一個資源會對其進行創建. 你上傳的JSON對象必須有某個鍵keys (下面文檔有描述)，其它的鍵會被忽略. 缺失鍵會引發錯誤.

在AMQP中，由于綁定沒有名稱或IDs，因此我們基于其所有屬性人工合成了一個. 

由于一般情況下很難預測這個名字, 你可以通過POST一個工廠URI來創建綁定.查看下面的例子.

注意事項

• arguments 字段會被忽略.你不創建一個隊列,交換器或使用參數進行綁定. 帶有參數的隊列，交換器或綁定也不會顯示這些參數．
• 權限偶爾才需要強制執行.如果一個用戶能用HTTP API進行認證，那么它們可以做任何事情.
• 從GET請求中返回的對象中包含許多與監控相關的信息. 它們是無證實的，并且將來可能要發生變化.

示例

下面有幾個快速例子,它們使用了Unix命令行工具curl:

• 獲取虛擬主機列表:

  $ curl -i -u guest:guest http://localhost:55672/api/vhosts 
  HTTP/1.1 200 OK 
  Server: MochiWeb/1.1 WebMachine/1.7 (participate in the frantic) 
  Date: Tue, 31 Aug 2010 15:46:59 GMT 
  Content-Type: application/json 
  Content-Length: 5  
  ["/"]

• 創建一個新虛擬主機:

  $ curl -i -u guest:guest -H "content-type:application/json" \   -XPUT http://localhost:55672/api/vhosts/foo 
  HTTP/1.1 204 No Content 
  Server: MochiWeb/1.1 WebMachine/1.7 (participate in the frantic) 
  Date: Fri, 27 Aug 2010 16:56:00 GMT 
  Content-Type: application/json 
  Content-Length: 0

  注意: 你必須將mime類型指定為application/json.

  Note: 在上傳的JSON對象中，對象名稱是不需要的，因為它已經包含在了URI中. 由于一個虛擬主機除了名稱外沒有其它屬性，這意味著你完全不需要指定一個body.

• 在默認虛擬主機中創建一個新的交換器:

  $ curl -i -u guest:guest -H "content-type:application/json" \   -XPUT -d'{"type":"direct","auto_delete":false,"durable":true,"arguments":[]}' \   http://localhost:55672/api/exchanges/%2f/my-new-exchange 
  HTTP/1.1 204 No Content 
  Server: MochiWeb/1.1 WebMachine/1.7 (participate in the frantic) 
  Date: Fri, 27 Aug 2010 17:04:29 GMT 
  Content-Type: application/json 
  Content-Length: 0

  注意: 在PUT或DELETE的響應中， 除非失敗了，否則我們絕不會返回一個body.

• 再刪除它:

  $ curl -i -u guest:guest -H "content-type:application/json" \   -XDELETE http://localhost:55672/api/exchanges/%2f/my-new-exchange 
  HTTP/1.1 204 No Content 
  Server: MochiWeb/1.1 WebMachine/1.7 (participate in the frantic) 
  Date: Fri, 27 Aug 2010 17:05:30 GMT 
  Content-Type: application/json 
  Content-Length: 0

參考

{"type":"direct","auto_delete":false,"durable":true,"arguments":[]}

{"auto_delete":false,"durable":true,"arguments":[]}

{"routing_key":"my_routing_key","arguments":[]}

{"password":"secret"}

{"scope":"client","configure":".*","write":".*","read":".*"}

rabbitmqctl list_exchanges -p /myvhost name type

rabbitmqctl list_bindings -p /myvhost exchange_name queue_name

rabbitmqctl list_connections send_pend port

rabbitmqctl list_channels connection messages_unacknowledged

rabbitmqctl status

rabbitmqctl report > server_report.txt

rabbitmqctl eval 'node().'

• 使 client 連接與程序相關聯
• 使用細粒度的權限
• 憑據翻滾(如. 周期性地或遭到破壞的情況下)

• 至少有128 MB
• 當RAM達到4GB時，可配置為75%的RAM限制
• 當RAM達到4GB－8GB時，可配置為80%的RAM限制
• 當RAM達到8GB－16GB時，可配置為85%的RAM限制
• 當RAM大于16GB時，可配置為90%的RAM限制

• 至少有2 GB
• 當限制為1到8GB的RAM時，可配置為RAM限制的50％
• 當限制為8到32GB的RAM時，可配置為RAM限制的40%
• 當限制超過32GB的RAM時，可配置為RAM限制的30%

• 希望的吞吐量
• 希望的復制( mirrors的數目)
• 數據局部性

原文：http://www.oracle.com/technetwork/articles/java/jsr356-1937161.html

學習如何在你的應用程序中集成WebSockets.

Published April 2013

對于許多基于客戶端－服務器程序來說，老的HTTP 請求-響應模型已經有它的局限性. 信息必須通過多次請求才能將其從服務端傳送到客戶端.

過去許多的黑客使用某些技術來繞過這個問題，例如：長輪詢(long polling)、基于 HTTP 長連接的服務器推技術(Comet). 

在2011年, IETF發布了標準WebSocket協議－RFC 6455. 從那時起，大多數Web瀏覽器都實現了支持WebSocket協議的客戶端APIs.同時，許多Java 包也開始實現了WebSocket協議.

WebSocket協議利用HTTP升級技術來將HTTP連接升級到WebSocket. 一旦升級后，連接就有了在兩個方向上相互獨立(全雙式)發送消息(數據楨)的能力. 

不需要headers 或cookies,這大大降低了所需的帶寬. 通常，WebSockets來周期性地發送小消息 (例如，幾個字節). 

JSR 356

JSR 356, WebSocket的Java API, 明確規定了API，當Java開發者需要在應用程序中集成WebSocket時，就可以使用此API—服務端和客戶端均可. 每個聲明兼容JSR 356的WebSocket協議，都必須實現這個API. 

因此，開發人員可以自己編寫獨立于底層WebSocket實現的WebSocket應用。這是一個巨大的好處，因為它可以防止供應商鎖定，并允許更多的選擇、自由的庫、應用程序服務器。

JSR 356是即將到來的java EE 7標準的一部分，因此，所有與Java EE 7兼容的應用服務器都有JSR 365標準WebSocket的實現.一旦建立，WebSocket客戶端和服務器節點已經是對稱的了。客戶端API與服務器端API的區別是很小的，JSR 356定義的Java client API只是Java EE7完整API的子集.

客戶段－服務器端程序使用WebSockets，通常會包含一個服務器組件和多個客戶端組件, 如圖１所示:

圖1

在這個例子中，server application 是通過Java編寫的,WebSocket 協議細節是由包含在Java EE 7容器中JSR 356 實現來處理的.

JavaFX 客戶端可依賴任何與JSR 356兼容的客戶端實現來處理WebSocket協議問題. 

其它客戶端(如,iOS 客戶端和HTML5客戶端)可使用其它 (非Java)與RFC6455兼容的實現來與server application通信.

編程模型

JSR 356定義的專家小組,希望支持Java EE開發人員常用的模式和技術。因此,JSR 356使用了注釋和注入。

一般來說，支持兩種編程模型:

• 注解驅動(annotation-driven). 通過使用注解POJOs, 開發者可與WebSocket生命周期事件交互.
• 接口驅動(interface-driven). 開發者可實現Endpoint接口和與生命周期交互的方法.

生命周期事件

典型的WebSocket 交互生命周期如下:

• 一端 (客戶端) 通過發送HTTP握手請求來初始化連接.
• 其它端(服務端) 回復握手響應.
• 建立連接.從現在開始，連接是完全對稱的.
• 兩端都可發送和接收消息.
• 其中一端關閉連接.

大部分WebSocket生命周期事件都與Java方法對應，不管是 annotation-driven 還是interface-driven.

Annotation-Driven 方式

接受WebSocket請求的端點可以是以 @ServerEndpoint 注解的POJO. 

此注解告知容器，此類應該被認為是WebSocket端點. 

必須的value 元素指定了WebSocket端點的路徑.

考慮下面的代碼片斷:

@ServerEndpoint("/hello")  public class MyEndpoint { } 

此代碼將會以相對路徑hello來發布一個端點.在后續方法調用中，此路徑可攜帶路徑參數，如： /hello/{userid}是一個有效路徑，在這里{userid} 的值，可在生命周期方法使用@PathParam 注解獲取.

在GlassFish中，如果你的應用程序是用上下文mycontextroot 部署的，且在localhost的8080端口上監聽, WebSocket可通過使用ws://localhost:8080/mycontextroot/hello來訪問.

初始化WebSocket連接的端點可以是以 @ClientEndpoint 注解的POJO.@ClientEndpoint 和 @ServerEndpoint的主要區別是ClientEndpoint 不接受路徑路值元素，因為它監聽進來的請求。

@ClientEndpoint  public class MyClientEndpoint {} 

Java中使用注解驅動POJO方式來初始化WebSocket連接，可通過如下代碼來完成:

javax.websocket.WebSocketContainer container = javax.websocket.ContainerProvider.getWebSocketContainer();  container.conntectToServer(MyClientEndpoint.class, new URI("ws://localhost:8080/tictactoeserver/endpoint")); 

此后，以 @ServerEndpoint 或@ClientEndpoint 注解的類都稱為注解端點.

一旦建立了WebSocket連接 ，就會創建 Session，并且會調用注解端點中以@OnOpen注解的方法. 

此方法包含了幾個參數:

• javax.websocket.Session 參數, 代表創建的Session
• EndpointConfig 實例包含了關于端點配置的信息
• ０個或多個以 @PathParam注解的字符串參數,指的是端點路徑的path參數

下面的方法實現了當打開WebSocket時，將會打印session的標識符:

@OnOpen public void myOnOpen (Session session) {    System.out.println ("WebSocket opened: "+session.getId()); } 

Session實例只要WebSocket未關閉就會一直有效. Session類中包含了許多有意思的方法，以允許開發者獲取更多關于的信息。

同時,Session 也包含了應用程序特有的數據鉤子,即通過getUserProperties() 方法來返回 Map<String, Object>. 

這允許開發者可以使用session-和需要在多個方法調用間共享的應用程序特定信息來填充Session實例.

i當WebSocket端收到消息時，將會調用以@OnMessage注解的方法.以@OnMessage 注解的方法可包含下面的參數:

• javax.websocket.Session 參數.
• ０個或多個以 @PathParam注解的字符串參數,指的是端點路徑的path參數
• 消息本身. 下面有可能消息類型描述.

當其它端發送了文本消息時，下面的代碼片斷會打印消息內容:

@OnMessage public void myOnMessage (String txt) {    System.out.println ("WebSocket received message: "+txt); }  

如果以@OnMessage i注解的方法返回值不是void, WebSocket實現會將返回值發送給其它端點.下面的代碼片斷會將收到的文本消息以首字母大寫的形式發回給發送者:

@OnMessage public String myOnMessage (String txt) {    return txt.toUpperCase(); }  

另一種通過WebSocket連接來發送消息的代碼如下:

RemoteEndpoint.Basic other = session.getBasicRemote(); other.sendText ("Hello, world"); 

在這種方式中，我們從Session 對象開始，它可以從生命周期回調方法中獲取(例如,以 @OnOpen注解的方法).session實例上getBasicRemote() 方法返回的是WebSocket其它部分的代表RemoteEndpoint. RemoteEndpoint 實例可用于發送文本或其它類型的消息，后面有描述.

當關閉WebSocket連接時,將會調用@OnClose 注解的方法。此方法接受下面的參數:

• javax.websocket.Session 參數. 注意，一旦WebSocket真正關閉了，此參數就不能被使用了，這通常發生在@OnClose 注解方法返回之后.
• A javax.websocket.CloseReason 參數，用于描述關閉WebSocket的原因,如：正常關閉，協議錯誤,服務過載等等.
• ０個或多個以 @PathParam注解的字符串參數,指的是端點路徑的path參數

下面的代碼片段打印了WebSocket關閉的原因:

@OnClose public void myOnClose (CloseReason reason) {    System.out.prinlnt ("Closing a WebSocket due to "+reason.getReasonPhrase()); } 

完整情況下，這里還有一個生命周期注解:如果收到了錯誤，將會調用 @OnError 注解的方法。

Interface-Driven 方式

annotation-driven 方式允許我們注解一個Java類，以及使用生命周期注解來注解方法. 

使用interface-driven方式,開發者可繼承javax.websocket.Endpoint 并覆蓋其中的onOpen, onClose, 以及onError 方法:

public class myOwnEndpoint extends javax.websocket.Endpoint {    public void onOpen(Session session, EndpointConfig config) {...}    public void onClose(Session session, CloseReason closeReason) {...}    public void onError (Session session, Throwable throwable) {...} } 

為了攔截消息，需要在onOpen實現中注冊一個javax.websocket.MessageHandler:

public void onOpen (Session session, EndpointConfig config) {    session.addMessageHandler (new MessageHandler() {...}); } 

MessageHandler 接口有兩個子接口: MessageHandler.Partial和 MessageHandler.Whole. 

MessageHandler.Partial 接口應該用于當開發者想要收到部分消息通知的時候,MessageHandler.Whole的實現應該用于整個消息到達通知。

下面的代碼片斷會監聽進來的文件消息，并將文本信息轉換為大小版本后發回給其它端點：

public void onOpen (Session session, EndpointConfig config) {    final RemoteEndpoint.Basic remote = session.getBasicRemote();    session.addMessageHandler (new MessageHandler.Whole<String>() {       public void onMessage(String text) {                  try {                      remote.sendString(text.toUpperCase());                  } catch (IOException ioe) {                      // handle send failure here                  }              }     }); } 

消息類型，編碼器，解碼器

WebSocket的JavaAPI非常強大，因為它允許發送任或接收任何對象作為WebSocket消息.

基本上，有三種不同類型的消息:

• 基于文本的消息
• 二進制消息
• Pong 消息,它是WebSocket連接自身

當使用interface-driven模式,每個session最多只能為這三個不同類型的消息注冊一個MessageHandler.

當使用annotation-driven模式,針對不同類型的消息，只允許出現一個@onMessage 注解方法. 在注解方法中，消息內容中允許的參數依賴于消息類型。

Javadoc for the @OnMessage annotation 明確指定了消息類型上允許出現的消息參數:

• "如果方法用于處理文本消息: 
  
  
  • String 用于接收整個消息
  • Java 原型或等價的類用于接收整個消息并將其轉換為此類型
  • String 和 boolean 對用于部分接收消息
  • Reader 用于以阻塞流的方式接收整個消息
  • 端點的任何對象參數存在文本解碼器 (Decoder.Text 或 Decoder.TextStream).
• 如果方法用于處理二進制消息: 
  
  
  • byte[] 或 ByteBuffer 用于接收整個消息
  • byte[] 和 boolean 對, 或者 ByteBuffer 和boolean對用于部分接收消息
  • InputStream 用于按阻塞流的方式接收整個消息
  • 端點的任何對象參數存在二進制解碼器(Decoder.Binary or Decoder.BinaryStream).
• 如果方法是用于處理pong消息: 
  
  
  • PongMessage 用于處理pong消息"

任何Java對象使用編碼器都可以編碼為基于文本或二進制的消息.這種基于文本或二進制的消息將轉輸到其它端點，在其它端點，它可以解碼成Java對象－或者被另外的WebSocket 包解釋. 

通常情況下，XML或JSON用于來傳送WebSocket消息, 編碼/解碼然后會將Java對象編組成XML或JSON并在另一端解碼為Java對象.

encoder是以javax.websocket.Encoder 接口的實現來定義,decoder是以javax.websocket.Decoder 接口的實現來定義的. 

有時，端點實例必須知道encoders和decoders是什么.使用annotation-driven方式, 可向@ClientEndpoint 和 @ServerEndpoint l注解中的encode和decoder元素傳遞 encoders和decoders的列表。

Listing 1 中的代碼展示了如何注冊一個 MessageEncoder 類(它定義了MyJavaObject實例到文本消息的轉換). MessageDecoder 是以相反的轉換來注冊的.

@ServerEndpoint(value="/endpoint", encoders = MessageEncoder.class, decoders= MessageDecoder.class) public class MyEndpoint { ... }  class MessageEncoder implements Encoder.Text<MyJavaObject> {    @override    public String encode(MyJavaObject obj) throws EncodingException {       ...    } }  class MessageDecoder implements Decoder.Text<MyJavaObject> {    @override     public MyJavaObject decode (String src) throws DecodeException {       ...    }     @override     public boolean willDecode (String src) {       // return true if we want to decode this String into a MyJavaObject instance    } } 

Listing 1

Encoder 接口有多個子接口:

• Encoder.Text 用于將Java對象轉成文本消息
• Encoder.TextStream 用于將Java對象添加到字符流中
• Encoder.Binary 用于將Java對象轉換成二進制消息
• Encoder.BinaryStream 用于將Java對象添加到二進制流中

類似地,Decoder 接口有四個子接口:

• Decoder.Text 用于將文本消息轉換成Java對象
• Decoder.TextStream 用于從字符流中讀取Java對象
• Decoder.Binary 用于將二進制消息轉換成Java對象
• Decoder.BinaryStream 用于從二進制流中讀取Java對象

結論

WebSocket Java API為Java開發者提供了標準API來集成IETF WebSocket標準.通過這樣做，Web 客戶端或本地客戶端可使用任何WebSocket實現來輕易地與Java后端通信。

也可參考

• JSR 356 on jcp.org
• JSR 356 specification work on java.net
• Tyrus (JSR 356 Reference Implementation) on java.net
• JSR 342, the Java EE 7 umbrella specification on jcp.org
• GlassFish, the Reference Implementation for Java EE