BASH 守护程序脚本 amqp-consumer not 持久化



首先,对不起我的英语:)我正在尝试守护一个脚本,该脚本使用 bash AMQP 客户端库(amqp-tools),以允许通过 RabbitMQ 代理转发消息。

这是脚本的一部分encrypter_mom_mailconsumer.sh

write_log INF "Forward broker message to encrypter_mom_mailencrypter.sh"
/usr/bin/amqp-consume 
    --server broker1.rmq:5672 
    --vhost "/" 
    --username ub1v1 --password aze 
    --exchange amq.direct 
    --routing-key to_encrypt 
    --declare 
    --queue q_encrypt 
    . /home/rabbit/encrypter_mom_mailencrypter.sh

当我在 shell(在我的 vm 内)中启动该脚本时,一切都很好! amqp-consume 冻结脚本并等待 AMPQ 消息。

但是当脚本在启动时启动时,作为守护进程,amqp-consumption 只需跳过该步骤即可。 脚本结束其执行...并且既没有打开TCP连接(netstat -tap)也没有processus(ps aufx)

这是使用启动-停止-守护程序的守护程序脚本

DAEMON="/home/rabbit/encrypter_mom_mailconsumer.sh"
DAEMON_OPT=""
DAEMON_USER="rabbit"
DAEMON_NAME="encrypter_mom_mailconsumer.sh"
PATH="/sbin:/bin:/usr/sbin:/usr/bin"
test -x $DAEMON || exit 0
. /lib/lsb/init-functions
d_start () {
    log_daemon_msg "Starting system $DAEMON_NAME Daemon"
    start-stop-daemon --background --start --quiet --chuid $DAEMON_USER --exec $DAEMON -- $DAEMON_OPT
    log_end_msg $?
}
d_stop () {
    log_daemon_msg "Stopping system $DAEMON_NAME Daemon"
    start-stop-daemon --name $DAEMON_NAME --stop --retry 5 --quiet --name $DAEMON_NAME
    log_end_msg $?
}
case "$1" in
    start|stop)
        d_${1}
        ;;
    restart|reload|force-reload)
        d_stop
        d_start
        ;;
    force-stop)
        d_stop
        killall -q $DAEMON_NAME || true
        sleep 2
        killall -q -9 $DAEMON_NAME || true
        ;;
    status)
        status_of_proc "$DAEMON_NAME" "$DAEMON" "system-wide $DAEMON_NAME" && exit 0 || exit $?
        ;;
    *)
        echo "Usage: /etc/init.d/$DAEMON_NAME {start|stop|force-stop|restart|reload|force-reload|status}"
        exit 1
        ;;
esac
exit 0

encrypter_mom_mailconsumer.sh日志(在 vm 启动时) - 他应该停止并等待"将代理消息转发到encrypter_mom_mailencrypter.sh"步骤

2015/03/13 15:15:25 [START] : Executing encrypter_mom_mailconsumer...
2015/03/13 15:15:25 [INFO] : Check script arguments and owner
2015/03/13 15:15:25 [INFO] : Forward broker message to encrypter_mom_mailencrypter.sh
2015/03/13 15:15:27 [INFO] : Status: 1
2015/03/13 15:15:27 [END] : Successfully executed

我不明白这个问题。你有什么提示吗?

如果我错过了一些信息,请告诉我!

我不得不启动我的 amqp-consumption 命令,并使用 &

.

我只需要注意停止虚拟机的方式,rabbitmq 需要清理它的交换和队列。

所以:

write_log INF "Forward broker message to encrypter_mom_mailencrypter.sh"
nohup /usr/bin/amqp-consume 
    --server broker1.rmq:5672 
    --vhost "/" 
    --username ub1v1 --password aze 
    --exchange amq.direct 
    --routing-key to_encrypt 
    --declare 
    --queue q_encrypt 
    /bin/bash /home/rabbit/encrypter_mom_mailencrypter.sh &

做到了!

:)

最新更新