RabbitMQ之web界面解析
RabbitMQ之web界面解析
登录rmq管理平台
点击某个队列进入详情页面
获取某个队列的信息
新建一个队列进行监听
其中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
接收