关注Linux 及系统架构: 06/13/13

2013年6月13日星期四

使用 Yum 搜索、罗列和显示软件包信息

使用 yum search <term> [more_terms] 命令，能够在已启用的软件包仓库中，对所有软件包的名称、描述和概述中进行搜索，最后，yum 会以显示符合合条件的搜索结果列表。

[lugir@hope ~]$ yum search totem
已加载插件：presto, refresh-packagekit, security
================================ Matched: totem ================================
gnome-python2-totem.i686 : 用于和 totem 交流的 python 绑定
oggconvert.noarch : Convert media files to Free formats
totem.i686 : Movie player for GNOME
totem-devel.i686 : Plugin writer's documentation for %{package}
totem-jamendo.i686 : Jamendo plugin for Totem
totem-lirc.i686 : LIRC (Infrared remote) plugin for Totem
totem-mozplugin.i686 : Mozilla plugin for Totem
totem-mythtv.i686 : MythTV plugin for Totem
totem-nautilus.i686 : Video and Audio Properties tab for Nautilus
totem-pl-parser.i686 : Totem Playlist Parser library
totem-pl-parser-devel.i686 : Development files for totem-pl-parser
totem-publish.i686 : Share your playlist with other Totems on the local network
totem-upnp.i686 : UPNP/DLNA plugin for Totem
totem-youtube.i686 : YouTube plugin for Totem
如果你不记得软件包的确切名称，但了解软件包的某些相关名词时，yum search 命令能够有效地帮助你找到想要的软件包。

软件包列表
yum list 以及相关的一些命令则能够为你提供有关软件包、软件包集和软件仓库的信息。

所有的 yum list 命令都能够使用 glob 表达式作为参数，对输出结果进行过滤。在 glob 表达式中，你可以使用 * 代表任何数量个字符，使用 ? 代表任何一个字符。通过后面的示例，你可以对 glob 表达式有些简单的认识。
yum list <glob_expr> [more_glob_exprs] ── 列出所有符合 glob 表达式的软件包
yum list all ── 列出所有已安装的和可用的软件包
yum list installed ── 列出所有已经安装在系统中的软件包。输出结果的最右边一列是取得该软件包的软件仓库。标识为 installed 的软件包则说明它是做为系统基本组件而预安装的。
yum list available ── 列出所有启用的软件仓库中可用的软件包
yum grouplist ── 列出所有软件包组
yum repolist ── 列出所有启用的软件仓库的 ID，名称及其包含的软件包的数量
查看软件包信息

使用 yum info <package_name> [more_names] 命令可查看一个或多个软件包的信息 (此处同样可以应用 glob 表达式)。

[lugir@hope ~]$ yum info totem
已加载插件：presto, refresh-packagekit, security
已安装的软件包
名称 : totem
架构 : i686
版本 : 2.28.5
次要版本 : 1.fc12
大小 : 7.9 M
仓库 : installed
From repo : updates
摘要 : Movie player for GNOME
URL : http://projects.gnome.org/totem/
授权方式 : GPLv2+ with exceptions
描述 : Totem is simple movie player for the GNOME desktop. It features
: a simple playlist, a full-screen mode, seek and volume controls,
: as well as a pretty complete keyboard navigation.
:
: Totem is extensible through a plugin system.
yum info <package_name> 与 rpm -q --info <package_name> 命令十分相似，不过 yum 还能够提供软件包的软件仓库来源信息 (即输出结果中的 From repo 行)。

RabbitMQ集群环境生产实例部署

原创作品，允许转载，转载时请务必以超链接形式标明文章原始出处、作者信息和本声明。否则将追究法律责任。http://opsmysql.blog.51cto.com/2238445/1030832

生产环境：

CentOS 6.3 x86_64

服务器主机名与IP列表：

mq136 172.28.2.136
mq137 172.28.2.137
mq164 172.28.2.164
mq165 172.28.2.165

在各节点服务器上作好hosts解析


cat >>/etc/hosts/<<EOF 
mq136      172.28.2.136 
mq137      172.28.2.137 
mq164      172.28.2.164 
mq165      172.28.2.165 
EOF

一、简介
RabbitMQ是流行的开源消息队列系统，用erlang语言开发。Erlang的分布式通讯安全策略，可以归结为 All or None。。RabbitMQ是AMQP（高级消息队列协议）的标准实现。RabbitMQ的结构图如下：

几个概念说明：

Broker：简单来说就是消息队列服务器实体。
Exchange：消息交换机，它指定消息按什么规则，路由到哪个队列。
Queue：消息队列载体，每个消息都会被投入到一个或多个队列。
Binding：绑定，它的作用就是把exchange和queue按照路由规则绑定起来。
Routing Key：路由关键字，exchange根据这个关键字进行消息投递。
vhost：虚拟主机，一个broker里可以开设多个vhost，用作不同用户的权限分离。
producer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。
channel：消息通道，在客户端的每个连接里，可建立多个channel，每个channel代表一个会话任务。

消息队列的使用过程大概如下：

（1）客户端连接到消息队列服务器，打开一个channel。
（2）客户端声明一个exchange，并设置相关属性。
（3）客户端声明一个queue，并设置相关属性。
（4）客户端使用routing key，在exchange和queue之间建立好绑定关系。
（5）客户端投递消息到exchange。

exchange接收到消息后，就根据消息的key和已经设置的binding，进行消息路由，将消息投递到一个或多个队列里。

exchange也有几个类型，完全根据key进行投递的叫做Direct交换机，例如，绑定时设置了routing key为”abc”，那么客户端提交的消息，只有设置了key为”abc”的才会投递到队列。对key进行模式匹配后进行投递的叫做Topic交换机，符号”#”匹配一个或多个词，符号”*”匹配正好一个词。例如”abc.#”匹配”abc.def.ghi”，”abc.*”只匹配”abc.def”。还有一种不需要key的，叫做Fanout交换机，它采取广播模式，一个消息进来时，投递到与该交换机绑定的所有队列。

RabbitMQ支持消息的持久化，也就是数据写在磁盘上，为了数据安全考虑，我想大多数用户都会选择持久化。消息队列持久化包括3个部分：
（1）exchange持久化，在声明时指定durable => 1（2）queue持久化，在声明时指定durable => 1（3）消息持久化，在投递时指定delivery_mode => 2（1是非持久化）

如果exchange和queue都是持久化的，那么它们之间的binding也是持久化的。如果exchange和queue两者之间有一个持久化，一个非持久化，就不允许建立绑定。

下面我们再了解下消息队列RabbitMQ集群,由于RabbitMQ是用erlang开发的，RabbitMQ 完全依赖 Erlang 的Cluster，而Erlang集群非常方便，因此配置RabbitMQ集群变得非常简单。

RabbitMQ的集群节点包括内存节点、磁盘节点。顾名思义内存节点就是将所有数据放在内存，磁盘节点将数据放在磁盘。不过，如前文所述，如果在投递消息时，打开了消息的持久化，那么即使是内存节点，数据还是安全的放在磁盘。

良好的设计架构可以如下：在一个集群里，有3台以上机器，其中1台使用磁盘模式，其它使用内存模式。其它几台为内存模式的节点，无疑速度更快，因此客户端（consumer、producer）连接访问它们。而磁盘模式的节点，由于磁盘IO相对较慢，因此仅作数据备份使用。

二、各节点安装rabbitmq

安装非常简单，只需几步搞定：

1. 安装epel源


rpm -ivh http://download.fedoraproject.org/pub/epel/6/x86_64/epel-release-6-7.noarch.rpm 
wget -O /etc/yum.repos.d/epel-erlang.repo http://repos.fedorapeople.org/repos/peter/erlang/epel-erlang.repo

2. 安装erlang


yum install erlang xmlto git -y 
rpm --import http://www.rabbitmq.com/rabbitmq-signing-key-public.asc

3. 安装rabbitmq

可以选择用yum安装，也可以选择下载rpm包安装，也可以用源码编译安装！

下载地址： http://www.rabbitmq.com/download.html

本文选择rpm包安装：


wget http://www.rabbitmq.com/releases/rabbitmq-server/v2.8.6/rabbitmq-server-2.8.6.noarch.rpm 
rpm -ivh  rabbitmq-server-2.8.6.noarch.rpm

4. 启动各节点rabbitmq，并验证启动情况


[root@mq136 ~]# rabbitmq-server --detached & 
 
[root@mq136 ~]# ps aux |grep rabbitmq 
 
rabbitmq  1394  0.0  0.0  10828   540 ?        S    Oct08   0:11 /usr/lib64/erlang/erts-5.8.5/bin/epmd -daemon 
 
root      2483  0.0  0.0 103244   836 pts/1    S+   17:40   0:00 grep rabbitmq 
 
rabbitmq  5657  6.3  1.9 2224044 157200 ?      Sl   Oct08 959:17 /usr/lib64/erlang/erts-5.8.5/bin/beam.smp -W w -K true -A30 -P 1048576 -- -root /usr/lib64/erlang -progname erl -- -home /var/lib/rabbitmq -- -noshell -noinput -sname rabbit@mq136 -boot /var/lib/rabbitmq/mnesia/rabbit@mq136-plugins-expand/rabbit -kernel inet_default_connect_options [{nodelay,true}] -sasl errlog_type error -sasl sasl_error_logger false -rabbit error_logger {file,"/var/log/rabbitmq/rabbit@mq136.log"} -rabbit sasl_error_logger {file,"/var/log/rabbitmq/rabbit@mq136-sasl.log"} -os_mon start_cpu_sup false -os_mon start_disksup false -os_mon start_memsup false -mnesia dir "/var/lib/rabbitmq/mnesia/rabbit@mq136" -noshell -noinput 
 
rabbitmq  5698  0.0  0.0  10788   520 ?        Ss   Oct08   0:00 inet_gethost 4 
 
rabbitmq  5699  0.0  0.0  12892   692 ?        S    Oct08   0:00 inet_gethost 4 
 
rabbitmq 11446  0.0  0.0  12892   680 ?        S    Oct13   0:00 inet_gethost 4 
 
[root@mq136 ~]# lsof -i:5672 
 
COMMAND   PID     USER   FD   TYPE  DEVICE SIZE/OFF NODE NAME 
 
beam.smp 5657 rabbitmq   18u  IPv4 5879364      0t0  TCP *:amqp (LISTEN)

三、集群配置

集群环境说明：

mq136作为磁盘节点，其它所有节点都作为内存节点！

1. 在各节点创建加入集群脚本


mq136:  
cat >>/home/zjqui/scripts/cluster.sh<<EOF 
rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl cluster  
rabbitmqctl start_app 
EOF 
 
mq137: 
cat >>/home/zjqui/scripts/cluster.sh<<EOF 
rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl cluster rabbit@mq136 
rabbitmqctl start_app 
EOF 
 
mq164: 
cat >>/home/zjqui/scripts/cluster.sh<<EOF 
rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl cluster rabbit@mq136 
rabbitmqctl start_app 
EOF 
 
mq165: 
cat >>/home/zjqui/scripts/cluster.sh<<EOF 
rabbitmqctl stop_app 
rabbitmqctl reset 
rabbitmqctl cluster rabbit@mq136 
rabbitmqctl start_app 
EOF

2. 各节点加入集群环境


[root@mq136 ~]# chmod +x /home/zjqui/scripts/cluster.sh

启动脚本顺序：先运行mq136节点集群脚本，然后再运行其它节点集群脚本:


[root@mq136 ~]# /home/zjqui/scripts/cluster.sh

各节点运行成功后，查看集群整体状态：


[root@mq136 ~]# rabbitmqctl cluster_status 
 
Cluster status of node rabbit@mq136 ... 
 
[{nodes,[{disc,[rabbit@mq136]}, 
 
         {ram,[rabbit@mq165,rabbit@mq164,rabbit@mq137]}]}, 
 
 {running_nodes,[rabbit@mq164,rabbit@mq165,rabbit@mq137,rabbit@mq136]}] 
 
...done.

可以看到mq136作为disc节点，其它节点是ram节点！集群简单配置到此完成！！

RabbitMQ官方中文入门教程(PHP版) 第四部分:路由(Routing)

路由(Routing)

在前面的教程中，我们实现了一个简单的日志系统。可以把日志消息广播给多个接收者。

本篇教程中我们打算新增一个功能——使得它能够只订阅消息的一个字集。例如，我们只需要把严重的错误日志信息写入日志文件（存储到磁盘），但同时仍然把所有的日志信息输出到控制台中

绑定（Bindings）

前面的例子，我们已经创建过绑定（bindings），代码如下：

`1`	`$exchange->publish($message,` `'');`

绑定（binding）是指交换器（exchange）和队列（queue）的关系。可以简单理解为：这个队列（queue）对这个交换器（exchange）的消息感兴趣。

绑定的时候可以带上一个额外的routing_key参数。为了避免与basic_publish的参数混淆，我们把它叫做binding key。以下是如何创建一个带binding key的绑定。

`1`	`$exchange->publish($message,` `$routeKey);`

binding key的含义取决于交换器（exchange）的类型。我们之前使用过的fanout类型会忽略这个值。

Direct类型的交换器（exchange）

我们的日志系统广播所有的消息给所有的消费者（consumers）。我们打算扩展它，使其可以能够精确的过滤消息。例如我们也许值是希望当接收到一个严重的错误的时候才把消息写入磁盘，以免浪费磁盘空间。

我们使用的fanout类型的交换器（exchange）扩展性不够——它能做的仅仅是广播。

我们将会使用direct类型的交换器（exchange）来代替。路由的算法很简单——交换器将会对binding key和routing key进行精确匹配，从而确定消息该分发到哪个队列。

下图能够很好的描述这个场景：

在这个场景中，我们可以看到direct exchange X和两个队列绑定了。第一个队列使用orange作为binding key，第二个队列有两个绑定，一个使用black作为binding key，另外一个是green。

这样以来，当routing key为orange的消息发布到交换器（exchange），就会被路由到队列Q1。routing key为black或者green的消息就会路由到Q2。其他的所有消息都将会被丢弃。

多个绑定（Multiple bindings）

多个队列使用相同的binding key是合法的。我们的这个例子，我们可以添加一个X和Q1之间的绑定，使用blackbinding key。这样一来，direct交换器就和fanout交换器的行为一样，将会广播消息到所有匹配的队列。带有routing key为black的消息都会发送到Q1和Q2。

Emitting logs

我们将会发送消息到一个direct exchange，把日志级别作为routing key。这样子负责处理接收的脚本就可以选择它要处理的日志级别。我们先看看触发日志。

我们需要创建一个交换器（exchange）：

`1`	`$exchange->setName('direct_logs');`

然后我们发送一则消息：

`1`	`$exchange->publish($message,` `$severity);`

我们先假设“severity”的值是info、warning、error中的一个。

订阅（Subscribing）

处理接收消息的方式和之前差不多，但是我们为每一个日志级别创建了一个新的绑定。

1foreach ($severities as $item) {

2$queue-&gt;bind($exchangeName, $item);

3}

整合

emit_log_direct.py的代码：

01<?php

02 

03/**

04 * PHP amqp(RabbitMQ) Demo-4

05 * @author  yuansir <yuansir@live.cn/yuansir-web.com>

06 */

07$severity = count($argv) > 2 ? $argv[1] : 'info';

08$message = empty($argv[2]) ? 'Hello World!' : ' ' . $argv[2];

09 

10$connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest'));

11$connection->connect() or die("Cannot connect to the broker!\n");

12 

13$channel = new AMQPChannel($connection);

14$exchange = new AMQPExchange($channel);

15$exchange->setName('direct_logs');

16$exchange->setType(AMQP_EX_TYPE_DIRECT);

17$exchange->declare();

18 

19$exchange->publish($message, $severity);

20var_dump("[x] Sent $message");

21 

22$connection->disconnect();

receive_logs_direct.py的代码：

01<?php

02 

03/**

04 * PHP amqp(RabbitMQ) Demo-4

05 * @author  yuansir <yuansir@live.cn/yuansir-web.com>

06 */

07$exchangeName = 'direct_logs';

08 

09$connection = new AMQPConnection(array('host' => '127.0.0.1', 'port' => '5672', 'vhost' => '/', 'login' => 'guest', 'password' => 'guest'));

10$connection->connect() or die("Cannot connect to the broker!\n");

11$channel = new AMQPChannel($connection);

12$exchange = new AMQPExchange($channel);

13$exchange->setName($exchangeName);

14$exchange->setType(AMQP_EX_TYPE_DIRECT);

15$exchange->declare();

16$queue = new AMQPQueue($channel);

17$queue->setFlags(AMQP_EXCLUSIVE);

18$queue->declare();

19 

20$severities = $argv;

21$file = $severities[0];

22unset($severities[0]);

23if (!$severities) {

24        var_dump("Usage:$file [info] [warning] [error]");

25        exit();

26} else {

27        foreach ($severities as $item) {

28                $queue->bind($exchangeName, $item);

29        }

30}

31 

32var_dump('[*] Waiting for messages. To exit press CTRL+C');

33while (TRUE) {

34        $queue->consume('callback');

35}

36$connection->disconnect();

37 

38function callback($envelope, $queue) {

39        $msg = $envelope->getBody();

40        var_dump('[x]' . $envelope->getRoutingKey() . ':' . $msg);

41        $queue->nack($envelope->getDeliveryTag());

42}

如果你希望只是保存warning和error级别的日志到磁盘，只需要打开控制台并输入：

`1`	`$ php receive_logs_direct.php warning error > logs_from_rabbit.log`

如果你希望所有的日志信息都输出到屏幕中，打开一个新的终端，然后输入：

1$ php receive_logs_direct.php info warning error

2 [*] Waiting for logs. To exit press CTRL+C

如果要触发一个error级别的日志，只需要输入：

1$ php emit_log_direct.php error "Run. Run. Or it will explode."

2 [x] Sent 'error':'Run. Run. Or it will explode.'

（转载请标明出处:Yuansir-web菜鸟-LAMP学习笔记:PHP版 RabbitMQ官方中文入门教程

订阅：博文 (Atom)

关注Linux 及系统架构

页面