<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
/*
接收MQ消息
*/
@Slf4j
@Component
public class MqReceiver {
@RabbitListener(queues = "spoon-queues")
public void process(String message) {
log.info("MqReceiver: {}", message);
}
}
/*
接收MQ消息
*/
@Slf4j
@Component
public class MqReceiver {
@RabbitListener(queuesToDeclare = @Queue("spoon-queues"))
public void process(String message) {
log.info("MqReceiver: {}", message);
}
}
/*
接收MQ消息
*/
@Slf4j
@Component
public class MqReceiver {
@RabbitListener(bindings = @QueueBinding(
value = @Queue("spoon-queues"),
exchange = @Exchange("spoon-exchange")
))
public void process(String message) {
log.info("MqReceiver: {}", message);
}
}
/*
发送MQ消息
*/
@SpringBootTest
class RabbitMqTestApplicationTests {
@Autowired
private AmqpTemplate amqpTemplate;
@Test
void contextLoads() {
amqpTemplate.convertAndSend("spoon-queues", "now : " + new Date());
}
}
/*
数码供应商 接收消息
*/
@RabbitListener(bindings = @QueueBinding(
exchange = @Exchange("spoon-order"),
key = "computer",
value = @Queue("queues-computer-order")
))
public void processComputer(String message) {
log.info("Computer MqReceiver: {}", message);
}
/*
水果供应商 接收消息
*/
@RabbitListener(bindings = @QueueBinding(
exchange = @Exchange("spoon-order"),
key = "fruit",
value = @Queue("queues-fruit-order")
))
public void processFruit(String message) {
log.info("Fruit MqReceiver: {}", message);
}
amqpTemplate.convertAndSend("spoon-order", "computer", "now : " + new Date());