项目是微服务架构,使用注册中心管理服务,其中使用了一个java工程代理访问rabbitmq,提供了两个接口,pull和ack。
pull根据请求用户与数据类型去rabbitMQ拉取数据,用户拉取数据处理后主动来ack
问题出在平铺这个pull服务时,由于是轮询方式的负载均衡,当消费请求打到pull-1,然后ack请求打到pull-2时,会出现ack失败,因为两次请求不是同一个实列的连接
所以目前必须在redis中记录每次pull请求对应的pull实例,然后ack的时候去redis中查询实例地址,再由网关转发到指定的实例上去才能成功ack
感觉这个方式非常不优雅
想了解一下rabbitmq有没有什么底层的原理可以解决这个问题?
--
另外考虑过从网关层面的解决方法:
根据用户名hash来指定用户每次调用的pull实例,这样一个用户调用的肯定是同一个实例,也就不存在上面这个问题了。
rabbitmq 消费与ack必须通过同一个实例连接
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
- 邀请回答
-
1条回答 默认 最新
- 有问必答小助手 2021-10-14 10:24关注
你好,我是有问必答小助手,非常抱歉,本次您提出的有问必答问题,技术专家团超时未为您做出解答
本次提问扣除的有问必答次数,将会以问答VIP体验卡(1次有问必答机会、商城购买实体图书享受95折优惠)的形式为您补发到账户。
因为有问必答VIP体验卡有效期仅有1天,您在需要使用的时候【私信】联系我,我会为您补发。解决 无用评论 打赏 举报
悬赏问题
- ¥20 腾讯企业邮箱邮件可以恢复么
- ¥15 有人知道怎么将自己的迁移策略布到edgecloudsim上使用吗?
- ¥15 错误 LNK2001 无法解析的外部符号
- ¥50 安装pyaudiokits失败
- ¥15 计组这些题应该咋做呀
- ¥60 更换迈创SOL6M4AE卡的时候,驱动要重新装才能使用,怎么解决?
- ¥15 让node服务器有自动加载文件的功能
- ¥15 jmeter脚本回放有的是对的有的是错的
- ¥15 r语言蛋白组学相关问题
- ¥15 Python时间序列如何拟合疏系数模型