其他火箭MQ
消息轨迹
暂略
配置
TradeTopicenable = True Brookker Ender 开放配置
虽然RocketMQ组群中的每一个Broker节点都用来储存从Clitend端收集和传送的信息轨迹数据,但对于RocketMQ组群中的Broker节点数目没有要求或限制。
对于信息轨迹数据较大的情况,可以指定火箭MQ集群中一个Broker节点作为存储信息线索的服务端,使用户的典型信息数据与电文轨迹数据的实际IMO完全分离,而不会相互不利。 根据这一模式,在RockeMQ集群中至少有两个Broker节点,其中一个被指定为存储信息轨迹数据的服务端。
保护电文跟踪的专题定义
RocketMQ的电文轨迹属性提供了两种存储跟踪数据的方法:
全系统一级的贸易旅游点
默认情况下,信件轨迹数据会保存在系统级 TraceTopic中(标题: RMZZESYS_TRACE_TOPIC**,** 排队到 1) 。 当布洛克节点启动时, 此主题会自动确定( 如上所解释的, 在布洛克端配置文件中的 tradeTospicable 开关变量必须设置为 True ) 。
贸易旅游
如果用户不想在系统级默认 TraceTopic中保存信息轨迹数据,他或她可以指定和建立一个用户级 TraceTopic以保存音轨(即构建一个标准主题)
处理 Clit 客户端时, 需要定制单词才能自定义 TraceTopic 。 例如, 请参见一些情况, 通常建议使用此系统和 TraceTopic 。
案例
RocketMQ 在原始协议中添加了自定义选项( AllowMsgTrace), 以便在信息被清除供消耗时能够打开电文轨迹 。
用户可以将信息轨迹数据保存到他们自己构建的用户“专题”的水平。
在您从描述轨迹的主题获取信息之前, 您必须先建立主题。 主题不是由 RocketMQ 自动生成的 。
关键属性
源码解读
AsyncTrace Dispatcher是代码实现的基本层次。
SendMessageHook
ConsumeMessageHook
通过实施上述两个接口,可以在信息传输之前、之后和之后记录信息轨迹,最好以不对称的方式记录信息,以避免大大增加信息发送与信息消耗之间的时间间隔。
核心步骤如下：
2:通过收集信息线索
2: 检索已保存信件音轨的主题
3: 贸易文本已编码;这是信息轨迹传输数据。
4: 将编码数据发送到 Broker 服务器 。
权限控制
RocketMQ4.4.Four.ACL特权管制已经实施,用于在RocketMQ4.Four.ACL.中进行0版升级。 ACL是出入控制清单的缩略语,通常称为ACL。 出入控制包括用户、资源、特权、作用等概念。
用户的想法,即支持用户名和密码的能力。
资源:需要保护的专题、专题信息以及参与信息消费的消费者群体都应得到保障,以便作为抽象的资源加以利用。
权限: 运行中, 特定资源 。 作用 : 在 RocketMQ 中只指定了两个角色 : 是否是管理员 。
配置
Plain_acl.yml 是 ACL 的默认配置名称, 必须在 $ROCKETM {HOME/store/ config 目录中使用 。
yml 配置是默认执行 RocketMQ 的许可控制存储。 用户可以在不重新启动 Broker 服务节点的情况下动态编辑权限控制定义的特性, 因为 Broker 结尾包含一个文件监听机制, 监听、 处理和装入文件每500分钟更改一次 。
如果 ACL 与高可用性部署( Master/ Slave 架构)同时激活,则 yml 配置文件将保存在 $ROCKEM HOME/store/ conf/plan_ acl. 设置中 。
在 Yml 配置文件的全球白色列表中,将奴隶节点的 IP 地址指定给 Master 节点 plain_acl 的信息。
我不知道你在说什么。在 yml 文件中重要参数的含义和应用
DENY 拒绝
任何公众或公众 或公众 或公众 或公众 或 公众 或 公众 或 公众 或 公众 或 公众 或 公众 或
PUB 发送权限
SUB 订阅权限
案例
配置 aclenable = true 在 Broker 的配置文件中 。
必须在代码中添加返回 RPCook 的方法 。
常见问题
MQ 中百万封信件的积压
互联网失败了, 数千万的数据在MQ中收集了很长一段时间。这是关于恢复消费者的活力,让他重新消费, 并等待几个小时的完成。这就是答案。尽管如此, 我们有一些短暂的紧急事件。
超过100万, 所以,如果有一百万到数千万的数据, 即使客户恢复了, 它需要大约一个小时。
如果新闻不重要, 通常会直接向消费者发布。 如果一个主题的信息 队列组( 20 套) 更大, 比如 20 套, 只消耗 4 个示例, 那么每个例子都相当于 5 分钟 队列, 此时您可以请求临时添加, 增加 20 种, 快速消费 。
例如,如果信息队列设定为小于4, 此时无法通过添加消费机器来固定, 现在是更新消费代码的时候了, 不是消费者消费, 而是将消费信息放在一个 mq 主题中, 该主题设定了 20 个信息队列, 相当于 20 个消费实例, 并消耗它 。
消费幂等
消息重复的场景
生产者
从再测试机制中产生的查询成功发送到M,然而,由于网络问题,M无法成功返回,导致再将再测试机制发送到M。
我在卡夫卡遇到的这个客户使用了卡夫卡-服务器2. Four.1,但我们使用了卡夫卡-客户1. One.Verion 0,导致客户再次尝试用不同数量的重复信息。
消费端
另一个组织者(_A)
系统在消费者成功地饮用新闻后重新启动了系统,但没有归还消费委员会。
MQ将信息再传送给同一信息组中的其他消费计算机,造成信息重复。
什么是幂等性？
例如,在电文接收端发生时,这意味着使用与SQL程序相同的输入多次呼叫处理功能来实现相同的输出。
update stat_table set count= 10 where id =1
此程序已经多次执行。 此程序正在等待, 我们不必担心重复它, 因为 id- equal 1 记录中的计数字段数是 10 。
考虑另一个 SQL 操作 。
update stat_table set count= count +1 where id= 1;
这种SQL程序不是临时性的,如果重复,结果就会改变。
MVCC
乐观锁的优点之一是,当生产者发送信息时,数据以数据版本号更新,消费者必须比较更新时所储存数据的版本号,不一致的版本号动作失败。
public boolean addCount(Long id, Long version);
update blogTable set count= count+1,version=version+1 where id=321 and version=123
每个版本只有成功实施的机会,如果失败,生产者必须重新获取的数据的最新版本数量必须再次改变。
去重表
利用数据库窗体属性实现,例如,一个典型的概念是在表格上创建一个独特的索引(还使用 Redis 缓存键),以确保一旦某类数据被执行,同一请求将不再重复(使用日志表记录已处理成功信件的代号,如果新到达的代号已经放在日志表格中,则该电文将不再被处理)。
使用 RocketMQ 键值 。
例如,电平台上的订单代号是最好的象征。 当用户点订单时,他们会遇到多个链接,如订单的生成、库存的减少、优惠券的减少等。 在执行的每个阶段,订单代号都经过测试,该步骤是否已经执行,如果是未执行的请求,操作已经执行,结果被缓存,而如果是已执行的代号,则直接返回执行前的结果,而没有采取任何行动。 这将尽可能避免操作的重复,执行的校准结果也可以用于控制此事等。