搞定kestrel

Kestrel是一个scala写的twitter开源的消息中间件，特点是:
   

高性能
小巧（2K行代码）
持久存储（记录日志到journal）
可靠（支持可靠获取）

Kestrel的前身是Ruby写的项目，后来twitter的开发人员尝试用scala重新实现。它的代码非常简洁并且优雅，推荐一读。

可支持的标准协议：

    SET          存
    GET          取
    FLUSH_ALL    清理
    STATS        状态


扩展协议：

    SHUTDOWN       关闭kestrel server，如果执行该操作，需强制重启Kestrel
    RELOAD         动态重新加载配置文件
    DUMP_CONFIG    dump配置文件
    FLUSH queueName   flush某个队列

安装daemon，下载地址：
解压后

./configure  && make  && make install

kestrel安装：
安装极其简单，下载地址：，解压，完毕！


然后拷贝某博客的文章，懒着打字，尊重他人成果
转自：http://snowolf.iteye.com/blog/1604531

Kestrel目录结构如下：

Kestrel
  |-kestrel-1.2.7-SNAPSHOT.jar
  |-kestrel-1.2.7-SNAPSHOT.pom
  |-config
      |-development.conf
      |-production.conf
  |-libs
  |-scripts
      |-devel.sh
      |-kestrel.sh
      |-qdump.sh

libs中的jar列表：

    configgy-1.6.4.jar
    naggati_2.7.7-0.7.4.jar
    slf4j-jdk14-1.5.2.jar
    twitteractors_2.7.7-2.0.0.jar
    json-1.1.3.jar
    scala-library.jar
    specs-1.6.2.1.jar
    vscaladoc-1.1-md-3.jar
    mina-core-2.0.0-M6.jar
    slf4j-api-1.5.2.jar
    twitteractors-1.1.0.jar
    xrayspecs-1.0.7.jar

我们只需要关注以下几个文件：
适用于开发环境：

• script/devel.sh用于验证服务配置是否可用
• config/development.conf配合devel.sh进行操作的配置文件

适用于生产环境：

• scripts/kestrel.sh核心执行文件
• config/production.conf核心配置文件

Kestrel脚本&配置说明
这里将Kestrel安装至/usr/local/kestrel路径下，你可能需要对应修改路径配置。
先说用于开发环境的脚本&配置文件：

vim devel.sh

#!/bin/bash
echo "Starting kestrel in development mode..."

# find jar no matter what the root dir name
SCRIPT_DIR=$(cd `dirname "$0"`; pwd)
ROOT_DIR=`dirname "$SCRIPT_DIR"`

#java -server -Xmx1024m -Dstage=development -jar "$ROOT_DIR"/kestrel_2.9.2-2.4.1.jar
java -server -Xmx1024m -Dstage=production -jar "$ROOT_DIR"/kestrel_2.9.2-2.4.1.jar  #表示使用production.scala配置文件

然后执行devel.sh进行测试：

./scripts/devel.sh
Starting kestrel in development mode...

不要关当前的对话框，新开一个对话框执行命令：

telnet localhost 22133
Trying 127.0.0.1...
Connected to localhost.localdomain (127.0.0.1).
Escape character is '^]'.
set x 0 0 5
12345
STORED

telnet localhost 22133
Trying 127.0.0.1...
Connected to localhost.localdomain (127.0.0.1).
Escape character is '^]'.
get x
VALUE x 0 5
12345
END
get x
END

如上操作，说明配置已成功。

然后进行生产环境配置：
kestrel.sh

APP_NAME="kestrel"
ADMIN_PORT="2223"
VERSION="2.4.1"
SCALA_VERSION="2.9.2"
APP_HOME="/usr/local/$APP_NAME"  #保证app_name是安装队列的根目录
INITIAL_SLEEP=15

JAR_NAME="${APP_NAME}_${SCALA_VERSION}-${VERSION}.jar"
STAGE="production"
FD_LIMIT="262144"

HEAP_OPTS="-Xmx256m -Xms256m -XX:NewSize=128m"   #这个地方是个坑啊，学过java的都知道，虚拟机600多M内存，大家悠着点
GC_OPTS="-XX:+UseConcMarkSweepGC -XX:+UseParNewGC"
GC_TRACE="-XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps -XX:+PrintTenuringDistribution -XX:+PrintHeapAtGC"
GC_LOG="-Xloggc:/var/log/$APP_NAME/gc.log"
DEBUG_OPTS="-XX:ErrorFile=/var/log/$APP_NAME/java_error%p.log"

执行脚本启动，然后测试

telnet localhost 22133
Trying 127.0.0.1...
Connected to localhost.localdomain (127.0.0.1).
Escape character is '^]'.
stats
STAT uptime 52568
STAT time 1343093076
STAT version 1.2.7-SNAPSHOT
STAT curr_items 0
STAT total_items 1
STAT bytes 0
STAT curr_connections 1
STAT total_connections 9
STAT cmd_get 2
STAT cmd_set 1
STAT cmd_peek 0
STAT get_hits 1
STAT get_misses 1
STAT bytes_read 91
STAT bytes_written 151
STAT queue_test_items 0
STAT queue_test_bytes 0
STAT queue_test_total_items 1
STAT queue_test_logsize 27
STAT queue_test_expired_items 0
STAT queue_test_mem_items 0
STAT queue_test_mem_bytes 0
STAT queue_test_age 0
STAT queue_test_discarded 0
STAT queue_test_waiters 0
STAT queue_test_open_transactions 0
END

最后，拷贝kestrel.sh文件到/etc/init.d/路径下，并赋予执行权限：

cp kestrel.sh /etc/init.d/kestrel
chmod +x /etc/init.d/kestrel

service kestrel {start|stop|restart|status}

PS:重点说明一点，队列名称/缓存键名称，一定不要始终“-”作为连接符，请使用“_”作为连接符，避免意想不到的错误。！

非常感谢楼上博客贡献者！~~向原创致敬