日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷解決方案
JavaEE7當(dāng)中的編程式Websocket端點(diǎn)

這篇文章將簡(jiǎn)要演示如何利用Java Websocket API的編程式版本開發(fā)并部署（服務(wù)器與客戶端）websocket端點(diǎn)。

站在用戶的角度思考問題，與客戶深入溝通，找到溫泉網(wǎng)站設(shè)計(jì)與溫泉網(wǎng)站推廣的解決方案，憑借多年的經(jīng)驗(yàn)，讓設(shè)計(jì)與互聯(lián)網(wǎng)技術(shù)結(jié)合，創(chuàng)造個(gè)性化、用戶體驗(yàn)好的作品，建站類型包括：成都做網(wǎng)站、成都網(wǎng)站建設(shè)、企業(yè)官網(wǎng)、英文網(wǎng)站、手機(jī)端網(wǎng)站、網(wǎng)站推廣、域名注冊(cè)、虛擬空間、企業(yè)郵箱。業(yè)務(wù)覆蓋溫泉地區(qū)。

第一步——擴(kuò)展javax.websocket.Endpoint類

 
 
    
  
  
  1. public class ProgrammaticEchoEnpoint extends Endpoint {
    2. 
  
  
  2. 
  
  
  3.     @Override
    4. 
  
  
  4. 
  
  
  5.     public void onOpen(Session session, EndpointConfig config) {
    6. 
  
  
  6. 
  
  
  7.         System.out.println("Peer " + session.getId() + " connected");
    8. 
  
  
  8. 
  
  
  9.         session.addMessageHandler(new MessageHandler.Whole() {
    10. 
  
  
  10. 
  
  
  11.             @Override
    12. 
  
  
  12. 
  
  
  13.             public void onMessage(String message) {
    14. 
  
  
  14. 
  
  
  15.                 try {
    16. 
  
  
  16. 
  
  
  17.                     session.getBasicRemote().sendText("Got message from " + session.getId() + "\n" + message);
    18. 
  
  
  18. 
  
  
  19.                 } catch (IOException ex) {
    20. 
  
  
  20. 
  
  
  21.                 }
    22. 
  
  
  22. 
  
  
  23.             }
    24. 
  
  
  24. 
  
  
  25.         });
    26. 
  
  
  26. 
  
  
  27.     }
    28. 
  
  
  28. 
  
  
  29.     @Override
    30. 
  
  
  30. 
  
  
  31.     public void onClose(Session session, CloseReason closeReason) {
    32. 
  
  
  32. 
  
  
  33.         System.out.println("Peer " + session.getId() + " disconnected due to " + closeReason.getReasonPhrase());
    34. 
  
  
  34. 
  
  
  35.     }
    36. 
  
  
  36. 
  
  
  37.     @Override
    38. 
  
  
  38. 
  
  
  39.     public void onError(Session session, Throwable error) {
    40. 
  
  
  40. 
  
  
  41.         System.out.println("Error communicating with peer " + session.getId() + ". Detail: "+ error.getMessage());
    42. 
  
  
  42. 
  
  
  43.     }
    44. 
  
  
  44. 
  
  
  45. }
    46.

接下來(lái)我們還要編寫客戶端端點(diǎn)（使用同樣的API組合）：

 
 
    
  
  
  1. public class ProgrammaticEchoClient extends Endpoint {
    2. 
  
  
  2. 
  
  
  3.     @Override
    4. 
  
  
  4. 
  
  
  5.     public void onOpen(Session session, EndpointConfig config) {
    6. 
  
  
  6. 
  
  
  7.         System.out.println("Connected to server");
    8. 
  
  
  8. 
  
  
  9.     }
    10. 
  
  
  10. 
  
  
  11.     //a message handler and other life cycle implementations have been skipped on purpose...
    12. 
  
  
  12. 
  
  
  13. }
    14.

第二步——實(shí)現(xiàn)ServerApplicationConfig接口

該接口屬于javax.websocket.server包的組成部分，且能夠通過覆寫以實(shí)現(xiàn)端點(diǎn)部署中的定制化邏輯（適用于注釋以及編程式端點(diǎn)）。

 
 
    
  
  
  1. public class CustomServerAppConfigProvider implements ServerApplicationConfig {
    2. 
  
  
  2. 
  
  
  3.     @Override
    4. 
  
  
  4. 
  
  
  5.     public Set getEndpointConfigs(Set> endpointClasses) {
    6. 
  
  
  6. 
  
  
  7.         Set result = new HashSet<>();
    8. 
  
  
  8. 
  
  
  9.         for (Class epClass : endpointClasses) {
    10. 
  
  
  10. 
  
  
  11.             //need to ignore Client endpoint class
    12. 
  
  
  12. 
  
  
  13.             if (epClass.equals(ProgrammaticChatEndpoint.class)) {
    14. 
  
  
  14. 
  
  
  15.                 ServerEndpointConfig sec = ServerEndpointConfig.Builder.create(epClass, "/letschat").build();
    16. 
  
  
  16. 
  
  
  17.                 result.add(sec);
    18. 
  
  
  18. 
  
  
  19.             }
    20. 
  
  
  20. 
  
  
  21.         }
    22. 
  
  
  22. 
  
  
  23.         return result;
    24. 
  
  
  24. 
  
  
  25.     }
    26. 
  
  
  26. 
  
  
  27.     @Override
    28. 
  
  
  28. 
  
  
  29.     public Set> getAnnotatedEndpointClasses(Set> scanned) {
    30. 
  
  
  30. 
  
  
  31.         return Collections.emptySet();
    32. 
  
  
  32. 
  
  
  33.     }
    34. 
  
  
  34. 
  
  
  35. }
    36.

怎樣處理Client端點(diǎn)？

如果有必要，大家也可以創(chuàng)建自己的ClientEndpointConfig實(shí)例，并利用它對(duì)指向websocket服務(wù)器端點(diǎn)的連接進(jìn)行初始化。

 
 
    
  
  
  1. WebSocketContainer webSocketContainer = ContainerProvider.getWebSocketContainer();
    2. 
  
  
  2. 
  
  
  3. ClientEndpointConfig config = ClientEndpointConfig.Builder.create().decoders(StockTickDecoder.class).build();
    4. 
  
  
  4. 
  
  
  5. Session session = webSocketContainer.connectToServer(StockTickerClient().class, config, 
    6. 
  
  
  6. 
  
  
  7.                                                     new URI("ws://hotstocks.com/ticker"));
    8.

注意事項(xiàng)：

  • 客戶端以及服務(wù)器端的config對(duì)象只能為等同于（編程式）對(duì)象的@ServerEndpoint以及@ClientEndpoint注釋元素（例如值、編碼器、解碼器以及配置器等等）。
  • 各獨(dú)立builder類（ServerEndpointConfig.Builder與ClientEndpointConfig.Builder）用于分別創(chuàng)建服務(wù)器與客戶端配置實(shí)例。
  • ServerEndpointConfig實(shí)例的創(chuàng)建屬于mandatory，因?yàn)榉?wù)器端點(diǎn)無(wú)法在不配合URI的前提下進(jìn)行部署。不過這種情況在客戶端端點(diǎn)方面不會(huì)出現(xiàn)——因?yàn)槠淙孔饔镁褪墙尤氍F(xiàn)有服務(wù)器端點(diǎn)。
  • 端點(diǎn)config（服務(wù)器&客戶端）擁有configurator概念，其可通過對(duì)應(yīng)builder方法進(jìn)行創(chuàng)建與設(shè)置。
  • 接下來(lái)我們還將發(fā)布更多與Websocket相關(guān)的指導(dǎo)性文章，各位敬請(qǐng)期待。

標(biāo)題名稱：JavaEE7當(dāng)中的編程式Websocket端點(diǎn)
轉(zhuǎn)載注明：http://m.5511xx.com/article/djoojgd.html