个人随笔
当前位置： 首页 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/214>尾页
有疑问发邮件到 : suibibk@qq.com 侵权立删
Copyright : 个人随笔   备案号 : 粤ICP备18099399号-2