异步网络请求,用的是Retrofit+okhttp+rxjava网络不好的情况下,怎么给出提示。 5C

一个点击按钮,里面是一个网络异步请求,我点击时会出来一个dialog:

 test.setOnClickListener{
    initDialog()
     RetrofitManager2.getApiBase().getRecognition("参数...")
                .timeout(10, TimeUnit.SECONDS)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread()).subscribe( Action1 {
                    if (mDialog != null) {
                        mDialog!!.dismiss()
                    }


        }, ApiErrorHandler(object : ApiErrorListener(){//这里是自定义的错误
            override fun onConnectException(t: Throwable) {
                super.onConnectException(t)
                ToastUtils.showShort(R.string.no_internet)


            }
            override fun onDatabaseException(t: DatabaseException) {
                super.onDatabaseException(t)

            }

            override fun onOtherException(t: Throwable) {
                super.onOtherException(t)

            }
        }))
}
    fun initDialog() {
        if (mDialog != null) {
            mDialog!!.dismiss()
        }
        mDialog = Dialog(this, R.style.Dialog)
        mDialog!!.setContentView(R.layout.firset_dialog_view)
        val window = mDialog!!.getWindow()
        val lp = window!!.attributes
        val screenW = getScreenWidth()
        lp.width = (0.6 * screenW).toInt()
        val titleTxtv = mDialog!!.findViewById<View>(R.id.tvLoad) as TextView
        titleTxtv.text = "请稍等..."
        mDialog!!.show()
        mDialog!!.setCanceledOnTouchOutside(false)
    }

如果在网络不好的情况下,这个dialog会一直在转圈,我想设置一个10秒的时间,如果这个请求还没有完成就给用户一个"当前网络信号不好",这样的提示,我用了rxjava的timeout,但是我找不到onError这个方法,都是onErrorReturn、onErrorResumeNext、onExceptionResumeNext这几个,对rxjava的运用还是不怎么熟悉,请问这个应该怎么实现。
object RetrofitManager {
private val unsafeHttpClient: OkHttpClient by lazy { createUnSafeOkHttpClient() }
private val httpClient: OkHttpClient by lazy { createOkhttpClient() }
private val retrofitClient: Retrofit by lazy { createRetrofit() }
private val api:ApiBase by lazy { retrofitClient.create(ApiBase::class.java) }
fun getOkHttpClient(): OkHttpClient = httpClient
fun getUnSafeOkHttpClient(): OkHttpClient = unsafeHttpClient
fun getRetrofit(): Retrofit = retrofitClient
fun getApiBase(): ApiBase = api
private fun createOkhttpClient(): OkHttpClient {
val loggingInterceptor = HttpLoggingInterceptor()
loggingInterceptor.level = HttpLoggingInterceptor.Level.BODY
return OkHttpClient.Builder()
.connectTimeout(10, TimeUnit.SECONDS)
.readTimeout(15, TimeUnit.SECONDS)
.writeTimeout(15, TimeUnit.SECONDS)
.addInterceptor(loggingInterceptor)
.addInterceptor(ApiPostInterceptor())
.addInterceptor(ApiResponseInterceptor())
.addInterceptor(ApiAutoBaseUrlInterceptor())
.build()
}
private fun createRetrofit(): Retrofit {
return Retrofit.Builder()
.baseUrl(TT_PHP_SERVER)
.client(httpClient)
.addCallAdapterFactory(RxJavaCallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.build()
}

private fun createUnSafeOkHttpClient(): OkHttpClient {
    val loggingInterceptor = HttpLoggingInterceptor()
    loggingInterceptor.level = HttpLoggingInterceptor.Level.BODY
    return UnsafeOkHttpClient.getUnsafeOkHttpClientBuilder()
            .connectTimeout(10, TimeUnit.SECONDS)
            .readTimeout(15, TimeUnit.SECONDS)
            .writeTimeout(15, TimeUnit.SECONDS)
            .addInterceptor(loggingInterceptor)
            .build()
}

}

@POST("china_mobile_recognition.php")
@FormUrlEncoded
fun getRecognition(@Field("session") session:String?,@Field("user_id")user_id:String?,@Field("appid")appid:String?
,@Field("token")token:String?,@Field("timestamp")timestamp:String?,@Field("phonenum")phonenum:String?
,@Field("msgid")msgid:String?,@Field("Sign")Sign:String?): Observable

1个回答

Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
异步网络请求,用的是Retrofit+okhttp+rxjava网络不好的情况下,怎么给出提示。
一个点击按钮,里面是一个网络异步请求,我点击时会出来一个dialog: ``` test.setOnClickListener{ initDialog() RetrofitManager2.getApiBase().getRecognition("参数...") .timeout(10, TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()).subscribe( Action1 { if (mDialog != null) { mDialog!!.dismiss() } }, ApiErrorHandler(object : ApiErrorListener(){//这里是自定义的错误 override fun onConnectException(t: Throwable) { super.onConnectException(t) ToastUtils.showShort(R.string.no_internet) } override fun onDatabaseException(t: DatabaseException) { super.onDatabaseException(t) } override fun onOtherException(t: Throwable) { super.onOtherException(t) } })) } fun initDialog() { if (mDialog != null) { mDialog!!.dismiss() } mDialog = Dialog(this, R.style.Dialog) mDialog!!.setContentView(R.layout.firset_dialog_view) val window = mDialog!!.getWindow() val lp = window!!.attributes val screenW = getScreenWidth() lp.width = (0.6 * screenW).toInt() val titleTxtv = mDialog!!.findViewById<View>(R.id.tvLoad) as TextView titleTxtv.text = "请稍等..." mDialog!!.show() mDialog!!.setCanceledOnTouchOutside(false) } ``` 如果在网络不好的情况下,这个dialog会一直在转圈,我想设置一个10秒的时间,如果这个请求还没有完成就给用户一个"当前网络信号不好",这样的提示,我用了rxjava的timeout,但是我找不到onError这个方法,都是onErrorReturn、onErrorResumeNext、onExceptionResumeNext这几个,对rxjava的运用还是不怎么熟悉,请问这个应该怎么实现。 object RetrofitManager { private val unsafeHttpClient: OkHttpClient by lazy { createUnSafeOkHttpClient() } private val httpClient: OkHttpClient by lazy { createOkhttpClient() } private val retrofitClient: Retrofit by lazy { createRetrofit() } private val api:ApiBase by lazy { retrofitClient.create(ApiBase::class.java) } fun getOkHttpClient(): OkHttpClient = httpClient fun getUnSafeOkHttpClient(): OkHttpClient = unsafeHttpClient fun getRetrofit(): Retrofit = retrofitClient fun getApiBase(): ApiBase = api private fun createOkhttpClient(): OkHttpClient { val loggingInterceptor = HttpLoggingInterceptor() loggingInterceptor.level = HttpLoggingInterceptor.Level.BODY return OkHttpClient.Builder() .connectTimeout(10, TimeUnit.SECONDS) .readTimeout(15, TimeUnit.SECONDS) .writeTimeout(15, TimeUnit.SECONDS) .addInterceptor(loggingInterceptor) .addInterceptor(ApiPostInterceptor()) .addInterceptor(ApiResponseInterceptor()) .addInterceptor(ApiAutoBaseUrlInterceptor()) .build() } private fun createRetrofit(): Retrofit { return Retrofit.Builder() .baseUrl(TT_PHP_SERVER) .client(httpClient) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .addConverterFactory(GsonConverterFactory.create()) .build() } private fun createUnSafeOkHttpClient(): OkHttpClient { val loggingInterceptor = HttpLoggingInterceptor() loggingInterceptor.level = HttpLoggingInterceptor.Level.BODY return UnsafeOkHttpClient.getUnsafeOkHttpClientBuilder() .connectTimeout(10, TimeUnit.SECONDS) .readTimeout(15, TimeUnit.SECONDS) .writeTimeout(15, TimeUnit.SECONDS) .addInterceptor(loggingInterceptor) .build() } } @POST("china_mobile_recognition.php") @FormUrlEncoded fun getRecognition(@Field("session") session:String?,@Field("user_id")user_id:String?,@Field("appid")appid:String? ,@Field("token")token:String?,@Field("timestamp")timestamp:String?,@Field("phonenum")phonenum:String? ,@Field("msgid")msgid:String?,@Field("Sign")Sign:String?): Observable<vildphoneBean>
安卓一些网络数据请求库 OkHttp,Retrofit,Volley,还有AsyncTask底层
安卓一些网络数据请求库 OkHttp,Retrofit,Volley,还有AsyncTask底层是不是都是HttpUrlConnect和HttpClient请求的?
Android、Retrofit+Rxjava,数据获取问题,第一个数据一直获取不到
我用Retrofit+Rxjava做数据处理的时候,一直获取不到第一个数据,比如下面这个,我获取到的数据都是从id=1那个开始的,请问是怎么回事,或者有没有好的例子借我参考一下,谢谢了! ``` { "status": true, "aaa": [ { "id": 0, "name": "第一", }, { "id": 1, "name": "第二", } ...... ] } ```
Retrofit2结合RxJava请求的时候,怎么获取响应头
我再使用网络请求的时候使用的是Retrofit2结合RxJava 网上的方法是在定义请求接口的时候使用 ``` @GET("/****act=****") Response<SomeClass> getSomeData(); ``` 但一个一个修改也太麻烦了,请问有什么好的方法吗?谢谢
retrofit+okhttp+rxjava的返回值解析时怎么做容错?
![图片说明](https://img-ask.csdn.net/upload/201807/26/1532571646_61237.png) ![图片说明](https://img-ask.csdn.net/upload/201807/26/1532571658_916788.png)
Retrofit2 + Rxjava 请求网络图片 的问题
接口如下 public interface ImgService { @GET Observable<ResponseBody> getImg(@Url String url); } Retrofit retrofit = new Retrofit.Builder() .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .addConverterFactory(GsonConverterFactory.create()) .baseUrl("http://pic41.nipic.com/") .build(); ImgService imgService = retrofit.create(ImgService.class); imgService.getImg("http://pic41.nipic.com/20140509/4746986_145156378323_2.jpg") .subscribeOn(Schedulers.io()) .map(new Func1<ResponseBody, Bitmap>() { @Override public Bitmap call(ResponseBody responseBody) { // 代码还从来没运行到过这个函数。。。 // responseBody.byteStream(); // return null; } }) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<Bitmap>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { e.printStackTrace(); } @Override public void onNext(Bitmap bitmap) { img.setImageBitmap(bitmap); } }); 现在出现的异常是: com.google.gson.stream.MalformedJsonException: Use JsonReader.setLenient(true) to accept malformed JSON at line 1 column 1 path $ 这个图片网址打开就是一张图片,不是Json数据,是因为这个原因吗? 现在一头雾水,问题出现在哪里?
Android如何用retrofit结合protobuf解析数据
客户要求支持Json和Protobuf两种序列化方式,请问怎么实现,json的我知道,但是protobuf不知道如何实现,网络框架使用的是Retrofit+Rxjava.请问有没有人做过protobuf相关的,给出参考链接也行啊
大神,请问retrofit +rxjava 获取数据,断网时奔溃是什么原因
就一个轮询的网络获取,断网过一会直接报错 报错为: java.lang.IllegalStateException: Fatal Exception thrown on Scheduler.Worker thread. at rx.android.schedulers.LooperScheduler$ScheduledAction.run(LooperScheduler.java:114) at android.os.Handler.handleCallback(Handler.java:739) at android.os.Handler.dispatchMessage(Handler.java:95) at android.os.Looper.loop(Looper.java:135) at android.app.ActivityThread.main(ActivityThread.java:5221) at java.lang.reflect.Method.invoke(Native Method) at java.lang.reflect.Method.invoke(Method.java:372) at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:899) at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:694) Caused by: rx.exceptions.OnErrorFailedException: Error occurred when trying to propagate error to Observer.onError at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:187) at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:115) at rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.checkTerminated(OperatorObserveOn.java:273) at rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.call(OperatorObserveOn.java:216) at rx.android.schedulers.LooperScheduler$ScheduledAction.run(LooperScheduler.java:107) at android.os.Handler.handleCallback(Handler.java:739)  at android.os.Handler.dispatchMessage(Handler.java:95)  at android.os.Looper.loop(Looper.java:135)  at android.app.ActivityThread.main(ActivityThread.java:5221)  at java.lang.reflect.Method.invoke(Native Method)  at java.lang.reflect.Method.invoke(Method.java:372)  at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:899)  at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:694)  Caused by: rx.exceptions.CompositeException: 2 exceptions occurred. at rx.observers.SafeSubscriber._onError(SafeSubscriber.java:187)  at rx.observers.SafeSubscriber.onError(SafeSubscriber.java:115)  at rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.checkTerminated(OperatorObserveOn.java:273)  at rx.internal.operators.OperatorObserveOn$ObserveOnSubscriber.call(OperatorObserveOn.java:216)  at rx.android.schedulers.LooperScheduler$ScheduledAction.run(LooperScheduler.java:107)  at android.os.Handler.handleCallback(Handler.java:739)  at android.os.Handler.dispatchMessage(Handler.java:95)  at android.os.Looper.loop(Looper.java:135)  at android.app.ActivityThread.main(ActivityThread.java:5221)  at java.lang.reflect.Method.invoke(Native Method)  at java.lang.reflect.Method.invoke(Method.java:372)  at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:899)  at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:694)  Caused by: rx.exceptions.CompositeException$CompositeExceptionCausalChain: Chain of Causes for CompositeException In Order Received => at android.util.Log.getStackTraceString(Log.java:330) at com.android.internal.os.RuntimeInit.Clog_e(RuntimeInit.java:59) at com.android.internal.os.RuntimeInit.access$200(RuntimeInit.java:43) at com.android.internal.os.RuntimeInit$UncaughtHandler.uncaughtException(RuntimeInit.java:85) at java.lang.ThreadGroup.uncaughtException(ThreadGroup.java:693) at java.lang.ThreadGroup.uncaughtException(ThreadGroup.java:690) at rx.android.schedulers.LooperScheduler$ScheduledAction.run(LooperScheduler.java:118) at android.os.Handler.handleCallback(Handler.java:739)  at android.os.Handler.dispatchMessage(Handler.java:95)  at android.os.Looper.loop(Looper.java:135)  at android.app.ActivityThread.main(ActivityThread.java:5221)  at java.lang.reflect.Method.invoke(Native Method)  at java.lang.reflect.Method.invoke(Method.java:372)  at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:899)  at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:694)  Caused by: java.net.SocketTimeoutException at java.net.PlainSocketImpl.read(PlainSocketImpl.java:488) at java.net.PlainSocketImpl.access$000(PlainSocketImpl.java:37) at java.net.PlainSocketImpl$PlainSocketInputStream.read(PlainSocketImpl.java:237) at okio.Okio$2.read(Okio.java:139) at okio.AsyncTimeout$2.read(AsyncTimeout.java:211) at okio.RealBufferedSource.indexOf(RealBufferedSource.java:306) at okio.RealBufferedSource.indexOf(RealBufferedSource.java:300) at okio.RealBufferedSource.readUtf8LineStrict(RealBufferedSource.java:196) at com.squareup.okhttp.internal.http.HttpConnection.readResponse(HttpConnection.java:191) at com.squareup.okhttp.internal.http.HttpTransport.readResponseHeaders(HttpTransport.java:80) at com.squareup.okhttp.internal.http.HttpEngine.readNetworkResponse(HttpEngine.java:906) at com.squareup.okhttp.internal.http.HttpEngine.access$300(HttpEngine.java:92) at com.squareup.okhttp.internal.http.HttpEngine$NetworkInterceptorChain.proceed(HttpEngine.java:891) at com.squareup.okhttp.internal.http.HttpEngine.readResponse(HttpEngine.java:749) at com.squareup.okhttp.Call.getResponse(Call.java:268) at com.squareup.okhttp.Call$ApplicationInterceptorChain.proceed(Call.java:224) at com.squareup.okhttp.Call.getResponseWithInterceptorChain(Call.java:195) at com.squareup.okhttp.Call.execute(Call.java:79) at retrofit.OkHttpCall.execute(OkHttpCall.java:116) at retrofit.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:111) at retrofit.RxJavaCallAdapterFactory$CallOnSubscribe.call(RxJavaCallAdapterFactory.java:88) at rx.Observable.unsafeSubscribe(Observable.java:10142) at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:48) at rx.internal.operators.OnSubscribeMap.call(OnSubscribeMap.java:33) at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48) at rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30) at rx.Observable.unsafeSubscribe(Observable.java:10142) at rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:9 这是什么问题,求大神解答 我自用剩下1c币了,大神不要嫌少,搭救我一下
retrofit2 rxjava gson解析空数组字符串 崩溃
当服务器返回[]这样的就程序就会崩溃,当服务器返回[]数组里有对象字符串就不崩溃
android retrofit 下载进度问题
在单独使用okhttp的时候,添加下载进度是通过拦截器,改造responsebody实现的,用retrofit原理其实一样。 但是我在项目中使用了 retrofit+rxjava+dagger2这种东西,有没有什么办法,不单独写下载工具,通过配置之类的方法,把api融合方便使用呢
使用Rxjava+Retrofit时出错
楼主是萌新,在使用Rxjava2+retrofit2时编译完成之后会报错: Caused by: java.lang.IllegalArgumentException: Unable to create call adapter for io.reactivex.Observable<java.lang.String>for method NewsService.getUser 依赖: compile 'io.reactivex.rxjava2:rxjava:2.0.4' compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'com.squareup.okhttp3:okhttp:3.5.0' compile 'com.google.code.gson:gson:2.8.0' compile 'com.squareup.retrofit2:retrofit:2.1.0' compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0' compile 'com.squareup.retrofit2:converter-gson:2.1.0' 部分代码: Retrofit retrofit = new Retrofit.Builder() .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .baseUrl("http://takeapp.com.cn/Home/register/") .build(); NewsService api = retrofit.create(NewsService .class); api.getUser("13222222222",MD5Tool.md5("123")); Service类接口: @POST("login") Observable<String> getUser(@Field("phone_num") String username, @Field("password") String password); 请问要如何解决
RxJava2 和 Retrofit2 依赖时出现问题
今天在使用RxJava2 和 Retrofit2在真机调试的时候出现如下错误: Error:Execution failed for task ':app:transformResourcesWithMergeJavaResForDebug'. > com.android.build.api.transform.TransformException: com.android.builder.packaging.DuplicateFileException: Duplicate files copied in APK META-INF/rxjava.properties File1: C:\Users\Administrator\.gradle\caches\modules-2\files-2.1\io.reactivex.rxjava2\rxjava\2.0.7\21734c0092a5d3c3ec99510e50c1ff76bdf0c65a\rxjava-2.0.7.jar File2: C:\Users\Administrator\.gradle\caches\modules-2\files-2.1\io.reactivex\rxjava\1.2.0\42bfaf64c94f3848ebf5cf1c2ea4ec9d1b3ac6c8\rxjava-1.2.0.jar 这是我的依赖: dependencies { compile fileTree(dir: 'libs', include: ['*.jar']) androidTestCompile('com.android.support.test.espresso:espresso-core:2.2.2', { exclude group: 'com.android.support', module: 'support-annotations' }) compile 'com.android.support:appcompat-v7:25.0.1' compile 'com.android.support.constraint:constraint-layout:1.0.2' testCompile 'junit:junit:4.12' compile 'com.squareup.okhttp3:okhttp:3.6.0' compile 'io.reactivex.rxjava2:rxjava:2.0.7' compile 'io.reactivex.rxjava2:rxandroid:2.0.1' compile 'com.squareup.retrofit2:retrofit:2.2.0' compile 'com.squareup.retrofit2:converter-gson:2.2.0' compile 'com.squareup.retrofit2:adapter-rxjava:2.2.0' }
在Rxjava2+Retrofit中使用retryWhen重新拉取请求失败
使用Rxjava2+ Retrofit 进行网络请求,在请求失败之后,使用retryWhen实现重新请求(如下面代码)。但发现没有实现预想的功能: ``` class TestRetryWhenHeartBeatException : Function<Observable<out Throwable>, ObservableSource<*>> { companion object { private val DELAY: Long = 6 private val TAG:String = TestRetryWhenHeartBeatException::class.java.simpleName } override fun apply(t: Observable<out Throwable>): ObservableSource<*> { logd(TAG,"retry when") return t.flatMap { Observable.timer(DELAY, TimeUnit.SECONDS) } } } ``` ``` mHeartBeatDisposable = Observable.interval(5,TimeUnit.SECONDS) .subscribeOn(Schedulers.io()) .unsubscribeOn(Schedulers.io()) // .repeatWhen(RepeatWhenHeartBeatCompleted()) .retryWhen(TestRetryWhenHeartBeatException()) .flatMap { if (TaskManager.mIdle) { logd(TAG, "heartbeat") mNetWorkApi.heartBeat(UrlManager.HEARTBEAT_URL) } else { Observable.create { emitter -> //emit a HttpResult with no data emitter.onNext(nullHeartBeat) } } } .subscribe({ data -> RxBus.getDefault().post(LostServerEvent(false)) logd(TAG, "post lost server false") }, { e -> loge(TAG, e.message) loge(TAG, "lost server") RxBus.getDefault().post(LostServerEvent(true)) }, {}) ```
retrofit2网络请求第一次请求时老是报这个错,手动请求又是没问题的
responseString: responseString get retrofit2.adapter.rxjava2.HttpException: HTTP 403 Forbidden
Retrofit + OkHttp + RxAndroid 缓存问题
@Override public okhttp3.Response intercept(Chain chain) throws IOException { Request request = chain.request(); //缓存 if(NetUtil.checkNetwork(mContext)==NetUtil.NO_NETWORK){ request = request.newBuilder() .cacheControl(CacheControl.FORCE_CACHE) .build(); Log.d("zgx","no network"); } okhttp3.Response response = chain.proceed(request); String requestUrl = response.request().url().uri().getPath(); if(!TextUtils.isEmpty(requestUrl)){ if(requestUrl.contains("LoginDataServlet")) { if (Looper.myLooper() == null) { Looper.prepare(); } createObservable("现在请求的是登录接口"); } } //缓存响应 if(NetUtil.checkNetwork(mContext)!=NetUtil.NO_NETWORK){ //有网的时候读接口上的@Headers里的配置,你可以在这里进行统一的设置 String cacheControl = request.cacheControl().toString(); Log.e("zgx","request====="+request); Log.e("zgx","request.toString()====="+request.header("body")); Log.e("zgx","request.cacheControl()====="+request.cacheControl()); Log.e("zgx","cacheControl====="+cacheControl); return response.newBuilder() .header("Cache-Control", cacheControl) .removeHeader("Pragma") .build(); }else{ return response.newBuilder() .header("Cache-Control", "public, only-if-cached, max-stale=120") .removeHeader("Pragma") .build(); } } 为什么String cacheControl = request.cacheControl().toString();获取不到值呢?
retrofit网络请求的参数中的斜杠被转义(自动添加了反斜杠)
String str = "123456/654321",传递给java后台服务端就自动变成了"123456\/654321",不知道怎么回事,用的是retrofit网络框架
proguard+retrofit2.4+adapter-rxjava2-2.4.0+rxjava2+rxandroid2
目前在做android的代码混淆,没有混淆之前,代码运行正常,当打开混淆之后,代码运行时出现如下差错: ``` 03-13 10:39:59.936 6285 6285 E AndroidRuntime: java.lang.IllegalArgumentException: Unable to create call adapter for class io.reactivex.b 03-13 10:39:59.936 6285 6285 E AndroidRuntime: for method RequestApis.getCameraInfo 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.ServiceMethod$Builder.methodError() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.ServiceMethod$Builder.createCallAdapter() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.ServiceMethod$Builder.build() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.Retrofit.loadServiceMethod() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.Retrofit$1.invoke() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at java.lang.reflect.Proxy.invoke(Proxy.java:393) 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at $Proxy0.getCameraInfo(Unknown Source) 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at com.xxx.helper.RetrofitHelper.getCameraInfo() ...... 03-13 10:39:59.936 6285 6285 E AndroidRuntime: Caused by: java.lang.IllegalStateException: Flowable return type must be parameterized as Flowable<Foo> or Flowable<? extends Foo> 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory.get() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.Retrofit.nextCallAdapter() 03-13 10:39:59.936 6285 6285 E AndroidRuntime: at retrofit2.Retrofit.callAdapter() ``` ``` 其中proguard配置: # Retrofit -dontwarn retrofit2.** -dontwarn org.codehaus.mojo.** -keep class retrofit2.** { *; } -keepattributes Signature -keepattributes Exceptions -keepattributes *Annotation* # Platform calls Class.forName on types which do not exist on Android to determine platform. -dontnote retrofit2.Platform # Platform used when running on RoboVM on iOS. Will not be used at runtime. -dontnote retrofit2.Platform$IOS$MainThreadExecutor # Platform used when running on Java 8 VMs. Will not be used at runtime. -dontwarn retrofit2.Platform$Java8 # Retain generic type information for use by reflection by converters and adapters. -keepattributes Signature # Retain declared checked exceptions for use by a Proxy instance. -keepattributes Exceptions -dontwarn retrofit2.adapter.rxjava.CompletableHelper$** # https://github.com/square/retrofit/issues/2034 #To use Single instead of Observable in Retrofit interface -keepnames class rx.Single #Retrofit does reflection on generic parameters. InnerClasses is required to use Signature and # EnclosingMethod is required to use InnerClasses. -keepattributes Signature, InnerClasses, EnclosingMethod # Retain service method parameters when optimizing. -keepclassmembers,allowobfuscation interface * { @retrofit2.http.* <methods>; } -keepattributes RuntimeVisibleAnnotations -keepattributes RuntimeInvisibleAnnotations -keepattributes RuntimeVisibleParameterAnnotations -keepattributes RuntimeInvisibleParameterAnnotations -keepattributes EnclosingMethod -keepclasseswithmembers interface * { @retrofit2.* <methods>; } -keepclasseswithmembers class * { @retrofit2.http.* <methods>; } # OkHttp3 -keepattributes Signature -keepattributes *Annotation* -keep class okhttp3.** { *; } -keep interface okhttp3.** { *; } -dontwarn okhttp3.** #OkHttp -keep class com.squareup.okhttp.** { *; } -keep interface com.squareup.okhttp.** { *; } -dontwarn com.squareup.okhttp.** -dontwarn okio.** ``` jar版本: adapter-rxjava2-2.4.0.jar retrofit-2.4.0.jar reactive-streams-1.0.2.jar rxjava-2.1.14.jar rxandroid-2.0.2.aar 有哪位大神帮忙看下,如何解决?
retrofit2+rxjava报错,接口使用call可以正常获取天气数据???
``` 接口: @GET("adat/cityinfo/{flag}") Observable<Weather> getWeather(@Path("flag") String flag); 请求代码: retrofit_weather = new Retrofit.Builder() .baseUrl(WEATHERIP) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJavaCallAdapterFactory.create()) .build(); InfoService serverse = retrofit_weather.create(InfoService.class); serverse.getWeather("101190404.html") .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Subscriber<Weather>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Weather weather) { text2.setText(weather.getWeatherinfo().getWeather()); } }); ``` 报错: ![图片说明](https://img-ask.csdn.net/upload/201606/22/1466565786_517831.png)
使用Retrofit请求可以串行执行吗?
如题。比如我现在有两个网络接口A和B。目前我需要先请求A,获得result1,再根据这个result1去请求网络接口B,获得最终需要的result2。这种情况要怎么写代码?我尝试将代码顺序执行,结果result1是空的,并不能将其作为参数传给网络接口B。所以有没有一种方法能让请求A先完全执行完毕再执行请求B?
RxJava+Retrofit文件下载代码在第二次下载时没有被调用是什么原因?
在使用RxJava+Retrofit进行文件下载,下面这段代码在第一个文件下载时,可以调用并下载成功,但在第二个文件下载时,没有被调用到,找了好久没有找到原因。(netWorkApi--是声明的Retrofit接口对象,里面是一些URL调用方法) ``` netWorkApi.download(url) .subscribeOn(Schedulers.io()) .unsubscribeOn(Schedulers.io()) .retryWhen(RetryWhenNetworkException()) .map(object : Func1<ResponseBody, Int> { override fun call(responseBody: ResponseBody): Int { Logger.t(TAG).d("write2File") return write2File(responseBody, name) } } ) .observeOn(AndroidSchedulers.mainThread()) .subscribe(downloadSubscriber) ```
终于明白阿里百度这样的大公司,为什么面试经常拿ThreadLocal考验求职者了
点击上面↑「爱开发」关注我们每晚10点,捕获技术思考和创业资源洞察什么是ThreadLocalThreadLocal是一个本地线程副本变量工具类,各个线程都拥有一份线程私...
程序员必须掌握的核心算法有哪些?
由于我之前一直强调数据结构以及算法学习的重要性,所以就有一些读者经常问我,数据结构与算法应该要学习到哪个程度呢?,说实话,这个问题我不知道要怎么回答你,主要取决于你想学习到哪些程度,不过针对这个问题,我稍微总结一下我学过的算法知识点,以及我觉得值得学习的算法。这些算法与数据结构的学习大多数是零散的,并没有一本把他们全部覆盖的书籍。下面是我觉得值得学习的一些算法以及数据结构,当然,我也会整理一些看过...
Linux(服务器编程):15---两种高效的事件处理模式(reactor模式、proactor模式)
前言 同步I/O模型通常用于实现Reactor模式 异步I/O模型则用于实现Proactor模式 最后我们会使用同步I/O方式模拟出Proactor模式 一、Reactor模式 Reactor模式特点 它要求主线程(I/O处理单元)只负责监听文件描述符上是否有事件发生,有的话就立即将时间通知工作线程(逻辑单元)。除此之外,主线程不做任何其他实质性的工作 读写数据,接受新的连接,以及处...
阿里面试官问我:如何设计秒杀系统?我的回答让他比起大拇指
你知道的越多,你不知道的越多 点赞再看,养成习惯 GitHub上已经开源 https://github.com/JavaFamily 有一线大厂面试点脑图和个人联系方式,欢迎Star和指教 前言 Redis在互联网技术存储方面使用如此广泛,几乎所有的后端技术面试官都要在Redis的使用和原理方面对小伙伴们进行360°的刁难。 作为一个在互联网公司面一次拿一次Offer的面霸,打败了...
五年程序员记流水账式的自白。
不知觉已中码龄已突破五年,一路走来从起初铁憨憨到现在的十九线程序员,一路成长,虽然不能成为高工,但是也能挡下一面,从15年很火的android开始入坑,走过java、.Net、QT,目前仍处于android和.net交替开发中。 毕业到现在一共就职过两家公司,目前是第二家,公司算是半个创业公司,所以基本上都会身兼多职。比如不光要写代码,还要写软著、软著评测、线上线下客户对接需求收集...
C语言魔塔游戏
很早就很想写这个,今天终于写完了。 游戏截图: 编译环境: VS2017 游戏需要一些图片,如果有想要的或者对游戏有什么看法的可以加我的QQ 2985486630 讨论,如果暂时没有回应,可以在博客下方留言,到时候我会看到。 下面我来介绍一下游戏的主要功能和实现方式 首先是玩家的定义,使用结构体,这个名字是可以自己改变的 struct gamerole { char n...
一文详尽系列之模型评估指标
点击上方“Datawhale”,选择“星标”公众号第一时间获取价值内容在机器学习领域通常会根据实际的业务场景拟定相应的不同的业务指标,针对不同机器学习问题如回归、分类、排...
究竟你适不适合买Mac?
我清晰的记得,刚买的macbook pro回到家,开机后第一件事情,就是上了淘宝网,花了500元钱,找了一个上门维修电脑的师傅,上门给我装了一个windows系统。。。。。。 表砍我。。。 当时买mac的初衷,只是想要个固态硬盘的笔记本,用来运行一些复杂的扑克软件。而看了当时所有的SSD笔记本后,最终决定,还是买个好(xiong)看(da)的。 已经有好几个朋友问我mba怎么样了,所以今天尽量客观...
程序员一般通过什么途径接私活?
二哥,你好,我想知道一般程序猿都如何接私活,我也想接,能告诉我一些方法吗? 上面是一个读者“烦不烦”问我的一个问题。其实不止是“烦不烦”,还有很多读者问过我类似这样的问题。 我接的私活不算多,挣到的钱也没有多少,加起来不到 20W。说实话,这个数目说出来我是有点心虚的,毕竟太少了,大家轻喷。但我想,恰好配得上“一般程序员”这个称号啊。毕竟苍蝇再小也是肉,我也算是有经验的人了。 唾弃接私活、做外...
压测学习总结(1)——高并发性能指标:QPS、TPS、RT、吞吐量详解
一、QPS,每秒查询 QPS:Queries Per Second意思是“每秒查询率”,是一台服务器每秒能够相应的查询次数,是对一个特定的查询服务器在规定时间内所处理流量多少的衡量标准。互联网中,作为域名系统服务器的机器的性能经常用每秒查询率来衡量。 二、TPS,每秒事务 TPS:是TransactionsPerSecond的缩写,也就是事务数/秒。它是软件测试结果的测量单位。一个事务是指一...
Python爬虫爬取淘宝,京东商品信息
小编是一个理科生,不善长说一些废话。简单介绍下原理然后直接上代码。 使用的工具(Python+pycharm2019.3+selenium+xpath+chromedriver)其中要使用pycharm也可以私聊我selenium是一个框架可以通过pip下载 pip installselenium -ihttps://pypi.tuna.tsinghua.edu.cn/simple/ ...
阿里程序员写了一个新手都写不出的低级bug,被骂惨了。
这种新手都不会范的错,居然被一个工作好几年的小伙子写出来,差点被当场开除了。
Java工作4年来应聘要16K最后没要,细节如下。。。
前奏: 今天2B哥和大家分享一位前几天面试的一位应聘者,工作4年26岁,统招本科。 以下就是他的简历和面试情况。 基本情况: 专业技能: 1、&nbsp;熟悉Sping了解SpringMVC、SpringBoot、Mybatis等框架、了解SpringCloud微服务 2、&nbsp;熟悉常用项目管理工具:SVN、GIT、MAVEN、Jenkins 3、&nbsp;熟悉Nginx、tomca...
2020年,冯唐49岁:我给20、30岁IT职场年轻人的建议
点击“技术领导力”关注∆每天早上8:30推送 作者|Mr.K 编辑| Emma 来源|技术领导力(ID:jishulingdaoli) 前天的推文《冯唐:职场人35岁以后,方法论比经验重要》,收到了不少读者的反馈,觉得挺受启发。其实,冯唐写了不少关于职场方面的文章,都挺不错的。可惜大家只记住了“春风十里不如你”、“如何避免成为油腻腻的中年人”等不那么正经的文章。 本文整理了冯...
程序员该看的几部电影
1、骇客帝国(1999) 概念:在线/离线,递归,循环,矩阵等 剧情简介: 不久的将来,网络黑客尼奥对这个看似正常的现实世界产生了怀疑。 他结识了黑客崔妮蒂,并见到了黑客组织的首领墨菲斯。 墨菲斯告诉他,现实世界其实是由一个名叫“母体”的计算机人工智能系统控制,人们就像他们饲养的动物,没有自由和思想,而尼奥就是能够拯救人类的救世主。 可是,救赎之路从来都不会一帆风顺,到底哪里才是真实的世界?如何...
Python绘图,圣诞树,花,爱心 | Turtle篇
每周每日,分享Python实战代码,入门资料,进阶资料,基础语法,爬虫,数据分析,web网站,机器学习,深度学习等等。 公众号回复【进群】沟通交流吧,QQ扫码进群学习吧 微信群 QQ群 1.画圣诞树 import turtle screen = turtle.Screen() screen.setup(800,600) circle = turtle.Turtle()...
作为一个程序员,CPU的这些硬核知识你必须会!
CPU对每个程序员来说,是个既熟悉又陌生的东西? 如果你只知道CPU是中央处理器的话,那可能对你并没有什么用,那么作为程序员的我们,必须要搞懂的就是CPU这家伙是如何运行的,尤其要搞懂它里面的寄存器是怎么一回事,因为这将让你从底层明白程序的运行机制。 随我一起,来好好认识下CPU这货吧 把CPU掰开来看 对于CPU来说,我们首先就要搞明白它是怎么回事,也就是它的内部构造,当然,CPU那么牛的一个东...
还记得那个提速8倍的IDEA插件吗?VS Code版本也发布啦!!
去年,阿里云发布了本地 IDE 插件 Cloud Toolkit,仅 IntelliJ IDEA 一个平台,就有 15 万以上的开发者进行了下载,体验了一键部署带来的开发便利。时隔一年的今天,阿里云正式发布了 Visual Studio Code 版本,全面覆盖前端开发者,帮助前端实现一键打包部署,让开发提速 8 倍。 VSCode 版本的插件,目前能做到什么? 安装插件之后,开发者可以立即体验...
破14亿,Python分析我国存在哪些人口危机!
一、背景 二、爬取数据 三、数据分析 1、总人口 2、男女人口比例 3、人口城镇化 4、人口增长率 5、人口老化(抚养比) 6、各省人口 7、世界人口 四、遇到的问题 遇到的问题 1、数据分页,需要获取从1949-2018年数据,观察到有近20年参数:LAST20,由此推测获取近70年的参数可设置为:LAST70 2、2019年数据没有放上去,可以手动添加上去 3、将数据进行 行列转换 4、列名...
2019年除夕夜的有感而发
天气:小雨(加小雪) 温度:3摄氏度 空气:严重污染(399) 风向:北风 风力:微风 现在是除夕夜晚上十点钟,再有两个小时就要新的一年了; 首先要说的是我没患病,至少现在是没有患病;但是心情确像患了病一样沉重; 现在这个时刻应该大部分家庭都在看春晚吧,或许一家人团团圆圆的坐在一起,或许因为某些特殊原因而不能团圆;但不管是身在何处,身处什么境地,我都想对每一个人说一句:新年快乐! 不知道csdn这...
听说想当黑客的都玩过这个Monyer游戏(1~14攻略)
第零关 进入传送门开始第0关(游戏链接) 请点击链接进入第1关: 连接在左边→ ←连接在右边 看不到啊。。。。(只能看到一堆大佬做完的留名,也能看到菜鸡的我,在后面~~) 直接fn+f12吧 &lt;span&gt;连接在左边→&lt;/span&gt; &lt;a href="first.php"&gt;&lt;/a&gt; &lt;span&gt;←连接在右边&lt;/span&gt; o...
在家远程办公效率低?那你一定要收好这个「在家办公」神器!
相信大家都已经收到国务院延长春节假期的消息,接下来,在家远程办公可能将会持续一段时间。 但是问题来了。远程办公不是人在电脑前就当坐班了,相反,对于沟通效率,文件协作,以及信息安全都有着极高的要求。有着非常多的挑战,比如: 1在异地互相不见面的会议上,如何提高沟通效率? 2文件之间的来往反馈如何做到及时性?如何保证信息安全? 3如何规划安排每天工作,以及如何进行成果验收? ...... ...
作为一个程序员,内存和磁盘的这些事情,你不得不知道啊!!!
截止目前,我已经分享了如下几篇文章: 一个程序在计算机中是如何运行的?超级干货!!! 作为一个程序员,CPU的这些硬核知识你必须会! 作为一个程序员,内存的这些硬核知识你必须懂! 这些知识可以说是我们之前都不太重视的基础知识,可能大家在上大学的时候都学习过了,但是嘞,当时由于老师讲解的没那么有趣,又加上这些知识本身就比较枯燥,所以嘞,大家当初几乎等于没学。 再说啦,学习这些,也看不出来有什么用啊!...
2020年的1月,我辞掉了我的第一份工作
其实,这篇文章,我应该早点写的,毕竟现在已经2月份了。不过一些其它原因,或者是我的惰性、还有一些迷茫的念头,让自己迟迟没有试着写一点东西,记录下,或者说是总结下自己前3年的工作上的经历、学习的过程。 我自己知道的,在写自己的博客方面,我的文笔很一般,非技术类的文章不想去写;另外我又是一个还比较热衷于技术的人,而平常复杂一点的东西,如果想写文章写的清楚点,是需要足够...
别低估自己的直觉,也别高估自己的智商
所有群全部吵翻天,朋友圈全部沦陷,公众号疯狂转发。这两周没怎么发原创,只发新闻,可能有人注意到了。我不是懒,是文章写了却没发,因为大家的关注力始终在这次的疫情上面,发了也没人看。当然,我...
这个世界上人真的分三六九等,你信吗?
偶然间,在知乎上看到一个问题 一时间,勾起了我深深的回忆。 以前在厂里打过两次工,做过家教,干过辅导班,做过中介。零下几度的晚上,贴过广告,满脸、满手地长冻疮。 再回首那段岁月,虽然苦,但让我学会了坚持和忍耐。让我明白了,在这个世界上,无论环境多么的恶劣,只要心存希望,星星之火,亦可燎原。 下文是原回答,希望能对你能有所启发。 如果我说,这个世界上人真的分三六九等,...
节后首个工作日,企业们集体开晨会让钉钉挂了
By 超神经场景描述:昨天 2 月 3 日,是大部分城市号召远程工作的第一天,全国有接近 2 亿人在家开始远程办公,钉钉上也有超过 1000 万家企业活跃起来。关键词:十一出行 人脸...
Java基础知识点梳理
虽然已经在实际工作中经常与java打交道,但是一直没系统地对java这门语言进行梳理和总结,掌握的知识也比较零散。恰好利用这段时间重新认识下java,并对一些常见的语法和知识点做个总结与回顾,一方面为了加深印象,方便后面查阅,一方面为了掌握好Android打下基础。
2020年全新Java学习路线图,含配套视频,学完即为中级Java程序员!!
新的一年来临,突如其来的疫情打破了平静的生活! 在家的你是否很无聊,如果无聊就来学习吧! 世上只有一种投资只赚不赔,那就是学习!!! 传智播客于2020年升级了Java学习线路图,硬核升级,免费放送! 学完你就是中级程序员,能更快一步找到工作! 一、Java基础 JavaSE基础是Java中级程序员的起点,是帮助你从小白到懂得编程的必经之路。 在Java基础板块中有6个子模块的学...
B 站上有哪些很好的学习资源?
哇说起B站,在小九眼里就是宝藏般的存在,放年假宅在家时一天刷6、7个小时不在话下,更别提今年的跨年晚会,我简直是跪着看完的!! 最早大家聚在在B站是为了追番,再后来我在上面刷欧美新歌和漂亮小姐姐的舞蹈视频,最近两年我和周围的朋友们已经把B站当作学习教室了,而且学习成本还免费,真是个励志的好平台ヽ(.◕ฺˇд ˇ◕ฺ;)ノ 下面我们就来盘点一下B站上优质的学习资源: 综合类 Oeasy: 综合...
相关热词 c# 识别回车 c#生成条形码ean13 c#子控制器调用父控制器 c# 写大文件 c# 浏览pdf c#获取桌面图标的句柄 c# list反射 c# 句柄 进程 c# 倒计时 线程 c# 窗体背景色
立即提问