MQ全称Message Queue ,即消息列队,RabbitMQ是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息列队协议) 协议实现的消息列队,它是一中应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。官网:https://www.rab ...
分类:
其他好文 时间:
2020-06-04 15:41:42
阅读次数:
66
消息如何保障100%的投递成功 什么是生产端的可靠性投递 保障消息的成功发出 保障MQ节点的成功接收 发送端收到MQ节点(Borker)确认应答 完善的消息进行补偿机制 生产端-可靠性投递(一) 消息落库,对消息状态进行打标 消息的延迟投递,做二次确认,回调检查 生产端-可靠性投递(二) 消息落库, ...
分类:
其他好文 时间:
2020-06-04 15:28:42
阅读次数:
42
背景 2019年的某个时候, 笔者负责解决公司系统内的基于Redis pubsub + Websocket消息推送的功能稳定性 过程 NO Detail 1. 初始情况: 笔者发现手写的Jedis客户端容易出现 断连, 每个小时至少发生一次, 时间不定. 没有进行多少次改参数的尝试.(因为已经打算寻 ...
分类:
其他好文 时间:
2020-06-04 14:07:58
阅读次数:
139
https://blog.csdn.net/u014209205/article/details/80642210 安装很简单。 简单使用https://blog.csdn.net/weixin_43763128/article/details/84332124 ...
分类:
其他好文 时间:
2020-06-04 13:52:00
阅读次数:
62
使用MQ的三大作用:1、同步变异步2、流量削峰3、解耦降低服务间的耦合性要不要使用MQ,需不需要使用MQ依据项目的需要做选择。 使用场景: 例如:注册用户时候,发送激活邮件。监控应用中抛出的异常,邮件通知管理员。也就是增加监控功能,且一个消息服务可以监控无数个应用。异构型架构系统间的各服务通信,因为 ...
分类:
其他好文 时间:
2020-06-01 11:43:45
阅读次数:
64
确保RabbitMQ的端口等配置正确,进入RabbitMQ中,开启一项配置。 例:开启RabbitMQ docker run -itd --name myrabbitmq -p 15672:15672 -p 5672:5672 rabbitmq 进入RabbitMQ docker exec -it ...
分类:
其他好文 时间:
2020-05-30 21:53:15
阅读次数:
331
1:18 1.什么是高并发系统的消息队列? 队列:对头+队列容器+对尾 消息队列(MessageQueue MQ):有一个队列容器,生产者(入队列),消费者(出队列) 2.使用消息队列的场景(使用消息队列的原因): 2.1 分布式场景 2.1.1 异步处理 多线程可以节省时间,但是会降低cpu吞吐量 ...
分类:
其他好文 时间:
2020-05-30 19:56:13
阅读次数:
59
rabbit-mq学习1:基本概念和快速入门 一、什么是MQ 消息队列(Message Queue,简称MQ)本质是个队列,遵循先入先出,主要用途:不同进程Process/线程Thread之间通信 。 可以用来在两个进程间进行异步的数据交换。进程A把消息放入消息队列中,然后继续执行后续任务;进程B从 ...
分类:
其他好文 时间:
2020-05-29 09:30:14
阅读次数:
59
1,安装依赖库 composer require php-amqplib/php-amqplib 地址:https://github.com/php-amqplib/php-amqplib 2,mq生产者.php include(__DIR__ . '../../public/config.php' ...
分类:
Web程序 时间:
2020-05-27 15:23:48
阅读次数:
257
消息中间件概述 什么是消息中间件 MQ全称为Message Queue: 消息队列是应用程序之间的通信. 为什么要使用MQ 在项目中, 可将一些无需即时返回且耗时的操作提取出来, 进行异步处理, 而这种异步处理的方式能大大节省服务器的请求响应时间, 从而提高了系统的吞吐量. 开发中消息队列的应用场景 ...
分类:
其他好文 时间:
2020-05-26 12:39:22
阅读次数:
51