ActiveMQ命令行：从文件中将消息发布到队列？

作者: 庸人自扰
发布时间: 2024-01-25 09:07:27 (6月前)
转自：

3 条回复

0#
回复此人
满目山河 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> ActiveMQ有一个REST接口，您可以使用，例如，从命令行发送消息 <code> curl </code> 效用。 </p> <P> 这是我为此目的编写并使用的脚本： </p> <pre> <code> #!/bin/bash # # # Sends a message to the message broker on localhost. # Uses ActiveMQ's REST API and the curl utility. # if [ $# -lt 2 -o $# -gt 3 ] ; then echo "Usage: msgSender (topic|queue) DESTINATION [ FILE ]" echo " Ex: msgSender topic myTopic msg.json" echo " Ex: msgSender topic myTopic <<< 'this is my message'" exit 2 fi UNAME=admin PSWD=admin TYPE=$1 DESTINATION=$2 FILE=$3 BHOST=${BROKER_HOST:-'localhost'} BPORT=${BROKER_REST_PORT:-'8161'} if [ -z "$FILE" -o "$FILE" = "-" ] ; then # Get msg from stdin if no filename given ( echo -n "body=" ; cat ) \ | curl -u $UNAME:$PSWD --data-binary '@-' --proxy "" \ "http://$BHOST:$BPORT/api/message/$DESTINATION?type=$TYPE" else # Get msg from a file if [ ! -r "$FILE" ] ; then echo "File not found or not readable" exit 2 fi ( echo -n "body=" ; cat $FILE ) \ | curl -u $UNAME:$PSWD --data-binary '@-' --proxy "" \ "http://$BHOST:$BPORT/api/message/$DESTINATION?type=$TYPE" fi </code> </pre> </DIV>

编辑
1#
回复此人
一只特立独行的猪 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 你可以使用 <a href="https://github.com/fmtn/a" rel="nofollow noreferrer"> “A”实用程序 </A> 去做这个。 </p> <P> <code> a -b tcp://somebroker:61616 -p?@someMessage.xml my-queue </code> </p> <P> 免责声明：我是A的作者，曾写过一次这样的事情。还有其他方法，例如REST接口，Groovy脚本等等。 </p> </DIV>

编辑

登录后才能参与评论