我正在使用以下代码将数据排入RabbitMQ:https://www.javainuse.com/spring/spring-boot-rabbitmq-hello-world
我正确地配置了以下属性以匹配RabbitMQ配置
- 主持人
- 使用者名称
- 密码
- 兑换
- 路由关键字
- 队列
但是RabbitMQSender#send
或rabbitTemplate.convertAndSend(exchange, routingkey, company);
没有将任何数据排入RabbitMQ,同时也没有返回任何错误
我试图更改用户名或密码到一个不正确的一个,我得到了not_authorized
,所以与正确的用户名/密码/队列/交换/路由键的连接似乎很好,但它没有做任何事情。
我尝试通过Curl发送事件,它工作正常,事件在RabbitMQ中正确排队
curl -v -u username:pwd -H "Accept: application/json" -H "Content-Type:application/json" POST -d'{
"properties": {
},
"routing_key": "my-routingkey",
"payload":"hi",
"payload_encoding": "string"
}' localhost:15672/api/exchanges/%2F/my-exchange/publish
spring RabbitTemplate#convertAndSend
是否在后台执行此API localhost:15672/api/exchanges/%2F/my-exchange/publish
?
如果不是,我需要在代码中更改什么?
2条答案
按热度按时间d5vmydt91#
我试图将事件排入远程RabbitMQ服务器,但该服务器在
kubernetes
中配置不正确:它缺少存储字段storage: 10Gi
,RabbitMQ在无提示的情况下失败...sqxo8psd2#
请检查是否创建了名称正确的Exchange