05-21 10:32 阅读 120

关注

spingboot使用rabbitmq

spingboot使用rabbitmq

1.引入依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId></dependency>

2.yml配置

spring:
  rabbitmq:
    host: 47.115.14.7
    port: 9903
    username: guest
    password: guest

3.生产者

@Componentpublic class ProduceSchedule {
    @Autowired    private AmqpTemplate amqpTemplate;

    @Scheduled(fixedRate = 1000)    public void send() {
        String msg = "MY_QUEUE send ..." + System.currentTimeMillis();
        amqpTemplate.convertAndSend(QueueNames.MY_QUEUE, msg);
    }
}

4.消费者

@Component
@Slf4jpublic class Receiver {

    @RabbitListener(queuesToDeclare = @Queue(QueueNames.MY_QUEUE))    public void receive(String msg) {
        log.info("MY_QUEUE receive：{}", msg);
    }
}

来源：https://www.cnblogs.com/liaozhenghan/p/14792627.html

服务器评测 http://www.cncsto.com/ 

服务器测评 http://www.cncsto.com/