PB 发送消息到Rabbit MQ

yushisx

免费乐捐，感谢支持

PB 发送消息到Rabbit MQ
然后找了下RabbitMQ的手册。 发现向RabbitMQ发送消息可以通过两种方法，
一种是官方自定义的AMQP协议， 这种协议是基于Socket的， 要解析数据包，还得会Socket编程。 主要是PB俺不熟悉， 里面牵扯到一大堆的字符串解析分割，之类的操作。很麻烦。
另外一种是RabbitMQ 自带的HTTP管理客户端，对外开放了HTTP API， 研究了一下， 发现HTTPAPI 支持推送消息到RabbitMQ 这种模式比较简单无需解析Socket的AMQP协议， 虽然慢了那么一点点， 但是对于我们这种企业内部的系统来讲， 这点性能损耗完全不影响。
经过一翻的折腾， 最后搞定了。

OLEObject dom, http
String Http_Name,result,ls_args
//注意这里的%2F是  vhost为/的对应值 所以这个 %2F 代表 /
Http_Name = "http://192.168.20.207:15672/api/exchanges/%2F/amq.topic/publish"
//Http_Name = "http://192.168.20.207:15672/api/nodes"
//dom = CREATE OLEObject
http = CREATE OLEObject
http.ConnectToNewObject("Msxml2.XMLHTTP")

ls_args = '{"properties":{},"routing_key":"IS.Report.Received@mm.com改成自己的key","payload":"具体的消息内容，自己处理吧","payload_encoding":"string"}'
//ls_args = ''
http.Open( "POST", Http_Name, TRUE)
http.setrequestheader("Content-type","application/json")
http.setrequestheader("Authorization","Basic TUtNUTpNS01R")  //TUtNUTpNS01R 是在 http://tool.oschina.net/encrypt?type=3 对 "用户名:密码" 进行base64加密后的字符串

http.setrequestheader("Content-Length",string( Len(ls_args) ) )
http.Send(ls_args)
do While http.readyState <> 4 // ' 查询状态,延时
yield()
Loop

result = http.responseText //这个测试用! 你可不写
messagebox( 'result ',result)

转自：https://blog.csdn.net/phker/article/details/83184361

bczhan

感谢，最近刚好需要用到，找了很久了