rabbitmq官网rabbitmq官网
本篇文章给大家谈谈rabbit mq官网，以及rabbitmq官网对应的知识点，文章可能有点长，但是希望大家可以阅读完，增长自己的知识，最重要的是希望对各位有所帮助，可以解决了您的问题，不要忘了收藏本站喔。
本文目录
rabbitMQ之安装和配置(一)rabbitmq命令和通过网页查看rabbit的消息队列一文带你了解RabbitMQ到底是个什么鬼!rabbitmq基础配置中文说明文档rabbitMQ之安装和配置(一)向/etc/yum.repos.d/下添加rabbitmq.repo文件
yumupdate-y
yuminstall-ymakegccgcc-c++m4opensslopenssl-develncurses-develunixODBCunixODBC-develjavajava-devel
yuminstallsocatlogrotate-y
yuminstallerlangrabbitmq-server-y
systemctlstartrabbitmq-server
RabbitMQ启动出错：-unabletoconnecttoepmdonxxxx:timeout(timedout)
因为本机主机名到IP地址的解析对应不起来；
192.168.100.251test-web2
保存退出，再次启动
设置RabbitMQ开机自启动：
systemctlenablerabbitmq-server
RabbitMQ其他操作：
rabbitmqctlstatus
rabbitmqctlstop
systemctlrestartrabbitmq-server
/etc/rabbitmq/rabbitmq.conf
rabbitmqctl:rabbitmq的客户端，用来连接管理rabbitmq；
rabbitmq-env:配置环境变量的管理者；
rabbitmq-plugins：rabbitmq后台插件管理；
rabbitmq-server：rabbitmq守护进程；
查看状态信息
1.启用网页版后台管理插件：
rabbitmq-pluginsenablerabbitmq_management
2.新建一
个用户名为admin,密码为admin的管理员，并授予管理员（administrator）权限。rabbitmqctladd_useradminadmin
rabbitmqctlset_user_tagsadminadministrator
3.设置admin可以使用的虚机权限。
添加admin虚拟机
rabbitmqctladd_vhostadmin
设置admin可以使用的虚机admin权限
rabbitmqctlset_permissions-padminadmin"."".""."
3.1用户管理
查看所有用户
rabbitmqctllist_users
添加一个用户
rabbitmqctladd_userzhaobl123456
配置权限
rabbitmqctlset_permissions-p"/"zhaobl"."".""."
查看用户权限
rabbitmqctllist_user_permissionszhaobl
设置tag
rabbitmqctlset_user_tagszhaobladministrator
删除用户（安全起见，删除默认用户）
rabbitmqctldelete_userguest
4.插件管理：
插件列表：
rabbitmq-pluginslist
启动插件：
rabbitmq-pluginsenableXXX（XXX为插件名）
停用插件：
rabbitmq-pluginsdisableXXX
5.打开后台web管理界面：http://localhost:15672/,刚才我们设置了admin用户，所以可以使用admin登录，也可以使用默认账号和密码都是guest登录。
进入管理界面后可以看到：7.其他配置
我们可以到官网地址：https://www.rabbitmq.com/configure.html，了解RabbitMQ的性能优化方面的配置。
使用Docker安装RabbitMQ
首先，我们得安装docker环境，docker环境的安装本站后面会有文章介绍，本文假设你的机器上已经安装好了docker环境。
先拉取RabbitMQ镜像：
dockerpullrabbitmq:3.8.1-management
然后查看镜像：
dockerimages
REPOSITORYTAGIMAGEIDCREATEDSIZE
rabbitmq3.8.1-management36ed80b6a1b15weeksago180MB
然后运行容器：
dockerrun--namerabbitmq-d-p5672:5672-p15672:15672-v/data:/var/lib/rabbitmqrabbitmq:3.8.1-management
最后，使用dockerps查看运行的容器。
这样，一个RabbitMQ的docker环境就装好了。
RabbitMQ技术入门与实战
https://blog.csdn.net/super_rd/category_9268807.html
rabbitmq命令和通过网页查看rabbit的消息队列1：启动
servicerabbitmq-serverstart
2：启用web管理界面
rabbitmq-pluginsenablerabbitmq_management
3：创建用户并设置权限
不知道用户和密码的可以创建用户并设置权限然后登陆网页查看
rabbitmqctladd_useradminadmin123
rabbitmqctlset_user_tagsadmin administrator
rabbitmqctlset_permissions-p/admin'.*''.*''.*'
4：登陆查看rabbit的消息状态
http://IP:15672/
5：其他命令
停止：servicerabbitmq-serverstop
启动：servicerabbitmq-serverstart
查看状态：servicerabbitmq-serverstatus
查看状态
rabbitmqctlstatus
查看用户列表
rabbitmqctllist_users
一文带你了解RabbitMQ到底是个什么鬼!MQ全程为messagequeue，即消息队列。是一种跨进程、异步通信机制、用于上下游传递消息。RabbitMQ是由Erlang语言开发，基于AMQP协议（AdvancedMessageQueuingProtocol高级消息队列协议）实现的消息队列，它是一种应用程序之间的通信方法，消息队列在实际开发应用中有着非常广泛的使用。下面主要介绍RabbitMQ的基础、架构以及在开发过程中遇到的一些常用问题，还有在面试过程中一些长问的问题。
RabbitMQ官网：https://www.rabbitmq.com
2007年Rabbit公司基于AMQP标准协议开发的RabbitMQ1.0发布。AMQP的主要特性是面向消息、队列、路由、可靠性、安全。AMQP协议更多用在企业系统内，对数据一致性、稳定性和可靠性有着很高的要求场景，对性能和吞吐量的要求在其次。
RabbitMQ基础架构如下图：
来介绍下上图中一些名词相关的概念：
RabbitMQ内置了几种常用的exchange，包含direct、topic、fanout、headers，下面主要介绍几种常用的exchange类型。
直连交换机，完全匹配路由key，所有发送到directexchange的消息会被转发到routeKey中指定的queue中。消息传递时，routeKey必须要完全匹配才会被队列接手，否则消息会被抛弃。
主题交换机，根据匹配路由规则来分发消息，#匹配一个或多个词，*匹配不多不少一个词。比如“log.#”能够匹配到“log.info.test”，“log.*”能够匹配到“log.err”。
广播交换机，不处理路由，只需要将队列绑定到交换机上，发送到交换机的消息会被转发到与该交换机绑定的所有的队列上。
RabbitMQ提供了三种模式，分别为单机模式、普通集群模式、镜像集群模式，下面分别介绍下这三种模式。
这个就是demo级别的，即单机情况不做集群，一般也就是你本地启动玩玩写写测试用的，没有人在生产用这种模式的。
多台机器上启动多个RabbitMQ实例，以两个节点（node-1，node-2）为例来进行说明。对于queue来说，消息实体只存在于其中一个节点node-1或者node-2，node-1和node-2两个节点仅有相同的元数据（即队列相关的结构）。当消息进入node-1后，consumer从node-2节点消费时，RabbitMQ会临时在node-1、node-2间进行消息传输，把A中的消息取出来并经过B在发送给consumer，所以consumer以ing改尽量连接每一个节点，从中获取消息。负责无论consumer连接node-1或者node-2，出口总在node-1，会产生瓶颈，如果当node-1节点故障后，node-2无法获取node-1的消息。如果做了持久化，那么必须要等到node-1恢复后，才能继续消费，如果消息没有做持久化，就会出小消息丢失的情况。
一般配合HAProxy配置为高可用集群，把需要的队列做成镜像队列，存在与多个节点属于RabbitMQ的HA方案。该模式解决了普通模式中的问题，其实质和普通模式不同之处在于，消息实体会主动在镜像节点间同步，而不是在客户端取数据时临时拉取。该模式带来的副作用也很明显，除了降低系统性能外，如果镜像队列数量过多，加之大量的消息进入，集群内部的网络带宽将会被这种同步通讯大大消耗掉。所以在对可靠性要求较高的场合中适用。
完成镜像队列设置之后，每各队列会被复制到各个节点，各个节点状态保持一致。因为RabbitMQ本身不提供负载均衡，需要搭建负载均衡器来提供负载转发，可以选择HAProxy和Nginx。
采用AMQP高级消息队列协议的一种消息队列技术,最大的特点就是消费并不需要确保提供方存在,实现了服务之间的高度解耦。
消息持久化，当然前提是队列必须持久化。
在消息生产时，MQ内部针对每条生产者发送的消息生成一个inner-msg-id，作为去重的依据（消息投递失败并重传），避免重复的消息进入队列；在消息消费时，要求消息体中必须要有一个bizId（对于同一业务全局唯一，如支付ID、订单ID、帖子ID等）作为去重的依据，避免同一条消息被重复消费。
将信道设置成confirm模式（发送方确认模式），则所有在信道上发布的消息都会被指派一个唯一的ID。
一旦消息被投递到目的队列后，或者消息被写入磁盘后（可持久化的消息），信道会发送一个确认给生产者（包含消息唯一ID）。
如果RabbitMQ发生内部错误从而导致消息丢失，会发送一条nack（notacknowledged，未确认）消息。
发送方确认模式是异步的，生产者应用程序在等待确认的同时，可以继续发送消息。当确认消息到达生产者应用程序，生产者应用程序的回调方法就会被触发来处理确认消息。
消费者接收每一条消息后都必须进行确认（消息接收和消息确认是两个不同操作）。只有消费者确认了消息，RabbitMQ才能安全地把消息从队列中删除。
这里并没有用到超时机制，RabbitMQ仅通过Consumer的连接中断来确认是否需要重新发送消息。也就是说，只要连接不中断，RabbitMQ给了Consumer足够长的时间来处理消息。保证数据的最终一致性；
下面列举几种特殊情况：
所以消息队列实际是一种非常复杂的架构，你引入它有很多好处，但是也得针对它带来的坏处做各种额外的技术方案和架构来规避掉，最好之后，你会发现，妈呀，系统复杂度提升了一个数量级，也许是复杂了10倍。但是关键时刻，用，还是得用的。最后希望这篇能给大家带来收获，喜欢加关注，后续持续更新！
rabbitmq基础配置中文说明文档本文为官方文档翻译版本rabbitmq3.7.5版本，原地址：https://github.com/rabbitmq/rabbitmq-server/blob/master/docs/rabbitmq.conf.example。以#开头的行为配置，key和等号以及value之间尽量保持有一个空格。以下的"默认"指的为在没有添加配置文件或者该key没有配置。
rabbitmq是使用基于tcp的amqp协议通信(如果需要ssl，可参考这里)，所以这里都是监听的tcp的端口。rabbitmq支持监听多端口，并支持指定网卡的ipv4和ipv6。格式为listeners
.tcp.${name}=${value}，name可以是任意不重复的值，如：defaul、local、local_v6等。value的格式有：(1)包括了(2)和(3)，(2)包括了(4)和(6)，(3)包括了(5)和(7)。下面对应的为其中情况的配置，按需求进行配置，不需要都配，大部分情况
只配置(1)。默认的配置为listeners.tcp.default=5672例:
接受TCP侦听器连接的Erlang进程数。一旦打开了一个使用tcp连接的套接字，它就始终保持打开状态，直至任何一方关闭它或因为一个错误而终止。在建立一个连接时，一般为每一次请求产生一个新进程，num_acceptors就是控制产生新进程的个数。假设有一个监听进程，其任务是等待传入的tcp请求。只要一个请求到达，响应该连接请求的进程就变成了接收进程。默认的配置为num_acceptors.tcp=10。
例:
AMQP0-9-1握手（socket连接和TLS握手之后）的最大时间，以毫秒为单位。
默认的配置为handshake_timeout=10000。
例:
设置为'true'以在接受一个连接时执行反DNS反查询。在rabbitmqctl中和web管理中将显示主机名称而不是IP地址。默认的配置为reverse_dns_lookups=true。
例:
开启后的效果
仅允许通过本地（即localhost）连接到代理的用户列表。如果您希望允许guest用户远程连接，则需要将其更改为loopback_users=none。
要将其他用户限制为仅限localhost的连接，请像这样执行（monitoring是用户的名称）：loopback_users.monitoring=true。默认的配置为loopback_users.guest=true。推荐设置loopback_users.guest=false。
例:
关于ssl的配置，内容比较多，参考官网。默认不配置。
选择要使用的认证/授权后端。可以配置ldap相关的设置。具体可以参考access-control。internal为由rabbitmq内部处理，默认的配置为auth_backends.1=internal。
例:
RabbitMQ具有对各种SASL认证机制的可插拔支持。服务器内置了三种这样的机制：PLAIN，AMQPLAIN和RABBIT-CR-DEMO，以及EXTERNAL可作为插件使用。您还可以通过在插件中实现rabbit_auth_mechanism行为来实现自己的身份验证机制。有关常规插件开发的更多信息，请参阅插件开发指南。默认的配置为PLAIN和AMQPLAIN。
内置的机制：
例:
有关rabbitmq-auth-mechanism-ssl插件的配置，查看:https://github.com/rabbitmq/rabbitmq-auth-mechanism-ssl
SSLhandshake超时时间,毫秒为单位。默认的配置为ssl_handshake_timeout=5000
。
例:
rabbitmq的用户的密码加密算法。修改该值只会影响新创建的用户，对应老用户需要重置密码进行更新。一般情况下不更改。默认的配置为password_hashing_module=rabbit_password_hashing_sha256。要使用SHA-512，请设置为rabbit_password_hashing_sha512。
例:
和web端的Importdefinitions、Exportdefinitions有关。好像没啥用==。
默认的用户及其权限和vhost。如果一个connect没有配置以下的配置，则使用默认值进行连接。
默认用户的tag。默认的配置default_user_tags.administrator=true。一般不需要改。
例:
heartbeat通常用来检测通信的对端是否存活（未正常关闭socket连接而异常crash）。其基本原理是检测对应的socket连接上数据的收发是否正常，如果一段时间内没有收发数据，则向对端发送一个心跳检测包，如果一段时间内没有回应则认为心跳超时，即认为对端可能异常crash了。
rabbitmq也不例外，heatbeat在客户端和服务端之间用于检测对端是否正常，即客户端与服务端之间的tcp链接是否正常。
heartbeat检测时间间隔的设置：
这里要注意的是：如果时间间隔配置为0，则表示不启用heartbeat检测。
例:
设置amqp协议最大允许的字节数。默认的配置为frame_max=131072(单位为字节，也就是128k)，注意该值不要设置过大，如果一条消息比较大(如传输文件)，可以通过PublishConfirm和ConsumerAcknowledgement机制，如设置过大，那么broker内存会容易被占完。也不要设置过小，保持在128k-1m之间。引用:使用RabbitMQ传输大文件，保证其完整性
例:
初始化时的最大字节，不知道哪里使用的。原文：Setthemaxframesizetheserverwillacceptbeforeconnectiontuningoccurs。
例:
设置每个连接的最大允许通道数量。0表示“没有限制”。默认的配置为channel_max=128。
例:
tcp连接相关的配置。尽量不要改。以下为默认的配置
例:
设置rabbitmq使用内存的阈值。有相对和绝对两种阈值。默认为vm_memory_high_watermark.relative=0.4。
队列开始将消息导出到光盘来释放内存的高水位限制的值。
例如，当vm_memory_high_watermark被设置为0.4并且该值被设置为0.5时，
可以在节点使用总可用RAM的20％时开始分页。大于1.0的值可能很危险，应谨慎使用。
一种替代方法是使用持久队列并发布消息，作为持久性。有了这个组合队列将消息更快地移动到磁盘。
另一种方法是配置队列来分页所有消息（都是持久和瞬态）到磁盘。
尽可能参阅http://rabbitmq.com/lazy-queues.html。
例:
内存使用情况报告策略。可以是以下之一，默认的配置为rss：
allocated：使用Erlang内存分配器统计信息
rss：使用操作系统RSS内存报告。这使用特定于操作系统的手段，并可能启动短暂的子进程。
legacy：使用legacy内存报告（运行时考虑使用多少内存）。这个策略相当不准确。
erlang：与legacy相同，为了向后兼容而保留
例:
根据watermarks检查内存级别。没发现具体作用。
例:
可用内存总量，不使用特定于操作系统的方式从环境中推断内存。只有当节点可用的实际最大RAM数量与节点将要推断的值不匹配时，才应使用这种方法。该值可以设置为整数个字节，或者可以以信息单位（例如“8GB”）设置。例如，当该值设置为4GB时，该节点会认为它在具有4GBRAM的计算机上运行。默认不设置该值。
例:
和vm_memory_high_watermark类似，disk_free_limit是控制硬盘的使用阈值。RabbitMQ正在存储数据的分区的磁盘可用空间限制。当可用磁盘空间低于此限制时，将触发流量控制。该值可以相对于RAM的总量或以字节或以信息单位表示的绝对值（例如"50MB"或"5GB"或"5KB"）来设置，或者，我们可以设置相对于可用RAM总量的限制。低于1.0的值可能很危险，应谨慎使用。默认为disk_free_limit.absolute=50MB。
例:
网络分裂。一种在系统的任何两个组之间的所有网络连接同时发生故障后所出现的情况。发生这种情况时，分裂的系统双方都会从对方一侧重新启动应用程序，进而导致重复服务或裂脑。由网络分裂造成的最为严重的问题是它会影响共享磁盘上的数据。默认为ignore模式。如何处理网络分裂？详细的文档可以参考官网文档
可用的模式是：
在消息中镜像同步批量大小。增加这将加快同步，但批量总大小（以字节为单位）不得超过2GiB。该设置可用于RabbitMQ3.6.0或更高版本。默认的配置为mirroring_sync_batch_size=4096(4k)。
例:
集群相关的配置，为了形成一个集群，新的（“空白”）节点需要能够发现他们的同伴。这可以使用各种机制（后端）来完成。有些机制假定所有集群成员都提前知道（例如，在配置文件中列出），其他机制是动态的（节点可以动态增删）。
内置的发现机制如下:
cluster_formation.node_type：节点类型。默认为disc。
cluster_keepalive_interval：像集群里的其他子节点发送存活消息的间隔(毫秒)。默认为cluster_keepalive_interval=10000
统计相关，与web管理插件显示有关。可配置的值如下：
例:
设置为true，以便使用HiPE预编译RabbitMQ的部分，这是Erlang的即时编译器。这会以增加启动时间为代价来提高服务器吞吐量。
您可能会看到启动时延迟几分钟的成本提高20-50％。这些数据非常依赖于工作负载和硬件。
HiPE支持可能不会编译到您的Erlang安装中。如果不是，启用此选项只会导致显示一条警告消息，启动将按正常进行。例如，Debian/Ubuntu用户需要安装erlang-base-hipe软件包。
HiPE在某些平台上完全不可用，特别包括Windows。
HiPE在17.5之前的Erlang/OTP版本中存在已知问题。HiPE强烈建议使用最新的Erlang/OTP版本。默认的配置为hipe_compile=false。
等待集群中的Mnesiatables变得可用时使用的超时。默认的配置mnesia_table_loading_retry_timeout=30000。
在等待集群中的Mnesiatables可用时，需要重试的次数。默认的配置mnesia_table_loading_retry_limit=10。
在消息的字节数中，消息将被直接嵌入到队列索引中。详情请看persistertuning。默认的配置queue_index_embed_msgs_below=4096。
是否启用后台定期强制GC为“等待”状态运行节点上的所有Erlang进程。
禁用后台GC可以减少客户端操作的延迟，保持启用状态可以减少二进制堆的RAM使用量（请参阅https://www.erlang-solutions.com/blog/erlang-garbage-collector.html）。
在尝试此选项之前，请查看内存（http://www.rabbitmq.com/memory-use.html）。
默认的配置background_gc_enabled=false，当配置为true时，可以设置gc的间隔，默认的配置为background_gc_target_interval=60000(毫秒)。
设置是否启用代理，启用后不能直连到broker。默认的配置proxy_protocol=false。
未知
有关web管理后台的配置。
查看http://www.rabbitmq.com/stomp.html。
http://www.rabbitmq.com/mqtt.html
查看https://github.com/rabbitmq/rabbitmq-amqp1.0
查看http://rabbitmq.com/ldap.html。
关于rabbit mq官网的内容到此结束，希望对大家有所帮助。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 931614094@qq.com 举报，一经查实，本站将立刻删除。