SpringBoot整合RabbitMQF 路由模式

---

---

配置类

@Configuration
public class RabbitMqConfig3 {

  //队列one 
	@Bean
	public Queue queueOne(){

		return new Queue("queueOne");
	}

  
   //队列Two
	@Bean
	public Queue queueTwo(){

		return new Queue("queueTwo");
	}


  
  //交换机。类型Direct（⭐️⭐️⭐️⭐️）
	@Bean
	public DirectExchange directExchange(){

		return new DirectExchange("directExchange");
	}

  //绑定 队列ONE和交换机directExchange 使用路由key-one (⭐️⭐️⭐️⭐️⭐️⭐️⭐️）
	@Bean
	public Binding queueOneBinding(){

		return BindingBuilder.bind(queueOne()).to(directExchange()).with("one");
	}
  
  
  
 //绑定 队列TWO 和交换机directExchange 使用路由key-two (⭐️⭐️⭐️⭐️⭐️⭐️⭐️）
	@Bean
	public Binding queueTwoBinding(){

		return BindingBuilder.bind(queueTwo()).to(directExchange()).with("two");
	}

  
   //绑定 队列TWO 和交换机directExchange 使用路由key-thress(⭐️⭐️⭐️⭐️⭐️⭐️⭐️）
	@Bean
	public Binding queueThreeBinding(){

		return BindingBuilder.bind(queueTwo()).to(directExchange()).with("three");
	}
}

发送消息 - 生产者

@Service
public class RabbitMqService3 {

	@Autowired
	RabbitTemplate rabbitTemplate;

	public void send(String routingKey){

    //指定交换机的名字
    //指定路由key
    //message
		rabbitTemplate.convertAndSend("directExchange",routingKey,"value:" + routingKey);
	}
}

接收消息 - 消费者

@Component
public class RabbitMqComponent3 {
  
 // @RabbitListener 只指定队列名字
@RabbitListener(queues = "queueOne")
public void listerQueueOne(String message){
	System.out.print("queueOne" + message);
}
  
  

@RabbitListener(queues = "queueTwo")
public void listerQueueTwo(String message){
	System.out.print("queueTwo" + message);
 }
}

---

---

---