ICode9

精准搜索请尝试: 精确搜索
  • 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可以将

  • 消息队列(MQ)2022-06-20 00:05:10

      消息队列之真知灼见  https://www.cnblogs.com/pyedu/p/11866829.html 一 什么是消息队列(MQ) MQ全称为Message Queue 消息队列(MQ)是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表,一端往消息队列中不断写入消息,而另一端则可以读取队列中的

  • 【RocketMQ】MQ消息发送2022-06-17 22:35:29

    消息发送 首先来看一个RcoketMQ发送消息的例子: @Service public class MQService { @Autowired DefaultMQProducer defaultMQProducer; public void sendMsg() { String msg = "我是一条消息"; // 创建消息,指定TOPIC、TAG和消息内容 Messag

  • 面试官竟然问我为啥要用MQ,幸亏我看了参考答案2022-06-16 15:36:49

    互联网公司的项目没有不用到MQ(消息队列)的,在简历中写上项目中用到MQ,也算是亮点之一。既然你写了,面试官就会问,你对MQ到底了解多少? 一个挺着啤酒肚,身穿格子衫,发际线严重后移的中年男子,手拿着保温杯,胳膊夹着MacBook向你走来。 面试官:小伙子,我看你简历上写了,在项目中用到了MQ,你们项目

  • Linux 镜像安装MQ 、集群部署等2022-06-09 18:33:13

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

  • go使用rabbitmq2022-06-09 18:03:16

    rabbitmq是一款消息中间件,采用erlang语言编写。基于AMQP协议来实现。AMQP的主要特征是面向消息、队列、路由(包括点对点和发布/订阅)、可靠性、安全。AMQP协议更多用在企业系统内,对数据一致性、稳定性和可靠性要求很高的场景,对性能和吞吐量的要求还在其次。消息的消费者被动拉取(rabb

  • 微服务使用MQ数据传输2022-06-09 17:03:56

    MQ传输的方法有7种,常用的有5种。   简单、工作、广播、路由、通配符。   如果是使用的 Linux 需要启动和安装 MQ 镜像:   导入依赖: <!--AMQP依赖,包含RabbitMQ--> <dependency> <groupId>org.springframework.boot</groupId> <artifac

  • Redis 队列和MQ 对比2022-06-07 19:01:50

    简介 为了保障基础服务的稳定,需要对MQ进行灾备,这个灾备主要是防患MQ突然不可能,基础服务依然可以调用其他队列来继续正常运行。第一想法是引入其他MQ中间件来做灾备,这样只需要实现一套生产者消费者就好。但因为公司这块中间件都使用的云产品。要过要使用其他类型的MQ中间件

  • 记一次rabbitmq 消息不能接受故障的处理2022-06-07 01:03:10

    问题 当时比较怪异,现象是通过rabbitmq 的management可以发送消息(消息内容比较小,很简单的),但是通过代码没有任何报错 但是消息就是不能看到(management 界面) 排错处理 开始以为是代码处理问题,但是没有异常日志,也怀疑因为代码发布造成队列错误造成消息写入错误,我一般的此类问题的方式

  • 消息治理,到底需要治理哪些内容?2022-05-29 10:35:01

    大家好,我是【架构摆渡人】,一只十年的程序猿。这是消息队列的第六篇文章,这个系列会给大家分享很多在实际工作中有用的经验,如果有收获,还请分享给更多的朋友。 不知道大家发现没有,虽然市面上已经有很多优秀的开源消息队列了,但是一些公司还是热衷于自研。并不是说开源的不好,而是开源的

  • RabbitMq基本概念2022-05-27 01:02:03

    目录一、什么是消息队列二、RabbitMQ的优势2.1 应用解耦2.2 异步提速2.3 流量削峰三、MQ的劣势四、RabbitMQ中的相关概念 一、什么是消息队列 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器。多用于分布式系统之间进行通信。消息指的是两个应用间传递的数据。

  • 实现延时消息2022-05-23 15:35:15

    1.基于外部存储实现的方案           基于外部存储的方案本质上都是一个套路,将 MQ 和 延时模块 区分开来,延时消息模块是一个独立的服务/进程。延时消息先保留到其他存储介质中,然后在消息到期时再投递到 MQ。 1.1、基于 数据库(如MySQL) 基于关系型数据库(如MySQL)延时消息表的方

  • 【mq】从零开始实现 mq-12-消息的批量发送与回执2022-05-18 10:34:07

    前景回顾 【mq】从零开始实现 mq-01-生产者、消费者启动 【mq】从零开始实现 mq-02-如何实现生产者调用消费者? 【mq】从零开始实现 mq-03-引入 broker 中间人 【mq】从零开始实现 mq-04-启动检测与实现优化 【mq】从零开始实现 mq-05-实现优雅停机 【mq】从零开始实现 mq-06-消费

  • 【mq】从零开始实现 mq-08-配置优化 fluent2022-05-10 22:35:38

    前景回顾 【mq】从零开始实现 mq-01-生产者、消费者启动 【mq】从零开始实现 mq-02-如何实现生产者调用消费者? 【mq】从零开始实现 mq-03-引入 broker 中间人 【mq】从零开始实现 mq-04-启动检测与实现优化 【mq】从零开始实现 mq-05-实现优雅停机 【mq】从零开始实现 mq-06-消费

专注分享技术,共同学习,共同进步。侵权联系[[email protected]]

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

ICode9版权所有