建站
咨詢
售后
建站咨詢
新聞中心
在現(xiàn)代應(yīng)用程序中，數(shù)據(jù)庫(kù)是不可或缺的組成部分，其具有存儲(chǔ)和檢索數(shù)據(jù)的重要功能。然而，當(dāng)數(shù)據(jù)庫(kù)執(zhí)行失敗時(shí)，會(huì)導(dǎo)致應(yīng)用程序出現(xiàn)一系列問(wèn)題，例如錯(cuò)誤或崩潰等。為了避免這種情況，消息隊(duì)列已經(jīng)成為處理數(shù)據(jù)庫(kù)執(zhí)行失敗的一種重要方式，它可以幫助我們?cè)谔囟〞r(shí)間檢測(cè)和修復(fù)錯(cuò)誤，從而提高應(yīng)用程序的可靠性。
什么是消息隊(duì)列？
消息隊(duì)列是一種跨進(jìn)程、跨網(wǎng)絡(luò)的通信方式，其中消息發(fā)送者將消息發(fā)送到隊(duì)列中，并由消息接收者從隊(duì)列中接收和處理消息，即“發(fā)布和訂閱”模式。消息隊(duì)列基于異步通信方式，可以提高應(yīng)用程序的性能和并發(fā)性，并且可以幫助我們?cè)诟哓?fù)載情況下處理消息，從而提高應(yīng)用程序的可伸縮性和可靠性。
消息隊(duì)列的優(yōu)勢(shì)
在處理數(shù)據(jù)庫(kù)執(zhí)行失敗的情況下，消息隊(duì)列具有以下優(yōu)勢(shì)：
1. 分離數(shù)據(jù)庫(kù)操作和應(yīng)用程序：當(dāng)應(yīng)用程序需要執(zhí)行數(shù)據(jù)庫(kù)操作時(shí)，可以將這些操作交給消息隊(duì)列來(lái)處理，從而避免在應(yīng)用程序中直接處理數(shù)據(jù)庫(kù)操作，減少數(shù)據(jù)庫(kù)操作對(duì)應(yīng)用程序的干擾。
2. 異步處理：消息隊(duì)列是基于異步通信的，可以幫助我們?cè)诟哓?fù)載情況下處理消息，從而提高應(yīng)用程序的性能和并發(fā)性。此外，消息隊(duì)列還可以幫助我們?cè)趹?yīng)用程序停止或崩潰時(shí)保持消息和狀態(tài)的完整性。
3. 可重試性和可恢復(fù)性：當(dāng)數(shù)據(jù)庫(kù)執(zhí)行失敗時(shí)，消息隊(duì)列可以將消息重新排隊(duì)，以便稍后重新嘗試。此外，如果消息無(wú)法修復(fù)，則可以將其發(fā)送到“死信隊(duì)列”，以便進(jìn)行后續(xù)處理。
消息隊(duì)列的實(shí)現(xiàn)方式
在處理數(shù)據(jù)庫(kù)執(zhí)行失敗的情況下，消息隊(duì)列可以采用以下實(shí)現(xiàn)方式：
1. 事務(wù)性消息：當(dāng)應(yīng)用程序需要執(zhí)行一系列數(shù)據(jù)庫(kù)操作時(shí)，可以將這些操作作為事務(wù)性消息發(fā)送到消息隊(duì)列中，以便在一定時(shí)間內(nèi)進(jìn)行提交或回滾。如果其中的某個(gè)操作發(fā)生錯(cuò)誤，則可以回滾事務(wù)，從而保證數(shù)據(jù)的完整性。
2. 數(shù)據(jù)庫(kù)通知：在數(shù)據(jù)庫(kù)執(zhí)行失敗時(shí)，可以使用數(shù)據(jù)庫(kù)通知機(jī)制將錯(cuò)誤信息發(fā)送到消息隊(duì)列中，并由應(yīng)用程序訂閱相應(yīng)的消息進(jìn)行處理。例如，使用PostgreSQL中的“LISTEN”和“NOTIFY”。
3. 延遲隊(duì)列：在處理一些對(duì)時(shí)效性沒(méi)有特別要求的任務(wù)時(shí)，可以使用延遲隊(duì)列。當(dāng)數(shù)據(jù)庫(kù)執(zhí)行失敗時(shí)，可以將任務(wù)放入延遲隊(duì)列中，并設(shè)置一定的延遲時(shí)間，以便在稍后處理。
4. 死信隊(duì)列：當(dāng)消息無(wú)法修復(fù)時(shí)，可以將其發(fā)送到死信隊(duì)列中，進(jìn)行后續(xù)處理。例如，可以將故障消息發(fā)送到監(jiān)控系統(tǒng)中，以便管理員進(jìn)行數(shù)據(jù)修復(fù)或人工處理。
結(jié)論
在現(xiàn)代應(yīng)用程序中，數(shù)據(jù)庫(kù)是不可或缺的組成部分，但當(dāng)數(shù)據(jù)庫(kù)執(zhí)行失敗時(shí)，會(huì)導(dǎo)致應(yīng)用程序出現(xiàn)一系列問(wèn)題。為了解決這個(gè)問(wèn)題，消息隊(duì)列成為處理數(shù)據(jù)庫(kù)執(zhí)行失敗的一種重要方式，它可以幫助我們?cè)谔囟〞r(shí)間檢測(cè)和修復(fù)錯(cuò)誤，從而提高應(yīng)用程序的可靠性。在使用消息隊(duì)列時(shí)，事務(wù)性消息、數(shù)據(jù)庫(kù)通知、延遲隊(duì)列和死信隊(duì)列等多種實(shí)現(xiàn)方式可以根據(jù)應(yīng)用程序的需求和場(chǎng)景進(jìn)行選擇。
成都網(wǎng)站建設(shè)公司-創(chuàng)新互聯(lián),建站經(jīng)驗(yàn)豐富以策略為先導(dǎo)10多年以來(lái)專注數(shù)字化網(wǎng)站建設(shè),提供企業(yè)網(wǎng)站建設(shè),高端網(wǎng)站設(shè)計(jì),響應(yīng)式網(wǎng)站制作,設(shè)計(jì)師量身打造品牌風(fēng)格,熱線:028-86922220統(tǒng)計(jì)局證書助手 數(shù)據(jù)庫(kù)操作失敗
因?yàn)閿?shù)據(jù)庫(kù)當(dāng)前在使用中。
刪除數(shù)據(jù)庫(kù)、終止數(shù)據(jù)庫(kù)連接和創(chuàng)建數(shù)據(jù)庫(kù)的備份副本之類的一些數(shù)據(jù)庫(kù)操作需要?dú)q悄關(guān)聯(lián)數(shù)據(jù)庫(kù)處于不活動(dòng)狀態(tài)并且該數(shù)據(jù)庫(kù)不能有相連的
應(yīng)用程序
。如果嘗試對(duì)有相連應(yīng)用程序的活動(dòng)數(shù)據(jù)庫(kù)執(zhí)行這類操作，攔戚那么該操作將失敗。
在php隊(duì)列php-resque里頭使用了數(shù)據(jù)庫(kù)的單例模式顯示MySQL server has gone away
PHP的輕量消息隊(duì)列php-resque使用說(shuō)明
消息隊(duì)列處理后臺(tái)任務(wù)帶來(lái)的問(wèn)題
項(xiàng)目中經(jīng)常會(huì)有后臺(tái)運(yùn)行任務(wù)的需求，比如發(fā)送郵件時(shí)，因?yàn)橐B接郵件服務(wù)器，往往需要5-10秒甚至更長(zhǎng)時(shí)間，如果能先給用戶一個(gè)成功的提示信息，然后在后臺(tái)慢慢處理發(fā)送郵件的操作，顯然會(huì)有更好的用戶體驗(yàn)。
為了實(shí)現(xiàn)類似的需求，Web項(xiàng)目中一般的實(shí)現(xiàn)方法是使用消息隊(duì)列(Message Queue)，比如MemcacheQ，RabbitMQ等等，都是很著名的產(chǎn)品。
消息隊(duì)列說(shuō)白了就是一個(gè)最簡(jiǎn)單的先進(jìn)先出隊(duì)列，隊(duì)列的一個(gè)成員就是一段文本。正是因?yàn)橄㈥?duì)列實(shí)在太簡(jiǎn)單了，當(dāng)拿著消息隊(duì)列時(shí)，反而有點(diǎn)無(wú)從下手的感覺(jué)，因?yàn)檫@僅僅一個(gè)發(fā)送郵件的任務(wù)，就會(huì)引申出很多問(wèn)題：
消息隊(duì)列只能存儲(chǔ)字符串類型的數(shù)據(jù)，如何將一個(gè)發(fā)送郵件這樣的“任務(wù)”，轉(zhuǎn)換為消息隊(duì)列中的一個(gè)“消息”?
消息隊(duì)列只負(fù)責(zé)數(shù)據(jù)的存放與進(jìn)出，本身不能執(zhí)行任何程序，那么我們要如何從消息隊(duì)列中一個(gè)一個(gè)取出數(shù)據(jù)，再將這些數(shù)據(jù)轉(zhuǎn)化回任務(wù)并執(zhí)行。
我們無(wú)法預(yù)知消息隊(duì)列何時(shí)會(huì)有數(shù)據(jù)產(chǎn)生，所以我們的任務(wù)執(zhí)行程序還需要具備監(jiān)控消息隊(duì)列的能力，也就是一個(gè)常駐后臺(tái)的守護(hù)進(jìn)程。
一般的Web應(yīng)用PHP都以cgi方式運(yùn)行，無(wú)法常駐內(nèi)存。我們知道php還有cli模式，那么守護(hù)進(jìn)程是否能以php cli來(lái)實(shí)現(xiàn)，效率如何？
當(dāng)守護(hù)進(jìn)程運(yùn)行時(shí)，Web應(yīng)用能否與后臺(tái)守護(hù)進(jìn)程交互，實(shí)現(xiàn)開(kāi)啟/殺死進(jìn)程的功能以及獲得進(jìn)程的運(yùn)行狀態(tài)？
Resque對(duì)后臺(tái)任務(wù)的設(shè)計(jì)與角色劃分
對(duì)以上這些問(wèn)題，目前為止我能找到的更好答案，并不是來(lái)自php，而是來(lái)自Ruby的項(xiàng)目Resque，正是由于Resque清晰簡(jiǎn)單的解決了后臺(tái)任務(wù)帶來(lái)的一系列問(wèn)題，Resque的設(shè)計(jì)也被Clone到Python、php、NodeJs等語(yǔ)言：比如Python下的pyres以及PHP下的php-resque等等，這里有各種語(yǔ)言版本的Resque實(shí)現(xiàn)，而在本篇日志里，我們虛襪笑當(dāng)然要以PHP版本為例來(lái)說(shuō)明如何用php-resque運(yùn)行一個(gè)后臺(tái)任務(wù)，可能一些細(xì)節(jié)方面會(huì)與Ruby版有出入，但是本文中以php版為準(zhǔn)。
Resque是這樣解決這些問(wèn)題的：
后臺(tái)任務(wù)的角色劃分
其實(shí)從上面的問(wèn)題已經(jīng)可以看出，只靠一個(gè)消息隊(duì)列是無(wú)法解決所有問(wèn)題的，需要新的角色介入。在Resque中，一個(gè)后臺(tái)任務(wù)被抽象為由三種角色共同完成：
Job | 任務(wù) ： 一個(gè)Job就是一個(gè)需要在后成的任務(wù)，比如本文舉例的發(fā)送郵件，就可以抽象為一個(gè)Job。在Resque中一個(gè)Job就是一個(gè)Class。
Queue | 隊(duì)列 ： 也就是上文的消息隊(duì)列，在Resque中，隊(duì)列則是由Redis實(shí)現(xiàn)的。Resque還提供了一個(gè)簡(jiǎn)單的隊(duì)列管理器，可以實(shí)現(xiàn)將Job插入/取出隊(duì)列等功能。
Worker | 執(zhí)行者 ： 負(fù)責(zé)從隊(duì)列中取出Job并執(zhí)行，可以以守護(hù)進(jìn)程的方式運(yùn)行在后臺(tái)。
那么基于這個(gè)劃分，一個(gè)后臺(tái)任務(wù)在Resque下的基本流程是這樣好碰的：
將一個(gè)后臺(tái)任務(wù)編寫為一個(gè)獨(dú)立的Class，這個(gè)Class就是一個(gè)Job。
在需要使用后臺(tái)程序的地方，系統(tǒng)將Job Class的名稱以及所需參數(shù)放入隊(duì)列。
以命令差含行方式開(kāi)啟一個(gè)Worker，并通過(guò)參數(shù)指定Worker所需要處理的隊(duì)列。
Worker作為守護(hù)進(jìn)程運(yùn)行，并且定時(shí)檢查隊(duì)列。
當(dāng)隊(duì)列中有Job時(shí)，Worker取出Job并運(yùn)行，即實(shí)例化Job Class并執(zhí)行Class中的方法。
至此就可以完整的運(yùn)行完一個(gè)后臺(tái)任務(wù)。
在Resque中，還有一個(gè)很重要的設(shè)計(jì)：一個(gè)Worker，可以處理一個(gè)隊(duì)列，也可以處理很多個(gè)隊(duì)列，并且可以通過(guò)增加Worker的進(jìn)程/線程數(shù)來(lái)加快隊(duì)列的執(zhí)行速度。
php-resque的安裝
需要提前說(shuō)明的是，由于涉及到進(jìn)程的開(kāi)辟與管理，php-resque使用了php的PCNTL函數(shù)，所以只能在Linux下運(yùn)行，并且需要php編譯PCNTL函數(shù)。如果希望用Windows做同樣的工作，那么可以去找找Resque的其他語(yǔ)言版本，php在Windows下非常不適合做后臺(tái)任務(wù)。
以Ubuntu12.04LTS為例，Ubuntu用apt安裝的php已經(jīng)默認(rèn)編譯了PCNTL函數(shù)，無(wú)需任何配置，以下指令均為root帳號(hào)安裝Redis
apt-get install redis-server
安裝Composer
apt-get install curl
cd /usr/local/bin
curl -s
| phpchmod a+x composer.phar
alias composer=’/usr/local/bin/composer.phar’
使用Composer安裝php-resque
假設(shè)web目錄在/opt/htdocs
apt-get install git git-core
cd /opt/htdocs
git clone php-resque
composer install
php-resque的使用
編寫一個(gè)Worker
其實(shí)php-resque已經(jīng)給出了簡(jiǎn)單的例子， demo/job.php文件就是一個(gè)最簡(jiǎn)單的Job：
class PHP_Job
{
public function perform()
{
sleep(120);
fwrite(STDOUT, ‘Hello!’);
}
}
這個(gè)Job就是在120秒后向STDOUT輸出字符Hello!
在Resque的設(shè)計(jì)中，一個(gè)Job必須存在一個(gè)perform方法，Worker則會(huì)自動(dòng)運(yùn)行這個(gè)方法。
將Job插入隊(duì)列
php-resque也給出了最簡(jiǎn)單的插入隊(duì)列實(shí)現(xiàn) demo/queue.php：
if(empty($argv)) {
die(‘Specify the name of a job to add. e.g, php queue.php PHP_Job’);}
require __DIR__ . ‘/init.php’;
date_default_timezone_set(‘GMT’);
Resque::setBackend(‘127.0.0.1:6379’);
$args = array(
’time’ => time(),
’array’ => array(
’test’ => ‘test’,
),
);
$jobId = Resque::enqueue(‘default’, $argv, $args, true);echo “Queued job “.$jobId.”\n\n”;
在這個(gè)例子中，queue.php需要以cli方式運(yùn)行，將cli接收到的之一個(gè)參數(shù)作為Job名稱，插入名為’default’的隊(duì)列，同時(shí)向屏幕輸出剛才插入隊(duì)列的Job Id。在終端輸入：
php demo/queue.php PHP_Job
結(jié)果可以看到屏幕上輸出：
Queued job b1f01038e5e833d24b46271a0e31f6d6即Job已經(jīng)添加成功。注意這里的Job名稱與我們編寫的Job Class名稱保持一致：PHP_Job查看Job運(yùn)行情況
php-resque同樣提供了查看Job運(yùn)行狀態(tài)的例子，直接運(yùn)行：
php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d6可以看到輸出為：
Tracking status of b1f01038e5e833d24b46271a0e31f6d6. Press to stop.
Status of b1f01038e5e833d24b46271a0e31f6d6 is: 1我們剛才創(chuàng)建的Job狀態(tài)為1。在Resque中，一個(gè)Job有以下4種狀態(tài)：
Resque_Job_Status::STATUS_WAITING = 1; (等待)Resque_Job_Status::STATUS_RUNNING = 2; (正在執(zhí)行)Resque_Job_Status::STATUS_FAILED = 3; (失敗)Resque_Job_Status::STATUS_COMPLETE = 4; (結(jié)束)因?yàn)闆](méi)有Worker運(yùn)行，所以剛才創(chuàng)建的Job還是等待狀態(tài)。
運(yùn)行Worker
這次我們直接編寫demo/resque.php：
date_default_timezone_set(‘GMT’);
require ‘job.php’;
require ‘../bin/resque’;
可以看到一個(gè)Worker至少需要兩部分：
可以直接包含Job類文件，也可以使用php的自動(dòng)加載機(jī)制，指定好Job Class所在路徑并能實(shí)現(xiàn)自動(dòng)加載包含Resque的默認(rèn)Worker： bin/resque
在終端中運(yùn)行：
QUEUE=default php demo/resque.php
前面的QUEUE部分是設(shè)置環(huán)境變量，我們指定當(dāng)前的Worker只負(fù)責(zé)處理default隊(duì)列。也可以使用QUEUE=* php demo/resque.php
來(lái)處理所有隊(duì)列。
運(yùn)行后輸出為
#!/usr/bin/env php
*** Starting worker
用ps指令檢查一下：
ps aux | grep resque
可以看到有一個(gè)php的守護(hù)進(jìn)程已經(jīng)在運(yùn)行了
07 0.0 0. pts/3 S+ 14:52 0:00 php demo/resque.php再使用之前的檢查Job指令
php demo/check_status.php b1f01038e5e833d24b46271a0e31f6d62分鐘后可以看到
Status of b1f01038e5e833d24b46271a0e31f6d6 is: 4任務(wù)已經(jīng)運(yùn)行完畢，同時(shí)屏幕上應(yīng)該可以看到輸出的Hello!
消息隊(duì)列數(shù)據(jù)庫(kù)執(zhí)行失敗處理的介紹就聊到這里吧，感謝你花時(shí)間閱讀本站內(nèi)容，更多關(guān)于消息隊(duì)列數(shù)據(jù)庫(kù)執(zhí)行失敗處理,消息隊(duì)列：應(yīng)對(duì)數(shù)據(jù)庫(kù)執(zhí)行失敗的處理方式,統(tǒng)計(jì)局證書助手 數(shù)據(jù)庫(kù)操作失敗,在php隊(duì)列php-resque里頭使用了數(shù)據(jù)庫(kù)的單例模式顯示MySQL server has gone away的信息別忘了在本站進(jìn)行查找喔。
成都創(chuàng)新互聯(lián)科技公司主營(yíng):網(wǎng)站設(shè)計(jì)、網(wǎng)站建設(shè)、小程序制作、成都軟件開(kāi)發(fā)、網(wǎng)頁(yè)設(shè)計(jì)、微信開(kāi)發(fā)、成都小程序開(kāi)發(fā)、網(wǎng)站制作、網(wǎng)站開(kāi)發(fā)等業(yè)務(wù)，是專業(yè)的成都做小程序公司、成都網(wǎng)站建設(shè)公司、成都做網(wǎng)站的公司。創(chuàng)新互聯(lián)公司集小程序制作創(chuàng)意，網(wǎng)站制作策劃，畫冊(cè)、網(wǎng)頁(yè)、VI設(shè)計(jì)，網(wǎng)站、軟件、微信、小程序開(kāi)發(fā)于一體。
文章名稱：消息隊(duì)列：應(yīng)對(duì)數(shù)據(jù)庫(kù)執(zhí)行失敗的處理方式(消息隊(duì)列數(shù)據(jù)庫(kù)執(zhí)行失敗處理)
轉(zhuǎn)載來(lái)于：http://m.5511xx.com/article/cdhiccd.html
