转: dubbo服务降级 dubbo服务降级 1. 在 dubbo 管理控制台配置服务降级 上图的配置含义是:consumer 调用 com.zhang.HelloService 的方法时,直接返回 null,不发起远程调用。 实际操作是:在 zk 的 /dubbo/com.zhang.HelloS ...
分类:
其他好文 时间:
2019-07-30 15:45:38
阅读次数:
82
消息无序产生的原因消息队列,既然是队列就能保证消息在进入队列,以及出队列的时候保证消息的有序性,显然这是在消息的生产端(Producer),但是往往在生产环境中有多个消息的消费端(Consumer),尽管消费端在拉取消息时是有序的,但各个消息由于网络等方面原因无法保证在各个消费端中处理时有序。场景分析先后两次修改了商品信息,消息A和消息B先后同步写入MySQL,接着异步写入消息队列中发送消息,此时
分类:
其他好文 时间:
2019-07-30 12:54:41
阅读次数:
93
一、kafka优点 高吞吐量、低延迟:kafka每秒可以处理几十万条消息,它的延迟最低只有几毫秒,每个topic可以分多个partition, consumer group 对partition进行consume操作。 可扩展性:kafka集群支持热扩展 持久性、可靠性:消息被持久化到本地磁盘,并且 ...
分类:
其他好文 时间:
2019-07-28 18:10:01
阅读次数:
100
1.kafka consumer流程1.1.在启动时或者协调节点故障转移时,消费者发送ConsumerMetadataRequest给bootstrap brokers列表中的任意一个brokers。在ConsumerMetadataResponse中,它接收消费者对应的消费组所属的协调节点的位置信 ...
想要获取更多文章可以访问我的博客 "代码无止境" 。 现在大部分的互联网公司都会采用微服务架构,但具体实现微服务架构的方式有所不同,主流上分为两种,一种是基于Http协议的远程调用,另外一种是基于RPC方式的调用。两种方式都有自己的代表框架,前者是著名的Spring Cloud,后者则是有阿里巴巴开 ...
分类:
其他好文 时间:
2019-07-24 10:11:15
阅读次数:
109
RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列,类似于kafka中的partition producer 生产者,先去连接name server,查询到对应的broker信息,再去连接broker consumer 消费者,先去连接na ...
分类:
其他好文 时间:
2019-07-23 11:39:13
阅读次数:
85
rocketmq的主要部分是由4种集群构成的:namesrv集群、broker集群、producer集群和consumer集群。 namesrv集群:也就是注册中心,rocketmq在注册中心这块没有使用第三方的中间件,而是自己写的代码来实现的,代码行数才1000行,producer、broker和 ...
分类:
其他好文 时间:
2019-07-22 15:20:47
阅读次数:
81
provider consumer monitor 常用标签 ...
分类:
其他好文 时间:
2019-07-21 18:13:12
阅读次数:
96
上一篇介绍了Context的使用方法。但是Context会让组件变得不纯粹,因为依赖了全局变量。所以这决定了Context一般不会大规模的使用。所以一般在一个组件中使用一个Context就好。 由于Consumer的特性,里面的代码必须是这个函数的返回值。这样就显得复杂与不优雅了。那该怎么解决呢?这 ...
分类:
其他好文 时间:
2019-07-21 18:06:04
阅读次数:
306
provider consumer 特殊场景 方法级别的设置 点对点链接(直连对应地址) ...