详解OkSocket与Android的简单使用

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();
    //在主进程初始化一次,多进程时需要区分主进程.
    OkSocket.initialize(this);
    //如果需要开启Socket调试日志,请配置
    //OkSocket.initialize(this,true);
  }
}

ConnectionManager 主要负责该地址的套接字连接断开发送消息等操作.
//连接参数设置(IP,端口号),这也是一个连接的唯一标识,不同连接,该参数中的两个值至少有其一不一样
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//调用OkSocket,开启这次连接的通道,调用通道的连接方法进行连接.
OkSocket.open(info).connect();

//连接参数设置(IP,端口号),这也是一个连接的唯一标识,不同连接,该参数中的两个值至少有其一不一样
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//调用OkSocket,开启这次连接的通道,拿到通道Manager
IConnectionManager manager = OkSocket.open(info);
//注册Socket行为监听器,SocketActionAdapter是回调的Simple类,其他回调方法请参阅类文档
manager.registerReceiver(new SocketActionAdapter(){
  @Override
  public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   Toast.makeText(context, "连接成功", LENGTH_SHORT).show();
  }
});
//调用通道进行连接
manager.connect();

//连接参数设置(IP,端口号),这也是一个连接的唯一标识,不同连接,该参数中的两个值至少有其一不一样
ConnectionInfo info = new ConnectionInfo("104.238.184.237", 8080);
//调用OkSocket,开启这次连接的通道,拿到通道Manager
IConnectionManager manager = OkSocket.open(info);
//获得当前连接通道的参配对象
OkSocketOptions options= manager.getOption();
//基于当前参配对象构建一个参配建造者类
OkSocketOptions.Builder builder = new OkSocketOptions.Builder(options);
//修改参配设置(其他参配请参阅类文档)
builder.setSinglePackageBytes(size);
//建造一个新的参配对象并且付给通道
manager.option(builder.build());
//调用通道进行连接
manager.connect();

//类A:
//...定义将要发送的数据结构体...
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() {
    //根据服务器的解析规则,构建byte数组
    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;
//...省略连接及设置回调的代码...
@Override
public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   //连接成功其他操作...
   //链式编程调用
   OkSocket.open(info)
    .send(new TestSendData());
   
   //此处也可将ConnectManager保存成成员变量使用.
   mManager = OkSocket.open(info);
   if(mManager != null){
    mManager.send(new TestSendData());
   }
   //以上两种方法选择其一,成员变量的方式请注意判空
}

//设置自定义解析头
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(包头数据)中解析出包体的长度,byteOrder是你在参配中配置的字节序,可以使用ByteBuffer比较方便解析
    return 0;
  }
});
//将新的修改后的参配设置给连接管理器
mManager.option(okOptionsBuilder.build());


//...正确设置解析头之后...
@Override
public void onSocketReadResponse(Context context, ConnectionInfo info, String action, OriginalData data) {
  //遵循以上规则,这个回调才可以正常收到服务器返回的数据,数据在OriginalData中,为byte[]数组,该数组数据已经处理过字节序问题,直接放入ByteBuffer中即可使用
}

//类A:
//...定义心跳管理器需要的心跳数据类型...
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;
//...省略连接及设置回调的代码...
@Override
public void onSocketConnectionSuccess(Context context, ConnectionInfo info, String action) {
   //连接成功其他操作...
   //链式编程调用,给心跳管理器设置心跳数据,一个连接只有一个心跳管理器,因此数据只用设置一次,如果断开请再次设置.
   OkSocket.open(info)
    .getPulseManager()
    .setPulseSendable(mPulseData)
    .pulse();//开始心跳,开始心跳后,心跳管理器会自动进行心跳触发
        
   //此处也可将ConnectManager保存成成员变量使用.
   mManager = OkSocket.open(info);
   if(mManager != null){
    PulseManager pulseManager = mManager.getPulseManager();
    //给心跳管理器设置心跳数据,一个连接只有一个心跳管理器,因此数据只用设置一次,如果断开请再次设置.
    pulseManager.setPulseSendable(mPulseData);
    //开始心跳,开始心跳后,心跳管理器会自动进行心跳触发
    pulseManager.pulse();
   }
   //以上两种方法选择其一,成员变量的方式请注意判空
}

//定义成员变量
private IConnectionManager mManager;
//当客户端收到消息后
@Override
public void onSocketReadResponse(Context context, ConnectionInfo info, String action, OriginalData data) {
  if(mManager != null && 是心跳返回包){//是否是心跳返回包,需要解析服务器返回的数据才可知道
    //喂狗操作
    mManager.getPulseManager().feed();
  }
}

//定义成员变量
private IConnectionManager mManager;
//...在任意地方...
mManager = OkSocket.open(info);
if(mManager != null){
  PulseManager pulseManager = mManager.getPulseManager();
  //手动触发一次心跳(主要用于一些需要手动控制触发时机的场景)
  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.