安卓使用网络请求框架Retrofit和OKGO的封装_@formurlencoded @post("/pdaservice/login") public -程序员宅基地

技术标签: 安卓  

implementation ‘com.lzy.net:okgo:2.1.4’//OKGO库
比较简单的调用如下:
public static void doRequestGetGiftCabinetList(String id, StringCallback callback) {

    OkGo.get(AppConfig.API_DOMAIN + "/user_api/request_get_gift_cabinet")
            .params("to_user_id", id)
            .tag("doRequestGetGiftCabinetList")
            .cacheMode(CacheMode.DEFAULT)
            .execute(callback);
}

以下是Retrofit的的用法,搭配rxjava使用:
@POST(“api/sso/login”)
@FormUrlEncoded
Observable phoneregister(@Field(“appid”) String appid);

以下是直接使用:
@GET("/reverse_geocoding/v3")
Call findLocation(@Query(“location”) String location, @Query(“ak”) String ak);

以下是RetrofitClient封装单例类, 实现网络请求,可以复制直接使用,在下面有配合rxjava使用的示例代码:

import android.content.Context;
import android.text.TextUtils;

import com.sim.chongwukongjing.BuildConfig;

import java.io.File;
import java.util.Map;
import java.util.concurrent.TimeUnit;

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;
import me.goldze.mvvmhabit.http.cookie.CookieJarImpl;
import me.goldze.mvvmhabit.http.cookie.store.PersistentCookieStore;
import me.goldze.mvvmhabit.http.interceptor.BaseInterceptor;
import me.goldze.mvvmhabit.http.interceptor.CacheInterceptor;
import me.goldze.mvvmhabit.http.interceptor.logging.Level;
import me.goldze.mvvmhabit.http.interceptor.logging.LoggingInterceptor;
import me.goldze.mvvmhabit.utils.KLog;
import me.goldze.mvvmhabit.utils.Utils;
import okhttp3.Cache;
import okhttp3.ConnectionPool;
import okhttp3.OkHttpClient;
import okhttp3.internal.platform.Platform;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.GsonConverterFactory;

/**
 *
 * @author goldze
 * @date 2017/5/10
 * RetrofitClient封装单例类, 实现网络请求
 */
public class RetrofitClient {
    //超时时间
    private static final int DEFAULT_TIMEOUT = 20;
    //缓存时间
    private static final int CACHE_TIMEOUT = 10 * 1024 * 1024;
    //服务端根路径
    public static String baseUrl = "http://smart.airmedic.cn:9088/arm/";

    private static Context mContext = Utils.getContext();

    private static OkHttpClient okHttpClient;
    private static Retrofit retrofit;

    private Cache cache = null;
    private File httpCacheDirectory;

    private static class SingletonHolder {
        private static RetrofitClient INSTANCE = new RetrofitClient();
    }

    public static RetrofitClient getInstance() {
        return SingletonHolder.INSTANCE;
    }

    private RetrofitClient() {
        this(baseUrl, null);
    }

    private RetrofitClient(String url, Map<String, String> headers) {

        if (TextUtils.isEmpty(url)) {
            url = baseUrl;
        }

        if (httpCacheDirectory == null) {
            httpCacheDirectory = new File(mContext.getCacheDir(), "goldze_cache");
        }

        try {
            if (cache == null) {
                cache = new Cache(httpCacheDirectory, CACHE_TIMEOUT);
            }
        } catch (Exception e) {
            KLog.e("Could not create http cache", e);
        }
        HttpsUtils.SSLParams sslParams = HttpsUtils.getSslSocketFactory();
        okHttpClient = new OkHttpClient.Builder()
                .cookieJar(new CookieJarImpl(new PersistentCookieStore(mContext)))
//                .cache(cache)
                .addInterceptor(new BaseInterceptor(headers))
                .addInterceptor(new CacheInterceptor(mContext))
                .sslSocketFactory(sslParams.sSLSocketFactory, sslParams.trustManager)
                .addInterceptor(new LoggingInterceptor
                        .Builder()//构建者模式
                        .loggable(BuildConfig.DEBUG) //是否开启日志打印
                        .setLevel(Level.BASIC) //打印的等级
                        .log(Platform.INFO) // 打印类型
                        .request("Request") // request的Tag
                        .response("Response")// Response的Tag
                        .addHeader("log-header", "I am the log request header.") // 添加打印头, 注意 key 和 value 都不能是中文
                        .build()
                )
                .connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .writeTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .connectionPool(new ConnectionPool(8, 15, TimeUnit.SECONDS))
                // 这里你可以根据自己的机型设置同时连接的个数和时间,我这里8个,和每个保持时间为10s
                .build();
        retrofit = new Retrofit.Builder()
                .client(okHttpClient)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .baseUrl(url)
                .build();

    }

    /**
     * create you ApiService
     * Create an implementation of the API endpoints defined by the {@code service} interface.
     */
    public static <T> T create(final Class<T> service) {
        if (service == null) {
            throw new RuntimeException("Api service is null!");
        }
        if(retrofit == null){
            synchronized (RetrofitClient.class){
                if(retrofit == null){
                    new RetrofitClient();
                }
            }
        }
        return retrofit.create(service);
    }

    /**
     * /**
     * execute your customer API
     * For example:
     * MyApiService service =
     * RetrofitClient.getInstance(MainActivity.this).create(MyApiService.class);
     * <p>
     * RetrofitClient.getInstance(MainActivity.this)
     * .execute(service.lgon("name", "password"), subscriber)
     * * @param subscriber
     */

    public static <T> T execute(Observable<T> observable, Observer<T> subscriber) {
        observable.subscribeOn(Schedulers.io())
                .unsubscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(subscriber);

        return null;
    }
}

以下是可以在present层使用的Retrofit和rxjava的示例代码:

private void login() {
        HttpApi mloginApi;
        mloginApi = RetrofitClient.create(HttpApi.class);//对上面封装的使用
        String motime = String.valueOf(System.currentTimeMillis());

        HashMap<String, String> hashMap = new HashMap<>();
        hashMap.put("motime",motime);
        hashMap.put("smstype","REG");
        hashMap.put("phone",phone.getText().toString());

        String androidID = Settings.System.getString(this.getContentResolver(), Settings.System.ANDROID_ID);
        //关于安卓设备唯一序列号的使用可以看我之前的博文
        String sign = signMD5("",hashMap);//加密签名

        FormBody body = new FormBody.Builder()
                    .add("appid", "")
                    .add("motime",  motime)
                    .add("sign", "")
                    .add("phone", phone.getText().toString())
                    .add("mac", androidID)
                    .add("passwd",editText3.getText().toString())
                    .build();

        Observable<LoginResult> observable = mloginApi.login(body);
        observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<LoginResult>() {
                    @Override
                    public void accept(LoginResult baseInfo) throws Exception {
                        if ("10000".equals(baseInfo.getCode())){
                            ToastUtils.showShort(baseInfo.getMsg());
                            if (checkBox2.isChecked()){
                                SharedPreferencesUtil.saveLoginInfo(getApplicationContext(),phone.getText().toString(),editText3.getText().toString());
                            }else {
                                SharedPreferencesUtil.deleteUser(getApplicationContext());
                            }
                            MyApplication.getInstance().setLoginResult(baseInfo);
                            if (baseInfo.getData().getDcvcnt()==0){
                                startActivity(AddMachineActivity.class);
                            }else {
                                startActivity(MyEquipmentAcitivity.class);
                            }

                            finish();
                        }else {
                            ToastUtils.showShort(baseInfo.getMsg());
                        }
                    }
                }, new Consumer<Throwable>() {
                    @Override
                    public void accept(Throwable throwable) throws Exception {
                        ToastUtils.showShort("登录失败,请稍后重试");
                    }
                });
    }
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/weixin_42446445/article/details/99940660

智能推荐

通过WebRTC实现实时视频通信(一)_webrtc可以与摄像头对讲吗-程序员宅基地

文章浏览阅读3.2k次,点赞2次,收藏10次。WebRTC,名称源自网页实时通信(Web Real-Time Communication)的缩写,是一个支持网页浏览器进行实时语音对话或视频对话的API。它于2011年6月1日开源并在Google、Mozilla基金会、Opera支持下被包括进万维网联盟的W3C推荐标准。_webrtc可以与摄像头对讲吗

matlab多变量拟合regress,matlab多元与非线性回归即拟合问题regressnlinfit-程序员宅基地

文章浏览阅读2k次。matlab多元与非线性回归即拟合问题regressnlinfit 回归(拟合)自己的总结(20100728) 1:学三条命令:polyfit(x,y,n)---拟合成一元幂函数(一元多次) regress(y,x)----可以多元, nlinfit(x,y,’fun’,beta0) (可用于任何类型的函数,任意多元函数,应用范围最主,最万能的) 2:同一个问题,可能这三条命令都可以使用,但结果肯..._matlab双曲线拟合

EOS代码架构及分析(三)_eos代码架构及分析 fly_鹏程万里-程序员宅基地

文章浏览阅读511次。EOS采用DPoS算法和块内分片技术,实现了百万级别TPS的超高性能,可以媲美中心化服务器的处理能力,同时保持去中心化的属性,成为了区块链3.0的代表。那么为什么EOS有如此出色的性能表现?本文将从EOS的核心设计原理以及主要数据结构进行分析。EOS VS Bitcoin我们知道,比特币采用POW共识算法确认区块:1)Bob向Alice发出一笔转账消息;2)客户端将消息广播给所有矿..._eos代码架构及分析 fly_鹏程万里

C# 调用 c 封装dll_c#调用c 的dll-程序员宅基地

文章浏览阅读747次。其中在定义嵌套结构体时需提前定义基础结构体。_c#调用c 的dll

Logstash中的四大插件_logstash 插件-程序员宅基地

文章浏览阅读380次。语法:(?举例:捕获10或11和长度的十六进制数的queue_id可以使用表达式(?filter {grok {如果表达式匹配失败,会生成一个tags字段,字段值为 _grokparsefailure,需要重新检查上边的match配置解析是否正确。_logstash 插件

数制转换及原码补码反码问题_原码10100001表示的十进制是-程序员宅基地

文章浏览阅读2k次。数制转换及原码补码反码问题标签(空格分隔): 面向对象技术与C++转载http://blog.sina.com.cn/s/blog_9b60c8e00100y47j.html和http://www.94cto.com/index/Article/content/id/59973.html 对文章进行整合和重新排版进制转换在计算机里,通常用数字后面紧跟一个英文字母来表示该数的数字,十进制一般用D,二_原码10100001表示的十进制是

随便推点

前端跨域携带cookie_前端请求携带cookie-程序员宅基地

文章浏览阅读4k次,点赞2次,收藏4次。前端需要跨域携带cookie_前端请求携带cookie

一、rip实验拓扑-程序员宅基地

文章浏览阅读741次,点赞21次,收藏18次。00 0000----192.168.1.128/26-----R1环回。10 0000----192.168.1.160/27-----L1环回。00 0000------192.168.1.192/26---R2环回。3、配置缺省路由,实现3.3.3.0/24互通,至此实现全网通,并测试。0 0000-----192.168.1.128/27----L0环回。2、配置RIP协议,宣告网段,除了3.3.3.0/24环回,,并测试。5、接口汇总,并防环,减少路由条目,测试,实现全网通。

animation.ArtistAnimation的天坑和报错【not enough image data】-程序员宅基地

文章浏览阅读1.5k次,点赞6次,收藏4次。1、plt.plot和plt.scatter的返回值不一样当对plt.scatter进行画动态gif图时,需要使用.findobj()比如im = plt.scatter(nix, niy, marker = "*",color = "b").findobj()ims.append(im)ani = animation.ArtistAnimation(fig, ims, interval=200, repeat_delay=1000) ani.save("test.gif", writer_not enough image data

【Python小工具系列】使用 Python 循环批量打开网页链接_python批量打开网址-程序员宅基地

文章浏览阅读1.3k次,点赞52次,收藏46次。欢迎来到我的博客,很高兴能够在这里和您见面!希望您在这里可以感受到一份轻松愉快的氛围,不仅可以获得有趣的内容和知识,也可以畅所欲言、分享您的想法和见解。非常期待和您一起在这个小小的网络世界里共同探索、学习和成长。 欢迎订阅本专栏 。_python批量打开网址

快人一步,X-DB如何实现极速DDL-程序员宅基地

文章浏览阅读78次。数据库DDL操作面临的问题互联网业务发展迅速,应用模式频繁更改是常态。相应地,数据库访问模式和schema也随之变化。DDL(Data Definition Language)是SQL的一类,主要作用是创建和更改数据的schema信息,最常见的操作包括:加减列、更改列类型、加减索引等。熟悉MySQL的同学都知道,在8.0以前,虽然Online DDL..._xhdddl

利用qwtplot3d库在QT界面中实现三维图形的绘制(VS2015 + Qt5.9.8)_qt绘制三维动图-程序员宅基地

文章浏览阅读3.2k次。1.环境配置从官网下载qwtplot3d的文件包(现在好像下载不了了,我这有0.2.7版本的)将压缩包解压到C盘根目录(注意不要包含中文路径)打开C:\qwtplot3d-0.2.7\qwtplot3d\qwtplot3d.pro文件执行qmake, 这步可能会报错,解决可参照此篇博文qmake成功后会在C:\qwtplot3d-0.2.7\build-qwtplot3d-Desktop_Qt_5_9_8_MSVC2015_64bit-Debug\lib文件夹下生成qwtplot3d.dll和q_qt绘制三维动图

推荐文章

热门文章

相关标签