消息队列 - 技术教程文章
rabbitmq和redis用作消息队列的区别
将redis发布订阅模式用做消息队列和rabbitmq的区别：可靠性 redis ：没有相应的机制保证消息的可靠消费，如果发布者发布一条消息，而没有对应的订阅者的话，这条消息将丢失，不会存在内存中；rabbitmq：具有消息消费确认机制，如果发布一条消息，还没有消费者消费该队列，那么这条消息将一直存放在队列中，直到有消费者消费了该条消息，以此可以保证消息的可靠消费；实时性redis:实时性高，redis作为高效的缓存服务器，所有数据都...
【RabbitMQ】1、安装【图】
1. 下载下载地址：http://www.rabbitmq.com/download.html2. windows下安装2.1. 安装Erlang下载：http://www.erlang.org/download/otp_win64_17.3.exe安装：安装完成。2.2. 安装RabbitMQ安装完成。 启动、停止、重新安装等。2.3. 启用管理工具1、点击2、输入命令：rabbitmq-plugins enable rabbitmq_management 3、在浏览器中输入地址查看：http://127.0.0.1:15672/4、使用默认账号登录：guest/ guest 3. Linux下安装3.1. 安装...
【Liunx】消息队列rabbitmp【代码】【图】
消息队列工作流程消息队列一般有三个角色： 队列服务端 队列生产者 队列消费者 消息队列工作流程就如同一个流水线，有产品加工，一个输送带，一个打包产品 输送带就是 不停运转的消息队列服务端 加工产品的就是 队列生产者 在传输带结尾打包产品的 就是队列消费者队列产品RabbitMQ Erlang编写的消息队列产品，企业级消息队列软件，支持消息负载均衡，数据持久化等。ZeroMQ saltstack软件使用此消息，速度最快。Redis key-value的系...
[Java] 分布式消息队列（MQ）【代码】【图】
概述场景服务解耦削峰填谷异步化缓冲：最终一致性/柔性事务MQ应用思考点生产端可靠性投递消费端幂等：消息只能消费一次高可用、低延迟、可靠性消息堆积能力可扩展性业界主流MQActiveMQ：适合传统需求，并发性差RabbitMQ：扩展性差RocketMQ：扩展性强Kafka：扩展性强，并发性强，可靠性差技术选型性能、优缺点、业务场景集群架构模式，分布式、可扩展、高可用、可维护性综合成本，集群规模，人员成本未来的方向、规划、思考ActiveMQ...
python2.0_s12_day10_rabbitMQ使用介绍【代码】【图】
RabbitMQ RabbitMQ是一个在AMQP基础上完整的，可复用的企业消息系统。他遵循Mozilla Public License开源协议。 MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息（针对应用程序的数据）来通信，而无需专用连接来链接它们。消 息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此来通信，直接调用通常是用于诸如远程过程调用的技术。排队指...
关于消息队列的使用【图】
消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ二、消息队列应用场景以下介绍消息队列在实际应用中常用的使用场景。异步处理，应用解耦，流量削锋和消息通讯四个场景。2.1异步处理场景说明：用户注册后，需要发注册邮件和注册短信。传统的做法有两种 1.串行的方...
mac下安装rabbitmq【代码】
使用homebrew安装rabbitmq，命令如下：brew install rabbitmq安装的位置如下/usr/local/Cellar/rabbitmq/3.7.18进入到sbin目录下cd /usr/local/Cellar/rabbitmq/3.7.18/sbin启动rabbitmq服务./rabbitmq-server访问http://localhost:15672进入rabbitmq管理页面关闭rabbitmq服务重新打开一个终端窗口./rabbitmqctl stop配置环境变量，编辑vim ~/.bash_profile，添加如下内容export RABBITMQ_HOME=/usr/local/Cellar/rabbitmq/3.7.18 ...
linux安装rabbitMQ
安装rabbitMQ需要提前安装elarge。参考多个博客安装，各种问题，各种失败。各种依赖问题。因此把安装步骤记录下来。1.安装elarge:wget http://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm rpm -Uvh erlang-solutions-1.0-1.noarch.rpm 安装各种依赖：yum -y install unixODBC unixODBC-devel wxBase wxGTK SDL wxGTK-glyum -y install install make gcc gcc-c++ kernel-devel m4 ncurses-devel openssl op...
RabbitMQ与AMQP协议【代码】【图】
AMQP（Advanced Message Queuing Protocol, 高级消息队列协议）是一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。RabbitMQ是一个实现了AMQP协议标准的开源消息代理和队列服务器。 1、基本概念在服务器中，三个主要功能模块连接成一个处理链完成预期的功能：1）“ex...
RabbitMQ入门教程(九)：首部交换机Headers【代码】【图】
原文:RabbitMQ入门教程(九)：首部交换机Headers版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。 本文链接：https://blog.csdn.net/vbirdbest/article/details/78638988分享一个朋友的人工智能教程。比较通俗易懂，风趣幽默，感兴趣的朋友可以去看看。简介首部交换机和扇形交换机都不需要路由键routingKey,交换机时通过Headers头部来将消息映射到队列的，有点像HTTP的Head...
下载安装ActiveMQ(消息队列)【图】
安装步骤：第一步、安装jdk环境，因为ActiveMQ是使用java语言编写。第二步、将下载好的activemq压缩包上传至Linux系统，进行解压。第三步、进入解压后的bin/目录，进行启动activemq。(关闭activemq的命令：./activemq stop)第五步、访问activemq后台管理系统，界面如下： 如果安装之后访问出错，则解决方案如下： 原文：http://www.cnblogs.com/1315925303zxz/p/6377551.html
Python消息队列
消息中间件 --->就是消息队列异步方式：不需要立马得到结果，需要排队同步方式：需要实时获得数据，坚决不能排队例子：#多进程模块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...
RabbitMQ（四）RabbitMQ死信邮箱（DLX）
DLX，Dead-Letter-Exchange（死信邮箱）利用DLX，当消息在一个队列中变成死信后，它能被重新publish到另一个Exchange，这个Exchange就是DLX。消息变成死信一向有以下几种情况：消息被拒绝（basic.reject or basic.nack）并且requeue=false消息TTL过期队列达到最大长度DLX也是一下正常的Exchange同一般的Exchange没有区别，它能在任何的队列上被指定，实际上就是设置某个队列的属性，当这个队列中有死信时，RabbitMQ就会自动的将这个...
linux进程间通信之消息队列【代码】【图】
我们已经知道进程通信的方式是有多种的，在上一篇博客中讲述了通过管道实现简单的进程间通信，那么接下来我们看看与之类似的另一种方式，通过消息队列来实现进程间通信。什么是消息队列消息队列提供了一种由一个进程向另一个进程发送块数据的方法。另外，每一个数据块被看作有一个类型，而接收进程可以独立接收具有不同类型的数据块。消息队列的好处在于我们几乎可以完全避免同步问题，并且可以通过发送消息屏蔽有名管道的问题。更...
RabbitMQ（python实现）学习之一：简单两点传输“Hello World”的实现【代码】【图】
一.基本配置注意 RabbitMQ支持python、Java、Ruby、PHP、C#等语言的支持，本博客主要是针对python讲解。本博客安装配置是基于ubuntu系统的。1.1安装配置epel源$ rpm -Uvh http://dl.fedoraproject.org/pub/ ... ease-6-8.noarch.rpm1.2安装erlang$: yum -y install erlang 或者$:sudo apt-get install erlang1.3安装rabbitmq-server$: yum -y install rabbitmq-server 或者$: sudo apt-get install rabbitmq-server1.4启动/停止ra...
分布式之消息队列【图】
1、为什么要使用消息队列?主要有三个原因:解耦、异步、削峰(1)解耦传统模式:传统模式的缺点：系统间耦合性太强，如上图所示，系统A在代码中直接调用系统B和系统C的代码，如果将来D系统接入，系统A还需要修改代码，过于麻烦！中间件模式:中间件模式的的优点：将消息写入消息队列，需要消息的系统自己从消息队列中订阅，从而系统A不需要做任何修改。(2)异步传统模式:传统模式的缺点：一些非必要的业务逻辑以同步的方式运行，太耗费时...
消息队列系列（四）：Rabbitmq常用命令行
打印了一些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 service is already present - only updating service parameters
C:\Users\Administrator>rabbitmq-service installRabbitMQ service is already present - only updating service parameters C:\Program Files\erl5.10.3\erts-5.10.3\bin\erlsrv: Warning, could not set correct interactive mode. Error: 句柄无效。C:\Program Files\erl5.10.3\erts-5.10.3\bin\erlsrv: Warning, could not set correct service description (comment)Error: 句柄无效。C:\Users\Administrator>rabbitmq-servi...
Windows10安装RabbitMQ【代码】
一、简介 RabbitMQ是流行的开源消息队列系统，用erlang语言开发。RabbitMQ是AMQP（高级消息队列协议）的标准实现。二、安装 1、安装erlang环境，下载安装包，网址：http://erlang.org/download/，如我下载的版本是：otp_win64_20.2.exe 安装比较简单，双击安装包，然后一直点击下一步，需要权限提示点击是即可。 2、安装RabbitMQ，下载安装包，网站：http://www.rabbitmq.com/install-windows.html，如我下载的版...
电商项目实战（架构八）——RabbitMQ实现延迟消息【代码】【图】
一、前言 RabbitMQ是一个开源的消息队列，轻量级且易于部署，并支持多种消息协议。RabbitMQ可以部署在分布式和联合配置中，以满足高规模、高可用性的需求。本文整合RabbitMQ实现延迟消息的过程，以发送延迟消息取消超时订单为例.二、RabbitMQ的安装和使用 1、安装Erlang，下载地址：http://erlang.org/download/otp_win_64_21.3.exe 2、安装RabbitMQ，下载地址：https://dl.bintray.com/rabbitmq/all/rabbitmq-server/3.7...
windows rabbitmq 安装
下载 otp_win64_19.1 下载 rabbitmq-server-3.6.5环境变量 设置 path D:\Program Files\erl8.1\binD:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.5\sbin> rabbitmq-plugins enable rabbitmq_management D:\Program Files\RabbitMQ Server\rabbitmq_server-3.6.5\sbin>rabbitmq-service start stop 原文：http://www.cnblogs.com/kedoudejingshen/p/6512746.html
RabbitMQ原理介绍【图】
RabbitMQ历史RabbitMQ消息系统是一个由erlang开发的AMQP（Advanced Message Queue ）的开源实现。在同步消息通讯的世界里有很多公开标准（如COBAR的IIOP，或者是SOAP等），但是在异步消息处理中却不是这样，只有大企业有一些商业实现（如微软的MSMQ ，IBM的Websphere MQ等），因此，在2006年的6月，Cisco 、Redhat、iMatix 等联合制定了AMQP的公开标准。RabbitMQ是由RabbitMQ Technologies Ltd开发并且提供商业支持的。该公司在201...
linux下安装RabbitMQ【代码】
1.安装erlang因为RabbitMQ是基于erlang语言开发的，所以想要安装RabbitMQ之前必须要安装erlang语言yum install erlang如报错No package erlang available，需要安装EPEL库（1）下载wget http://dl.fedoraproject.org/pub/epel/6/x86_64/epel-release-6-8.noarch.rpm如果没有安装wget，可以先安装 yum -y install wget（2）安装rpm -ivh epel-release-6-8.noarch.rpm2.安装RabbitMQ rpm包（1）下载rpm包wget http://www.rabbitmq.co...
rabbitmq部署【图】
参考原文 https://www.cnblogs.com/saryli/p/9729591.htmlrabbitmq的安装与erlang的版本有关，我本地安装的是rabbitmq 3.8.9,与erlang23.1，最好版本保持一致，或者仔细阅读官方的支持文档，否则可能造成不必要的问题。有些图我并未截图，所以用了原教程的图，细微差别，不影响安装。第一步：下载并安装erlang原因：RabbitMQ服务端代码是使用并发式语言Erlang编写的，安装Rabbit MQ的前提是安装Erlang。下载地址：http://www.erlan...
RabbitMQ安装使用（直接交换direct exchange）
原文：http://yuwenlin.iteye.com/blog/2204966
RabbitMQ【代码】【图】
RabbitMQ安装docker# 下载镜像docker pull rabbitmq # 运行镜像 docker run -d --name my-rabbitmq -p 4369:4369 -p 5671:5671 -p 5672:5672 -p 25672:25672 rabbitmqwindows安装Erlanghttp://www.erlang.org/downloads 下载otp_winxx_{版本}.exe安装并配置环境变量%ERLANG_HOME%\bin安装RabbitMqhttps://www.rabbitmq.com/install-windows.html官网下载rabbitmq-server-{版本}.exe关键词Producer：生产者Consumer：消费者Channel：...
消息队列RabbitMQ（二）：RabbitMQ的系统架构概述【图】
前言RabbitMQ是基于AMQP协议的，要想深入理解RabbitMQ，就必须先了解AMQP是个什么东东？AMQP协议AMQP即Advanced Message Queuing Protocol，高级消息队列协议，是面向消息中间件设计的应用层协议的一个开放标准。AMQP是一个应用层协议，可以把它类比为HTTP协议，底层都是基于TCP/IP协议的，只不过它是针对消息中间件设定的，它的设计都是为了实现在生产者和消费者中间传递消息。默认端口为5672。接下来我们来分析分析AMQP协议的设计...
Python【10】【网络编程】- Memcache、Redis、RabbitMQ、SQLAlchemy【代码】【图】
知识参鉴：百度百科、Mr.7Memcached1、基础认知Memcached 是一个高性能的分布式内存对象缓存系统，用于动态Web应用以减轻数据库负载。它通过在内存中缓存数据和对象来减少读取数据库的次数，从而提高动态、数据库驱动网站的速度。Memcached基于一个存储键/值对的hashmap。其守护进程（daemon ）是用C写的，但是客户端可以用任何语言来编写，并通过memcached协议与守护进程通信。 2、安装使用（1）安装wget http://memcached.org/la...
消息队列
消息队列允许一个或者多个进程向它写入与读取消息。Linux 维护着一个msgque 消息队列链表，其中每个元素指向一个描叙消息队列的msqid_ds 结构。当创建新的消息队列时，系统将从系统内存中分配一个msqid_ds 结构，同时将其插入到数组中。 另外，Linux 保留有关队列修改时间信息，如上次系统向队列中写入的时间等。msqid_ds 包含两个等待队列：一个为队列写入进程使用而另一个由队列读取进程使用。由于Linux 严格限制可写入消息的个...
虚拟机Ubuntu 18.04安装RabbitMQ 3.7.9【图】
Windows 10家庭中文版，VirtualBox，Ubuntu 18.04，Rabbitmq 3.7.9，Erlang/OTP 20 [erts-9.2]， 在虚拟机上装好了Ubuntu，写了一个一对一的Spring Boot程序，成功发送、接收消息，本文为记录这个过程——第一次用rabbitmq。 这次用的是deb包安装，后面可以使用apt工具安装下。 下载安装包后，双击即可开始安装：安装成功。 第一次写的程序执行失败了，因为，新建用户admin没有虚拟机的权限：添加后执行成功。 命令：ps auxnetstat...