个人随笔
网站介绍
火龙的爷爷
2116759078@qq.com
一个程序员的学习笔记
网站统计
访问 1065296
趣玩记单词(广告)
网站标签
当前位置:
首页
RocketMQ
四、微服务消息队列异步解耦设计思路
背景用户调用某一个微服务,然后微服务登记消息给消费程序处理,此时我们的微服务接口只能够返回调用微服务成功,但是具体业务逻辑有没有执行成功又是还未确定的,此时怎么操作呢?思路这种需要等消费程序处理完才知道结果的业务逻辑,我们可以约定好,调用微服务的时候传入一个唯一的流水号参数,然后消费程序在消费完后就以该流水号为key将处理结果放入redis中(没有reids的话,可以放入一个表中),设置过期...
RocketMQ
2021-03-03 18:43:53
三、ConsumeFromWhere
消费者从那个位置消费,分别为:1 CONSUME_FROM_LAST_OFFSET:第一次启动从队列最后位置消费,后续再启动接着上次消费的进度开始消费2 CONSUME_FROM_FIRST_OFFSET:第一次启动从队列初始位置消费,后续再启动接着上次消费的进度开始消费3 CONSUME_FROM_TIMESTAMP:第一次启动从指定时间点位置消费,后续再启动接着上次消费的进度开始消费以上...
RocketMQ
2021-03-02 18:09:27
二、为何设置RocketMQ消费的最大线程数无效,线程池最大只能达到consumeThreadMin?
consumeThreadMin和consumeThreadMax控制消费者并发的线程数,注意:由于消费者线程池使用的是无界队列,因此消费者消费线程数最多只有consumeThreadMin个(线程池的最大线程数只有在线程池使用队列是有界队列,并且有界队列已满,并且核心线程都在运行时,线程池才会创建新的线程,直到数量等于最大线程数)
RocketMQ
2021-03-02 17:58:29
一、简单理解RocketMQ集群消费,广播消费,分组消费的使用场景
下面的三种模式都是在消费同一个topic的前提下才会有效的。集群消费集群消费模式下,相同 Consumer Group的每个Consumer实例负载均衡的接受消息,于nginx的负载均衡,一条消息只会在一个consumer消费。正常我们用的都是这种模式,如果业务量庞大,那么就可以多启动几个消费程序即可。广播消费广播消费模式下,相同 Consumer Group 的每个 Consumer 实例...
RocketMQ
2020-12-24 10:35:47
不同的消费组消费同一个Topic,可以同时收到消息
位于不同consumerGroup组的 consumer端,可以同时消费相同topic的消息。若是消费组相同,则相当于负载,每条消息只能一个consumer端消费!
RocketMQ
2020-09-28 10:26:18
(转)RocketMQ架构原理
RocketMQ是阿里开源的分布式消息中间件,跟其它中间件相比,RocketMQ的特点是纯JAVA实现;集群和HA实现相对简单;在发生宕机和其它故障时消息丢失率更低。一、RocketMQ专业术语先讲专业术语的含义,后面会画流程图来更好的去理解它们。Producer消息生产者,位于用户的进程内,Producer通过NameServer获取所有Broker的路由信息,根据负载均衡策略选择将消息发...
RocketMQ
2020-07-07 20:41:22
关于Druid重试机制的问题及解决方案
使用了Druid作为数据库连接池,当数据源链接失败时,报出了以下错误:019-04-09 10:09:36 [Druid-ConnectionPool-Create-2053591126] [ com.alibaba.druid.pool.DruidDataSource ] [ 53 ] [ ERROR ] create connection SQLException, url: jdbc:...
RocketMQ
2020-06-12 22:40:39
消息中间件选型分析
1概述1.1 基于MQ应用的技术分析随着企业信息化建设的不断深入。多种业务应用相互关联,容易造成底层数据分散,应用系统间的耦合度高。针对该问题应从总体上调整眼下系统架构。面向不同业务应用提供统一的数据访问服务,使用消息中间件对不同系统间的交互进行解耦.消息中间件技术有两个核心功能:异步和解耦。这两个核心功能总体上提高了应用系统的工作效率,增强了系统的可用性、稳定性和可扩展性。提升了用户体验。...
RocketMQ
2020-03-21 23:28:57
五、基于RocketMQ的分布式事务解决方案(转)
前言在系统变的复杂后,分布式、微服务等架构技术,就要考虑到应用在系统中了。尤其数据量大了后,就需要对数据库进行拆分。如:注册的用户数据,量大了后,就需要考虑分库分表一旦数据库进行了分拆,那就出现很多头疼的问题,其中之一就是事务问题。那我们就来看看问题是怎么出现的?场景先来上个图进行数据拆分后,就类似上面的架构上图中我们就拿用户的数据进行举例,用户量一旦几千万时,就需要进行分库分表;上图就分了...
RocketMQ
2020-03-03 23:08:42
四、RocketMQ入门(RocketMQ 存储文件)
一、RocketMQ存储概要设计RMQ主要存储的文件包括commitlog文件、consumeQueue文件、IndexFile文件。CommitLog是消息存储文件,所有消息主题的消息都存储在CommitLog文件中;ConsumeQueue是消息消费队列文件,消息达到commitlog文件后将被异步转发到消息消费队列,供消息消费者消费;IndexFile是消息索引文件,主要存储的是key...
RocketMQ
2020-02-14 23:46:55
首页
<
1/2
14
>
尾页
有疑问发邮件到 : suibibk@qq.com 侵权立删
Copyright : 个人随笔
备案号 : 粤ICP备18099399号-2