try{
//这里是连接MQ
$conn=newAMQPConnection($config);
$res=$conn->connect();

//这里是从连接里头得到一个信道 ， 你别管这个玩意儿是啥 ， 你就这么写就好 ， 其他的先不管 。 以后你熟悉了再说 。
$ch=newAMQPChannel($conn);

//通过信道创建一个交换机 ， 这里要注意 ， 交换机名称问题不大 ， 但是type和队列名称需要重点注意 ， 不要搞错了 ， 我这里写的是消费者 ， 生成者大家有兴趣自行完成 。
$exchange=newAMQPExchange($ch);
//type是交换机类型 ， 一般你按照我写的这个写 ， 不用改
$exchange->setType(AMQP_EX_TYPE_DIRECT);
//这里是flag标记 ， 你直接这么写就好 ，
$exchange->setFlags(AMQP_AUTODELETE);
$exchange->setName('this_is_exchange');//这是交换机名称 ， 这里你可以动态创建 ， 也可以写死 。 建议写死 。
$exchange->declareExchange();//声明交换机 ，
$q=newAMQPQueue($ch);//创建队列
$q->setFlags(AMQP_AUTODELETE);//这里是flag标记 ， 你直接这么写就好 ，
$q->declareQueue();//声明队列
$q->setName(\"1SonPurchaseOrderStatus\");//设置队列名称
$q->bind($exchange->getName());//给队列绑定交换机 。
//这个consume 就是消费消息啦 ，
$q->consume(
function($envelope$queue)  {
var_dump($envelope->getBody());

AMQP_AUTOACK);$q->delete();
$exchange->delete();
$conn->disconnect();
catch(Exception$exc) {
echo$exc->getTraceAsString();
var_dump($exc->getTrace());
finally{
$q->delete();
$exchange->delete();
$conn->disconnect();

?>
以上就是一个简单的php下使用RabbitMQ的示例 。 MQ的使用本身很简单 ， 难点在于结合实际业务 。 大家如果有什么问题不懂的 ， 欢迎留言 。 我可以解答PHP java C# py 前端 ， 游戏编程 等相关的问题 ， 以及大家在平时学习工作中遇到的问题都可以说出来讨论 。

稿源：(我叫梅小春)

【傻大方】网址：/c/1122a09522021.html

标题：PHP|Windows环境PHP如何使用RabbitMQ？( 二 )