beanstalkd 訊息佇列發郵件

2021-09-10 02:26:58 字數 1197 閱讀 4791

放入訊息

/*

* * 獲取beanstalk例項

* * @staticvar resource|bool $beanstalk

* @return resource */

function get_beanstalk()

'libraries/beanstalkd/pheanstalk_init.php';

//載入配置檔案

$ci =&get_instance();

$ci->config->load('

beanstalkd');

$bean_config = $ci->config->item('

beanstalk_server');

$beanstalk = new pheanstalk_pheanstalk($bean_config['

host

'], $bean_config['

port

']);

return

$beanstalk;}/*

* * 傳送到佇列函式

* * @param string $tube 佇列名稱

* @param string $info 寫入到佇列的資訊

* @param int $priority 佇列優先順序

* @param int $delay 遷移到正式傳送佇列的延遲時間

* @param int $ttr 佇列reserve後的過期時間

* @return bool */

function send2queue($tube, $info, $priority = 1024, $delay = 0, $ttr = 60

)

自動指令碼讀取佇列,傳送訊息

/*

* * 傳送郵件

*/public

function send_email()

}$pheanstalk->delete($job);}}

function send_email($to, $subject, $content, $cc='', $bcc=''

)

posted @

2018-04-20 18:04

懶牛拉車 閱讀(

...)

編輯收藏

beanstalkd訊息佇列

簡介 beanstalkd,乙個高效能 輕量級的分布式記憶體佇列系統,最初設計的目的是想通過後台非同步執行耗時的任務來降低高容量web應用系統的頁面訪問延遲,支援過有9.5 million使用者的facebook causes應用。後來開源,現在有postrank大規模部署和使用,每天處理百萬級任務...

Beanstalkd訊息佇列介紹

beanstalkd是乙個高效能,輕量級的分布式記憶體佇列 1 支援優先順序 支援任務插隊 2 延遲 實現定時任務 3 持久化 定時把記憶體中的資料刷到binlog日誌 4 預留 把任務設定成預留,消費者無法取出任務,等某個合適時機再拿出來處理 5 任務超時重發 消費者必須在指定時間內處理任務,如果...

beanstalkd 訊息佇列發郵件

放入訊息 獲取beanstalk例項 staticvar resource bool beanstalk return resource function get beanstalk libraries beanstalkd pheanstalk init.php 載入配置檔案 ci get ins...