@Component
public class StartListener implements ApplicationRunner {
@Autowired
private AdMapper adMapper;
@Autowired
private RabbitTemplate rabbitTemplate;
@Override
public void run(ApplicationArguments args) throws Exception {
List ads = adMapper.selectAll();
for (Ad ad : ads) {
String position = ad.getPosition();
rabbitTemplate.convertAndSend("", RabbitMQConfig.AD_UPDATE_QUEUE,ad.getPosition());
// 只将当前 行数据 中的position 值发送到 rabbitMQ 中
System.out.println("项目启动时读取数据:"+ad.getPosition());
}
}
}



