Spring RabbitMQ转换和发送无法正常工作

laximzn5  于 2022-11-08  发布在  RabbitMQ
关注(0)|答案(2)|浏览(179)

我正在使用以下代码将数据排入RabbitMQ:https://www.javainuse.com/spring/spring-boot-rabbitmq-hello-world
我正确地配置了以下属性以匹配RabbitMQ配置

  • 主持人
  • 使用者名称
  • 密码
  • 兑换
  • 路由关键字
  • 队列

但是RabbitMQSender#sendrabbitTemplate.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
如果不是,我需要在代码中更改什么?

d5vmydt9

d5vmydt91#

我试图将事件排入远程RabbitMQ服务器,但该服务器在kubernetes中配置不正确:它缺少存储字段storage: 10Gi,RabbitMQ在无提示的情况下失败...

spec:
  replicas: 1
  image: rabbitmq:3.10.7-management
  persistence:
    storageClassName: managed-csi
    storage: 10Gi
sqxo8psd

sqxo8psd2#

请检查是否创建了名称正确的Exchange

相关问题