websocket autobahn jar包的用法
生活随笔
收集整理的這篇文章主要介紹了
websocket autobahn jar包的用法
小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.
autobahn-0.5.0.jar 文件的地址:?http://pan.baidu.com/s/1slQYcKP
使用websocket好簡單方便,據(jù)一天來我們公司的大神說:websocket是封裝好的成熟的框架,比socket更安全,用起來方便。在原有websocket的基礎(chǔ)上加了一個心跳包的功能。
并且設(shè)置了一個鏈接超時的時間限制。代碼還需要不停地優(yōu)化。
package com.example.administrator.connmanager;
import android.content.Context;
import android.os.Handler;
import android.os.TokenWatcher;
import android.util.Log;
import java.util.Timer;
import java.util.TimerTask;
import de.tavendo.autobahn.WebSocketConnection;
import de.tavendo.autobahn.WebSocketException;
import de.tavendo.autobahn.WebSocketHandler;
import de.tavendo.autobahn.WebSocketOptions;
/**
* @author
* @version 1.0
* @date 2016/9/8 0008
*/
public class ConnManager {
private WebSocketConnection mWebSocketConnection;
private Timer mTimer;
private TimerTask mTimerTask;
private WebSocketOptions mWebSocketOptions;
private Context mContext;
public static List<String> list=new ArrayList<String>();
String uri=null;
public ConnManager(Context context,String ipadress,int port){
mWebSocketConnection=new WebSocketConnection();
mTimer=new Timer();
this.uri="ws://"+ipadress+":"+port;
mWebSocketOptions=new WebSocketOptions();
setwebsocketoptions();
this.mContext=context; //心跳包,不停地發(fā)送消息給服務(wù)器
mTimerTask=new TimerTask() {
@Override
public void run() {
mWebSocketConnection.sendTextMessage("");
Log.i("yuhan", "連接中。。。。。");
}
};
} //鏈接服務(wù)器端的代碼
public void connect(){
try {
mWebSocketConnection.connect(uri, new WebSocketHandler() {
@Override
public void onOpen() {
Log.d("yuhan", "Status: Connected to " + uri);
sendHB();
}
@Override
public void onTextMessage(String payload) {
Log.d("yuhan", "Got echo: " + payload); if(payload.equals("用戶刷新-已收到")) {nowdate=System.currentTimeMillis(); }
}
@Override
public void onClose(int code, String reason) {
Log.d("yuhan", "Connection lost."+reason);
}
},mWebSocketOptions);
} catch (WebSocketException e) {
Log.d("yuhan", e.toString());
}
} //開啟心跳包,每一秒發(fā)送一次消息,如果返回lost再重連
public void sendHB(){
mTimer.schedule(mTimerTask, 1000, 1000); //每次發(fā)送心跳包,服務(wù)器接收到響應(yīng)就會返回一個值,如果查過5s還沒有收到返回值,那么就判定是斷網(wǎng)。 if((System.currentTimeMillis()-nowdate)>5000&&nowdate!=0) {mWebSocketConnection.disconnect();mTimer.cancel();// connect(); Log.i("yuhan", "" + System.currentTimeMillis() + "nowdate:" + nowdate + mWebSocketConnection.isConnected());return; }
}
public void sendMessage(String data){
mWebSocketConnection.sendTextMessage(data);
} //調(diào)整鏈接是否超時的時間限制
public void setwebsocketoptions(){
mWebSocketOptions.setSocketConnectTimeout(30000);
mWebSocketOptions.setSocketReceiveTimeout(10000);
}
}
import android.content.Context;
import android.os.Handler;
import android.os.TokenWatcher;
import android.util.Log;
import java.util.Timer;
import java.util.TimerTask;
import de.tavendo.autobahn.WebSocketConnection;
import de.tavendo.autobahn.WebSocketException;
import de.tavendo.autobahn.WebSocketHandler;
import de.tavendo.autobahn.WebSocketOptions;
/**
* @author
* @version 1.0
* @date 2016/9/8 0008
*/
public class ConnManager {
private WebSocketConnection mWebSocketConnection;
private Timer mTimer;
private TimerTask mTimerTask;
private WebSocketOptions mWebSocketOptions;
private Context mContext;
public static List<String> list=new ArrayList<String>();
String uri=null;
public ConnManager(Context context,String ipadress,int port){
mWebSocketConnection=new WebSocketConnection();
mTimer=new Timer();
this.uri="ws://"+ipadress+":"+port;
mWebSocketOptions=new WebSocketOptions();
setwebsocketoptions();
this.mContext=context; //心跳包,不停地發(fā)送消息給服務(wù)器
mTimerTask=new TimerTask() {
@Override
public void run() {
mWebSocketConnection.sendTextMessage("");
Log.i("yuhan", "連接中。。。。。");
}
};
} //鏈接服務(wù)器端的代碼
public void connect(){
try {
mWebSocketConnection.connect(uri, new WebSocketHandler() {
@Override
public void onOpen() {
Log.d("yuhan", "Status: Connected to " + uri);
sendHB();
}
@Override
public void onTextMessage(String payload) {
Log.d("yuhan", "Got echo: " + payload); if(payload.equals("用戶刷新-已收到")) {nowdate=System.currentTimeMillis(); }
}
@Override
public void onClose(int code, String reason) {
Log.d("yuhan", "Connection lost."+reason);
}
},mWebSocketOptions);
} catch (WebSocketException e) {
Log.d("yuhan", e.toString());
}
} //開啟心跳包,每一秒發(fā)送一次消息,如果返回lost再重連
public void sendHB(){
mTimer.schedule(mTimerTask, 1000, 1000); //每次發(fā)送心跳包,服務(wù)器接收到響應(yīng)就會返回一個值,如果查過5s還沒有收到返回值,那么就判定是斷網(wǎng)。 if((System.currentTimeMillis()-nowdate)>5000&&nowdate!=0) {mWebSocketConnection.disconnect();mTimer.cancel();// connect(); Log.i("yuhan", "" + System.currentTimeMillis() + "nowdate:" + nowdate + mWebSocketConnection.isConnected());return; }
}
public void sendMessage(String data){
mWebSocketConnection.sendTextMessage(data);
} //調(diào)整鏈接是否超時的時間限制
public void setwebsocketoptions(){
mWebSocketOptions.setSocketConnectTimeout(30000);
mWebSocketOptions.setSocketReceiveTimeout(10000);
}
}
總結(jié)
以上是生活随笔為你收集整理的websocket autobahn jar包的用法的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: HashMap?面试?我是谁?我在哪?
- 下一篇: PDF格式分析(五十二)Digital