自定義Protocol Buffer javanano轉(zhuǎn)換工廠

首先介紹Protocol Buffer 和 javanao 的概念

Protocol Buffers (a.k.a., protobuf) are Google's language-neutral, platform-neutral, extensible mechanism for serializing structured data.

Protocol Buffer (又名,protobuf)是 Google 提供的一種語言中立,平臺中立,可擴展的序列化/結(jié)構(gòu)化數(shù)據(jù)的機制。

JavaNano is a special code generator and runtime library designed specially for resource-restricted systems, like Android. It is very resource-friendly in both the amount of code and the runtime overhead.

JavaNano是專門為資源受限系統(tǒng)(如Android)設(shè)計的特殊代碼生成器和運行時庫。 代碼量和運行時開銷都非常資源友好。

工作中接手的項目中,使用了Protocol Buffer javanano。查看編譯生成的java類,會發(fā)現(xiàn),javanano相比普通版本做了很大程度上的閹割,去掉了getter/setter方法、builder模式、Parser解析器。javanano直接解析并沒有啥問題,而且很簡單方便,但是,對于習(xí)慣了使用RxJava+Retrofit的我,使用工廠統(tǒng)一解析肯定是個硬性需求。所以問題來了,普通版本的轉(zhuǎn)換工廠(com.squareup.retrofit2:converter-protobuf:2.3.0)是使用反射獲取的Parser實例進行解析,javanano就使用不了,所以就有了這個自定義轉(zhuǎn)換工廠。

創(chuàng)建工廠

工廠類包含對ResponseBody/RequestBody兩種類型的轉(zhuǎn)換。

首先,是對ResponseBody響應(yīng)消息的解析轉(zhuǎn)換

public Converter<ResponseBody, T> responseBodyConverter(Type type, Annotation[] annotations, Retrofit retrofit) {
        //判斷type是否是class
        if (!(type instanceof Class<?>)) {
            return null;
        }
        Class<?> c = (Class<?>) type;
        //判斷type是否是MessageNano的實現(xiàn)類
        if (!MessageNano.class.isAssignableFrom(c)) {
            return null;
        }
        //把c傳遞過去,以便在convert時創(chuàng)建T的實例
        return new ProtoNanoResponseBodyConverter<>(c);
    }

ResponseBody對應(yīng)的轉(zhuǎn)換器

final class ProtoNanoResponseBodyConverter<T extends MessageNano>
        implements Converter<ResponseBody, T> {

    private Class<?> c;

    public ProtoNanoResponseBodyConverter(Class<?> c) {
        this.c = c;
    }

    @Override
    public T convert(@NonNull ResponseBody value) throws IOException {
        T msg = null;
        try {
            //noinspection unchecked
            msg = (T) c.newInstance();
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        }
        assert msg != null;
        //當(dāng)然,最后還是使用mergeFrom方法,將Response中的字節(jié)寫入上面創(chuàng)建的實例msg
        return T.mergeFrom(msg, value.bytes());
    }
}

然后是對RequestBody的轉(zhuǎn)換,判斷條件和ResponseBody相同

@Override
    public Converter<T, RequestBody> requestBodyConverter
            (Type type, Annotation[] parameterAnnotations,
             Annotation[] methodAnnotations, Retrofit retrofit) {
        if (!(type instanceof Class<?>)) {
            return null;
        }
        if (!MessageNano.class.isAssignableFrom((Class<?>) type)) {
            return null;
        }
        return new ProtoNanoRequestBodyConverter<>();
    }

ResponseBody對應(yīng)的轉(zhuǎn)換器

class ProtoNanoRequestBodyConverter<T extends MessageNano> implements Converter<T, RequestBody> {

    private static final MediaType MEDIA_TYPE = MediaType.parse("application/x-protobuf");

    @Override
    public RequestBody convert(@NonNull T value) throws IOException {
        //調(diào)用MessageNano的toByteArray轉(zhuǎn)換成字節(jié)流
        return RequestBody.create(MEDIA_TYPE, MessageNano.toByteArray(value));
    }
}

使用簡介

 Retrofit retrofit = new Retrofit.Builder()
                .baseUrl(BASE_URL)
                .client(client.build())
                .addConverterFactory(ProtoNanoConverterFactory.create())
                .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                .build();

和所有工廠類的使用一樣簡單。

All in all

自定義工廠的過程非常簡單,實質(zhì)上只是對T.mergeFrom(msg, value.bytes())MessageNano.toByteArray(value)的進一步封裝,統(tǒng)一在創(chuàng)建retrofit對象的使用加入轉(zhuǎn)換邏輯,不必每次在回調(diào)里再行處理。

源碼看這里

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務(wù)。

友情鏈接更多精彩內(nèi)容