第一步先下載ws的jar包
好像沒有直接依賴的庫，所以只能下jar包，放到libs中。
我使用的是github中的 這個(gè)地址 的庫，
這是我下載好的jar包 --> 點(diǎn)這里
然后接著放到libs中進(jìn)行依賴jar包
第二步創(chuàng)建Service
創(chuàng)建服務(wù)很簡單，只需要在服務(wù)中創(chuàng)建對(duì)象，開啟連接，發(fā)送信息，接受信息
因?yàn)槲覀兘邮艿氖莏son數(shù)據(jù) ，所有對(duì)接受圖片、文件等沒有研究...（大家可以自己嘗試）
public class SocketService extends Service {
public static String WEB_SOCKET_HOST = "ws://xxxx.xxx.com/wss";//這個(gè)是后臺(tái)給的地址，根據(jù)自家的地址寫上去即可
private static final String TAG = "ws";
private static WebSocketConnection webSocketConnection; // ws 對(duì)應(yīng)的類
private static WebSocketOptions options = new WebSocketOptions(); //ws的個(gè)選項(xiàng)，聲明出來即可使用了
private boolean isOpen;//ws打開的狀態(tài)
@Nullable
@Override
public IBinder onBind(Intent intent) {
return new MyBinder();
}
@Override
public void onCreate() {
super.onCreate();
}
@Override
public int onStartCommand(Intent intent, int flags, int startId) {
webSocketConnect();
return super.onStartCommand(intent, flags, startId);
}
@Override
public void onDestroy() {
super.onDestroy();
closeWebsocket();
}
//這里使用binder 主要是為了在activity中進(jìn)行通訊， 大家也可以使用EventBus進(jìn)行通訊
public class MyBinder extends Binder {
public SocketService getService(){
return SocketService.this;
}
}
/**
* 連接ws
*/
public void webSocketConnect() {
webSocketConnection = new WebSocketConnection();
try {
webSocketConnection.connect(WEB_SOCKET_HOST, new WebSocketHandler() {
//websocket啟動(dòng)時(shí)候的回調(diào)
@Override
public void onOpen() {
L.e("ws- onOpen: 開啟成功??！");
isOpen = true ;
}
//websocket接收到消息后的回調(diào)
@Override
public void onTextMessage(String content) {
L.e(content + "接受到的ws信息" );
//這里可以使用EventBus將內(nèi)容傳遞到activity
}
//websocket關(guān)閉時(shí)候的回調(diào)
@Override
public void onClose(int code, String reason) {
L.e("onClose: 服務(wù)器關(guān)閉??！" + reason);
isOpen = false ;
L.d("ws- 關(guān)閉");
}
}, options);
} catch (WebSocketException e) {
e.printStackTrace();
L.d("ws- 打開異常");
isOpen = false ;
closeWebsocket();
}
}
/**
* 關(guān)閉ws
*/
public void closeWebsocket() {
if (webSocketConnection != null && webSocketConnection.isConnected()) {
webSocketConnection.disconnect();
webSocketConnection = null;
}
}
/**
* ws是否連接
* @return
*/
public boolean isOpen(){
return isOpen ;
}
/**
* 發(fā)送信息，我們發(fā)送都是使用base64加密的，看自家需求
* @param base64
*/
public void sendMsg(String base64){
if (webSocketConnection != null && isOpen )webSocketConnection.sendTextMessage(base64);
L.d("ws- 發(fā)送 message");
}
}
第三步就是發(fā)送信息到后臺(tái)
主要就是activity通過bindService，拿到service的對(duì)象，然后調(diào)用sendMsg（base64）即可，在onTextMessage（）回調(diào)中接受數(shù)據(jù)
//得到service的對(duì)象后，調(diào)用發(fā)送信息方法即可
private ServiceConnection mConnection = new ServiceConnection() {
@Override
public void onServiceConnected(ComponentName name, IBinder service) {
WebSocketService.MyBinder binder = (WebSocketService.MyBinder) service;
mService = binder.getService();
mService.sendMsg(base64);//發(fā)送內(nèi)容根據(jù)后臺(tái)需求進(jìn)行操作，我們是將json對(duì)象base64加密發(fā)送的
}
@Override
public void onServiceDisconnected(ComponentName name) {
}
};
第四步（有發(fā)送就又接收）接收數(shù)據(jù)
接收數(shù)據(jù)，可以使用EventBus （這個(gè)方便）， 也可以自定義一個(gè)回調(diào)即可。
EventBus我就不多謝了，在接收的地方post出去，activity接收一下就行了。這里寫下回調(diào)。
//在service中創(chuàng)建回調(diào)接口
private OnDataReceiverListener mListener ;
//設(shè)置監(jiān)聽
public void setOnDataReceiverListener(OnDataReceiverListener listener){
mListener = listener ;
}
public interface OnDataReceiverListener {
void onTextMsg(String text);
}
//在接收的地方，將回調(diào)接收即可
//websocket接收到消息后的回調(diào)
@Override
public void onTextMessage(String content) {
L.e(content + "接受到的ws信息" );
if (mListener != null){
mListener.onTextMsg(content);
}
}
//之后在activity中設(shè)置回調(diào)
@Override
protected void onResume() {
super.onResume();
if (mService != null){
mService.setOnDataReceiverListener(new WebSocketService.OnDataReceiverListener() {
@Override
public void onTextMsg(String text) {
L.d("接收到的信息 " + text);
}
});
}
}
現(xiàn)在初步的發(fā)送 、接收 都可以實(shí)現(xiàn)了，但是還有很多問題！??！比如 穩(wěn)定性 ！?。。ㄒ?yàn)槲覀內(nèi)绻l(fā)送信息，不規(guī)律 或者長時(shí)間不發(fā)送，這個(gè)ws雖然開著，但是已經(jīng)斷開連接了0.0）
第五步 穩(wěn)定性 優(yōu)化
穩(wěn)定性優(yōu)化，我們做的也就是間斷性的向后臺(tái)的服務(wù)發(fā)送固定的無用信息，然后服務(wù)器在返回給自己。這樣就爆出了一直連接（及所謂的 心跳 ）
//我們?cè)趙s open的時(shí)候就開始發(fā)送心跳
//websocket啟動(dòng)時(shí)候的回調(diào)
@Override
public void onOpen() {
L.e("ws- onOpen: 開啟成功??！");
isOpen = true ;
mTimer = new Timer();
mTimer.schedule(new TimerTask() {
@Override
public void run() {
//發(fā)送信息有時(shí)候會(huì)異常，不過不多...
try {
webSocketConnection.sendTextMessage("固定數(shù)據(jù)， 自己接受");
}catch (Exception e){
e.printStackTrace();
}
}
} , 0 , 60 * 1000);
}
現(xiàn)在穩(wěn)定性算是差不多告一段落了，（給自己一個(gè)棒棒糖?。?br> 前段時(shí)間我們經(jīng)理給我們說這個(gè)也會(huì)有問題的?。。。ㄒ粋€(gè)大棒槌過來了）
最后一小步（經(jīng)理說的一句話：事件驅(qū)動(dòng)）
事件驅(qū)動(dòng)：什么意思？google去....
經(jīng)理說的大概意思是：ws是在服務(wù)里的，我們操作數(shù)據(jù)是在activity中的，所以你在操作的時(shí)候，也不一定確認(rèn)ws是否開啟了？所以需要在activity中進(jìn)行操作....（不懂），但是大家看代碼就應(yīng)該能懂的了0.0
//在這之前我們已經(jīng)做了基礎(chǔ)了， 就是那個(gè)心跳！我們發(fā)送什么 服務(wù)器就返回什么，使用timer來操作
if (mService != null){
mService.setOnDataReceiverListener(new WebSocketService.OnDataReceiverListener() {
@Override
public void onTextMsg(String text) {
L.d("接收到的信息 " + text);
//這里保存一下當(dāng)前接受到數(shù)據(jù)后的時(shí)間
mWsXinTiao = System.currentTimeMillis();
}
});
}
mTimer = new Timer();
mTimer.schedule(new TimerTask() {
@Override
public void run() {
if (System.currentTimeMillis() - mWsXinTiao > 60 * 1000) {
//進(jìn)到自己就說明ws的心跳在規(guī)定的時(shí)間內(nèi) 未 接收信息，看自己的需求了
//比如stopService ， 在startService
//或者將有關(guān)ws獲取的數(shù)據(jù)的一系列操作給Gone掉，屏蔽掉，提個(gè)示 whatever...
//這樣就保證了 activity這邊的關(guān)于ws的一系列操作都是可行的！有反應(yīng)的?。。〖?以activity為主導(dǎo)進(jìn)行操作！
}
}
} , 0 , 75 * 1000);//比心跳時(shí)間多一點(diǎn) 也沒事。
