SRS(SimpleRTMPServer) 是国人写的一款非常优秀的开源流媒体服务器软件，可用于直播/录播/视频客服等多种场景，其定位是运营级的互联网直播服务器集群。一、安装官网提供了3种安装方式：从源码编译安装、利用docker（学习用)、直接下载安装包安装相信很多人主要目的是出于学习srs如何使用，对c+...

接上篇继续学习各种方法：4.9、reduce/reduceWith@TestpublicvoidreduceTest(){Flux.range(1,10).reduce((x,y)->x+y).subscribe(System.out::println);Flux.range(1,10).reduceWith((...

Reactor3与之前学习的RxJava是同一类(反应式编程)框架，基本概念大致差不多，简单记录一下：Reactor3利用了java8中的CompletableFuture、Stream、Duration，在此基础上发展出了二个更通用的模型：Flux及Mono.一、FluxFlux简单点讲，就是一个可以发射1到N个元素...

接上回继续，今天来学习下zip（打包)操作一、zip操作@TestpublicvoidzipTest(){Observable.zip(Observable.create(emitter->{for(inti=0;i<10;i++){emitter.onNext(100+i);}}),Observable....

上一篇已经熟悉了Observable的基本用法，但是如果仅仅只是“生产-消费”的模型，这就体现不出优势了，java有100种办法可以玩这个：）一、更简单的多线程正常情况下，生产者与消费者都在同一个线程里处理，参考下面的代码：finallongstart=System.currentTimeMil...

作为github上star数极高的响应式编程java扩展类库，rxjava是啥就不多说了，网上能查到一堆介绍，下面是一些学习记录：前提依赖：compile'io.reactivex.rxjava2:rxjava:2.1.9'一、Observable1.1helloworldrxjava中的核心思路是“生产者...

前几天遇到一个需求，因为要兼容旧项目的编码格式，需要spring-cloud的rest接口，输出gb2312编码，本以为是一个很容易的事情，比如下面这样：@RequestMapping(method=RequestMethod.POST,value="syncPaymentList",consumes={"applic...

对绝大多数程序员而言，写接口文档是一件痛苦的事情，相对文档，他们更愿意写代码。最理想的情况就是：代码即文档！服务开发完成后，部署上去文档就自动生成，没错，这就是springfox+swagger要解决的问题！swagger号称THEWORLD'SMOSTPOPULARAPITOOLING。但swagger默认情况下，仍...

turbine是啥就不多解释了，初次接触的可以移步springcloud学习(4)-hystrix服务熔断处理拉到最后看一下，turbinestream默认情况下启动成功后，eureka的注册列表里，看不到该服务。这其实是turbine的一个bug，详情见：https://github.com/spring-clou...

业务复杂的微服务架构中，往往服务之间的调用关系比较难梳理，一次http请求中，可能涉及到多个服务的调用(eg:serviceA->serviceB->serviceC...)，如果想分析各服务间的调用关系，以及各服务的响应耗时，找出有性能瓶颈的服务，这时zipkin就派上用场，它是Twitter公司开源的一...

业务繁忙的系统，原则上是不允许停机的，那么问题来了，如果真有严重的bug要修复，不得不发布，怎么做到不停机发布，对业务无感知呢？eureka提供了一系列resturl，可以对注册实例进行操作，比如：将服务离线/上线，注册/注销，动态修改meta元数据等，详情见本文最后的参考wiki。 不停机发布的思路：通常s...

微服务架构体系中，通常一个业务系统会有很多的微服务，比如：OrderService、ProductService、UserService...，为了让调用更简单，一般会在这些服务前端再封装一层，类似下面这样：前面这一层俗称为“网关层”，其存在意义在于，将"1对N"问题转换成了"1对1&rdquo...

 分布式环境下的统一配置框架，已经有不少了，比如百度的disconf，阿里的diamand。今天来看下springcloud对应的解决方案：如上图，从架构上就可以看出与disconf之类的有很大不同，主要区别在于：配置的存储方式不同disconf是把配置信息保存在mysql、zookeeper中，而sprin...

hystrix是一个专用于服务熔断处理的开源项目，当依赖的服务方出现故障不可用时，hystrix有一个所谓的断路器，一但打开，就会直接拦截掉对故障服务的调用，从而防止故障进一步扩大（类似中电路中的跳闸，保护家用电器）。使用步骤：（仍然在之前的示例代码上加以改造）一、添加hystrix依赖compile'org.spri...

feign 是一个让rest服务调用更简洁的开源项目，很多介绍文章或书也称它为声明式REST调用。传统的webservice中，通过引用wsdl来自动生成一些client的代理类（或stub代码），feign跟这个有点类似，但是更灵活。先回顾一下，上节中service-consumer对服务的调用代码：1@G...