RabbitMQ之web界面解析

RabbitMQ之web界面解析

登录rmq管理平台

RabbitMQ之web界面解析

点击某个队列进入详情页面

RabbitMQ之web界面解析

获取某个队列的信息

RabbitMQ之web界面解析

新建一个队列进行监听

RabbitMQ之web界面解析
其中ttl的时间单位:微秒
上图设置得太短了(100),懒得重新截图了。。。♪(・ω・)ノ
1秒=1000000 微秒(μs)

下面重新建立一个队列,不设置过期时间
RabbitMQ之web界面解析


通过过滤器,可以快速找到刚刚添加的队列

RabbitMQ之web界面解析


新建一个交换机(direct为例)

RabbitMQ之web界面解析

将Exchange与Queue绑定

点击Exchange的Name可进入到Exchange的详情页面,在里面将Exchange与Queue进行Binding
RabbitMQ之web界面解析


绑定结果


RabbitMQ之web界面解析

Exchange发送消息

点进交换器之后有一栏是Publish message,我们发送消息就是在这里进行发送的:
RabbitMQ之web界面解析
填写好之后,点击Publish message发送。

发送成功后切换到Queues查看是否收到消息,很显然 test.11.10 收到了一条消息,点击 test.11.10 进去查看
RabbitMQ之web界面解析
进来之后,展开Get message选项,点击GetMessage(s)就能得到消息了
RabbitMQ之web界面解析
在这里getMessage后,并不会进行消费。只是便于查看报文信息

在queues界面也可以查看队里的绑定信息

RabbitMQ之web界面解析


实战问题

消息阻塞

现象1:web界面都是ready,全部都未消费
现象2:web界面都是unacked

根本原因:消费者接收到消息,消息的解析出现异常

解析异常原因1:行为分析传过来的图片是以Base64形式传输的而非url,导致解析时出现Error:(22, 37) java: 常量字符串过长
解决方法1:不去读行为分析服务器传过来的base64图片
引申问题:String溢出。

Java String 的字节长度<65535,因此在String s = “”;中,最多可以有65534个字符。如果超过这个个数。就会在编译期报错。

解析异常原因2:spring.cloud.stream.bindings.iBehaviorAlarmMessageInput.contentType=application/json设置的JSON,然而在消费者处用来String/Message接收。导致接收到的报文都是数字。。
解决方法2:消费者采用JSONObject接收



参考链接1
参考链接2
参考链接3