为了避免意外宕机以后丢失信息,需要做到重启后可以恢复消息队列,消息系统一般都会采用持久化机制。 ActiveMQ的消息持久化机制有JDBC,AMQ,KahaDB和LevelDB, 无论使用哪种持久化方式,消息的存储逻辑都是一致的。也就是说发送者将消息发送出去后,消息中心首先将消息存储到本地数据文件、 ...
分类:
其他好文 时间:
2018-02-25 19:24:58
阅读次数:
205
风浪子 风浪子 概述 MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。RabbitMQ是一个在AMQP基础上完整的,可复用的企业消息系统。他遵循Mozilla Public License开源协议。AMQP(高级消息队列协议) 是一个异步消息传递所使用的应 ...
分类:
Web程序 时间:
2018-02-24 19:24:10
阅读次数:
225
【前言】 RabbitMQ消息的传递并非使用HTTP协议,而是AMQP协议,因此除非开发暴露一个HTTP请求接口出来,否则无法直接使用HTTP请求发送json串数据,实现数据publish到MQ中。 【测试方法】 前提:有可视化的RabbitMQ管理页面; 方法:利用Jmeter,录制RabbitM ...
分类:
其他好文 时间:
2018-02-21 19:41:22
阅读次数:
1432
一、简介 RabbitMQ是流行的开源消息队列系统,用erlang语言开发。RabbitMQ是AMQP(高级消息队列协议)的标准实现。 二、安装 1、安装erlang环境,下载安装包,网址:http://erlang.org/download/,如我下载的版本是:otp_win64_20.2.exe ...
分类:
Windows程序 时间:
2018-02-14 13:22:00
阅读次数:
1335
队列: 从概念上来讲,AMQP消息路由必须有三部分:交换器、队列和绑定。生产者把消息发布到交换器上;消息最终到达队列,并被消费者接收;绑定决定了消息如何从路由器路由到特定的队列。 消费者通过以下两种方式从特定的队列中接收消息: 1)通过AMQP的basic.consume命令订阅。这样做会将信道置为 ...
分类:
其他好文 时间:
2018-02-12 18:38:05
阅读次数:
219
RabbitMQ Exchange分发消息时根据类型的不同分发策略有区别,目前共四种类型:direct、fanout、topic、headers 。headers 匹配 AMQP 消息的 header 而不是路由键,此外 headers 交换器和 direct 交换器完全一致,但性能差很多,目前几乎 ...
分类:
其他好文 时间:
2018-02-11 12:33:04
阅读次数:
204
面向EDA(事件驱动架构)的方式来设计你的消息 AMQP routing key的设计 RabbitMQ cluster搭建 Mirror queue policy设置 两个不错的RabbitMQ plugin 大型应用插件(Sharding、Rederation) Queue镜像失败手动同步 各集 ...
分类:
其他好文 时间:
2018-02-10 11:11:10
阅读次数:
232
RabbitMQ特点 RabbitMQ 是一个由 Erlang 语言开发的 AMQP 的开源实现。 AMQP :Advanced Message Queue,高级消息队列协议。它是应用层协议的一个开放标准,为面向消息的中间件设计,基于此协议的客户端与消息中间件可传递消息,并不受产品、开发语言等条件的 ...
分类:
其他好文 时间:
2018-02-07 12:03:48
阅读次数:
186
Kafka的概念: 1、 AMQP协议 1、 AMQP协议 1、 AMQP协议 Advanced Message Queuing Protocol (高级消息队列协议) The Advanced Message Queuing Protocol (AMQP):是一个标准开放的应用层的消息中间件(Me ...
分类:
其他好文 时间:
2018-02-05 18:45:25
阅读次数:
150
原文地址: "Spring Boot 入门之消息中间件篇(五)" 博客地址: 一、前言 在消息中间件中有 2 个重要的概念:消息代理和目的地。当消息发送者发送消息后,消息就被消息代理接管,消息代理保证消息传递到指定目的地。 我们常用的消息代理有 JMS 和 AMQP 规范。对应地,它们常见的实现分别 ...
分类:
编程语言 时间:
2018-01-28 00:04:55
阅读次数:
292