前端需要实时的消息,vue使用stomp连接rabbitmq,怎么去订阅频道,带有路由key的?不能获取消息,请问哪里出了问题
java代码:
@RabbitListener(
bindings = {
@QueueBinding(
value = @Queue(value = "topic_msg_web_123"),
exchange = @Exchange(value = RabbitMqConstant.EXCHANGE_DIRECT),
key ="single_msg_123"
),
@QueueBinding(
//发布-订阅
value = @Queue(value = "topic_msg_web_123"),
exchange = @Exchange(value = RabbitMqConstant.EXCHANGE_TOPIC,type = ExchangeTypes.TOPIC),
key ="topic.msg.123"
),
@QueueBinding(
value = @Queue(value = "topic_msg_web_123"),
//广播
exchange = @Exchange(value = RabbitMqConstant.EXCHANGE_FANOUT,type = ExchangeTypes.FANOUT)
)
}
)
前端代码:
client.subscribe(xxx/${xxx}
, this.responseCallback, this.onFailed);
收到服务器消息后 在responseCallback回调里向服务器发送确认消息
client.send("/xxx/xxx", {"content-type":"text/plain"}, xxx);