Java响应式编程之handle怎么使用

这篇文章主要介绍“Java响应式编程之handle怎么使用”，在日常操作中，相信很多人在Java响应式编程之handle怎么使用问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Java响应式编程之handle怎么使用”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

Java handle用法

JAVA响应式编程Reactor中如果需要对一个flux中的数据进行提前返回 可以使用handle

具体如下：

@GetMapping("/a")    public Mono<Object> a() throws InterruptedException {        long begin = System.currentTimeMillis();        Mono<String> m5 = Mono.just("").map(s -> {            try {                TimeUnit.SECONDS.sleep(5);                System.out.println("5");                System.out.println(System.currentTimeMillis() - begin);            } catch (InterruptedException e) {                e.printStackTrace();            }            return "5";        }).subscribeOn(Schedulers.boundedElastic());        Mono<String> m8 = Mono.just("").map(s -> {            try {                TimeUnit.SECONDS.sleep(8);                System.out.println("8");                System.out.println(System.currentTimeMillis() - begin);            } catch (InterruptedException e) {                e.printStackTrace();            }            return "8";        }).subscribeOn(Schedulers.boundedElastic());        Mono<String> m10 = Mono.just("").map(s -> {            try {                TimeUnit.SECONDS.sleep(15);                System.out.println("15");                System.out.println(System.currentTimeMillis() - begin);            } catch (Exception e) {                e.printStackTrace();            }            return "15";        }).subscribeOn(Schedulers.boundedElastic());                Mono<Object> single = Flux.merge(m8, m5, m10).handle(((s, synchronousSink) -> {            if ("8".equals(s)) {                synchronousSink.next("卢本伟牛");                synchronousSink.complete();            }        })).defaultIfEmpty("null").single();        return single;    }

subscribeOn(Schedulers.boundedElastic())是让这些mono进行异步处理

上述定义了3个Mono进行请求 使用Sleep进行模拟请求中业务处理耗时

m5是需要执行3s m8是需要执行8s m10是需要执行15s

如果我们有多个耗时处理的请求 需要同时请求 然后又需要合并结果 并且返回我们需要的结果 进行提前返回。

例如：我需要同时请求这些接口 当8这个接口有结果返回的时候 由于其他请求时间太长了 需要提前返回一个值 放弃其他结果处理 所以我们可以进行判断.

//这个s代表前面传入的元素 执行完会传入这个handle  // synchronousSink.next() 代表我执行完这个流返回给下一个进行处理  next(Object)  // synchronousSink.complete(); 代表我们执行完取消其他的流Flux.merge(m8, m5, m10).handle(((s, synchronousSink) -> {            if ("8".equals(s)) {                synchronousSink.next("卢本伟牛");                synchronousSink.complete();            }        })).subscribe(s -> {                    System.err.println(s);                });

由于上面当s为8的时候 将卢本伟牛传入下一个流 然后执行完成 所以还有个m10不会执行完 就会直接丢弃

我们进行测试

发现控制台打印

我们如果使用传统的mvc执行m5我们会耗时5s m8会耗时8s 加起来就是13s

我们使用响应式编程则只会耗时8s 当如果多个耗时操作拼接在一起 我们需要多个返回结果的时候我们可以使用handle进行提前返回

返回结果为卢本伟牛 也就是我们之前当s为8时执行的 ，synchronousSink.next(“卢本伟牛”);，将这个字符串传给最终结果的流，当然我们也可以根据自己的逻辑 发放多个synchronousSink.next。

handle的标准使用方式

在Java语言中，直接将handle声明为Activity的内部类去使用handle，非静态内部类会持有外部类的一个隐试引用，这样就可能造成外部类无法被垃圾回收，从而导致内存泄漏。

故而，给出规范的handle使用方式如下：

handle的基类

public class UIHandler<T> extends Handler{      protected WeakReference<T> ref;      public UIHandler(T cla){        ref = new WeakReference<T>(cla);     }       public T getRef(){          return ref != null ? ref.get() : null;      }}

handle运用实例

public class MainActivity extends Activity｛     private final MainHandler mHandler = new MainHandler(this);     @Override    protected void onCreate(Bundle savedInstanceState){        super.oncreate(savedInstanceState);        setContentView(R.layout.activity_main);        mHandler.post(mRunnable);    }     private static final Runnable mRunnable = new Runnable(){         @Override         public void run(){          }    };     private class MainHandler extends UIHandler{         private MainHandler(MainActivity activity){             super(activity);         }                  @Override         public void handleMessage(Message msg){             super.handleMessage(msg);             MainActivity activity = (MainActivity)ref.get();             if(activity != null){                if (activity.isFinishing()                    return;　　　　　　　　　　switch(msg.what){　　　　　　　　　　　　case 1:　　　　　　　　　　　　break;　　　　　　　　　　}             }         }    }｝

到此，关于“Java响应式编程之handle怎么使用”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注编程网网站，小编会继续努力为大家带来更多实用的文章！