话不多少 上来就是干
如果你想直接可以使用，可以直接参考项目代码 github源代码
首先引入依赖
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);
}
}
转播
