写了一个监控mq的脚本,把这个脚本加入crontab里进行时刻监控,于是#crontab -e,添加语句: * * * * * cd /目录 && python mq脚本名.py >/root/mq.log 2>&1 将执行的结果发送到/root/mq.log里,打开一看里面出现了这样的错误: 但是 ...
分类:
编程语言 时间:
2019-01-24 10:57:49
阅读次数:
176
"事务消息组件的套路" 本文总结一些互联网产品的服务端关于处理事务消息的套路 套路1:最终一致性消息模型 该方案关键是要有个消息表。另外,一般会有个队列,而且我们一般都会假设这个MQ不丢消息。 基本思路如下 消息生产方 需要额外建一个消息表,并记录消息发送状态。消息表和业务数据要在一个事务里提交(有 ...
分类:
其他好文 时间:
2019-01-24 00:27:47
阅读次数:
172
一、重客户端 写入缓存: 应用同时更新数据库和缓存 如果数据库更新成功,则开始更新缓存,否则如果数据库更新失败,则整个更新过程失败。 判断更新缓存是否成功,如果成功则返回 如果缓存没有更新成功,则将数据发到MQ中 应用监控MQ通道,收到消息后继续更新Redis。 问题点:如果更新Redis失败,同时 ...
分类:
其他好文 时间:
2019-01-23 18:13:00
阅读次数:
214
原文:windows下 安装 rabbitMQ 及操作常用命令rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang O... ...
MQ全称为Message Queue, 是一种分布式应用程序的的通信方法,它是消费-生产者模型的一个典型的代表,producer往消息队列中不断写入消息,而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表,是一款基于AMQP协议可复用的企业消息系统。业务上, ...
分类:
其他好文 时间:
2019-01-20 22:54:22
阅读次数:
236
转自:http://hi.baidu.com/lubezhang/blog/item/bd308b3b7ecce3ec14cecb4f.html IBM MQ(IBM Message Queue)是IBM的一款商业消息中间产品,适用于分布式计算环境或异构系统之中。消息队列技术是分布式应用间交换信息的 ...
分类:
其他好文 时间:
2019-01-20 20:04:51
阅读次数:
395
@Conditional的使用 作用: 根据条件,决定类是否加载到Spring Ioc容器中,在SpringBoot中有大量的运用 应用场景 :在一些需要条件满足才是实例化的类中,使用此注解,我曾经在项目中需要根据不同的场景使用不同的mq中间件的时候使用过,在mq的实例化bean上,加上此注解,根据 ...
分类:
其他好文 时间:
2019-01-20 19:59:21
阅读次数:
757
案例:经典案例,以目前流行点外卖的案例,用户下单后,调用订单服务,让后订单服务调用派单系统通知送外卖人员送单,这时候订单系统与派单系统采用MQ异步通讯。 RabbitMQ解决分布式事务原理: 采用最终一致性原理。需要保证以下三要素1、确认生产者一定要将数据投递到MQ服务器中(采用MQ消息确认机制)2 ...
分类:
其他好文 时间:
2019-01-18 23:13:30
阅读次数:
180
什么是消息队列? 从数据结构上看,就是实现了一个队列的功能,单纯的放到一个系统里面,可入可出。 为什么使用消息队列? 1、解耦业务,防止业务过于复杂 2、流量消峰(限购,设置消息数量) 3、系统间传送消息 消息格式: 1、规定格式才能进行解析 消息队列类型: 1、点对点 2、订阅 ...
分类:
其他好文 时间:
2019-01-18 13:59:03
阅读次数:
185
介绍 ABP中一些配置都是通过模块的Configuration属性来配置的。例如在模块的生命周期方法中可以进行一系列的配置 审计 MQ Redis....也可以替换一些ABP默认配置 通常我们的用户模块(自定义模块)都会继承自 AbpModule ,它是ABP所有模块的基类.也是个抽象类. 这里的两 ...
分类:
其他好文 时间:
2019-01-17 19:35:29
阅读次数:
250