Rxjava实现10秒轮训和5秒轮训的交替使用

先来抛出需求：商家接收的客户发出的订单肯定是越快越好，大家普遍认为推送是最好的选择，然而真正现实场景中，在消费高峰期（晚上聚餐去人最多的餐厅吃饭），推送的延时性是让商家最不可忍受的，当然，可能跟我们接入的免费版的SDK有关，收费版的我们公司没有使用过，如果你们使用过收费版的，麻烦评论区告知我们收费版的会不会存在延时，丢推送这些无法忍受的问题。

所以我们后来用轮训和推送同时使用，然后做一个过滤，谁先到就优先处理，其余的过滤掉，刚开始接入轮训的时候肯定是要确定一个让商家能忍受的时间来获取订单，于是就有了每10秒一次请求一次订单，在商用一段时间后，抱怨比之前少了很多。但是还是有些商家不满意，消费人群特别多的商家，如果每个人等10秒，总会有些不满意的声音。

于是，新的需求就如期而来了。。。闲时每10秒轮训一次，高峰期每5秒轮训一次，过了高峰期又恢复到10秒轮训一次。

怎么感觉在写小说呢？我都看不下去了，密密麻麻的。。。

针对：闲时–每10秒轮训一次，忙时–每5秒轮训一次

我们用一个效果来模拟这个场景：
**0—30秒：每10秒一次
31—60秒：每5秒一次**

轮训用Rxjava的interval()来实现，效果：

代码如下：

package com.ishangbin.shop.ui;import android.os.Bundle;
import android.os.PersistableBundle;
import android.support.v7.app.AppCompatActivity;import com.ishangbin.shop.ui.act.util.LogUtil;import java.util.Calendar;
import java.util.concurrent.TimeUnit;import rx.Observable;
import rx.Observer;
import rx.Subscription;/*** Created by zhouhui on 2017/12/28.*/public class TestActivity extends AppCompatActivity {/*** 5秒轮训*/private ObserverShort mShortObserver;private Observable<Long> mObservableOrderPollingShort;private Subscription mSubscriptionOrderPollingShort;/*** 10秒轮训*/private ObserverLong mObserverLong;private Observable<Long> mObservableOrderPollingLong;private Subscription mSubscriptionOrderPollingLong;@Overridepublic void onCreate(Bundle savedInstanceState, PersistableBundle persistentState) {super.onCreate(savedInstanceState, persistentState);// 参数说明：// 参数1 = 第1次延迟时间；// 参数2 = 间隔时间数字；// 参数3 = 时间单位；// Observable.interval(5, 5, TimeUnit.SECONDS)mShortObserver = new ObserverShort();mObservableOrderPollingShort = Observable.interval(5, 5, TimeUnit.SECONDS);mObserverLong = new ObserverLong();mObservableOrderPollingLong = Observable.interval(10, 10, TimeUnit.SECONDS);initLongPolling();}@Overridepublic void onDestroy() {if (mSubscriptionOrderPollingShort != null && mSubscriptionOrderPollingShort.isUnsubscribed()) {mSubscriptionOrderPollingShort.unsubscribe();}if (mSubscriptionOrderPollingLong != null && mSubscriptionOrderPollingLong.isUnsubscribed()) {mSubscriptionOrderPollingLong.unsubscribe();}super.onDestroy();}/*** 短轮训*/private void initShortPolling() {mSubscriptionOrderPollingShort = mObservableOrderPollingShort.subscribe(mShortObserver);}/*** 长轮训*/private void initLongPolling() {mSubscriptionOrderPollingLong = mObservableOrderPollingLong.subscribe(mObserverLong);}/*** 短轮训的回调*/public class ObserverShort implements Observer<Long> {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable throwable) {}@Overridepublic void onNext(Long aLong) {Calendar curDateTime = Calendar.getInstance();curDateTime.setTimeInMillis(System.currentTimeMillis());int year = curDateTime.get(Calendar.YEAR);int month = curDateTime.get(Calendar.MONTH);int day = curDateTime.get(Calendar.DAY_OF_MONTH);int hour = curDateTime.get(Calendar.HOUR_OF_DAY);int minute = curDateTime.get(Calendar.MINUTE);int second = curDateTime.get(Calendar.SECOND);LogUtil.i("OrderPollingService---未打印订单的轮训(短)---" + second);if (second < 30) {mSubscriptionOrderPollingShort.unsubscribe();initLongPolling();}}}/*** 长轮训的回调*/public class ObserverLong implements Observer<Long> {@Overridepublic void onCompleted() {}@Overridepublic void onError(Throwable throwable) {}@Overridepublic void onNext(Long aLong) {Calendar curDateTime = Calendar.getInstance();curDateTime.setTimeInMillis(System.currentTimeMillis());int second = curDateTime.get(Calendar.SECOND);LogUtil.i("OrderPollingService---未打印订单的轮训(长)---" + second);if (second >= 30) {mSubscriptionOrderPollingLong.unsubscribe();initShortPolling();}}}
}

Rxjava实现10秒轮训和5秒轮训的交替使用相关推荐

获取某一帧、某一秒、某几秒画面
文章目录前言一.某一帧二.某一秒三.某几秒总结前言有时,我们在看一段视频时,又好看的画面,可以当作桌面背景,或者是喜欢的明星,好看的美女姐姐等,我们都可以通过程序实现截取说明: 1.某 ...
android扫雷计时器,扫雷纪录：高级31秒，中级7秒，初级0.49秒，怎么做到的？
原标题:扫雷纪录:高级31秒,中级7秒,初级0.49秒,怎么做到的? 大家在接触电脑的时候肯定都接触过一款叫做扫雷的游戏,这个小游戏是1981年微软设计师罗伯特·杜尔和卡特·约翰逊两位工程师设计的.很 ...
输入时间的前一秒和后一秒（c语言）
题目: [问题描述] 从键盘输入24小时制的某个时间,计算并输出其前一秒和后一秒的时间. [输入形式] 从键盘输入24小时制的某个时间,格式为:hh:mm:ss. [输出形式] 输出2行,第1行为输入 ...
python 速度 memmap_从20秒到0.5秒：一个使用Rust语言来优化Python性能的案例
<从20秒到0.5秒:一个使用Rust语言来优化Python性能的案例>要点: 本文介绍了从20秒到0.5秒:一个使用Rust语言来优化Python性能的案例,希望对您有用.如果有疑问,可 ...
转从20秒到0.5秒：一个使用Rust语言来优化Python性能的案例
注: 转自微信公众号"高可用架构":从20秒到0.5秒:一个使用Rust语言来优化Python性能的案例导读:Python 被很多互联网系统广泛使用,但在另外一方面,它也存在一 ...
shell高级脚本：“秒”转换为“时-分-秒”；ping
"秒"转换为"时-分-秒" swap_seconds () {SEC=$1(( SEC < 60 )) && echo -e " ...
秒毫秒微秒纳秒皮秒飞秒
millisecond 1ms (毫秒) 1毫秒=0.001秒=10-3秒 microsecond 1μs (微秒) 1微秒= ...
开机启动win7，自动启动突出显示的选择之前的秒数有30秒
遇到问题:重装了系统,win7开机,会"显示自动启动突出显示的选择之前的秒数有30秒":这时候的30秒显得时间太长,一般都不会愿意等. 解决问题:一开始还以为是bios里面修改设置 ...
一秒快速抠图一秒图片高清处理
作为运营人,作为平面设计师.我们离不开与图片设计.图片处理等相关的工作.在运营工作新人中,很多新的运营专员/运营者对Ps并不是特别熟练.我们也知道除外PS还有其它非主流的抠图软件,但是大体都是描绘一个 ...

Rxjava实现10秒轮训和5秒轮训的交替使用

Rxjava实现10秒轮训和5秒轮训的交替使用相关推荐

最新文章

热门文章