面试题：为什么使用消息队列？消息队列有什么优点和缺点？Kafka、ActiveMQ、RabbitMQ、RocketMQ 都有什么区别，以及适合哪些场景？面试官心理分析其实面试官主要是想看看：第一，你知不知道你们系统里为什么要用消息队列这个东西？不少候选人，说自己项目里用了 Redis、MQ，但是其实他并不知道自己为什么要用这个东西。其实说白了，就是为了用而用，或者是别人设计的架构，他从头到尾都没思考过。没有对自己的架构问过为什么的人，...
将redis发布订阅模式用做消息队列和rabbitmq的区别：可靠性 redis ：没有相应的机制保证消息的可靠消费，如果发布者发布一条消息，而没有对应的订阅者的话，这条消息将丢失，不会存在内存中；rabbitmq：具有消息消费确认机制，如果发布一条消息，还没有消费者消费该队列，那么这条消息将一直存放在队列中，直到有消费者消费了该条消息，以此可以保证消息的可靠消费；实时性redis:实时性高，redis作为高效的缓存服务器，所有数据都...
消息队列工作流程消息队列一般有三个角色： 队列服务端 队列生产者 队列消费者 消息队列工作流程就如同一个流水线，有产品加工，一个输送带，一个打包产品 输送带就是 不停运转的消息队列服务端 加工产品的就是 队列生产者 在传输带结尾打包产品的 就是队列消费者队列产品RabbitMQ Erlang编写的消息队列产品，企业级消息队列软件，支持消息负载均衡，数据持久化等。ZeroMQ saltstack软件使用此消息，速度最快。Redis key-value的系...
概述场景服务解耦削峰填谷异步化缓冲：最终一致性/柔性事务MQ应用思考点生产端可靠性投递消费端幂等：消息只能消费一次高可用、低延迟、可靠性消息堆积能力可扩展性业界主流MQActiveMQ：适合传统需求，并发性差RabbitMQ：扩展性差RocketMQ：扩展性强Kafka：扩展性强，并发性强，可靠性差技术选型性能、优缺点、业务场景集群架构模式，分布式、可扩展、高可用、可维护性综合成本，集群规模，人员成本未来的方向、规划、思考ActiveMQ...
消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ二、消息队列应用场景以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦，流量削锋和消息通讯四个场景。2.1异步处理场景说明：用户注册后，需要发注册邮件和注册短信。传统的做法有两种 1.串行的方...
安装步骤：第一步、安装jdk环境，因为ActiveMQ是使用java语言编写。第二步、将下载好的activemq压缩包上传至Linux系统，进行解压。第三步、进入解压后的bin/目录，进行启动activemq。(关闭activemq的命令：./activemq stop)第五步、访问activemq后台管理系统，界面如下： 如果安装之后访问出错，则解决方案如下： 原文：http://www.cnblogs.com/1315925303zxz/p/6377551.html
消息中间件 --->就是消息队列异步方式：不需要立马得到结果，需要排队同步方式：需要实时获得数据，坚决不能排队例子：#多进程模块multiprocessingfrom multiprocessing import Processfrom multiprocessing import Queuedef write(q): for i in ["a", "b", "c", "d"]: q.put(i) print ("put {0} to queue".format(i)) def read(q): while 1: result = q.get() print ("get {0} from queue".for...
我们已经知道进程通信的方式是有多种的，在上一篇博客中讲述了通过管道实现简单的进程间通信，那么接下来我们看看与之类似的另一种方式，通过消息队列来实现进程间通信。什么是消息队列消息队列提供了一种由一个进程向另一个进程发送块数据的方法。另外，每一个数据块被看作有一个类型，而接收进程可以独立接收具有不同类型的数据块。消息队列的好处在于我们几乎可以完全避免同步问题，并且可以通过发送消息屏蔽有名管道的问题。更...
1、为什么要使用消息队列?主要有三个原因:解耦、异步、削峰(1)解耦传统模式:传统模式的缺点：系统间耦合性太强，如上图所示，系统A在代码中直接调用系统B和系统C的代码，如果将来D系统接入，系统A还需要修改代码，过于麻烦！中间件模式:中间件模式的的优点：将消息写入消息队列，需要消息的系统自己从消息队列中订阅，从而系统A不需要做任何修改。(2)异步传统模式:传统模式的缺点：一些非必要的业务逻辑以同步的方式运行，太耗费时...
打印了一些rabbitmq服务状态信息，包括内存，硬盘，和使用erlong的版本信息rabbitmqctl -q status 查看所有队列消息rabbitmqctl list_queues 添加用户rabbitmqctl add_user admin 123456注意：添加用户后login failed的问题，原因是未授权，还需执行下面的命令 admin赋予管理员权限rabbitmqctl set_user_tags admin administrator 添加权限rabbitmqctl set_permissions -p "/" username ".*" ".*" ".*" 列出用户权限rabbitmqctl ...
前言RabbitMQ是基于AMQP协议的，要想深入理解RabbitMQ，就必须先了解AMQP是个什么东东？AMQP协议AMQP即Advanced Message Queuing Protocol，高级消息队列协议，是面向消息中间件设计的应用层协议的一个开放标准。AMQP是一个应用层协议，可以把它类比为HTTP协议，底层都是基于TCP/IP协议的，只不过它是针对消息中间件设定的，它的设计都是为了实现在生产者和消费者中间传递消息。默认端口为5672。接下来我们来分析分析AMQP协议的设计...
消息队列允许一个或者多个进程向它写入与读取消息。Linux 维护着一个msgque 消息队列链表，其中每个元素指向一个描叙消息队列的msqid_ds 结构。当创建新的消息队列时，系统将从系统内存中分配一个msqid_ds 结构，同时将其插入到数组中。 另外，Linux 保留有关队列修改时间信息，如上次系统向队列中写入的时间等。msqid_ds 包含两个等待队列：一个为队列写入进程使用而另一个由队列读取进程使用。由于Linux 严格限制可写入消息的个...
1、安装amqp拓展 安装流程2、下载工具包 php-amqplib composer require php-amqplib/php-amqplib 3、代码操作如下 【消费消息】 1 <?php 2//配置信息 3$conn_args = array( 4 ‘host‘ => ‘127.0.0.1‘,5 ‘port‘ => ‘5672‘, 6 ‘login‘ => ‘zcw‘, 7 ‘password‘ => ‘123456‘, 8 ‘vhost‘=>‘/‘ 9); 10$e_name = ‘exchange1‘; //交换机名 11$q_name = ‘queue1‘; //队列名 12$k_route = ...
在本人的上一篇博客文章：Netty构建分布式消息队列（AvatarMQ）设计指南之架构篇 中，重点向大家介绍了AvatarMQ主要构成模块以及目前存在的优缺点。最后以一个生产者、消费者传递消息的例子，具体演示了AvatarMQ所具备的基本消息路由功能。而本文的写作目的，是想从开发、设计的角度，简单的对如何使用Netty，构建分布式消息队列背后的技术细节、原理，进行一下简单的分析和说明。 首先，在一个企业级的架构应用中，究竟何时需引...
原文：http://skaka.me/blog/2016/04/21/springcloud1/不同于单一架构应用(Monolith), 分布式环境下, 进行事务操作将变得困难, 因为分布式环境通常会有多个数据源, 只用本地数据库事务难以保证多个数据源数据的一致性. 这种情况下, 可以使用两阶段或者三阶段提交协议来完成分布式事务.但是使用这种方式一般来说性能较差, 因为事务管理器需要在多个数据源之间进行多次等待. 有一种方法同样可以解决分布式事务问题, 并且性能较好, 这...