Python隊(duì)列RabbitMQ使用方法實(shí)例記錄-創(chuàng)新互聯(lián)

本文實(shí)例講述了Python隊(duì)列RabbitMQ 使用方法。分享給大家供大家參考，具體如下：

創(chuàng)新互聯(lián)建站主營(yíng)屯昌網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,重慶APP開(kāi)發(fā),屯昌h5小程序開(kāi)發(fā)搭建,屯昌網(wǎng)站營(yíng)銷(xiāo)推廣歡迎屯昌等地區(qū)企業(yè)咨詢

目前的exchange的路由策略是：每個(gè)需要隊(duì)列的服務(wù)獨(dú)享一個(gè)隊(duì)列（queue），消費(fèi)者（consumer）采用ACK自動(dòng)應(yīng)答模式處理隊(duì)列消息。

如果需要新增一個(gè)隊(duì)列服務(wù)，需要做如下開(kāi)發(fā)步驟：

1.創(chuàng)建隊(duì)列，發(fā)送消息

<?php
$routingkey = 'key';
//設(shè)置你的連接
$conn_args = array('host' => 'localhost', 'port' => '5672', 'login' => 'guest', 'password' => 'guest');
$conn = new AMQPConnection($conn_args);
if ($conn->connect()) {
  echo "Established a connection to the broker \n";
} else {
  echo "Cannot connect to the broker \n ";
}
//你的消息
$message = json_encode(array('Hello World3!', 'php3', 'c++3:'));
//創(chuàng)建channel
$channel = new AMQPChannel($conn);
//創(chuàng)建exchange
$ex = new AMQPExchange($channel);
$ex->setName('exchange2'); //創(chuàng)建名字
$ex->setType(AMQP_EX_TYPE_DIRECT);
$ex->setFlags(AMQP_DURABLE);
echo "exchange2 status:" . $ex->declareExchange();
echo "\n";
for ($i = 0; $i < 100; $i++) {
  if ($routingkey == 'key2') {
    $routingkey = 'key';
  } else {
    $routingkey = 'key2';
  }
  $ex->publish($message, $routingkey);
}

當(dāng)前名稱(chēng)：Python隊(duì)列RabbitMQ使用方法實(shí)例記錄-創(chuàng)新互聯(lián)
當(dāng)前地址：http://muchs.cn/article26/cddsjg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站建設(shè)、網(wǎng)站維護(hù)、定制開(kāi)發(fā)、營(yíng)銷(xiāo)型網(wǎng)站建設(shè)、做網(wǎng)站、用戶體驗(yàn)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)