你好,游客 登录 注册 搜索
背景:
阅读新闻

RabbitMQ基础入门指南

[日期:2017-10-14] 来源:Linux社区  作者:Linux [字体: ]

  1、背景

  1)选择RabbitMQ,而不是ActiveMQ/ZeroMQ/Apache Qpid的原因:

  (1)RabbitMQ难以置信的容易安装和使用。

  (2)除了Qpid外,RabbitMQ是唯一实现了AMQP标准的代理服务器。

  (3)正是由于Erlang,RabbitMQ集群不可思议的简单。

  (4)RabbitMQ比竞争对手更可靠,更能防止崩溃。

  2、安装和运行(CentOS 7)

  1)由于RabbitMQ是采用Erlang编写的,因此需要先安装该语言库:

[root@localhost ~]# wget http://erlang.org/download/otp_src_19.1.tar.gz
...
[root@localhost ~]# tar -zxvf otp_src_19.1.tar.gz
...
[root@localhost ~]# cd otp_src_19.1/
# 若运行configure脚本时出现"No curses library functions found"错误,则执行yum install ncurses-devel
[root@localhost otp_src_19.1]# ./configure
...
[root@localhost otp_src_19.1]# make && make install
...
# erl命令输出如下信息时,表示安装成功
[root@localhost otp_src_19.1]# erl
Erlang/OTP 19 [erts-8.1] [source] [64-bit] [async-threads:10] [hipe] [kernel-poll:false]

Eshell V8.1  (abort with ^G)
1>

  2)安装RabbitMQ

  (1)从http://www.rabbitmq.com/download.html获得压缩包(如rabbitmq-server-3.6.6.tar.xz),解压得到rabbitmq-server-3.6.6目录。

  (2)进入该目录,执行make && make install。

  3)运行:

[root@localhost rabbitmq-server-3.6.6]# bash ./deps/rabbit/scripts/rabbitmq-server

              RabbitMQ 3.6.6. Copyright (C) 2007-2016 Pivotal Software, Inc.
  ##  ##      Licensed under the MPL.  See http://www.rabbitmq.com/
  ##  ##
  ##########  Logs: /var/log/rabbitmq/rabbit@localhost.log
  ######  ##        /var/log/rabbitmq/rabbit@localhost-sasl.log
  ##########
              Starting broker...
 completed with 0 plugins.

  此时可执行如下命令检查服务器状态:

# 输出代理服务器的状态、运行中的应用程序和节点等
[root@localhost rabbitmq-server-3.6.6]# bash ./deps/rabbit/scripts/rabbitmqctl status
Status of node rabbit@localhost ...
[{pid,25640},
 {running_applications,[{rabbit,"RabbitMQ","3.6.6"},
                        {mnesia,"MNESIA  CXC 138 12","4.14.1"},
                        {os_mon,"CPO  CXC 138 46","2.4.1"},
                        {rabbit_common,[],"3.6.6"},
                        {xmerl,"XML parser","1.3.12"},
                        {ranch,"Socket acceptor pool for TCP protocols.",
                              "1.2.1"},
                        {sasl,"SASL  CXC 138 11","3.0.1"},
                        {stdlib,"ERTS  CXC 138 10","3.1"},
                        {kernel,"ERTS  CXC 138 10","5.1"}]},
 {os,{unix,linux}},
... ... 

  3、基本概念

  1)AMQP:高级消息队列协议。

  从概念上来讲,AMQP消息路由必须有三部分:交换器、队列和绑定。生产者把消息发布到交换器上;消息最终到达队列,并被消费者接收;绑定决定了消息如何从路由器路由到特定的队列。

  2)信道

  你必须首先连接到Rabbit,才能消费或者发布消息。一旦TCP连接打开(通过了认证),应用程序就可以创建一条AMQP信道。信道是建立在“真实的”TCP连接内的虚拟连接。AMQP命令都是通过信道发送出去的。每条信道都会被指派一个唯一ID。

  引入信道概念的原因:主要是对操作系统来说建立和销毁TCP会话是非常昂贵的开销。在一条TCP连接上创建多条信道,而不是创建多条TCP连接,既可以满足性能方面的要求,又能确保各个信道数据的私密性,就像拥有独立连接一样。

  3)消息:包含有效载荷(payload)和标签(label)。有效载荷就是你想要传输的数据。标签描述了有效载荷,并且RabbitMQ用它来决定谁将获得消息的拷贝。

  消费者接收到的每一条消息都必须进行确认:或者通过AMQP的basic.ack命令显式发送确认,或者在订阅到队列时将auto_ack参数设置为true。

  消费者拒绝消息的方法:一、从RabbitMQ服务器断开连接。RabbitMQ将把消息重新入队并发送给另一个消费者。好处:所有RabbitMQ版本都支持。缺点:这样连接/断开连接的方式会额外增加RabbitMQ的负担。二、RabbitMQ 2.0.0或以上版本可使用AMQP的basic.reject命令。如果把reject命令的requeue参数设置为true,RabbitMQ会将消息重新发送给下一个订阅的消费者。如果设置为false,则会立即把消息从队列中移除,而不会把它发送给新的消费者(比如检测到一条格式错误的消息时)。你也可以通过对消息确认的方式来简单地忽略该消息。

  4)队列

  消费者从特定队列接收消息的方式:通过AMQP的basic.consume命令订阅;通过AMQP的basic.get命令从队列获得单条消息。

  如果队列当前无人订阅,则消息会在队列中等待。当队列拥有多个消费者时,队列收到的消息将以循环的方式发送给消费者(负载均衡)。每条消息只会发送给一个订阅的消费者。

  如何创建队列:通过AMQP的queue.declare命令。如果不指定队列名称,Rabbit会分配一个随机名称并在declare命令的响应中返回。如果消息不能丢失,则生产者和消费者都应该尝试去创建队列(发送出去的消息如果路由到了不存在的队列,Rabbit会忽略它们)。如果可以丢失,或你实现了一种方法来重新发布未处理的消息,则可以只让消费者创建队列。

  5)交换器和绑定

  生产者把消息发布到交换器上。然后,根据确定的规则(路由键),RabbitMQ将决定消息该投递到哪个队列。队列通过路由键绑定到交换器。当你把消息发送到代理服务器时,消息将拥有一个路由键(可能为空),RabbitMQ会将其和绑定使用的路由键进行匹配。如果匹配,则消息将投递到相应的队列。如果路由的消息不匹配任何绑定模式,则消息将进入“黑洞”。

  有如下四种类型的交换器,每种类型实现了不同的路由算法:

  (1)direct:如果路由键匹配,消息就被投递到对应的队列。服务器必须实现direct类型交换器,包含一个空白字符串名称的默认交换器。

  (2)fanout:把消息投递给所有附加在此交换器上的队列(广播)。

  (3)topic:使得来自不同源头的消息能够到达同一个队列。

  (4)headers:允许你匹配AMQP消息的header而非路由键。除此之外,它和direct完全一致,但性能会差很多,因此不太实用,而且几乎再也用不到了。

  6)虚拟主机(vhost):每一个RabbitMQ服务器都能创建虚拟消息服务器,我们称之为虚拟主机。

  每一个vhost本质上是一个mini版的RabbitMQ服务器,拥有自己的队列、交换器和绑定。更重要的是,它拥有自己的权限机制(AMQP并没有指定权限控制是在vhost级别还是在服务器端级别实现。这留给了服务器的开发者去决定。在RabbitMQ的例子中,权限控制以vhost为单位)。这使得你能安全地使用一个RabbitMQ服务器来服务众多应用程序,因为各个vhost实例间实现了逻辑上的分离。另外,它还能避免队列和交换器的命名冲突。

  当你在Rabbit里创建一个用户时,用户通常会被指派给至少一个vhost,并且只能访问被指派vhost内的队列、交换器和绑定。

  创建vhost:rabbitmqctl add_vhost [vhost_name]。vhost创建成功后,就可以连接上去并添加队列和交换器了。

  删除vhost:rabbitmqctl delete_vhost [vhost_name]。

  查看Rabbit服务器上运行哪些vhost:rabbitmqctl list_vhosts。 

  参考资料:

  《RabbitMQ实战:高效部署分布式消息队列》

RabbitMQ实战:高效部署分布式消息队列 中文PDF扫描版下载见   http://www.linuxidc.com/Linux/2017-10/147592.htm

 本文永久更新链接地址http://www.linuxidc.com/Linux/2017-10/147591.htm

linux
相关资讯       RabbitMQ入门  RabbitMQ基础 
本文评论   查看全部评论 (0)
表情: 表情 姓名: 字数

       

评论声明
  • 尊重网上道德,遵守中华人民共和国的各项有关法律法规
  • 承担一切因您的行为而直接或间接导致的民事或刑事法律责任
  • 本站管理人员有权保留或删除其管辖留言中的任意内容
  • 本站有权在网站内转载或引用您的评论
  • 参与本评论即表明您已经阅读并接受上述条款