RabbitMQ介绍 RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue）的开源实现的产品，RabbitMQ是一个消息代理，从“生产者”接收消息并传递消息至“消费者”，期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P，相 ...
分类：
编程语言 时间：
2017-08-10 22:33:15
阅读次数：
173
RabbitMQ介绍 RabbitMQ是一个由erlang开发的AMQP（Advanced Message Queue）的开源实现的产品，RabbitMQ是一个消息代理，从“生产者”接收消息并传递消息至“消费者”，期间可根据规则路由、缓存、持久化消息。“生产者”也即message发送者以下简称P，相 ...
分类：
编程语言 时间：
2017-08-08 17:58:50
阅读次数：
306
一，什么是消息中间件 关注于数据的发送和接收，利用高效可靠的异步消息传递机制集成分布式系统。 1.老王最开始讲故事时需要挨个打电话给小红，小黄。有时还有可能打不通。但是通过微信公众号，可以将消息发送到公众号，然后再小红小黄有空的时间再订阅。 2.登录系统的例子 通过服务调用外部系统感知服务在使用消息 ...
分类：
其他好文 时间：
2017-08-03 12:33:54
阅读次数：
194
一、消息的存储方式ActiveMQ支持JMS规范中的持久化消息与非持久化消息持久化消息通常用于不管是否消费者在线，它们都会保证消息会被消费者消费。当消息被确认消费后，会从存储中删除非持久化消息通常用于发送通知以及实时数据，通常要求性能优先，消息可靠性并不是必须的情况MQ..
分类：
其他好文 时间：
2017-06-22 16:43:50
阅读次数：
203
消息的持久化，保证了消费者离线后，再次进入系统，不会错过消息，但是这也会消耗很多的资源。从5.6开始，可以对持久化消息进行如下管理：我们还可能希望删除那些不活动的订阅者，如下：<brokername="localhost"
offlineDurableSubscriberTimeout="600000"
offlineDurableSu..
分类：
其他好文 时间：
2017-05-11 22:14:54
阅读次数：
294
一、消息确认 为了确保消息一定被消费者处理，rabbitMQ提供了消息确认功能，就是在消费者处理完任务之后，就给服务器一个回馈，服务器就会将该消息删除，如果消费者超时不回馈，那么服务器将就将该消息重新发送给其他消费者 默认是开启的，在消费者端通过下面的方式开启消息确认, 首先将autoAck自动确认 ...
分类：
其他好文 时间：
2017-05-07 12:50:27
阅读次数：
175
http://www.infoq.com/cn/articles/solution-of-distributed-system-transaction-consistency 在OLTP系统领域，我们在很多业务场景下都会面临事务一致性方面的需求，例如最经典的Bob给Smith转账的案例。传统的企业开 ...
分类：
其他好文 时间：
2017-05-02 14:01:09
阅读次数：
215
非持久的Topic消息示例 对于非持久的Topic消息的发送基本跟前面发送队列信息是一样的，只是把创建Destination的地方，由创建队列替换成创建Topic，例如： Destination destination = session.createTopic("MyTopic"); 对于非持久的 ...
分类：
其他好文 时间：
2017-04-12 01:49:36
阅读次数：
369
接上一篇《ActiveMQ从入门到精通（一）》，本篇主要讨论的话题是：消息的顺序消费、JMSSelectors、消息的同步/异步接受方式、Message、P2P/PubSub、持久化订阅、持久化消息到MySQL以及与Spring整合等知识。消息的顺序消费在上一篇文章中，我们已经明确知道了ActiveMQ并不能保证..
分类：
其他好文 时间：
2017-03-21 00:12:29
阅读次数：
329
折腾ActiveMQ时遇到的问题和解决方法： 1.先讲严重的：服务挂掉。 这得从ActiveMQ的储存机制说起。在通常的情况下，非持久化消息是存储在内存中的，持久化消息是存储在文件中的，它们的最大限制在配置文件的<systemUsage>节点中配置。但是，在非持久化消息堆积到一定程度，内存告急的时候 ...
分类：
其他好文 时间：
2017-03-12 16:27:11
阅读次数：
1379
