因为多机环境fanout广播模式,每台机器需要使用自己的队列接受消息
所以尝试使用以下的方案
private static final String QUEUE_NAME="foo."+IPUtils.getLocalhostIp(); @RabbitListener(queues = QUEUE_NAME) public void process(String command){ ... }
but…果断报错:Attribute value must be constant
解决方案—-Spring SPEL表达式闪亮登场(网上都是什么乱七八糟复杂又不好用的)
private static final String QUEUE_NAME="foo."+IPUtils.getLocalhostIp(); @Bean public Queue queue(){ return new Queue(QUEUE_NAME,true); } @RabbitListener(queues = "#{queue.name}") public void process(String command){ ... }
以上
作者:乔_a988
链接:
https://www.jianshu.com/p/a0e4f45e0176
来源:简书
著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。