Hystrix 停止开发。。。Spring Cloud 何去何从？
!(https://oscimg.oschina.net/oscnet/8f265631921542e3b74f72b2759d88a5.png)栈长得到消息，Hystrix停止开发了。。。大家如果有对Hystrix不清楚的，请看下这篇文章：分布式服务防雪崩熔断器，Hystrix理论实战(https://www.oschina
Flink读取Kafka数据，进行汇总
今天介绍用Flink读取Kafka生成的数据，并进行汇总的案例第一步：环境准备，kafka，flink，zookeeper。我这边是用的CDH环境，kafka跟zookeeper都安装完毕，并测试可以正常使用第二步：用kafka创建一个生产者进行消息生产./kafkaconsoleproducer.shbroker
Spring Cloud套件
SpringCloud提供的服务 配置管理服务注册服务发现断路器负载均衡智能路由服务间调用一次性令牌微代理思维导图模板全局锁控制总线分布式式会话集群状态领导选举分布式消息 子项目功能说明SpringCloudConfig配置中心，利用git来集
Javascript并发模型和事件循环
JavaScript的"并发模型"是基于事件循环的，这个并发模型有别于Java的多线程，javascript的并发是单线程的。Javascript中有个重要一块，EventLoop，能把单线程的JavaScript使出多线程的感觉。"EventLoop是一个程序结构，用于等待和发送消息和事件。（aprogrammingconst
RabbitMQ基本示例，轮询机制，no_ack作用
一、RabbitMQ简介：'''RabbitMQ就是消息队列之前不是学了Queue了吗，都是队列还学RabbitMQ干嘛？干的事情是一样的Python的Queue有两个，一个线程Queue生产者消费者模型，一个进程Queue用于父进程与子进程交互两个完全独
Git 原生钩子的深度优化
前言Git是最流行的版本控制工具，和大多数版本控制工具一样，Git也拥有钩子特性，用户可以利用钩子实现一些附加功能，在《ProGitv2》中，对钩子类型，消息格式等有详细介绍：8.3CustomizingGitGitHooks(https://www.oschina.net/action/GoToLink?urlht
Android的Binder机制浅析
1\.引言 一般实际的软件系统中进程间通信（IPC）的实现方法有命名管道（namedpipe），共享内存(sharedmemory)，消息队列（messagequeue），Socket等方法。在Android的框架（Framework）中，以Binder作为框架内进程间（通常如服务和客户间）通信的主要实现手段。这可能是出于效
Python celery简介
Celery异步分布式什么是celery？他是一个python开发的异步分布式任务调度模块celery本身不提供消息服务，使用第三方服务，也就是broker来传递任务，目前支持rabbitmq，redis，数据库等等。我们使用redis连接URL的格式为：redis://:password@hostname:port/
Kafka中所谓的分区器，到底是什么？
消息在通过send()方法发往broker的过程中，有可能需要经过拦截（Interceptor）、序列化器（Serializer）(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fmp.weixin.qq.com%2Fs%3F__biz%3DMzU3OTc1MDM1Mg%3D%3D
RocketMQ一个新的消费组初次启动时从何处开始消费呢？
1、抛出问题一个新的消费组订阅一个已存在的Topic主题时，消费组是从该Topic的哪条消息开始消费呢？首先翻阅DefaultMQPushConsumer的API时，setConsumeFromWhere(ConsumeFromWhereconsumeFromWhere)API映入眼帘，从字面意思来看是设置消费者从哪里开始消费，正是解