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.生产者
@Component public 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 @Slf4j public class Receiver { @RabbitListener(queuesToDeclare = @Queue(QueueNames.MY_QUEUE)) public void receive(String msg) { log.info("MY_QUEUE receive:{}", msg); } }
标签:String,spingboot,spring,rabbitmq,QUEUE,使用,msg,MY,public 来源: https://www.cnblogs.com/liaozhenghan/p/14792627.html