码迷,mamicode.com
首页 >  
搜索关键字:消费者    ( 4818个结果
中通消息平台 Kafka 顺序消费线程模型的实践与优化
各类消息中间件对顺序消息实现的做法是将具有顺序性的一类消息发往相同的主题分区中,只需要将这类消息设置相同的 Key 即可,而 Kafka 会在任意时刻保证一个消费组同时只能有一个消费者监听消费,因此可在消费时按分区进行顺序消费,保证每个分区的消息具备局部顺序性。由于需要确保分区消息的顺序性,并不能并 ...
分类:编程语言   时间:2020-12-15 12:04:52    阅读次数:6
Dubbo服务治理之灰度发布方案(版本发布控制影响范围)
微信公众号:[中间件兴趣圈]作者简介:《RocketMQ技术内幕》作者方案背景背景:基于Dubbo服务的治理,是否可以支持业务级别的灰度发布、是否基于业务参数的路由转发。例如以GIS为例,当发布一个新版本时,是否可以以按照解析地址或合作伙伴来区分,版本发布之初,只希望地址为:广东省的解析请求发送到新版本,而其他的地址请求还是使用旧版;或者根据合作伙伴例如UCP(优享寄)的请求转发到新版本服务器,其
分类:其他好文   时间:2020-12-08 12:47:20    阅读次数:5
RocketMQ生产环境主题扩分片后遇到的坑
消息组接到某项目组反馈,topic在扩容后出现部分队列无法被消费者,导致消息积压,影响线上业务?考虑到该问题是发送在真实的线上环境,为了避免泄密,本文先在的虚拟机中来重现问题。1、案情回顾1.1集群现状集群信息如下:例如业务主体名topic_dw_test_by_order_01的路由信息如图所示:当前的消费者信息:broker的配置信息如下:brokerClusterName=DefaultCl
分类:其他好文   时间:2020-12-07 12:44:57    阅读次数:13
RocketMQ主从集群模式搭建
主从模式环境可以保障消息的即时性与可靠性投递一条消息后,关闭主节点从节点继续可以提供消费者数据进行消费,但是不能接收消息主节点上线后进行消费进度offset同步准备两台机器,一主一从:机器IPhostname角色192.168.243.169rocketmq01master192.168.243.170rocketmq02slave我这里事先在两台机器上安装好了RocketMQ,关于RocketM
分类:其他好文   时间:2020-12-05 10:54:50    阅读次数:10
Kafka作为分布式消息系统的系统解析
Apache Kafka由Scala和Java编写,基于生产者和消费者模型作为开源的分布式发布订阅消息系统。它提供了类似于JMS的特性,但设计上又有很大区别,它不是JMS规范的实现,如Kafka允许多个消费者主动拉取数据,而在JMS中只有点对点模式消费者才会主动拉取数据 ...
分类:其他好文   时间:2020-12-04 11:04:22    阅读次数:7
消费者如何不自动提交偏移量,由应用提交?
将 auto.commit.offset 设为 false,然后在处理一批消息后 commitSync() 或者 异步提交 commitAsync() 即: ConsumerRecords<> records = consumer.poll(); for (ConsumerRecord<> reco ...
分类:其他好文   时间:2020-12-03 12:16:37    阅读次数:6
dubbo消费端源码分析
? 这篇文章主要是讲述dubbo的消费者初始化发生的事情,比如:怎么注入和注入什么对象到带有@DubboReference和@Reference注解的成员变量里,怎么去建立dubbo的连接,怎么获取注册中心里提供者的地址等等 消费端的入口-DubboAutoConfiguration ? 因为根据s ...
分类:其他好文   时间:2020-11-27 11:13:36    阅读次数:7
AIOps在美团的探索与实践——故障发现篇
AIOps在美团的探索与实践——故障发现篇以下文章来源于美团技术团队,作者胡原锦冬俊峰等美团技术团队美团技术团队10000+工程师,如何支撑中国领先的生活服务电子商务平台?4.6亿消费者、630万商户、2000多个行业、几千亿交易额背后是哪些技术?这里是美团、大众点评、美团外卖、美团配送、美团优选等技术团队的对外窗口。undefinedAIOps,最初的定义是AlgorithmITOperatio
分类:其他好文   时间:2020-11-12 14:27:43    阅读次数:17
rabbitMQ系列1:深入理解AMQP协议
一、AMQP协议简介: AMQP(高级消息队列协议)是一个进程间传递异步消息的网络协议。 二、AMQP工作流程: 1、发布者发布消息,经由交换机。交换机根据路由规则将收到的消息分发给与该交换机绑定的队列。最后 AMQP 代理会将消息投递给订阅了此队列的消费者,或者消费者按照需求自行获取。 2、发布者 ...
分类:其他好文   时间:2020-11-11 15:44:16    阅读次数:5
为了戒网,我给每个网站自动添加3-25秒的访问延迟
为了戒网,我给每个网站自动添加3-25秒的访问延迟在软件行业中存在着很多惊人的事实,消费者网络中的收入以及潜在的收入来源(无论是访问量还是销售量),都紧密地跟访问延迟相关。这是基于避免用户跳出以及提高转化率等方面考虑。相关数据:亚马逊发现每100ms延迟损失1%销售额(链接1)了解如何为移动页面访问速度创建访问基准(链接2)加载时间如何影响你的底线(链接3)但是,如果在减少延迟时能从客户身上赚到更
分类:Web程序   时间:2020-11-08 16:33:15    阅读次数:31
4818条   上一页 1 ... 6 7 8 9 10 ... 482 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!