新项目由自己重头架构，因此使用MVP模式,库的使用上使用了Rxjava 2.0,OkHttp 3.0,Retrofit 2.0 及JDK1.8中的新特性lambda表达式。
1.Android Studio Gradle 配置
在project下的build.gradle中配置
dependencies {
classpath'com.android.tools.build:gradle:2.3.1'classpath'com.neenbedankt.gradle.plugins:android-apt:1.8'
classpath'me.tatarka:gradle-retrolambda:3.2.5'
}
在Module:app的build.gradle中配置
applyplugin:'com.android.application'
applyplugin:'com.neenbedankt.android-apt'
applyplugin:'me.tatarka.retrolambda'
sourceSets {
main {
jniLibs.srcDir'libs' //无需在java目录下新建jniLibs文件夹
}
}
compileOptions { //期盼2.4快点到，不用使用jack
sourceCompatibilityJavaVersion.VERSION_1_8
targetCompatibilityJavaVersion.VERSION_1_8
}
configurations.all {
resolutionStrategy.force'com.google.code.findbugs:jsr305:1.3.9'
}
dexOptions {
jumboMode =true
}
packagingOptions{
exclude'META-INF/rxjava.properties'
}
apt'com.jakewharton:butterknife-compiler:8.5.1'
compile'com.jakewharton:butterknife:8.5.1'
compile'com.google.dagger:dagger:2.6'
apt'com.google.dagger:dagger-compiler:2.6'
compile'io.reactivex.rxjava2:rxjava:2+'
compile'io.reactivex.rxjava2:rxandroid:2+'
compile'com.squareup.okhttp3:okhttp:3.3.1'
compile'com.squareup.okhttp3:logging-interceptor:3.3.1'
compile'com.google.code.gson:gson:2.8.0'
compile'com.squareup.retrofit2:retrofit:2+'
compile'com.squareup.retrofit2:converter-gson:2+'
compile'com.squareup.retrofit2:adapter-rxjava2:2+'
建立访问接口规则
public interfaceIHttpService {
/**上报设备信息**/
@FormUrlEncoded
@POST("device/info/save")
Observable<BaseRespon> postDeviceInfo(@Field("jsonResult") String device);
/**上报信号信息**/
@FormUrlEncoded
@POST("device/signal/save")
Observable<BaseRespon> postSignalInfo(@Field("jsonResult") String signalList);
/**上报APP详细记录**/
@FormUrlEncoded
@POST("sample/save")
@Observable
Observable<BaseRespon> postDetialAppInfo(@Field("jsonResult") String signalList,@Field("catCode")String catCode);
/**文件上传**/
@Multipart
@POST("upload/file")
Observable<BaseRespon> postPcapFile(@PartMultipartBody.Part file,@Part("timetamp")String timetamp);
@GET
Observable<String> getPGW(@UrlString url);
}
实现接口
public static RetrofitService init() {
if(apiservice==null) {
OkHttpClient okHttpClient =newOkHttpClient
.Builder()
.addInterceptor(sLoggingInterceptor)
.retryOnConnectionFailure(true)
.connectTimeout(20,TimeUnit.SECONDS).build();
Retrofit retrofit =newRetrofit.Builder()
.client(okHttpClient)
.addConverterFactory(GsonConverterFactory.create())
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.baseUrl(SERVICE_HOST)
.build();
Retrofit cmccretrofit =newRetrofit.Builder()
.client(okHttpClient)
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.baseUrl(SERVICE_HOST)
.build();
apiservice= retrofit.create(IHttpService.class);
icmccApi= cmccretrofit.create(ICMCCapi.class);
}
returnInstanceRetrofit.INSTANCE;
}
POST JSON
public void postDeviceInfo(DeviceInfo record) {
String deviceInfo =newGsonBuilder().create().toJson(record);
apiservice.postDeviceInfo(deviceInfo)
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(response -> {
Logger.v("Next code %d",response.getCode());
Logger.v("Next message %s",response.getMessage());
if(response.getCode() ==200) {
postListSignalInfo(record.getTimetamp());
}
},error -> {error.printStackTrace();Logger.v("Error %s",error.getMessage());},() ->Logger.d("Complete "));}
public void postAppRecordInfo(String timeTamp) {
DeviceInfo info = DeviceInfo.where("timetamp like ? and isposted = 0",timeTamp).findFirst(DeviceInfo.class);
if(info !=null) {
postDeviceInfo(info);
}
}
UPLOAD FILE
public void postPcapFile(String timeTamp){
File pcapFile =newFile(PcapFileLoader.SDCARD_PCAP_LOG_FILE,timeTamp+"_capture.pcap");
if(pcapFile.exists()){
Uri fileUri = Uri.fromFile(pcapFile);
Log.d("fileRri",fileUri.toString());
RequestBody requestFile = RequestBody.create(MediaType.parse("application/pcap-stream"),pcapFile);
MultipartBody.Part body =
MultipartBody.Part.createFormData("file",pcapFile.getName(),requestFile);//file为接口参数，必须与后台接收一致
apiservice.postPcapFile(body,timeTamp)
.subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.subscribe(request->{
Logger.v("next code %d",request.getCode());
Logger.v("next message %s",request.getMessage());
if(request.getCode() ==200){
DeviceInfoinfo= DataSupport.where("timetamp like ?",timeTamp).findFirst(DeviceInfo.class);
if(info!=null){
info.setIsposted(true);
info.save();
}
}
},error->Logger.e(error,"message %s",error.getMessage()),()->{
Logger.v("%s","postFileCompleted");
});
}
}
