日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

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

新聞中心

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

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

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

第一步——擴展javax.websocket.Endpoint類

 
 
  1. public class ProgrammaticEchoEnpoint extends Endpoint {
  2.     @Override
  3.     public void onOpen(Session session, EndpointConfig config) {
  4.         System.out.println("Peer " + session.getId() + " connected");
  5.         session.addMessageHandler(new MessageHandler.Whole() {
  6.             @Override
  7.             public void onMessage(String message) {
  8.                 try {
  9.                     session.getBasicRemote().sendText("Got message from " + session.getId() + "\n" + message);
  10.                 } catch (IOException ex) {
  11.                 }
  12.             }
  13.         });
  14.     }
  15.     @Override
  16.     public void onClose(Session session, CloseReason closeReason) {
  17.         System.out.println("Peer " + session.getId() + " disconnected due to " + closeReason.getReasonPhrase());
  18.     }
  19.     @Override
  20.     public void onError(Session session, Throwable error) {
  21.         System.out.println("Error communicating with peer " + session.getId() + ". Detail: "+ error.getMessage());
  22.     }
  23. }

接下來我們還要編寫客戶端端點(使用同樣的API組合):

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

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

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

 
 
  1. public class CustomServerAppConfigProvider implements ServerApplicationConfig {
  2.     @Override
  3.     public Set getEndpointConfigs(Set> endpointClasses) {
  4.         Set result = new HashSet<>();
  5.         for (Class epClass : endpointClasses) {
  6.             //need to ignore Client endpoint class
  7.             if (epClass.equals(ProgrammaticChatEndpoint.class)) {
  8.                 ServerEndpointConfig sec = ServerEndpointConfig.Builder.create(epClass, "/letschat").build();
  9.                 result.add(sec);
  10.             }
  11.         }
  12.         return result;
  13.     }
  14.     @Override
  15.     public Set> getAnnotatedEndpointClasses(Set> scanned) {
  16.         return Collections.emptySet();
  17.     }
  18. }

怎樣處理Client端點?

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

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

注意事項:

  • 客戶端以及服務(wù)器端的config對象只能為等同于(編程式)對象的@ServerEndpoint以及@ClientEndpoint注釋元素(例如值、編碼器、解碼器以及配置器等等)。
  • 各獨立builder類(ServerEndpointConfig.Builder與ClientEndpointConfig.Builder)用于分別創(chuàng)建服務(wù)器與客戶端配置實例。
  • ServerEndpointConfig實例的創(chuàng)建屬于mandatory,因為服務(wù)器端點無法在不配合URI的前提下進行部署。不過這種情況在客戶端端點方面不會出現(xiàn)——因為其全部作用就是接入現(xiàn)有服務(wù)器端點。
  • 端點config(服務(wù)器&客戶端)擁有configurator概念,其可通過對應(yīng)builder方法進行創(chuàng)建與設(shè)置。
  • 接下來我們還將發(fā)布更多與Websocket相關(guān)的指導(dǎo)性文章,各位敬請期待。

當(dāng)前題目:JavaEE7當(dāng)中的編程式Websocket端點
當(dāng)前路徑:http://www.dlmjj.cn/article/djoojgd.html