allprojects {
  repositories {
    jcenter()
  }
}

dependencies {
  compile 'com.tonystark.android:socket:1.0.0'
}

<uses-permission android:name="android.permission.INTERNET"/>
<uses-permission android:name="android.permission.ACCESS_NETWORK_STATE"/>

-dontwarn com.xuhao.android.libsocket.**
-keep class com.xuhao.android.socket.impl.abilities.** { *; }
-keep class com.xuhao.android.socket.impl.exceptions.** { *; }
-keep class com.xuhao.android.socket.impl.EnvironmentalManager { *; }
-keep class com.xuhao.android.socket.impl.BlockConnectionManager { *; }
-keep class com.xuhao.android.socket.impl.UnBlockConnectionManager { *; }
-keep class com.xuhao.android.socket.impl.SocketActionHandler { *; }
-keep class com.xuhao.android.socket.impl.PulseManager { *; }
-keep class com.xuhao.android.socket.impl.ManagerHolder { *; }
-keep class com.xuhao.android.socket.interfaces.** { *; }
-keep class com.xuhao.android.socket.sdk.** { *; }
# 枚舉類不能被混淆
-keepclassmembers enum * {
  public static **[] values();
  public static ** valueOf(java.lang.String);
}
-keep class com.xuhao.android.socket.sdk.OkSocketOptions$* {
  *;
}

public class MyApplication extends Application {
  @Override
  public void onCreate() {
    super.onCreate();
    //在主進(jìn)程初始化一次,多進(jìn)程時(shí)需要區(qū)分主進(jìn)程.
    OkSocket.initialize(this);
    //如果需要開啟Socket調(diào)試日志,請配置
    //OkSocket.initialize(this,true);
  }
}

ConnectionManager 主要負(fù)責(zé)該地址的套接字連接斷開發(fā)送消息等操作.
//連接參數(shù)設(shè)置(IP,端口號),這也是一個(gè)連接的唯一標(biāo)識,不同連接,該參數(shù)中的兩個(gè)值至少有其一不一樣
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//調(diào)用OkSocket,開啟這次連接的通道,調(diào)用通道的連接方法進(jìn)行連接.
OkSocket.open(info).connect();

//連接參數(shù)設(shè)置(IP,端口號),這也是一個(gè)連接的唯一標(biāo)識,不同連接,該參數(shù)中的兩個(gè)值至少有其一不一樣
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//調(diào)用OkSocket,開啟這次連接的通道,拿到通道Manager
IConnectionManager manager = OkSocket.open(info);
//注冊Socket行為監(jiān)聽器,SocketActionAdapter是回調(diào)的Simple類,其他回調(diào)方法請參閱類文檔
manager.registerReceiver(new SocketActionAdapter(){
  @Override
  public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   Toast.makeText(context, "連接成功", LENGTH_SHORT).show();
  }
});
//調(diào)用通道進(jìn)行連接
manager.connect();

//連接參數(shù)設(shè)置(IP,端口號),這也是一個(gè)連接的唯一標(biāo)識,不同連接,該參數(shù)中的兩個(gè)值至少有其一不一樣
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//調(diào)用OkSocket,開啟這次連接的通道,拿到通道Manager
IConnectionManager manager = OkSocket.open(info);
//獲得當(dāng)前連接通道的參配對象
OkSocketOptions options= manager.getOption();
//基于當(dāng)前參配對象構(gòu)建一個(gè)參配建造者類
OkSocketOptions.Builder builder = new OkSocketOptions.Builder(options);
//修改參配設(shè)置(其他參配請參閱類文檔)
builder.setSinglePackageBytes(size);
//建造一個(gè)新的參配對象并且付給通道
manager.option(builder.build());
//調(diào)用通道進(jìn)行連接
manager.connect();

//類A:
//...定義將要發(fā)送的數(shù)據(jù)結(jié)構(gòu)體...
public class TestSendData implements ISendable {
  private String str = "";

  public TestSendData() {
    JSONObject jsonObject = new JSONObject();
    try {
      jsonObject.put("cmd", 14);
      jsonObject.put("data", "{x:2,y:1}");
      str = jsonObject.toString();
    } catch (JSONException e) {
      e.printStackTrace();
    }
  }

  @Override
  public byte[] parse() {
    //根據(jù)服務(wù)器的解析規(guī)則,構(gòu)建byte數(shù)組
    byte[] body = str.getBytes(Charset.defaultCharset());
    ByteBuffer bb = ByteBuffer.allocate(4 + body.length);
    bb.order(ByteOrder.BIG_ENDIAN);
    bb.putInt(body.length);
    bb.put(body);
    return bb.array();
  }
}

//類B:
private IConnectionManager mManager;
//...省略連接及設(shè)置回調(diào)的代碼...
@Override
public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   //連接成功其他操作...
   //鏈?zhǔn)骄幊陶{(diào)用
   OkSocket.open(info)
    .send(new TestSendData());
   
   //此處也可將ConnectManager保存成成員變量使用.
   mManager = OkSocket.open(info);
   if(mManager != null){
    mManager.send(new TestSendData());
   }
   //以上兩種方法選擇其一,成員變量的方式請注意判空
}

//設(shè)置自定義解析頭
OkSocketOptions.Builder okOptionsBuilder = new OkSocketOptions.Builder(mOkOptions);
okOptionsBuilder.setHeaderProtocol(new IHeaderProtocol() {
  @Override
  public int getHeaderLength() {
    //返回自定義的包頭長度,框架會解析該長度的包頭
    return 0;
  }

  @Override
  public int getBodyLength(byte[] header, ByteOrder byteOrder) {
    //從header(包頭數(shù)據(jù))中解析出包體的長度,byteOrder是你在參配中配置的字節(jié)序,可以使用ByteBuffer比較方便解析
    return 0;
  }
});
//將新的修改后的參配設(shè)置給連接管理器
mManager.option(okOptionsBuilder.build());


//...正確設(shè)置解析頭之后...
@Override
public void onSocketReadResponse(Context context, ConnectionInfo info, String action, OriginalData data) {
  //遵循以上規(guī)則,這個(gè)回調(diào)才可以正常收到服務(wù)器返回的數(shù)據(jù),數(shù)據(jù)在OriginalData中,為byte[]數(shù)組,該數(shù)組數(shù)據(jù)已經(jīng)處理過字節(jié)序問題,直接放入ByteBuffer中即可使用
}

//類A:
//...定義心跳管理器需要的心跳數(shù)據(jù)類型...
public class PulseData implements IPulseSendable {
  private String str = "pulse";

  @Override
  public byte[] parse() {
    byte[] body = str.getBytes(Charset.defaultCharset());
    ByteBuffer bb = ByteBuffer.allocate(4 + body.length);
    bb.order(ByteOrder.BIG_ENDIAN);
    bb.putInt(body.length);
    bb.put(body);
    return bb.array();
  }
}

//類B:
private IConnectionManager mManager;
private PulseData mPulseData = new PulseData;
//...省略連接及設(shè)置回調(diào)的代碼...
@Override
public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   //連接成功其他操作...
   //鏈?zhǔn)骄幊陶{(diào)用,給心跳管理器設(shè)置心跳數(shù)據(jù),一個(gè)連接只有一個(gè)心跳管理器,因此數(shù)據(jù)只用設(shè)置一次,如果斷開請?jiān)俅卧O(shè)置.
   OkSocket.open(info)
    .getPulseManager()
    .setPulseSendable(mPulseData)
    .pulse();//開始心跳,開始心跳后,心跳管理器會自動進(jìn)行心跳觸發(fā)
        
   //此處也可將ConnectManager保存成成員變量使用.
   mManager = OkSocket.open(info);
   if(mManager != null){
    PulseManager pulseManager = mManager.getPulseManager();
    //給心跳管理器設(shè)置心跳數(shù)據(jù),一個(gè)連接只有一個(gè)心跳管理器,因此數(shù)據(jù)只用設(shè)置一次,如果斷開請?jiān)俅卧O(shè)置.
    pulseManager.setPulseSendable(mPulseData);
    //開始心跳,開始心跳后,心跳管理器會自動進(jìn)行心跳觸發(fā)
    pulseManager.pulse();
   }
   //以上兩種方法選擇其一,成員變量的方式請注意判空
}

//定義成員變量
private IConnectionManager mManager;
//當(dāng)客戶端收到消息后
@Override
public void onSocketReadResponse(Context context, ConnectionInfo info, String action, OriginalData data) {
  if(mManager != null && 是心跳返回包){//是否是心跳返回包,需要解析服務(wù)器返回的數(shù)據(jù)才可知道
    //喂狗操作
    mManager.getPulseManager().feed();
  }
}

//定義成員變量
private IConnectionManager mManager;
//...在任意地方...
mManager = OkSocket.open(info);
if(mManager != null){
  PulseManager pulseManager = mManager.getPulseManager();
  //手動觸發(fā)一次心跳(主要用于一些需要手動控制觸發(fā)時(shí)機(jī)的場景)
  pulseManager.trigger();
}

Copyright [2017] [徐昊]

  Licensed under the Apache License, Version 2.0 (the "License");
  you may not use this file except in compliance with the License.
  You may obtain a copy of the License at

   http://www.apache.org/licenses/LICENSE-2.0

  Unless required by applicable law or agreed to in writing, software
  distributed under the License is distributed on an "AS IS" BASIS,
  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  See the License for the specific language governing permissions and
  limitations under the License.