RabbitMQ之web界面解析

登录rmq管理平台

队列中的消息被分成了两种状态，一种是等待投递给消费者的消息；一部分是已经投递给消费者，但是还未收到消费者确认信号的消息。
如果rmq一直没收到消费者的确认信号，并且此时与消费者断开连接，那么rmq会安排该消息重新进入队列，等待投递给下一个消费者（也可能是原来的那个消费者）

可以看出当前队列中的消息有”Ready“状态和”Unacknowledged“。分别对应上文的等待投递给消费者的消息数和已经投递给消费者但是还未收到确认信号的消息数。

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

获取某个队列的信息

新建一个队列进行监听

其中ttl的时间单位：微秒
上图设置得太短了（100），懒得重新截图了。。。♪(･ω･)ﾉ
1秒=1000000 微秒(μs)

下面重新建立一个队列，不设置过期时间

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

新建一个交换机（direct为例）

将Exchange与Queue绑定

点击Exchange的Name可进入到Exchange的详情页面，在里面将Exchange与Queue进行Binding

绑定结果：

Exchange发送消息

点进交换器之后有一栏是Publish message，我们发送消息就是在这里进行发送的：

填写好之后，点击Publish message发送。

发送成功后切换到Queues查看是否收到消息，很显然 test.11.10 收到了一条消息，点击 test.11.10 进去查看

进来之后，展开Get message选项，点击GetMessage(s)就能得到消息了

在这里getMessage后，并不会进行消费。只是便于查看报文信息

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

实战问题

消息阻塞

现象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