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

Ubuntu 16.04配置 RabbitMQ 服务

[日期:2018-02-21] 来源:Linux社区  作者:yangs0 [字体: ]

1.首先,添加相应的源

Ubuntu 16.04 下

echo "deb https://dl.bintray.com/rabbitmq/debian xenial main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list

在 Ubuntu 17.10 下

echo "deb https://dl.bintray.com/rabbitmq/debian artful main" | sudo tee /etc/apt/sources.list.d/bintray.rabbitmq.list

2.配置公钥

wget -O- https://www.rabbitmq.com/rabbitmq-release-signing-key.asc | sudo apt-key add -

3. 更新并安装服务

sudo apt-get update

sudo apt-get install rabbitmq-serve

安装结束后默认是运行的

invoke-rc.d rabbitmq-server stop/start  //可以运行,该代码进行开启或关闭

开启页面管理

rabbitmq-plugins enable rabbitmq_management

运行该代码即可访问 http://localhost:15672/ 进行页面管理

以上,安装RabbitMQ 服务就完成了。

RabbitMQ一些基本函数介绍

1.连接

// 连接服务,获取句柄
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
 
$connection->isConnected() or die("Cannot connect to the broker!\n");
 
$channel = $connection->channel();

2.定义

//direct:在direct类型的exchange中,只有这两个routingkey完全相同,exchange才会选择对应的binging进行消息路由。
//fanout:此exchange的路由规则很简单直接将消息路由到所有绑定的队列中,无须对消息的routingkey进行匹配操作。
//topic:此类型exchange和上面的direct类型差不多,这里的routingkey可以有通配符:'*','#' ,其中'*'表示匹配一个单词,
// '#'则表示匹配没有或者多个单词,对 key 进行模式匹配,比如 ab* 可以传递到所有 ab* 的 queue
// headers : 不常用
$channel->exchange_declare('demo', 'direct'); //声明交换机,相当于定义规则

//passive: 消极处理, 判断是否存在队列,存在则返回,不存在直接抛出 PhpAmqpLib\Exception\AMQPProtocolChannelException 异常
//durable:true、false true:在服务器重启时,能够存活
//exclusive :是否为当前连接的专用队列,在连接断开后,会自动删除该队列,生产环境中应该很少用到吧。
//autodelete:当没有任何消费者使用时,自动删除该队列
//nowait : 相当于一个async版的声明队列,可以看到是没有返回的。调完方法就结束。也不等队列创建结果
//auto_delete: 当所有消费客户端连接断开后,是否自动删除队列
//arguments: 附加参数,规则设置
$channel->queue_declare('kzae', false, false, false, false);

//队列绑定交换机
$channel->queue_bind('hello','amq.direct', 'bbb');

3.发送

//mandatory标志告诉服务器至少将该消息route到一个队列中,否则将消息返还给生产者;
//immediate标志告诉服务器如果该消息关联的queue上有消费者,则马上将消息投递给它,如果所有queue都没有消费者,
//直接把消息返还给生产者,不用将消息入队列等待消费者了
$channel->basic_publish($msg, 'amq.direct', 'bbb');

4.接收

//采用 no-ack 的方式进行确认,也就是说,每次 Consumer 接到数据后,不管是否处理完成,RabbitMQ Server 会立即把这个 Message 标记为完成,然后从 Queue 中删除
$channel->basic_consume('hello', '', false, false, false, false, $callback);

5.回调

$callback = function(PhpAmqpLib\Message\AMQPMessage $msg) {
    echo " [x] Received ", $msg->body, "\n";
 
    //delivery_info['channel']: PhpAmqpLib\Channel\AMQPChannel
    var_dump($msg->delivery_info);
    $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']); //确认ack
};

6. 结束

$channel->close();
$connection->close();

CentOS 7.2 下 RabbitMQ 集群搭建 http://www.linuxidc.com/Linux/2016-12/137812.htm 

CentOS7环境安装使用专业的消息队列产品RabbitMQ http://www.linuxidc.com/Linux/2016-11/13673.htm 

RabbitMQ入门教程  http://www.linuxidc.com/Linux/2015-02/113983.htm 

在CentOS7上安装RabbitMQ 详解  http://www.linuxidc.com/Linux/2017-05/143765.htm 

NServiceBus 结合 RabbitMQ 使用教程  http://www.linuxidc.com/Linux/2017-05/143787.htm 

CentOS 7下RabbitMQ集群安装配置  http://www.linuxidc.com/Linux/2017-10/147707.htm 

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

CentOS7上RabbitMQ安装详述  http://www.linuxidc.com/Linux/2017-12/149202.htm 

RabbitMQ分布式集群架构和高可用性(HA)  http://www.linuxidc.com/Linux/2017-12/149466.htm

CentOS 7下安装配置RabbitMQ详细教程  http://www.linuxidc.com/Linux/2018-01/150600.htm

RabbitMQ 的详细介绍请点这里
RabbitMQ 的下载地址请点这里

本文永久更新链接地址https://www.linuxidc.com/Linux/2018-02/151028.htm

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

       

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