ANDROID WebSocket+STOMP 1.0版本

37 阅读 0 评论 25 点赞

我是靠谱客的博主清脆大米，最近开发中收集的这篇文章主要介绍ANDROID WebSocket+STOMP 1.0版本，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

Android WebSocket并没有原生的支持，所以那些第三方库如雨后春笋的出现了，那些就不举例了，这里就把一些最简单的开源的东西整合到一起，并且加入了对STOMP的支持，这里命名为cn.fullstacks.websocket，下载地址：http://download.csdn.net/detail/joeysheng/9581442

下面来看看怎么使用

WebSocket

 
         List<BasicNameValuePair> extraHeaders = Arrays.asList( 
        
         new 
         BasicNameValuePair( 
         "Cookie" 
         , 
         "session=abcd" 
         ); 
        
         ); 
        
         WebSocketClient client = 
         new 
         WebSocketClient(URI.create( 
         "wss://irccloud.com" 
         ), 
         new 
         WebSocketClient.Handler() { 
        
         @Override 
        
         public 
         void 
         onConnect() { 
        
         Log.d(TAG, 
         "Connected!" 
         ); 
        
         } 
        
         @Override 
        
         public 
         void 
         onMessage(String message) { 
        
         Log.d(TAG, String.format( 
         "Got string message! %s" 
         , message)); 
        
         } 
        
         @Override 
        
         public 
         void 
         onMessage( 
         byte 
         [] data) { 
        
         Log.d(TAG, String.format( 
         "Got binary message! %s" 
         , toHexString(data)); 
        
         } 
        
         @Override 
        
         public 
         void 
         onDisconnect( 
         int 
         code, String reason) { 
        
         Log.d(TAG, String.format( 
         "Disconnected! Code: %d Reason: %s" 
         , code, reason)); 
        
         } 
        
         @Override 
        
         public 
         void 
         onError(Exception error) { 
        
         Log.e(TAG, 
         "Error!" 
         , error); 
        
         } 
        
         }, extraHeaders); 
        
         client.connect();

连通之后就可以发送消息了

 
    
         // Later…  
        
 
         client.send( 
         "hello!" 
         ); 
        
 
         client.send( 
         new 
         byte 
         [] { 
         0xDE 
         , 
         0xAD 
         , 
         0xBE 
         , 
         0xEF 
         }); 
        
 
         client.disconnect(); 
        
 
  

STOMP

 
         Map<String,String> headersSetup = 
         new 
         HashMap<String,String>(); 
        
         headersSetup.put( 
         "Cookie" 
         , 
         "session=abc" 
         ); 
        
         Stomp stomp =  
         new 
         Stomp( 
         "ws://localhost:8080/wsport" 
         , headersSetup, 
         new 
         ListenerWSNetwork() { 
        
         @Override 
        
         public 
         void 
         onState( 
         int 
         state) { 
        
         Log.d( 
         "stomp onSate" 
         ,String.format( 
         "state:%n" 
         ,state)); 
        
         } 
        
         }); 
        
         stomp.connect(); 
        
         //订阅主题 
        
         stomp.subscribe( 
         new 
         Subscription( 
         "topic/greetings" 
         , 
         new 
         ListenerSubscription() { 
        
         @Override 
        
         public 
         void 
         onMessage(Map<String, String> headers, String body) { 
        
         //接收到消息 
        
         } 
        
         }));

连通好之后就可以发送消息了

 
         stomp.send( 
         "/websocket/sendToTopic" 
         , headers, 
         "hello stomp!" 
         ); 
        
         stomp.disconnect();