amqp投递了未创建的exchange后, 再也无法投递正确的exchange

[khiphop]

我投递的exchange和routing Key 从缓存配置获取

以下情况都是代码不动, 只改缓存

情况一:

• 当把exchange改成未创建的, 无法投递成功
• 在缓存改回正常的exchange后, 无法投递成功

这种情况应该如何改善呢?
hyperf2.1 + "gemini/hyperf2.2-amqp": "^2.2",

情况二(提供参考):

• 把routing key 改成未创建的, 无法投递成功
• 把routing key 改回正常的, 可以继续成功投递

[limingxinleo]

未创建的 exchange 会在一开始进行初始化，如果初始化阶段已经过了，动态修改 exchange 自然是无法投递成功

[khiphop]

我没有用 @Producer(exchange="hyperf", routingKey="hyperf") 注释

是参数传递进去的

[khiphop]

未创建的 exchange 会在一开始进行初始化，如果初始化阶段已经过了，动态修改 exchange 自然是无法投递成功

我没有用 @Producer(exchange="hyperf", routingKey="hyperf") 注释

是参数传递进去的

[limingxinleo]

一样的。。。

正常投递的时候，是不会动态创建exchange的，你可以自己declare

[khiphop]

一样的。。。

正常投递的时候，是不会动态创建exchange的，你可以自己declare

不会自动创建未创建的exchange是可以接受的
但缓存改回正确的exchange后就再也投递不成功了, 这个有没有办法解决

[limingxinleo]

这个不应该啊，贴代码我看看

[khiphop]

情况

• 1. 请求项目, 投递exchange: a(已存在), routing_key:a(已存在), 成功
• 2. 请求项目, 投递exchange: b(已存在), routing_key:b(已存在), 成功
• 3. 请求项目, 投递exchange: c(不存在), routing_key:a(不存在), 失败
• 4. 请求项目, 投递exchange: a(已存在), routing_key:a(已存在), 失败
• 5. 请求项目, 投递exchange: b(已存在), routing_key:b(已存在), 失败
• 6. 第n次请求, 投递exchange: a(已存在), routing_key:a(已存在), 失败

[limingxinleo]

确实是个问题，但我查了发送的数据，是一模一样的

这里建议不要投递 不存在的 exchange 了

[limingxinleo]

如果执意要投递 exchange

那就使用 confirm 模式

    public function produce(ProducerMessageInterface $producerMessage, bool $confirm = false, int $timeout = 5): bool
    {
        return retry(1, function () use ($producerMessage, $confirm, $timeout) {
            return $this->produceMessage($producerMessage, $confirm, $timeout);
        });
    }

[limingxinleo]

这个问题应该 rabbitmq 内部的问题，当投递了不存在的 exchange 后，那个 channel 就有问题了，如果使用了 confirm 模式，会报错然后销毁这个 channel，如果不使用 confirm 模式，后面用这个 channel 投递时，任何消息都无法投递成功。

当然，如果 exchange 存在，你切换 routingKey 是没有任何问题的，即使这个 key 不存在。

相关 issue

php-amqplib/php-amqplib#823