序 本文主要研究一下rocketmq的SequenceProducerImpl SequenceProducerImpl io/openmessaging/rocketmq/producer/SequenceProducerImpl.java {代码...} 采用的是LinkedBlockingQueue，send方法实际调用的是添加到队列 另外提供了commit以及rollback方法，都加了synchronized保证对LinkedBlockingQueue操作的线程安全 com...

alpha-server是servicecomb-saga的分布式事务协调中心，采用spring boot开发，可以直接从jar包启动，需要依赖mysql或pg数据库，同时初始化数据。启动命令如下：

另外调用OMSUtil.msgConvert将api的BytesMessage转换为org.apache.rocketmq.common.message.Message

ServiceLifecycle的startup里头调用DefaultMQProducer的start方法，shutdown里头调用DefaultMQProducer的shutdown方法

openmessaging-java/openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/PullConsumerApp.java

openmessaging-java/openmessaging-api/src/main/java/io/openmessaging/MessagingAccessPoint.java

openmessaging-java/openmessaging-api/src/main/java/io/openmessaging/producer/Producer.java

namespace，类似cgroup的namespace，用来进行安全隔离，每个namespace有自己的producer、consumer、topic、queue等

ZGC全称是Z Garbage Collector，是一款可伸缩(scalable)的低延迟(low latency garbage)、并发(concurrent)垃圾回收器，旨在实现以下几个目标：

spring-cloud-netflix-eureka-client-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/netflix/ribbon/eureka/EurekaRibbonClientConfiguration.java

spring-cloud-netflix-ribbon-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/netflix/ribbon/RibbonClientConfiguration.java

spring-cloud-netflix-ribbon-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/netflix/ribbon/apache/HttpClientRibbonConfiguration.java

spring-cloud-netflix-ribbon-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/netflix/ribbon/support/AbstractLoadBalancingClient.java

spring-cloud-commons-2.0.0.RELEASE-sources.jar!/org/springframework/cloud/client/loadbalancer/AsyncLoadBalancerAutoConfiguration.java

spring-cloud-netflix-ribbon-2.0.0.RC2-sources.jar!/org/springframework/cloud/netflix/ribbon/RibbonAutoConfiguration.java

序 本文主要研究一下resilience4j的fallback 使用实例 {代码...} Try vavr-0.9.2-sources.jar!/io/vavr/control/Try.java {代码...} 这个Try继承了Value接口 另外就是提供了一些静态工厂方法，ofSupplier方法会触发方法的执行，如果成功返回Success，有异常返回Failure Try.Success vavr-0.9.2-sources.jar!/io/vavr/con...

resilience4j-retry-0.13.0-sources.jar!/io/github/resilience4j/retry/Retry.java

resilience4j-bulkhead-0.13.0-sources.jar!/io/github/resilience4j/bulkhead/Bulkhead.java

resilience4j-circuitbreaker-0.13.0-sources.jar!/io/github/resilience4j/circuitbreaker/internal/CircuitBreakerStateMachine.java

resilience4j-circuitbreaker-0.13.0-sources.jar!/io/github/resilience4j/circuitbreaker/CircuitBreaker.java

resilience4j-circuitbreaker-0.13.0-sources.jar!/io/github/resilience4j/circuitbreaker/CircuitBreakerConfig.java

序 本文主要研究下resilience4j的基本功能 maven {代码...} CircuitBreaker {代码...} CircuitBreaker主要是实现针对接口异常的断路统计以及断路处理 Timelimiter {代码...} 主要是实现超时的控制 Bulkhead {代码...} Bulkhead目前来看是用来控制并行(parallel)调用的次数 RateLimiter {代码...} 用来做流控 Fallback {...

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/AbstractCommand.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/AbstractCommand.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/metric/consumer/BucketedCounterStream.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/metric/HystrixEventStream.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/HystrixThreadPoolProperties.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/strategy/executionhook/HystrixCommandExecutionHook.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/strategy/properties/HystrixPropertiesStrategy.java

hystrix-core-1.5.12-sources.jar!/com/netflix/hystrix/strategy/metrics/HystrixMetricsPublisher.java