本文转载于： https://www.zhihu.com/question/43557507 知乎专题： Kafka，Mq，Redis作为消息队列使用时的差异？ （里面还有很多回答值得去看和思考） 1 资料文档 Kafka：中。有 kafka 作者自己写的书，网上资料也有一些。 rabbitmq：多。有一些不错的书，网上资料多。 zeromq：少。没有专门写 zeromq 的书，网上的资料多是一些代码的实现和简单介绍。 rocketmq：少。没有专门写 rocketmq 的书，网上的资料良莠不齐，官...
1.rabbitmq的集成 首先在配置文件里增加#rabbitMQ spring.rabbitmq.host=127.0.0.1 spring.rabbitmq.port=5672 spring.rabbitmq.username=root spring.rabbitmq.password=root spring.rabbitmq.publisher-confirms=true spring.rabbitmq.publisher-returns=true spring.rabbitmq.template.mandatory=true 1.1这里的username和password是需要接下来我们自己在rabbitmq里添加的用户和密码，也可以使用默认的用户和密码guest 1.2 安装...
目录1. celery 简介2. celery 安装及部署2.1 celery 安装2.2 rabbitmq 安装3. run起一个简单的demo3.1 tasks.py 文件3.2 在terminal中调用celery：3.3 调用woker并查看执行情况 1. celery 简介 关于celery的简介，网上一大堆，在此不做赘述。 举个不太恰当的例子来作说明。celery就是一个服务团队，进入一家餐馆开始服务后，他的厨子在不停地做菜，前台有多个顾客不停地在吃，只要桌子上没有菜了，就会有新做好的端上来，直至所有...
本文转载至:https://www.cnblogs.com/flower1990/p/7466882.html 一、安装JAVA JDK 1、下载安装包 http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 注意：根据32/64位操作系统下载对应的安装包 2、添加系统变量：JAVA_HOME=C:\Program Files (x86)\Java\jdk1.8.0_144 二、安装ZooKeeper 1、 下载安装包 http://zookeeper.apache.org/releases.html#download 2、 解压并进入ZooKeeper目录，笔...
CAP 是一个基于 .NET Standard 的 C# 库，它是一种处理分布式事务的解决方案，同样具有 EventBus 的功能，它具有轻量级、易使用、高性能等特点。参考中文官网 从这张图可以看到CAP主要是保证消息的一致性,没有事务回滚的操作,需要自己实现消息双向推送 我一开始以为实现分布式事务锁的机制,后来消息微服务用锁实现事务也不太合适 下面是我写的一个Demo CAP 支持的多种消息队列,我这里用的是kafka 1.kafka 安装,localtime是时区文件...
分布式消息队列（MQ） 场景服务解耦 削峰填谷 异步化缓冲：最终一致性/柔性事务MQ应用思考点生产端可靠性投递 消费端幂等：消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性业界主流MQActiveMQ：适合传统需求，并发性差 RabbitMQ：扩展性差 RocketMQ：扩展性强 Kafka：扩展性强，并发性强，可靠性差技术选型性能、优缺点、业务场景 集群架构模式，分布式、可扩展、高可用、可维护性 综合成本，集群规模，人员成本 未...
原文链接：https://my.oschina.net/Raymond/blog/226063 前言 本文想介绍一下前段时间在写enode时，顺便实现的一个分布式消息队列equeue。这个消息队列的思想不是我想出来的，而是通过学习阿里的rocketmq后，自己用c#实现了一个轻量级的简单版本。一方面可以通过写这个队列让自己更深入的掌握消息队列的一些常见问题；另一方面也可以用来和enode集成，为enode中的command和domain event的消息传递提供支持。目前在.net平台，比较好...
一、什么是消息队列？1、消息就是数据。2、队列有队尾和队头，队列有入队和出队，队列先进先出。3、生产者存数据入口4、消费者取数据入口二、推模型--发布订阅模型--阻塞 主动把消息推给订阅者。数据实时要求高，用推。 三、拉模型--生产者消费者模型--非阻塞消费者自己去拉取数据。数据实时要求不高，用拉。 四、它有哪些优势？为什么使用它？可以解决一些分布式场景，如：异步场景，应用解耦，流量削峰，今天讲讲解决异步场景。 ...
消息队列的消息重复消费 消息重复消费是使用消息队列之后，必须考虑的一个问题，也是比较严重和常见的问题。比如有这样的一个场景，用户下单成功后我需要去一个活动页面给他加GMV（销售总额），最后根据他的GMV去给他发奖励，这是电商活动很常见的玩法。 类似累计下单金额到哪个梯度给你返回什么梯度的奖励这样。我只能告诉你这样的活动页面100%是用异步去加的，不然一个用户下一单就给他加一下，那就意味着对那张表就要操作一下，...