RabbitMQ常用端口 client端通信端口: 5672 管理端口 : 15672 server间内部通信端口: 25672 可能的问题 如端口出现不能访问,考虑是否防火墙问题,可以使用形如以下命令开启或直接关闭防火墙: firewall-cmd --add-port=15672/tcp --p ...
分类:
其他好文 时间:
2020-07-19 17:46:41
阅读次数:
74
什么是RabbitMQ简介(优点)基于ErLang语言开发有高可用高并发的优点,适合集群。开源、稳定、易用、跨平台、支持多种语言、文档齐全。有消息确认机制和持久化机制,可靠性高。概念生产者和消费者Producer:消息的生产者Consumer:消息的消费者Queue消息队列提供了FIFO的处理机制,具有缓存消息的能力。在RabbitMQ中,队列消息可以设置为持久化,临时或者自动删除。如果是持久化的
分类:
其他好文 时间:
2020-07-19 11:25:40
阅读次数:
75
工欲善其事,必先利其器。 什么是Celery Celery是一个简单、灵活且可靠的,处理大量消息的分布式系统,专注于实时处理的异步任务队列,同时也支持任务调度。 上面的图是一个利用Celery进行异步处理的架构,属于生产者-消费者模式,架构由三部分组成: 消息中间件(message broker): ...
分类:
其他好文 时间:
2020-07-19 00:54:19
阅读次数:
106
(env) D:\python_learn\meiduo_project\meiduo_mall>celery -A celery_tasks.main worker -l info celery@CZZI-BBMGSW v4.4.6 (cliffs) ***** -- ******* Window ...
分类:
其他好文 时间:
2020-07-19 00:50:02
阅读次数:
73
一、RabbitMQ简介 1. 应用场景 (1)任务异步处理 ? 将不需要同步处理的并且耗时长的操作由消息队列通知消息接收方进行异步处理。缩短了应用程序的响应时间。 (2)应用程序解耦合 ? MQ相当于一个中介,生产方通过MQ与消费方交互,它将应用程序进行了解耦合。 2. 工作原理 ? 下图是Rab ...
分类:
其他好文 时间:
2020-07-18 22:55:09
阅读次数:
100
什么是消息队列(MQ) 消息是在不同应用间传递的数据。这里的消息可以非常简单,比如只包含字符串,也可以非常复杂,包含多个嵌套的对象。消息队列(Message Queue)简单来说就是一种应用程序间的通讯方式,消息发送后立即返回,然后由消息系统保证消息的可靠性传输,消息生产者只需要把消息发到 MQ 中 ...
分类:
其他好文 时间:
2020-07-18 22:06:33
阅读次数:
69
Docker-compose常用软件部署(mysql、redis、rabbitmq) 废话不多说,下面就直接给出部署文件已经启动脚本,这个会持续更新。以下的部署方式均是单例部署。高可用或者其他部署方案我会单独写相应的文章。 mysql数据库 redis缓存 rabbitmq消息队列 compose- ...
分类:
数据库 时间:
2020-07-18 21:56:39
阅读次数:
84
Rabbitmq的使用四_Java Client方式使用Topic模式 1.官方文档地址:https://www.rabbitmq.com/tutorials/tutorial-five-java.html 2.定义:topic和direct类似,也是将消息发送到RoutingKey和Binding ...
分类:
编程语言 时间:
2020-07-18 20:00:00
阅读次数:
93
前言 某个产品 或者订单,有个有效期 过了有效期要取消 方法一 : 写个脚本,用crontab 定时扫描 改变状态 但是最低只能一分钟 ,不适合 方法二 : 用swoole得毫秒定时器,每秒钟去扫描表 明显占用资源 mysql受不了 方法三 :用rabbitmq延时队列 一开始将其丢入mq 死信队列 ...
分类:
其他好文 时间:
2020-07-18 15:40:48
阅读次数:
65
延迟任务应用场景 场景一:物联网系统经常会遇到向终端下发命令,如果命令一段时间没有应答,就需要设置成超时。 场景二:订单下单之后30分钟后,如果用户没有付钱,则系统自动取消订单。 场景三:过1分钟给新注册会员的用户,发送注册邮件等。 php 使用rabbitmq-delayed-message-ex ...
分类:
Web程序 时间:
2020-07-18 15:27:31
阅读次数:
88