最简单接受MQ消息的方法-annotation

2018-09-29
阅读 3 分钟
7.9k
上述代码不仅定义了一个队列,并在argument中加入了死信队列,来接受失败消息同时,我们在接受参数时 传入了 channel以及 tag, 这样可以很方便的进行消息回传了,比如: channel.baskAck(...)

Spring Cloud分布式事务终极解决方案探讨

2018-01-09
阅读 5 分钟
92k
一 小小推广 讲座 本话题已收入视频讲座《Spring Cloud分布式事务解决方案》大家不妨围观下 开源项目 我们利用消息队列实现了分布式事务的最终一致性解决方案,请大家围观。可以参考Github CoolMQ源码,项目支持网站: [链接],最新文章或实现会更新在上面 二 前言 阿里2017云栖大会《破解世界性技术难题!GTS让分布式事...

白话RabbitMQ(五): 主题路由器(Topic Exchange)

2018-01-02
阅读 4 分钟
3.3k
在之前的建立路由中我们改进了日志系统。我们摒弃无脑发送消息的广播路由器,而使用能够根据绑定键(binding key)来发送消息的,从而能有有选择的后去logs.

白话RabbitMQ(四): 建立路由

2018-01-01
阅读 4 分钟
3k
在订阅/发布中我们建立了一个简单的日志系统,从而将log消息广播给一些消费者。这章我们会在此基础上加入一些新的特性-我们将有针对性的进行消息分发,比如,只把错误(error)消息保存到磁盘,与此同时,打印出所有的消息。

白话RabbitMQ(三):发布/订阅

2018-01-01
阅读 4 分钟
3.4k
为了更好的阐述这个模式,我们会建立一个新的简单的logging系统,包含2个步骤-第一步发送log信息,第二步能够接受并将信息打印出来,而且在第二步中所有的消费者都会接受到同样的消息,比如一个消费者用来将log信息写到磁盘,另外一个接受信息并显示在屏幕上。因此一旦有有消息,消息会广播到所有的消费者。

白话RabbitMQ(二): 任务队列

2017-12-31
阅读 7 分钟
5.6k
在第一篇中我们描述了如何最简单的RabbitMQ操作,如何发送、接受消息。在今天这篇文章中我们将描述如何创建一个任务队列,来将高耗时的任务分发到多个消费者,从而提高处理效率。

Rabbitmq各参数详解

2017-12-15
阅读 4 分钟
15.3k
Rabbitmq舍弃了繁重的事务消息而使用了消息确认机制实现了分布式事务,实在是解耦之一大神器。但是其配置起来挺麻烦,各种参数,各种调整。但国内貌似资料很少,找来找去都找不到,自己撸一发先