springboot使用rabbitmq

话不多少 上来就是干

如果你想直接可以使用，可以直接参考项目代码 github源代码

首先引入依赖

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

application.properties配置信息

#默认端口配置

server.port=8080

rabbit配置

spring.rabbitmq.host=127.0.0.1
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/

@Component
public class ProduceRabbitComponent {

@Autowired
private RabbitTemplate rabbitTemplate;

@Scheduled(cron = "0 * * * * *") // 每分钟发送一次数据信息
public void sendRabbitMessage() {
        String message = UUID.randomUUID().toString();
        System.out.println(message);
        rabbitTemplate.convertAndSend("queue_one", message);
        rabbitTemplate.convertAndSend("queue_two", message);
    }

 }