@ConditionalOnExpression("'true") 当括号中的内容为true时,使用该注解的类被实例化,支持语法如下: @ConditionalOnExpression("${mq.cumsumer.enabled}==1&&${rabbitmq.comsumer.enabled:t ...
分类:
编程语言 时间:
2020-06-24 16:26:23
阅读次数:
319
一、消息队列概述 消息队列(MessageQueue,简称为MQ)其本质是就是个队列,FIFO先进先出,只不过是队列中储放的主要内容是message,因而叫消息队列主要用于:不同的服务server、进程process、线程thread相互间通信二、选用消息队列的场景①异步处理②流量控制③服务解耦④发 ...
分类:
系统相关 时间:
2020-06-24 00:34:13
阅读次数:
122
RabbitMQ 是一款优秀的消息中间件。相比于 kafka 更好上手,相比于 ActiveMQ 拥有更好的性能。 RabbitMQ 支持单机部署,集群部署。 集群部署有包括 : 普通模式(多节点集群)、镜像集群。 节点分为 : 磁盘节点(disc) 和 内存节点 (RAM)。 镜像集群其实也是 镜 ...
分类:
其他好文 时间:
2020-06-24 00:25:28
阅读次数:
55
一、需求情况?MQ用户的1个通常要求是:“我怎么使用X技术连接我的?MQ网络?”。这其中X是某种其它网络或通信技术简洁明了的答案是构建1个“桥梁”。桥指的是1个小型应用程序,它用一种协议与1个套接字交流,并将其转换成为另1个套接字的另一种协议。假如你喜欢,还可以将之称为1个协议解释器。?MQ中1个通 ...
分类:
其他好文 时间:
2020-06-22 23:22:26
阅读次数:
92
1、mq的应用场景: 1) 对于数据量大或者处理耗时长的操作,我们可以引入 MQ 实现异步通信,减少客户端的等待,提升响应速度。 2) 对于改动影响大的系统之间,可以引入 MQ 实现解耦,减少系统之间的直接依赖。 3) 对于会出现瞬间的流量峰值的系统,我们可以引入 MQ 实现流量削峰,达到保护应用和 ...
分类:
其他好文 时间:
2020-06-21 20:26:08
阅读次数:
103
ansible 和saltstack对比 SaltStack 底层有一个消息队列:Zero-MQ(message queue) # 1.ansible是基于ssh协议来工作的,但是saltstack也有支持ssh协议的模式 # 2.但是一般来说,选择saltstack就是为了使用客户端和服务端的方式 ...
分类:
其他好文 时间:
2020-06-21 00:30:27
阅读次数:
50
异步邮件验证需要使用celery以及django的celery框架 pip install celery pip install django-celery celery需要中间任务队列支持,这里使用rabbitmq rabbitmq MQ全称为Message Queue, 是一种分布式应用程序的的 ...
分类:
其他好文 时间:
2020-06-20 19:50:23
阅读次数:
63
1 问题 环境: CentOS7.8.2003 (x86 / 64bit) 版本: RabbitMQ 3.6.15 (Erlang 19.3) 安装方式: 二进制源码压缩安装 2 解决思路 2.1 思路1 关闭进程,并重启 step1 查询mq的进程 ps -ef | grep rabbitmq s ...
分类:
系统相关 时间:
2020-06-19 12:23:47
阅读次数:
130
介绍 一种高吞吐量的分布式发布订阅消息系统 消息类型:主体Topic(广播)、队列Queue(一对一) 消息系统类型:同步消息系统、异步消息系统 常见消息产品:Redis、Kafka、JMS 术语 Topic:Kafka处理消息源(feeds of messages)的不同分类(不同于传统MQ) P ...
分类:
数据库 时间:
2020-06-18 21:34:03
阅读次数:
82
在windows server 2008上安装websphere mq7.5 服务端,建立队列。通过java client向我的机器的队列发送消息和接收消息。 mq安装成功,队列管理器、队列、通道也都建起来了,用mq自带的api检测程序检测也成功了。 接下来,在另外一台机器上通过程序发送消息,结果就 ...
分类:
其他好文 时间:
2020-06-18 10:54:47
阅读次数:
312