专栏首页Java架构师必看memcacheq 服务安装与原理

memcacheq 服务安装与原理

memcacheQ是一个单纯的分布式消息队列服务。它的安装依赖于BerkeleyDB和libev网络

memcacheQ是一个单纯的分布式消息队列服务。它的安装依赖于BerkeleyDB 和 libevent,所以要先安装这BerkeleyDB和libevent:

一,BerkeleyDB

  1. 下载软件包,http://download.oracle.com/berkeley-db/db-5.0.21.tar.gz
  2. 解压缩后,cd build_unix
  3. ../dist/configure
  4. make
  5. sudo make install

二,libevent (需要1.4.x 或更高)

  1. 下载软件包:http://monkey.org/~provos/libevent/
  2. 解压缩后configure & make & make install

三,memcacheQ

  1. 下载软件包:http://code.google.com/p/memcacheq/downloads/list
  2. 解压缩,cd进目录
  3. ./configure –with-bdb=/usr/local/BerkeleyDB.5.0 –with-libevent=/usr/local/lib –enable-threads
  4. make
  5. sudo make install

四,启动memcacheQ

  1. 使用memcacheq -h 的命令来查看命令行选项
  2. 启动memcacheq:memcacheq -d -r -H /data1/memcacheq -N -R -v -L 1024 -B 1024 > /data1/mq_error.log 2>&1

五,使用

使用以上命令启动mq后,(注意上面的-B参数表示messag的body长度不能超过1024 bytes),使用mq时只需要用到两个命令: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协议基本一致,只是把key name换成queue name,而且在set的命令中,忽略了expire_time的参数。毕竟mq的数据存储是存在berkeleyDB中,做了持久化存储,没有内存的过期时间。

当使用set命令时,就向指定的消息队列中写入了一条新消息,也就是向BerkeleyDB中新insert了一条数据,当使用get命令时,就从 指定队列中取出一条新消息,也就是向BerkeleyDB中delete了一条数据。当使用stats查看一个指定队列时,可以看到这个队列一共接收了多 少消息,其中被取出了多少条。

示例:

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

上面执行了两次set的命令,使用stats queue查看时,可以看到q4的队列中共有消息2条,已取出0条;当使用get取出第一条后,再此使用stats queue查看,q4中消息有2条,其中已取出1条。

本文由来源 21aspnet,由 system_mush 整理编辑,其版权均为 21aspnet 所有,文章内容系作者个人观点,不代表 Java架构师必看 对观点赞同或支持。如需转载,请注明文章来源。

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 一句话说清聚集索引和非聚集索引以及MySQL的InnoDB和MyISAM

    聚集索引和非聚集索引以及MySQL的InnoDB和MyISAM经常遇到有人向我咨询这个问题,其实呢,数据库 ...

    Java架构师必看
  • 详解Apache下.htaccess文件常用配置

    .htaccess文件是Apache服务器中最常用的一个配置文件,它负责相关目录下的网页配置。...

    Java架构师必看
  • 到底什么是微服务?

    最近几年,越来越多的开发人员使用“微服务”一词来阐述他们的系统或应用架构,当然或许这只是他们在吹嘘自己在技术潮流中并未落伍。我认为,IT科技行业的人士至少要了...

    Java架构师必看
  • PICE(6):集群环境里多异类端点gRPC Streaming - Heterogeneous multi-endpoints gRPC streaming

       gRPC Streaming的操作对象由服务端和客户端组成。在一个包含了多个不同服务的集群环境中可能需要从一个服务里调用另一个服务端提供的服务。这时调用服...

    用户1150956
  • JavaWeb——JSP入门学习(JSP基本概念、JSP脚本、JSP内置对象)

    本章内容只对JSP内容做入门介绍,是为了会话技术的Cookie和Session内容的承接,后续再写文章详细介绍JSP。

    Winter_world
  • Python爬虫实战:模拟登录淘宝网站

    在完成爬虫任务的时候,我们总是会遇到用户账号登陆的问题,如果自己手动登陆的话,那么工作量就很大了,如何解决登陆问题呢?

    松鼠爱吃饼干
  • Python 计算一年有多少秒

    py3study
  • 《JSP极简教程》在jsp页面获取session对象两种方法九大内置对象代码实例

    1、request.getSession().getAttribute("X") 2、${sessionScope.X}

    一个会写诗的程序员
  • 重构老系统遗留代码的一些方法学习笔记

    表示某种不相依赖性或者解耦性。如果两个或者更多事物种的一个发生变化,不会影响其他事物。这些事物就是正交的。在设计良好的系统中,数据库代码与用户界面是正交的:你可...

    Jerry Wang
  • liferay-progress-bar

    上次山寨了一个smile face,最近因为一直都在测70,然后就又对70的progress bar起了兴趣。

    littlelyon

扫码关注云+社区

领取腾讯云代金券