起因:開始想在windows安裝beanstalkd,可以找了很多資料都沒有成功。最終還是妥協。在虛擬機器上裝乙個centos系統,然後在centos上安裝beanstalkd供windows使用
yum install epel-release
yum install beanstalkd --enablerepo=epel
安裝成功
啟動。這裡用的是預設埠。ip位址是虛擬機器上的ip位址,注意,這個地方不要寫成127.0.0.1。畢竟,我是要在windows上訪問beanstalkd服務
/usr/bin/beanstalkd -l 127.0.0.1 -p 11300 &
重啟service beanstalkd restart
關閉防火牆
service iptables stop
到此,虛擬機器上的操作已經完成。接下來就是到windows伺服器上去測試,是否可以正常訪問了
測試php**如下
<?php$queue_name = '
testque';
send2queue($queue_name,1);
send2queue($queue_name,2);
send2queue($queue_name,3);
$pheanstalk =get_beanstalk();
while($job = $pheanstalk->watch($queue_name)->ignore('
default
')->reserve(3
))
結果正常。注意「reserve(3)」這個地方。3表示獲取任務3秒鐘如果沒有反應,表示任務獲取失敗。如果沒有這個數字,可能會出現超時的情況
訊息佇列 訊息佇列
輪詢排程 一次性分發所有訊息,保證訊息平均分配,不管消費者是否能正常消費 訊息應答 保證消費端能確實消費,不丟失 公平 乙個乙個分發所有訊息,在保證分發到的執行緒確認回覆後,才分發下個訊息給下個空閒的消費者,訊息持久化 保證佇列中的訊息不丟失,包括3要素 交換器 訊息佇列 訊息都必須宣告持久化 發布...
訊息佇列 訊息佇列 kafka
kafka是乙個分布式的基於發布 訂閱模式的訊息佇列,主要用於大資料實時處理領域。要理解kafka首先要有分布式的概念,要有訊息佇列的概念。分布式系統最大的優勢就是解耦和削峰,這種情況下,a系統生成了乙個訊息,b系統非同步獲取,那麼就需要乙個存放訊息的訊息佇列 mq 相比較傳統的訊息佇列,訊息被消費...
linux訊息佇列 Linux訊息佇列
訊息佇列,unix的通訊機制之一,可以理解為是乙個存放訊息 資料 容器。將訊息寫入訊息佇列,然後再從訊息佇列中取訊息,一般來說是先進先出的順序。可以解決兩個程序的讀寫速度不同 處理資料速度不同 系統耦合等問題,而且訊息佇列裡的訊息哪怕程序崩潰了也不會消失。最簡單的訊息記憶體的使用流程 ftok函式生...