Rust实现RabbitMQ Stream Client简易适配器遇Stream不存在错误求助

你碰到的StreamDoesNotExist { stream: "loan_request" }错误原因很直接：RabbitMQ Stream 不会自动创建流，你要消费的loan_request流当前不存在，必须先创建才能进行消费操作。

下面给两种可行的解决方式：

1. 手动创建流 #

通过RabbitMQ的管理界面或者命令行工具提前创建流：

• 如果用命令行，执行rabbitmq-streams add_stream loan_request --vhost /（默认vhost为/，如果你的环境用了其他vhost，替换成对应值即可）。
• 如果用管理界面，找到Stream相关的功能入口，输入流名称loan_request完成创建。

2. 代码中自动创建流 #

在消费者连接后、构建消费者实例前，添加创建流的逻辑。修改你的Consumer实现代码：

pub async fn set_event_callback(event_name: &str, callback: BaseCallback) {
    let connection = Self::new_connection().await;
    
    // 尝试创建流：如果流已存在，该调用会返回错误，这里可以根据需求处理错误
    match connection.stream_creator().create(event_name).await {
        Ok(_) => println!("流 {} 创建成功", event_name),
        Err(e) => println!("创建流时出错：{}（如果是流已存在则可忽略此错误）", e),
    }
    
    let consumer = connection.consumer();
    consumer
        .build(event_name)
        .await
        .unwrap();
}

额外提示 #

• 避免滥用unwrap()：实际项目中应该用match或?运算符处理错误，而不是直接unwrap()触发panic，这样能让程序更健壮。
• 确认RabbitMQ服务状态：确保本地RabbitMQ服务正常运行，且端口5552配置正确（RabbitMQ Stream默认端口就是5552，没问题）。

内容的提问来源于stack exchange，提问作者Dave S.