网页开发模板_成都中高风险地区名单最新_网络营销产品推广方案_在什么网站可以免费

引入依赖

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

编写config类

@Configuration
public class RabbitmqConfig {public static final String RECORD_QUEUE = "teaching-assistant-record_queue";@Beanpublic Jackson2JsonMessageConverter jsonMessageConverter() {return new Jackson2JsonMessageConverter();}@Beanpublic Queue queue() {//创建一个队列队列，并指定队列的名字return new Queue(RECORD_QUEUE,true);}
}

使用rabbitmq

@Overridepublic String add(ExamRecordDto examRecordDto) {rabbitTemplate.convertAndSend("", RabbitmqConfig.RECORD_QUEUE,examRecordDto);return "Exam record added successfully";}@Autowiredprivate ExamRecordMapper examRecordMapper;@RabbitListener(queues = {RabbitmqConfig.RECORD_QUEUE})public void receiveHelloQueueMessage(ExamRecordDto examRecordDto) {System.out.println("消费者收到消息:"+examRecordDto.toString());QueryWrapper<ExamRecordEntity> queryWrapper=new QueryWrapper<>();queryWrapper.eq("exam_id",examRecordDto.getExamId());queryWrapper.eq("exercise_id",examRecordDto.getExerciseId());queryWrapper.eq("user_id",examRecordDto.getUserId());if(examRecordMapper.selectOne(queryWrapper)!=null){examRecordMapper.delete(queryWrapper);}examRecordMapper.insert(examRecordDto.toEntity());}