ICode9

精准搜索请尝试: 精确搜索
  • RabbitMQ部署指南2022-09-15 10:00:42

    RabbitMQ部署指南       1.单机部署 我们在Centos7虚拟机中使用Docker来安装。 1.1.下载镜像 方式一:在线拉取 docker pull rabbitmq:3.8-management 方式二:从本地加载 在课前资料已经提供了镜像包:   上传到虚拟机中后,使用命令加载镜像即可: docker load -i mq.tar 1.2.安

  • 数据转换处理,拼接2022-09-08 23:04:16

    1、8位,16位,32位数据转换 8位转16位 将2个8位数据high、low合成一个16位数据data_u16: data_u16 = (high<<8) | low;   16位转8位 将一个16位数据data_u16拆分成2个8位数据high、low: high = (data_u16 >> 8) & 0xff; //高8位 low = data_u16 & 0xff; //低8位 8位转32位将4个

  • 消息中间件2022-09-07 14:30:22

    用途 异步处理 比如某个调用链的业务逻辑可以分为关键和非关键, 那么关键步骤执行完就能立即返回响应, 非关键步骤可以放入MQ异步地消费 在业务高峰期, 可以用k8s动态增加关键服务的节点, 用MQ将非关键操作暂存 在业务低谷期, 再动态减少关键服务的节点, 消费掉非关键服务

  • 可靠消息最终一致性2022-09-06 01:02:56

      先上图:   1. 首先会发送事务消息给MQ Server 2. MQ 会回复一个发送成功的消息,此时MQ Server并不能投递消息,因此还没有收到发送的确认 3. MQ发起方会执行本地事务。 4. 执行完以后就发送commit 或者Rollback 如果是commit的话就开始投递消息; 如果是Rollback,MQ Server 就会删除

  • MQ系列5:RocketMQ消息的发送模式2022-09-01 15:03:08

    MQ系列1:消息中间件执行原理 MQ系列2:消息中间件的技术选型 MQ系列3:RocketMQ 架构分析 MQ系列4:NameServer 原理解析 在之前的篇章中,我们学习了RocketMQ的原理,以及RocketMQ中 命名服务 ServiceName 的运行流程,本篇从消息的生产、消费来理解一条消息的生命周期。 1 消息生产 在RocketM

  • 如何解决消息队列的延时以及过期失效问题?2022-08-29 00:30:08

    如何解决消息队列的延时以及过期失效问题?消息队列满了以后该怎么处理?有几百万消息持续积压几小时,说说怎么解决? 面试官心理分析 你看这问法,其实本质针对的场景,都是说,可能你的消费端出了问题,不消费了;或者消费的速度极其慢。接着就坑爹了,可能你的消息队列集群的磁盘都快写满了,

  • MQ的消息丢失/重复/积压的问题解决2022-08-28 00:02:16

    在我们实际的开发过程中,我们肯定会用到MQ中间件,常见的MQ中间件有kafka,RabbitMQ,RocketMQ。在使用的过程中,我们必须要考虑这样一个问题,在使用MQ的时候,我们怎么确保消息100%不丢失? 案例背景 以我们熟悉的淘宝系统为例子,在用户下订单的时候,通常会给客户发放一下优惠劵。在整个过程中

  • MQ (一)2022-08-27 11:32:24

    目录MQ 主要应用场景 MQ 主要应用场景 应用解耦(异步) 系统的耦合性越高,容错性就越低。以电商应用为例,用户创建订单后,如果耦合调用库存系统、物流系统、支付系统,任何一个子系统出现故障或者因为升级等原因暂时不可用,都会造成下单操作异常,影响用户使用体验 使用消息队列解耦

  • MQ系列3:RocketMQ 架构分析2022-08-26 01:03:56

    MQ系列1:消息中间件执行原理MQ系列2:消息中间件的技术选型 1 背景 我们前面两篇对主流消息队列的基本构成和技术选型做了详细的分析。从本篇开始,我们会专注当下主流MQ之一的RocketMQ。从他的如下的几个方面去讨论: 基础能力(如 组织构成、消息发送、消息存储(持久化)、消息通信、消息

  • RabbitMQ 入门系列:1、MQ的应用场景的选择与Rabbit安装2022-08-19 16:00:22

    1、MQ的应用场景的选择: 可以参考网上的对比图:   遥想当年,MQ都是MSMQ(微软)的,现在,都不在参考图上了。 对MQ的使用,根据应用场景,选择适合的MQ即可,本系列仅介绍RabbitMQ。 2、下载地址: RabbitMQ 官网下载:https://www.rabbitmq.com/download.html 按提示,下载最新版本安装即可。 因为Rab

  • redis实现消息队列的几种方式及其优劣2022-08-17 18:32:54

    redis实现消息队列的几种方式及其优劣 衡与墨 已于 2022-04-27 20:46:32 修改 5617 收藏 24分类专栏: redis 精华 文章标签: redis pub-sub stream 消息队列版权 redis同时被 2 个专栏收录19 篇文章0 订阅订阅专栏 精华12 篇文章0 订阅订阅专栏概述常用的消息队列有,rabbitMq、kafka

  • /opt/module/canal/conf/canal.properties2022-08-16 21:03:32

    ################################################# ######### common argument ############################################################### tcp bind ipcanal.id= 10canal.ip = 192.168.200.106# register ip to zookeepercanal.register.ip =canal.port = 11111ca

  • 为什么要用MQ?2022-08-15 23:33:26

    1 - 解耦 A系统调B C D 系统,如果新加一个系统E也需要A系统传的数据,C系统不需要A系统调用,这样A系统就会不停的改代码,很崩溃,可以让A系统把消息发送到MQ里,哪个系统需要就去订阅消费,A系统不用再关心有没有调用失败或者成功,其他系统不需要A系统数据直接取消订阅不消费即可     2 -

  • SpringCloud-消息驱动(Stream)2022-08-12 16:34:05

      Stream 概述 https://spring.io/projects/spring-cloud-stream#overview https://docs.spring.io/spring-cloud-stream/docs/current/reference/html/ Stream解决什么问题? 当系统中使用多个不同的MQ时,使用spring cloud stream可以屏蔽 不同消息中间件的差异,统一消息的编程模型;

  • 如何保证MQ重复消费的幂等性2022-08-08 16:01:11

    添加一个中间件,取名为内存set,消费者每次消费到了MQ的一条消息的时候,想内存set中插入消费记录,如果消费者消费的消息存在于内存set中,则这条消息被过滤 基于数据库的唯一键,保证重复数据不会被插入多条

  • 消息队列MQ2022-07-23 23:31:15

    一、消息队列概述 MQ(Message Queue)消息队列,是基础数据结构中“先进先出”的一种数据结构。指把要传输的数据(消息)放在队列中,用队列机制来实现消息传递——生产者产生消息并把消息放入队列,然后由消费者去处理。消费者可以到指定队列拉取消息,或者订阅相应的队列,由MQ服务端给其推送消

  • 17、如何解决消息队列的延时以及过期失效问题?消息队列满了以后该怎么处理?有几百万 消息持续积压几小时,说说怎么解决2022-07-23 10:00:40

    消息积压处理办法:临时紧急扩容:先修复 consumer 的问题,确保其恢复消费速度,然后将现有 cnosumer 都停掉。新建一个 topic,partition 是原来的 10 倍,临时建立好原先 10 倍的 queue 数量。然后写一个临时的分发数据的 consumer 程序,这个程序部署上去消费积压的数据,消费之

  • 12、mq 的缺点2022-07-23 08:35:33

    系统可用性降低系统引入的外部依赖越多,越容易挂掉,本来你就是 A 系统调用 BCD 三个系统的接口就好了,人 ABCD 四个系统好好的,没啥问题,你偏加个 MQ 进来,万一MQ 挂了咋整?MQ 挂了,整套系统崩溃了,你不就完了么。系统复杂性提高硬生生加个 MQ 进来,你怎么保证消息没有重复消费?

  • 一次线上事故,我顿悟了异步的精髓2022-07-11 08:02:55

    在高并发的场景下,异步是一个极其重要的优化方向。 前段时间,生产环境发生一次事故,笔者认为事故的场景非常具备典型性 。 写这篇文章,笔者想和大家深入探讨该场景的架构优化方案。希望大家读完之后,可以对异步有更深刻的理解。 1 业务场景 老师登录教研平台,会看到课程列表,点击课程后,课

  • RabbitMQ的概念 为什么使用RabbitMQ2022-07-07 10:04:09

    1. 消息队列 1.1. MQ 的相关概念 1.1.1. 什么是 MQ ​ MQ(message queue),从字面意思上看,本质是个队列,FIFO 先入先出,只不过队列中存放的内容是message 而已,还是一种跨进程的通信机制,用于上下游传递消息。在互联网架构中,MQ 是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信

  • (转载)redis的发布/订阅和mq消息队列的区别,该如何选择?2022-07-05 18:02:21

    原文连接:https://blog.csdn.net/superit401/article/details/86171473 本文以reids和rocketmq对比 很多人一直有个疑问(包括我之前也是):redis支持已经消息队列(发布/订阅)了,为什么还需要mq呢? 项目已经集成了redis,为什么还要多集成一个mq,那不是显得更臃肿吗?增加了维护成本 re

  • MQ实现分布式事物处理说明比较2022-07-04 22:35:46

    分布式事务就是要保证不同节点之间的数据一致性。 常见的分布式事务解决方案 1、2PC(二阶段提交)方案 - 强一致性 2、3PC(三阶段提交)方案 3、TCC (Try-Confirm-Cancel)事务 - 最终一致性 4、Saga事务 - 最终一致性 5、本地消息表 - 最终一致性 6、MQ事务 - 最终一致性   《=====》

  • RocketMQ2022-07-04 21:32:20

    一.  用途    1 .流量削峰:   MQ 可以将系统的超量请求暂存其中,一边后期可以慢慢进行处理,避免请求丢失或压垮系统。保证系统面多大量请求的稳定性  2. 异步解耦  :上游系统对下游系统的调用若为同步调用,则回大大降低系统的吞吐和并发度,且系统耦合度太高。而异步调用则可以解

  • roket MQ 延迟消费2022-06-30 13:35:58

    发送端,执行Message对象的setDelayTimeLevel();   比如需要延迟10s  message.setDelayTimeLevel(3);   默认延迟等级1:1s 2:5s 3:10s 4:30s 5:1m 6:2m 7:3m 8:4m 9:5m 10:6m 11:7m 12:8m 13:9m 14:10m 15:20m 16:30m 17:1h 18:2h

  • 第一章:01_RocketMQ概述2022-06-30 13:00:07

    一、MQ简介 MQ,Message Queue,是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息生产、存储、消费全过程API的软件系统。消息即数据。一般消息的体量不会很大。 二、MQ用途 从网上可以查看到很多的关于MQ用途的叙述,但总结起来其实就以下三点。 1、限流削峰 MQ可以将

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有