當(dāng)前位置：首頁 > 人文社科 > 生活经验 >内容正文

生活经验

memcacheq 服务安装与原理

發(fā)布時(shí)間：2023/11/27 生活经验 46 豆豆

生活随笔收集整理的這篇文章主要介紹了 memcacheq 服务安装与原理小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

memcacheQ是一個單純的分布式消息隊(duì)列服務(wù)。它的安裝依賴于BerkeleyDB 和 libevent，所以要先安裝這BerkeleyDB和libevent：

一，BerkeleyDB

下載軟件包，http://download.oracle.com/berkeley-db/db-5.0.21.tar.gz
解壓縮后，cd build_unix
../dist/configure
make
sudo make install

二，libevent （需要1.4.x 或更高）

下載軟件包：http://monkey.org/~provos/libevent/
解壓縮后configure & make & make install

三，memcacheQ

下載軟件包：http://code.google.com/p/memcacheq/downloads/list
解壓縮，cd進(jìn)目錄
./configure –with-bdb=/usr/local/BerkeleyDB.5.0 –with-libevent=/usr/local/lib –enable-threads
make
sudo make install

四，啟動memcacheQ

使用memcacheq -h 的命令來查看命令行選項(xiàng)
啟動memcacheq：memcacheq -d -r -H /data1/memcacheq -N -R -v -L 1024 -B 1024 > /data1/mq_error.log 2>&1

五，使用

使用以上命令啟動mq后，（注意上面的-B參數(shù)表示messag的body長度不能超過1024 bytes），使用mq時(shí)只需要用到兩個命令：set和get：

set <queue name> <flags> 0 <message_len>\r\n
<put your message body here>\r\n
STORED\r\n

get <queue name>\r\n
VALUE <queue name> <flags> <message_len>\r\n
<your message body will come here>\r\n
END\r\n

可以看到，和memcache協(xié)議基本一致，只是把key name換成queue name，而且在set的命令中，忽略了expire_time的參數(shù)。畢竟mq的數(shù)據(jù)存儲是存在berkeleyDB中，做了持久化存儲，沒有內(nèi)存的過期時(shí)間。

當(dāng)使用set命令時(shí)，就向指定的消息隊(duì)列中寫入了一條新消息，也就是向BerkeleyDB中新insert了一條數(shù)據(jù)，當(dāng)使用get命令時(shí)，就從指定隊(duì)列中取出一條新消息，也就是向BerkeleyDB中delete了一條數(shù)據(jù)。當(dāng)使用stats查看一個指定隊(duì)列時(shí)，可以看到這個隊(duì)列一共接收了多少消息，其中被取出了多少條。

示例：

fengbo@onlinegame-10-121:~$ telnet 127.0.0.1 22202 Trying 127.0.0.1… Connected to 127.0.0.1. Escape character is ‘^]’. set q4 0 0 5 hello STORED set q4 0 0 5 world STORED stats queue STAT q4 2/0 END get q4 VALUE q4 0 5 hello END stats queue STAT q4 2/1 END

上面執(zhí)行了兩次set的命令，使用stats queue查看時(shí)，可以看到q4的隊(duì)列中共有消息2條，已取出0條；當(dāng)使用get取出第一條后，再此使用stats queue查看，q4中消息有2條，其中已取出1條。

總結(jié)

以上是生活随笔為你收集整理的memcacheq 服务安装与原理的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。