美文网首页Android developerAndroidrxjava
Retrofit 2.0 超能实践(二),Okhttp完美同步持

Retrofit 2.0 超能实践(二),Okhttp完美同步持

作者: Tamic | 来源:发表于2016-06-17 16:59 被阅读11899次

    原文出自csdn:
    http://blog.csdn.net/sk719887916/article/details/51700659

    通过对Retrofit2.0的<Retrofit 2.0 超能实践,完美支持Https传输>基础入门和案例实践,掌握了怎么样使用Retrofit访问网络,加入自定义header,包括加入SSL证书,基本的调试基础,但是正常的开发中会涉及cookie同步问题,可以实现一些自动或免登录登陆问题,接下来进入cookie同步姿势

    Cookie

    Cookies是一种能够让网站服务器把少量数据储存到客户端的硬盘或内存,或是从客户端的硬盘读取数据的一种技术。Cookies是当你浏览某网站时,由Web服务器置于你硬盘上的一个非常小的文本文件,它可以记录你的用户ID、密码、浏览过的网页、停留的时间等信息。当你再次来到该网站时,网站通过读取Cookies,得知你的相关信息,就可以做出相应的动作,如在页面显示欢迎你的标语,或者让你不用输入ID、密码就直接登录等等。

    从本质上讲,它可以看作是你的身份证。但Cookies不能作为代码执行,也不会传送病毒,且为你所专有,并只能由提供它的服务器来读取。保存的信息片断以“名/值”对(name-value pairs)的形式储存,一个“名/值”对仅仅是一条命名的数据。一个网站只能取得它放在你的电脑中的信息,它无法从其它的Cookies文件中取得信息,也无法得到你的电脑上的其它任何东西。

    Cookies中的内容大多数经过了加密处理,因此一般用户看来只是一些毫无意义的字母数字组合,只有服务器的CGI处理程序才知道它们真正的含义。

    Cookie也是http的会话跟踪技术,也包含web端的session。cookie的作用就是为了解决HTTP协议无状态的缺陷所作的努力.

    Cookie结构

    发送规则:

    浏览器(设备)根据下面的几个规则决定是否发送某个Cookie信息:

    • 请求的主机名是否与某个存储的Cookie的Domain属性匹配;
    • 请求的端口号是否在该Cookie的Port属性列表中;
    • 请求的资源路径是否在该Cookie的Path属性指定的目录及子目录中;
    • 该Cookie的有效期是否已过。

    下面是cookie代码示例:

         HTTP/1.1 200 OK
         Content-type: text/html
         Set-Cookie: name=value
         Set-Cookie: name2=value2; Expires=Wed, 09 Jun 2021 10:18:14 GMT
        (content of page)
    

    Cookie请求头字段中的每个Cookie之间用逗号或分号分隔。

    在Cookie请求头字段中除了必须有“名称=值”的设置外,还可以有Version、Path、Domain、Port等属性名之前,都要增加一个“$”字符作为前缀。

    Version属性只能出现一次,且要位于Cookie请求头字段设置值的最前面,如果需要设置鞭个Cookie信息的Path、Domain、Port等属性,它们必须位于该Cookie信息的“名称=值”设置之后。

    Path属性指向子目录的Cookie排在Path属性指向父目录的Cookie之前。

    在Servlet程序中作用Cookie

    Servlet API中提供了一个javax.servlet.http.Cookie类来封闭Cookie信息,它包含有生成Cookie信息和提取Cookie信息的各个属性的方法。

    Cookie类的方法:

    • (构造方法:public Cookie(java.lang.String name,java.lang.String value)
    • getName方法
    • setValue与getValue方法
    • setMaxAge与getMaxAge方法
    • setPath与getPath方法
    • setDomian与getPath方法
    • setVersion与getVersion方法
    • setComment与getComment方法
    • setSecoure与getSecure方法

    方式一:

    自定义cookie

    HttpClient中大家都知道加入cookie的方式

    AsyncHttpClient client = new AsyncHttpClient();
    PersistentCookieStore myCookieStore = new PersistentCookieStore(MainActivity.this);
    client.setCookieStore(myCookieStore);
    

    因此Retrofit中需自我实现一个PersistentCookieStore 用来储存OkHttpCookies。

    -PersistentCookieStore

    /**
      * Created by Tamic on 2016-06-09.
      */
    public class PersistentCookieStore {
    private static final String LOG_TAG = "PersistentCookieStore";
    private static final String COOKIE_PREFS = "Cookies_Prefs";
    
    private final Map<String, ConcurrentHashMap<String, Cookie>> cookies;
    private final SharedPreferences cookiePrefs;
    
    
    public PersistentCookieStore(Context context) {
        cookiePrefs = context.getSharedPreferences(COOKIE_PREFS, 0);
        cookies = new HashMap<>();
    
        //将持久化的cookies缓存到内存中 即map cookies
        Map<String, ?> prefsMap = cookiePrefs.getAll();
        for (Map.Entry<String, ?> entry : prefsMap.entrySet()) {
            String[] cookieNames = TextUtils.split((String) entry.getValue(), ",");
            for (String name : cookieNames) {
                String encodedCookie = cookiePrefs.getString(name, null);
                if (encodedCookie != null) {
                    Cookie decodedCookie = decodeCookie(encodedCookie);
                    if (decodedCookie != null) {
                        if (!cookies.containsKey(entry.getKey())) {
                            cookies.put(entry.getKey(), new ConcurrentHashMap<String, Cookie>());
                        }
                        cookies.get(entry.getKey()).put(name, decodedCookie);
                    }
                }
            }
        }
    }
    
    protected String getCookieToken(Cookie cookie) {
        return cookie.name() + "@" + cookie.domain();
    }
    
    public void add(HttpUrl url, Cookie cookie) {
        String name = getCookieToken(cookie);
    
        //将cookies缓存到内存中 如果缓存过期 就重置此cookie
        if (!cookie.persistent()) {
            if (!cookies.containsKey(url.host())) {
                cookies.put(url.host(), new ConcurrentHashMap<String, Cookie>());
            }
            cookies.get(url.host()).put(name, cookie);
        } else {
            if (cookies.containsKey(url.host())) {
                cookies.get(url.host()).remove(name);
            }
        }
    
        //讲cookies持久化到本地
        SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
        prefsWriter.putString(url.host(), TextUtils.join(",", cookies.get(url.host()).keySet()));
        prefsWriter.putString(name, encodeCookie(new OkHttpCookies(cookie)));
        prefsWriter.apply();
    }
    
    public List<Cookie> get(HttpUrl url) {
        ArrayList<Cookie> ret = new ArrayList<>();
        if (cookies.containsKey(url.host()))
            ret.addAll(cookies.get(url.host()).values());
        return ret;
    }
    
    public boolean removeAll() {
        SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
        prefsWriter.clear();
        prefsWriter.apply();
        cookies.clear();
        return true;
    }
    
    public boolean remove(HttpUrl url, Cookie cookie) {
        String name = getCookieToken(cookie);
    
        if (cookies.containsKey(url.host()) && cookies.get(url.host()).containsKey(name)) {
            cookies.get(url.host()).remove(name);
    
            SharedPreferences.Editor prefsWriter = cookiePrefs.edit();
            if (cookiePrefs.contains(name)) {
                prefsWriter.remove(name);
            }
            prefsWriter.putString(url.host(), TextUtils.join(",", cookies.get(url.host()).keySet()));
            prefsWriter.apply();
    
            return true;
        } else {
            return false;
        }
    }
    
    public List<Cookie> getCookies() {
        ArrayList<Cookie> ret = new ArrayList<>();
        for (String key : cookies.keySet())
            ret.addAll(cookies.get(key).values());
    
        return ret;
    }
    
    /**
     * cookies 序列化成 string
     *
     * @param cookie 要序列化的cookie
     * @return 序列化之后的string
     */
    protected String encodeCookie(OkHttpCookies cookie) {
        if (cookie == null)
            return null;
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        try {
            ObjectOutputStream outputStream = new ObjectOutputStream(os);
            outputStream.writeObject(cookie);
        } catch (IOException e) {
            Log.d(LOG_TAG, "IOException in encodeCookie", e);
            return null;
        }
    
        return byteArrayToHexString(os.toByteArray());
    }
    
    /**
     * 将字符串反序列化成cookies
     *
     * @param cookieString cookies string
     * @return cookie object
     */
    protected Cookie decodeCookie(String cookieString) {
        byte[] bytes = hexStringToByteArray(cookieString);
        ByteArrayInputStream byteArrayInputStream = new ByteArrayInputStream(bytes);
        Cookie cookie = null;
        try {
            ObjectInputStream objectInputStream = new ObjectInputStream(byteArrayInputStream);
            cookie = ((OkHttpCookies) objectInputStream.readObject()).getCookies();
        } catch (IOException e) {
            Log.d(LOG_TAG, "IOException in decodeCookie", e);
        } catch (ClassNotFoundException e) {
            Log.d(LOG_TAG, "ClassNotFoundException in decodeCookie", e);
        }
    
        return cookie;
    }
    
    /**
     * 二进制数组转十六进制字符串
     *
     * @param bytes byte array to be converted
     * @return string containing hex values
     */
    protected String byteArrayToHexString(byte[] bytes) {
        StringBuilder sb = new StringBuilder(bytes.length * 2);
        for (byte element : bytes) {
            int v = element & 0xff;
            if (v < 16) {
                sb.append('0');
            }
            sb.append(Integer.toHexString(v));
        }
        return sb.toString().toUpperCase(Locale.US);
    }
    
    /**
     * 十六进制字符串转二进制数组
     *
     * @param hexString string of hex-encoded values
     * @return decoded byte array
     */
    protected byte[] hexStringToByteArray(String hexString) {
        int len = hexString.length();
        byte[] data = new byte[len / 2];
        for (int i = 0; i < len; i += 2) {
            data[i / 2] = (byte) ((Character.digit(hexString.charAt(i), 16) << 4) + Character.digit(hexString.charAt(i + 1), 16));
        }
        return data;
    }
    
    • OkHttpCookies

    需要实现序列化的 OkHttpCookies 用来持久OkHttpCookies

       /**
     * Created by LIUYONGKUI on 2016-05-20.
      */
    public class OkHttpCookies implements Serializable {
    
    private transient final Cookie cookies;
    private transient Cookie clientCookies;
    
    public OkHttpCookies(Cookie cookies) {
        this.cookies = cookies;
    }
    
    public Cookie getCookies() {
        Cookie bestCookies = cookies;
        if (clientCookies != null) {
            bestCookies = clientCookies;
        }
        return bestCookies;
    }
    
    private void writeObject(ObjectOutputStream out) throws IOException {
        out.writeObject(cookies.name());
        out.writeObject(cookies.value());
        out.writeLong(cookies.expiresAt());
        out.writeObject(cookies.domain());
        out.writeObject(cookies.path());
        out.writeBoolean(cookies.secure());
        out.writeBoolean(cookies.httpOnly());
        out.writeBoolean(cookies.hostOnly());
        out.writeBoolean(cookies.persistent());
    }
    
    private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException {
        String name = (String) in.readObject();
        String value = (String) in.readObject();
        long expiresAt = in.readLong();
        String domain = (String) in.readObject();
        String path = (String) in.readObject();
        boolean secure = in.readBoolean();
        boolean httpOnly = in.readBoolean();
        boolean hostOnly = in.readBoolean();
        boolean persistent = in.readBoolean();
        Cookie.Builder builder = new Cookie.Builder();
        builder = builder.name(name);
        builder = builder.value(value);
        builder = builder.expiresAt(expiresAt);
        builder = hostOnly ? builder.hostOnlyDomain(domain) : builder.domain(domain);
        builder = builder.path(path);
        builder = secure ? builder.secure() : builder;
        builder = httpOnly ? builder.httpOnly() : builder;
        clientCookies =builder.build();
    }
    

    }

    -自定义CookieManger

    实现有一个自定义的CookieManger来管理cookies,实现以K-V结构获取set,getCookier

        public class CookieManger implements CookieJar {
    
    
    public static String APP_PLATFORM = "app-platform";
    
    
    private static Context mContext;
    
    private static PersistentCookieStore cookieStore;
    
    public CookieManger(Context context) {
        mContext = context;
        if (cookieStore == null ) {
            cookieStore = new PersistentCookieStore(mContext);
        }
    
    }
    
    
    
    
    
    @Override
    public void saveFromResponse(HttpUrl url, List<Cookie> cookies) {
        if (cookies != null && cookies.size() > 0) {
            for (Cookie item : cookies) {
                cookieStore.add(url, item);
            }
        }
    }
    
    @Override
    public List<Cookie> loadForRequest(HttpUrl url) {
        List<Cookie> cookies =cookieStore.get(url);
        return cookies;
    }
    
    static class Customer {
    
        private String userID;
        private String token;
    
        public Customer(String userID, String token) {
            this.userID = userID;
            this.token = token;
        }
    
        public String getUserID() {
            return userID;
        }
    
        public void setUserID(String userID) {
            this.userID = userID;
        }
    
        public String getToken() {
            return token;
        }
    
        public void setToken(String token) {
            this.token = token;
        }
    
    }
    
    • Retrofit加入cookie

    OkHttpClient okHttpClient = new OkHttpClient.Builder()
                .addNetworkInterceptor(
                        new HttpLoggingInterceptor().setLevel(HttpLoggingInterceptor.Level.HEADERS))
                .cookieJar(new CookieManger(context))
                .addInterceptor(loginInterceptor)
                .connectTimeout(DEFAULT_TIMEOUT, TimeUnit.SECONDS)
                .build();
    
        
        Retrofit retrofit = new Retrofit.Builder()
                .client(okHttpClient)
                .build();
    

    总结

    实现加入cookies持久,实现免登陆基本步骤

    1 实现可序列化的OkHttpcookies

    2 实现储存OkHttpcookies的PersistentCookieStore

    3 实现cookies管理工具CookieManger

    4 构建OKHttpClient

    5 Retrofit加入自定义的okHttpClient

    6直接调用RetrofitClient

    方式二:

    方法一可能对某些网站不兼容,可以借助retfoit的拦截器实现用来加入cookie
    OKHttp原理请看我写的这个系列:
    OkHttp 3.x 源码解析之Interceptor 拦截器

    public class ReadCookiesInterceptor implements   Interceptor {
    
     @Override
      public Response intercept(Chain chain) throws IOException {
        Request.Builder builder = chain.request().newBuilder();
          HashSet<String> preferences = (HashSet) Preferences.getDefaultPreferences().getStringSet(Preferences.PREF_COOKIES, new HashSet<>());
         for (String cookie : preferences) {
            builder.addHeader("Cookie", cookie);
            Log.v("OkHttp", "Adding Header: " + cookie); // This is done so I know which headers are being added; this interceptor is used after the normal logging of OkHttp
         }
    
        return chain.proceed(builder.build());
     }
    }
    

    用来保存Cookies

    public class SaveCookiesInterceptor implements Interceptor {
       @Override
       public Response intercept(Chain chain) throws IOException {
          Response originalResponse = chain.proceed(chain.request());
    
          if (!originalResponse.headers("Set-Cookie").isEmpty()) {
             HashSet<String> cookies = new HashSet<>();
    
             for (String header : originalResponse.headers("Set-Cookie")) {
              cookies.add(header);
             }
    
             Preferences.getDefaultPreferences().edit()
                    .putStringSet(Preferences.PREF_COOKIES, cookies)
                    .apply();
        }
    
          return originalResponse;
    }
    

    }

    okhttp

    OkHttpClient okHttpClient = new OkHttpClient();
    okHttpClient.interceptors().add(new ReadCookiesInterceptor());
    okHttpClient.interceptors().add(new SaveCookiesInterceptor());
    

    Retrofit

     Retrofit retrofit = new Retrofit.Builder()
                .client(okHttpClient)
                .build();
    

    方式三:

    RxJava+ Retrofit

    实现Interceptor器,用来将本地的cookie追加到http请求头中;

    public class AddCookiesInterceptor implements Interceptor {
        private Context context;
        private String lang;
    
        public AddCookiesInterceptor(Context context, String lang) {
            super();
            this.context = context;
            this.lang = lang;
    
        }
    
        @Override
        public Response intercept(Chain chain) throws IOException {
            if (chain == null)
                Log.d("http", "Addchain == null");
            final Request.Builder builder = chain.request().newBuilder();
            SharedPreferences sharedPreferences = context.getSharedPreferences("cookie", Context.MODE_PRIVATE);
            Observable.just(sharedPreferences.getString("cookie", ""))
                    .subscribe(new Action1<String>() {
                        @Override
                        public void call(String cookie) {
                            if (cookie.contains("lang=ch")){
                                cookie = cookie.replace("lang=ch","lang="+lang);
                            }
                            if (cookie.contains("lang=en")){
                                cookie = cookie.replace("lang=en","lang="+lang);
                            }
                            //添加cookie
    //                        Log.d("http", "AddCookiesInterceptor"+cookie);
                            builder.addHeader("cookie", cookie);
                        }
                    });
            return chain.proceed(builder.build());
        }
    }
    
    

    实现Interceptor器,将Http返回的cookie存储到本地

    public class ReceivedCookiesInterceptor implements Interceptor {
        private Context context;
        SharedPreferences sharedPreferences;
    
        public ReceivedCookiesInterceptor(Context context) {
            super();
            this.context = context;
            sharedPreferences = context.getSharedPreferences("cookie", Context.MODE_PRIVATE);
        }
    
        @Override
        public Response intercept(Chain chain) throws IOException {
            if (chain == null)
                Log.d("http", "Receivedchain == null");
            Response originalResponse = chain.proceed(chain.request());
            Log.d("http", "originalResponse" + originalResponse.toString());
            if (!originalResponse.headers("set-cookie").isEmpty()) {
                final StringBuffer cookieBuffer = new StringBuffer();
                Observable.from(originalResponse.headers("set-cookie"))
                        .map(new Func1<String, String>() {
                            @Override
                            public String call(String s) {
                                String[] cookieArray = s.split(";");
                                return cookieArray[0];
                            }
                        })
                        .subscribe(new Action1<String>() {
                            @Override
                            public void call(String cookie) {
                                cookieBuffer.append(cookie).append(";");
                            }
                        });
                SharedPreferences.Editor editor = sharedPreferences.edit();
                editor.putString("cookie", cookieBuffer.toString());
                Log.d("http", "ReceivedCookiesInterceptor" + cookieBuffer.toString());
                editor.commit();
            }
    
            return originalResponse;
        }
    }
    
    

    本方法是androidformjm@sina.com提供的方法,这里感谢作者。

    小结

    本文详细介绍了retrofit持久cookie的姿势,也同样试用与okhttp。以上三种方式至少有一种适合你,webView的cookie同步请看
    http://www.jianshu.com/p/17054c21dd78

    so iz 或许下一步你将会Retrofit遇到文件和图片上传问题,别急会 干货即将来临!

    Retrofit 2.0系列请阅读

    相关文章

      网友评论

      • 天上下雪不下雨:兄弟,
        SharedPreferences.Editor editor = sharedPreferences.edit();
        editor.putString("cookie", cookieBuffer.toString());
        Log.d("http", "ReceivedCookiesInterceptor" + cookieBuffer.toString());
        editor.commit();

        这样的话,假如登录后,另外一个接口又出现set-cookie 这样保存你的登录cookie就丢掉了,好歹应该把之前的加上,拿来就用动不动就出401未授权,坑死我了,希望别人不要采坑了
      • 正规程序员:这几种cookie持久化方法较推荐哪种呢,就稳定性来说
        正规程序员:Preferences.getDefaultPreferences,能把此类贴出来吗?
      • KnightGuard:jdk 1.8路过也会出8楼的问题
      • 帅气的大红薯: 访问的链接不同后 再访问就不对了应该如何解决呢
      • xyzsyy0102:请问下,和拦截器取得的cookie有啥区别呢
        xyzsyy0102:不好意思,我自己的问题,cookie存储的不一样
        xyzsyy0102:你好,请问下,为什么我用cookiejar请求数据没有问题,但是请求图片资源出现了问题,拦截器只添加cookiejar吗?
      • 产品小贤:第二个方案有在项目中实践过吗?我实际使用过程中可能会出现下面的错误:


        # RxIoScheduler-17(16933)
        SIGABRT
        解析原始
        1 #00 pc 00000000000692cc /system/lib64/libc.so (tgkill+8) [arm64-v8a]
        2 #01 pc 0000000000067884 /system/lib64/libc.so (pthread_kill+68) [arm64-v8a]
        3 #02 pc 00000000000246cc /system/lib64/libc.so (raise+28) [arm64-v8a]
        4 #03 pc 000000000001efd8 /system/lib64/libc.so (abort+60) [arm64-v8a]
        5 #04 pc 0000000000022420 /system/lib64/libc.so (__libc_fatal+128) [arm64-v8a]
        6 #05 pc 0000000000022444 /system/lib64/libc.so (__fortify_chk_fail+32) [arm64-v8a]
        7 #06 pc 0000000000070914 /system/lib64/libc.so (__FD_SET_chk+32) [arm64-v8a]
        8 #07 pc 000000000000e038 /system/lib64/libjavacrypto.so [arm64-v8a]
        9 #08 pc 00000000000171a8 /system/lib64/libjavacrypto.so [arm64-v8a]
        10 #09 pc 0000000002b0d368 /data/dalvik-cache/arm64/system@framework@boot.oat (oatexec+7029608) [arm64-v8a]
        11 java:
        12 com.android.org.conscrypt.OpenSSLSocketImpl$SSLOutputStream.write(OpenSSLSocketImpl.java:771)
        Tamic: @zex 我没用拦截器 建议用cookiejar
        产品小贤:SaveCookiesInterceptor的intercept接口可能会报上面的错误
      • 锕鎖:方式二怎么就实现同步持久化 Cookie了?
      • 夜枫_郎:方式1会报空指针异常呀???
        NullPointerException: Attempt to invoke virtual method 'java.util.Set java.util.concurrent.ConcurrentHashMap.keySet()' on a null object reference

        prefsWriter.putString(url.host(), TextUtils.join(",", cookies.get(url.host()).keySet()));在.调用keySet()方法的对象为null,为什么?
        Tamic:@夜枫_郎 你用的jdk1.7?
        夜枫_郎:在这个PersistentCookieStore类中,大约80行左右位置,就是将cookie存在本地
      • coexist:Preferences类的代码呢
        Android_冯星:我想看看您的Preferences类代码
        新手谢谢关照
        coexist:@Tamic ok
        Tamic:@coexist SharePreferences啊 只不过单列处理包装了下而已
      • 落雨收柴:楼主,实现cookie的存储addInterceptor(loginInterceptor)是必须的吗?
        落雨收柴:@Tamic 谢谢
        Tamic:@落雨收柴 不需要
      • 2b6414e0700d:楼主项目的链接在哪里呢? 文章末尾也没有啊!怎么用啊
        2b6414e0700d:谢谢分享
        Tamic:@SENSOR灬保 https://github.com/NeglectedByBoss/RetrofitClient
      • 沐风雨木:楼主您好,恕我愚钝,这个要怎么用呢,看了一上午,也没明白要怎么用,能发给我一个Demo吗?QQ:513792933
        沐风雨木:@Tamic 酷!又读了你的其他文章,受益匪浅,感谢!
        Tamic:@沐风雨木 :https://github.com/NeglectedByBoss/RetrofitClient
        Tamic:@沐风雨木 文末尾有项目地址
      • TheLights:mark
        Tamic:@TheLights 感谢支持
      • 8314e3a0c30e:retrofit,尼玛,公司还没用,咋办呢
        Tamic:@赵丰年 可以写个适配器 接口转化就行了
        8314e3a0c30e:@Tamic 只能在后面的新功能里搞
        Tamic:@赵丰年 谁不让用,拿电脑砸谁

      本文标题:Retrofit 2.0 超能实践(二),Okhttp完美同步持

      本文链接:https://www.haomeiwen.com/subject/cuyvdttx.html