[TOC] # 簡介 Fanout 就是我們熟悉的?播模式或者訂閱模式，給 Fanout 交換機發送消息，綁定了這個交換機的所有隊列都收到這個消息 # 定義隊列 這?使?了 A、B 兩個個隊列綁定到 Fanout 交換機上?，發送端的 routing\_key 寫任何字符都會被忽略 ~~~ import org.springframework.amqp.core.Binding; import org.springframework.amqp.core.BindingBuilder; import org.springframework.amqp.core.FanoutExchange; import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitConfig { /** * 定義隊列 */ @Bean public Queue AMessage() { return new Queue("fanout.A"); } @Bean public Queue BMessage() { return new Queue("fanout.B"); } @Bean public Queue CMessage() { return new Queue("fanout.C"); } /** * 定義交換機 */ @Bean FanoutExchange fanoutExchange() { return new FanoutExchange("fanoutExchange"); } /** * 分部進?綁定 */ @Bean Binding bindingExchangeA(Queue AMessage, FanoutExchange fanoutExchange) { return BindingBuilder.bind(AMessage).to(fanoutExchange); } @Bean Binding bindingExchangeB(Queue BMessage, FanoutExchange fanoutExchange) { return BindingBuilder.bind(BMessage).to(fanoutExchange); } } ~~~ # 定義發送者 ~~~ import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @Component public class FanoutSender { @Autowired private AmqpTemplate rabbitTemplate; public void send() { String context = "hi, fanout msg "; System.out.println("Sender : " + context); this.rabbitTemplate.convertAndSend("fanoutExchange","", context); } } ~~~ # 定義接收者 **接收者A** ~~~ import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component @RabbitListener(queues = "fanout.A") public class FanoutReceiverA { @RabbitHandler public void process(String message) { System.out.println("fanout Receiver A: " + message); } } ~~~ **接收者B** ~~~ import org.springframework.amqp.rabbit.annotation.RabbitHandler; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; @Component @RabbitListener(queues = "fanout.B") public class FanoutReceiverB { @RabbitHandler public void process(String message) { System.out.println("fanout Receiver B: " + message); } } ~~~ # 測試 綁定到 fanout 交換機上?的隊列都收到了消息 ~~~ @Autowired private FanoutSender sender; @Test public void fanoutSender() throws Exception { sender.send(); Thread.sleep(1000L); } ~~~