作者：糖果

STOMP协议是一种简单的消息文本协议。协义本身简单明了，用消息头定义和消息体数据传输。

RabbitMQ做为一种队列中间件，提供了STOMP协议的支持，我们可以通过STOMP协议向队列发送消息。下面的例子中，我们将使用LUA程序向RabbitMQ发送消息， 通过Python程序读取消息。

send.lua文件

local client = require "stomp"
local mq, err = client:new()
local ok, err = mq:connect("127.0.0.1", 61613)
local msg = "say hi!"
local headers = {}
headers["destination"] = "/queue/test"
headers["app-id"] = "APP"
local ok, err = mq:send(info_json, headers)

对上面的代码说明一下：

连接时候RabbitMQ的IP是本机的127.0.0.1， STOMP协议的服务的端口是默认的61613。

在headers的头定义部分，指明了我们发送信息的目的地“/queue/test“名字为Test的队列。

其实可以深入到STOMP的LUA的实现内部，仔细研究一下是如何实现，如何直接通过sock，发送数据帧到服务器，可以作为独立的章节。

与LUA不同，Python对STOMP协议支持的比较好，不需要甄别第三库，然后再选择使用。用pythonstomp就好。

receive.py文件

import stomp
import time
import sys
import random
import json

class MyListener(stomp.ConnectionListener):
    def on_error(self, headers, message):
        print('received an error %s' % message)

    def on_message(self, headers, message):
        for k,v in headers.iteritems():
            print('header: key %s , value %s' %(k,v))
        print('received message\n %s'% message)

conn=stomp.Connection([('127.0.0.1',61613)])
conn.set_listener('somename',MyListener())
conn.start()
conn.connect(wait=True)
message='say hi!'
dest = '/queue/test'
headers={'seltype':'mandi-age-to-man','type':'textMessage','MessageNumber':random.randint(0,65535)}

metadata = [
]
info_json = json.dumps(metadata)
conn.send(body=info_json, destination='/queue/test')
conn.disconnect()

接受程序和发送程序的主要流程区别是：要在接受端注册监听回调程序。

上面的

conn.set_listener('somename',MyListener())
conn.start()

这两行代码就是注册监听类，在队列上有消息的时候，就会调用监听回调。

on_message。发生错误的时候调用。on_error函数。

具体的实现不完全列出来，针对一般的STOMP连接过程，列出”连接“和

发送的”消息包”的数据结构，结构采用的是LUA语法，table类型定义的。

共计二帧的数据：

connect_frame = {
  "CONNECT\n",
  "accept-version:1.2\n",
  "login:guest\n",
  "passcode:guest\n",
  "host:/\n",
  "\n\n",
  "\0"
}

send_frame = {
  "SEND\n",
  "destination:/queue/test\n",
  "app-id:APP\n",
  "\n",
  "say hi!\n",
  "\0"
}

包体的第一个字段“CONNECT,SEND”都是协议的命令，剩下的是说明字段。
文字不能把所有的问题和协议都描述清楚，可参考以下网站：
http://stomp.github.io/stomp-specification-1.1.html

PS:转载到其它平台请注明作者姓名及原文链接，请勿用于商业用途。