×

rabbitmq

聊聊RabbitMq动态监听这点事

百度首页排名卖蜘蛛 百度首页排名卖蜘蛛 发表于2024-05-26 浏览9192 评论0
很长时间没有分享过学习心得了,看了下发布记录,最后一篇文章的时间都在2020-12-10年了,今天抽时间整理下一个很早就想整理的技术分享。顺便说句题外话,因为我一直没时间整理,再加上开发的小伙伴对Mq的理解不够,我开掉了好几个处理这个事情的开发小伙伴,所以我希望这篇文章能对大家带来一点帮助。 背景说明 Mq(消息队列)做为一个消峰工具而常被使用,我们常用的Mq主要分为以下四种: ActiveMQ RabbitMq Kafka RocketMq 今天主要是聊聊RabbitMq,业务场景上

rabbitmq

【操作系统】生产者消费者问题(操作系统生产者消费者问题代码)

杍杋 杍杋 发表于2024-05-26 浏览6134 评论0
问题描述 系统中有一组生产者进程和一组消费者进程,生产者进程每次生产一个产品放入缓冲区,消费者进程每次从缓冲区取出一个产品并使用。(注:这里的“产品”理解为某种数据) 生产者、消费者共享一个初始为空、大小为n的缓冲区。 问题分析 缓冲区是有容量限制的,只有缓冲区没满时,生产者才能把产品放入缓冲区,否则必须等待。 如果此时缓冲区已经满了,那么生产者如果想要继续往缓冲区写入数据的话,只能先将自己阻塞。只有缓冲区不空时,消费者才能从中取出产品,否则必须等待。 消费者进程想要从缓冲区取走

rabbitmq

基于一次线上Rabbitmq 积压问题的排查总结和分析(rabbitmq解决数据积压)

Justin Justin 发表于2024-05-26 浏览4594 评论0
1,mq积压如何解决? 2,我们怎么去排查mq积压的问题? mq问题排查的核心: 1,mq消息队列消费不过来,查看管道和连接数据。 2,mq消息数据积压数据消费不过来,自动ack比手动ack快。 3,程序性能不行。 4,数据库锁表,数据库io过高也会导致数据积压。 5,增加消费者连接数配置。(不推荐) 我们消息队列积压了一千四百多万的业务数据,数据积压了会一直积压,如果不处理对业务有很大的影响。 我们看我们管道和消费都是正常的,所以程序处理慢的问题就在我们写的消费程序上

rabbitmq

RabbitMQ(基本概念+在docker容器化下安装与使用,集群搭建)

执行注册任务 执行注册任务 发表于2024-05-26 浏览10086 评论0
一、MQ: MQ全称MessageQueue(消息队列),是在消息的传输过程中保存消息的容器,多用于分布式系统之间进行通信。 MQ有如下特点 优势:1、应用解耦 2、任务异步处理 3、削峰填谷 劣势:1、系统可用性降低2、系统复杂性提高3、如何保证数据的一致性 常见的MQ产品: 本文主要讲解RabbitMQ的安装和使用。 二、RabbitMQ基本概念 1.Broker :接收和分发消息的应用, RabbitMQ Server 就是 Message Broke

rabbitmq

SpringCloud、RabbitMQ、Websocket集群搭建以及集群通信

造梦先生 造梦先生 发表于2024-05-26 浏览8224 评论0
最近遇到了一个难题,搭建websocket集群实现消息推送,在这之前基本没接触过websocket和集群问题,这次找了很多资料和博文,在经历了几天的研究和设计实现了websocket集群的搭建和集群的通信。 一、环境准备 软件方面:主要是Erlang+RabbitMQ得提前安装好。不知道如何安装的可以转到我的文章查看。Erlang及RabbitMQ下载安装 二、设计思路 ①集群的实现我使用spring-cloud-gateway、Spring-cloud-alibaba等框架实现,设计基

rabbitmq

使用rabbitmq广播模式来处理集群下的websocket消息推送

成绍勇? 成绍勇? 发表于2024-05-26 浏览7088 评论0
websocket属于长连接,当客户端连接上服务端后,将保持于服务端的连接。 而当websocket服务端存在集群的情况,如果需要将某个消息发送到客户端时,通过接口调用发送,这种情况只能将消息发送到与这台服务端连接的客户端,会存在部分客户无法接收消息的情况。 后续通过搜集资料选择采用了用rabbitmq来做websocket的集群,即通过使用mq的广播交换机,然后结合服务端启动创建动态队列来绑定同一个交换机,这样便能使集群中的每一个服务端都能收到消息,然后再去往连在当前服务端的websocke