认识达内从这里开始

昆明达内培训的老师今天给大家分享，connection与channel：连接与信道

connection是指物理的连接，一个client与一个server之间有一个连接；一个连接上可以建立多个channel，可以理解为逻辑上的连接。一般应用的情况下，有一个channel就够用了，不需要创建更多的channel。示例代码：

//创建连接和channel

$conn = new AMQPConnection($conn_args);  

if (!$conn->connect()) {  

die("Cannot connect to the broker!\n");  

}  

$channel = new AMQPChannel($conn); 

##3，exchange与 routingkey：交换机与路由键##

为了将不同类型的消息进行区分，设置了交换机与路由两个概念。比如，将A类型的消息发送到名为‘C1’的交换机，将类型为B的发送到'C2'的交换机。当客户端连接C1处理队列消息时，取到的就只是A类型消息。进一步的，如果A类型消息也非常多，需要进一步细化区分，比如某个客户端只处理A类型消息中针对K用户的消息，routingkey就是来做这个用途的。

$e_name = 'e_linvo'; //交换机名

$k_route = array(0=> 'key_1', 1=> 'key_2'); //路由key

//创建交换机   

$ex = new AMQPExchange($channel);  

$ex->setName($e_name);

$ex->setType(AMQP_EX_TYPE_DIRECT); //direct类型 

$ex->setFlags(AMQP_DURABLE); //持久化

echo "Exchange Status:".$ex->declare()."\n";  

for($i=0; $i<5; ++$i){

echo "Send Message:".$ex->publish($message . date('H:i:s'), $k_route[i%2])."\n"; 

}

由以上代码可以看到，发送消息时，只要有“交换机”就够了。至于交换机后面有没有对应的处理队列，发送方是不用管的。routingkey可以是空的字符串。在示例中，我使用了两个key交替发送消息，是为了下面更便于理解routingkey的作用。

对于交换机，有两个重要的概念：

A，类型。有三种类型：Fanout类型最简单，这种模型忽略routingkey；Direct类型是使用最多的，使用确定的routingkey。这种模型下，接收消息时绑定'key_1'则只接收key_1的消息；最后一种是Topic，这种模式与Direct类似，但是支持通配符进行匹配，比如：'key_*'，就会接受key_1和key_2。Topic貌似美好，但是有可能导致不严谨，所以还是推荐使用Direct。

B，持久化。指定了持久化的交换机，在重新启动时才能重建，否则需要客户端重新声明生成才行。

需要特别明确的概念：交换机的持久化，并不等于消息的持久化。只有在持久化队列中的消息，才能持久化；如果没有队列，消息是没有地方存储的；消息本身在投递时也有一个持久化标志的，PHP中默认投递到持久化交换机就是持久的消息，不用特别指定。

了解详情请登陆昆明达内IT培训官网（km.tedu.cn）！