上篇回顾本文是《docker-compose下的java应用启动顺序两部曲》的终篇，在上一篇《docker-compose下的java应用启动顺序两部曲之一：问题分析》中，我们以SpringCloud环境下的注册中心和业务服务为例，展示了docker-compose.yml中depends_on参数的不足：即只能控制容器创建顺序，但我们想要的是eureka服务就绪之后再启动业务服务，并且docker官方也认为depends_on参数是达不到这个要求的，如下图所示： 针对上述问题，docker给出的解...
我继续玩Reactor,现在我看到compose运算符的行为与flatMap完全一样,我想知道是否有任何我不理解的差异.@Test public void compose() throws InterruptedException {Scheduler mainThread = Schedulers.single();Flux.just(("old element")).compose(element ->Flux.just("new element in new thread").subscribeOn(mainThread).doOnNext(value -> System.out.println("Thread:" + Thread.currentThread().getName()))).doOnNext(va...
原文链接：http://blog.danlew.net/2015/03/02/dont-break-the-chain/ 在RxJava中一种比较nice的思想是能够通过一系列的操作符看到数据是如何转换的： Observable.from(someSource) .map(data -> manipulate(data)).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(data -> doSomething(data));1 2 3 4 5假设想要给多个流重复利用一系列操作符该怎么办呢？比如，我想在工作线程中处理数据，在...
Rx通过链接它们而不是嵌套它们，具有应用运算符的特定样式。此样式并不罕见，这对于不可变对象更有意义，甚至可以在标准Java特性中找到它，例如字符串：String s = new String(“Hi”).toLowerCase().replace（a，c）;此样式允许您按照应用顺序查看修改，并且在使用大量运算符时它也看起来更整洁。 理想情况下，您希望您的Rx运算符与其他运算符一样适合链：许多语言都有支持这种方法的方法。不方便的是，Java没有。您必须编辑Obser...
一张图片告诉你他们的区别是什么!注:该图片来自于java In action
最近在整理docker-compose内存的问题，写了一个模板，供大家参考。 version: 2.3services: test: #服务名称 container_name: zidingyi#容器名称 image: centos:latest volumes: - "./ceshi:/ceshi" environment: #环境变量 aa: 1 bb: 2 network_mode: "host" #网络类型 cpus: 0.5 #单核的50％ CPU数量（默认0.000） cpu_shares: 73 #CPU份额 #cpu_quota: 50000 #限制CPU CFS（完全公平...