RabbitMQ的基本使用

<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());