php amqp 消息队列 RabbitMQ 交换器类型 直连 (三)
1、AMQP_EX_TYPE_DIRECT:直连型
直连型又包括: 1对1 和1对N(N对1、 N对N)接收端receive.php代码如下
<?php $connect = new AMQPConnection(); $connect->connect(); $channel = new AMQPChannel($connect); $exchange = new AMQPExchange($channel); $exchange->setName('exchange'); $exchange->setType(AMQP_EX_TYPE_DIRECT); $exchange->declare(); $queue = new AMQPQueue($channel); $queue->setName('logs'); $queue->declare(); $queue->bind('exchange', 'logs'); while (true) { $queue->consume('callback'); } $connection->close(); function callback($envelope, $queue) { var_dump($envelope->getBody()); $queue->nack($envelope->getDeliveryTag()); }
发送端send.php代码如下
<?php $connect = new AMQPConnection(); $connect->connect(); $channel = new AMQPChannel($connect); $exchange = new AMQPExchange($channel); $exchange->setName('exchange'); $exchange->setType(AMQP_EX_TYPE_DIRECT); $exchange->declare(); $exchange->publish('direct type test','logs'); var_dump("Send Message OK"); $connect->disconnect();
运行结果如图所示
创建receive_one.php和receive_two.php 并把send.php代码改成如下代码方便我们观看 receive_one.php 和 receive_two.php 代码相同 或者用dos运行多个接收端
<?php $connect = new AMQPConnection(); $connect->connect(); $channel = new AMQPChannel($connect); $exchange = new AMQPExchange($channel); $exchange->setName('exchange'); $exchange->setType(AMQP_EX_TYPE_DIRECT); $exchange->declare(); $queue = new AMQPQueue($channel); $queue->setName('logs'); @$queue->declare(); $queue->bind('exchange', 'logs'); while (true) { $queue->consume('callback'); } $connection->close(); function callback($envelope, $queue) { var_dump($envelope->getBody()); $queue->nack($envelope->getDeliveryTag()); }
send.php
<?php $connect = new AMQPConnection(); $connect->connect(); $channel = new AMQPChannel($connect); $exchange = new AMQPExchange($channel); $exchange->setName('exchange'); $exchange->setType(AMQP_EX_TYPE_DIRECT); $exchange->declare(); for ($index = 1; $index < 5; $index++) { $exchange->publish($index,'logs'); var_dump("Send:$index"); } $exchange->delete(); $connect->disconnect();
运行结果如下
列队会把消息分配给每一个接收端分配处理这里看似完美但是如果想要更好的处理不同的任务就需要 公平调度
比如当1、3处理的都是简单的人 2、4都是处理的复杂的任务 如果任务过多时 receive_one.php是空闲的而receive_two.php是任务繁重的 我们进行如下测试 send.php改成5改成50
for ($index = 1; $index < 50; $index++) { $exchange->publish($index,'logs'); var_dump("Send:$index"); }
receive_two.php 加上 sleep(3)
function callback($envelope, $queue) { var_dump($envelope->getBody()); sleep(3); $queue->nack($envelope->getDeliveryTag()); }
我们运行程序结果如下
receive_one全部运行完而receive_two才运行一个 之后receive_one一直空闲 我们可以通过 在接收端设置 $channel->setPrefetchCount(1);
任务没人完成前不接收新的消息把消息发送给其他接收端
如下receive_one.php 和 receive_two.php
$channel = new AMQPChannel($connect);
$channel = new AMQPChannel($connect); $channel->setPrefetchCount(1);

熱AI工具

Undresser.AI Undress
人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool
免費脫衣圖片

Clothoff.io
AI脫衣器

Video Face Swap
使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

熱工具

記事本++7.3.1
好用且免費的程式碼編輯器

SublimeText3漢化版
中文版,非常好用

禪工作室 13.0.1
強大的PHP整合開發環境

Dreamweaver CS6
視覺化網頁開發工具

SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)

如何在iPhone上使用滑動在iMessages中回覆注意:滑動回應功能僅適用於iOS17中的iMessage對話,不適用於「訊息」應用程式中的常規SMS對話。在iPhone上開啟「訊息」應用程式。然後,前往iMessage對話,只需在您要回覆的iMessage上向右滑動即可。完成此操作後,所選的iMessage將成為焦點,而所有其他訊息將在背景中模糊不清。您將看到一個文字框,用於鍵入回復以及“+”圖標,用於訪問iMessage應用程序,如“簽到”、“位置”、“貼紙”、“照片”等。只需輸入您的訊息,

訊息已發出但被對方拒絕是所發送的訊息已經成功地從設備發送出去,但由於某種原因,對方並沒有接收到這條訊息。更具體地說,這通常是因為對方已經設定了某些權限或採取了某些操作,導致你的訊息無法被正常接收。

在iOS17中,Apple在其訊息應用程式中添加了幾項新功能,以使與其他Apple用戶的交流更具創意和樂趣。其中一個功能是能夠使用表情符號作為貼紙。貼紙已經在訊息應用程式中存在多年了,但到目前為止,它們並沒有太大變化。這是因為在iOS17中,Apple將所有標準表情符號視為貼紙,讓它們以與實際貼紙相同的方式使用。這本質上意味著您不再局限於在對話中插入它們。現在,您也可以將它們拖曳到訊息氣泡上的任何位置。您甚至可以將它們堆疊在一起,以創建小表情符號場景。以下步驟向您展示了它在iOS17中的工作方式

1.被加入黑名單:訊息已發出但被對方拒收了一般是被拉黑了,這時你將無法向對方發送訊息,對方也無法收到你的訊息。 2.網路問題:如果接收方的網路狀況不佳,或有網路故障,就可能導致訊息無法成功接收。此時,可以嘗試等待網路恢復正常後再次發送訊息。 3.對方設定了免打擾:如果接收方在微信中設定了免打擾功能,那麼在一定時間內,發送方的訊息將不會被提醒或顯示。

小米14Pro是一款性能配置非常出色的旗艦機型,自從正式發布以來就擁有很高的銷量,小米14Pro的很多小功能是會被大家忽視的,比如說是設置來消息亮屏,功能雖小,但是十分實用的,在使用手機的過程中大家會遇到各種問題,那麼小米14Pro怎麼設定來訊息亮屏呢?小米14Pro怎麼設定來訊息亮屏?步驟一:開啟手機的「設定」應用程式。步驟二:向下滑動直到找到「鎖定螢幕和密碼」選項,並點擊進入。步驟三:在「鎖定畫面和密碼」選單中,找到並點選「接收通知時亮屏」選項。步驟四:在「接收通知時亮屏」頁面中,打開開關以啟

佇列技術在PHP與MySQL中的消息延遲和訊息重試的應用摘要:隨著Web應用程式的不斷發展,對於高並發處理和系統可靠性方面的需求越來越高。佇列技術作為一種解決方案,被廣泛應用於PHP與MySQL中,以實現訊息延遲和訊息重試的功能。本文將介紹隊列技術在PHP與MySQL中的應用,包括佇列的基本原理、使用佇列實現訊息延遲的方法和使用佇列實作訊息重試的方法,並給出

JavaQueue佇列的效能分析與最佳化策略摘要:佇列(Queue)是Java中常用的資料結構之一,廣泛應用於各種場景。本文將從效能分析和最佳化策略兩個面向來探討JavaQueue佇列的效能問題,並給出具體的程式碼範例。引言佇列是一種先進先出(FIFO)的資料結構,可用來實作生產者-消費者模式、執行緒池任務佇列等場景。 Java提供了多種佇列的實現,例如Arr

iPhone上的原生「訊息」應用程式可讓您輕鬆編輯已傳送的文字。這樣,您可以糾正您的錯誤、標點符號,甚至是自動更正可能已應用於您的文字的錯誤短語/單字。在這篇文章中,我們將了解如何在iPhone上編輯訊息。如何在iPhone上編輯訊息必需:運行iOS16或更高版本的iPhone。您只能在「訊息」應用程式上編輯iMessage文本,並且只能在發送原始文字後的15分鐘內編輯。不支援非iMessage資訊文本,因此無法檢索或編輯它們。在iPhone上啟動訊息應用程式。在「訊息」中,選擇要從中編輯訊息的對話
