autobahn-0.5.0.jar 文件的地址：?http://pan.baidu.com/s/1slQYcKP 使用websocket好簡單方便，據一天來我們公司的大神說：websocket是封裝好的成熟的框架，比socket更安全，用起來方便。在原有websocket的基礎上加了一個心跳包的功能。 并且設置了一個鏈接超時的時間限制。代碼還需要不停地優化。 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; //心跳包，不停地發送消息給服務器
mTimerTask=new TimerTask() {
@Override
public void run() {
mWebSocketConnection.sendTextMessage("");
Log.i("yuhan", "連接中。。。。。");
}
};
} //鏈接服務器端的代碼
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());
}
} //開啟心跳包，每一秒發送一次消息，如果返回lost再重連
public void sendHB(){
mTimer.schedule(mTimerTask, 1000, 1000); //每次發送心跳包，服務器接收到響應就會返回一個值，如果查過5s還沒有收到返回值，那么就判定是斷網。 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);
} //調整鏈接是否超時的時間限制
public void setwebsocketoptions(){
mWebSocketOptions.setSocketConnectTimeout(30000);
mWebSocketOptions.setSocketReceiveTimeout(10000);
}
}

總結

以上是生活随笔為你收集整理的websocket autobahn jar包的用法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。