消息推送系统

@RestController

高校科研管理系统

public class MessageController {

@Autowired

private RabbitTemplate rabbitTemplate;

@PostMapping("/send")

public ResponseEntity sendMessage(@RequestBody MessageDTO message) {

rabbitTemplate.convertAndSend("messageExchange", "message.routing.key", message);

return ResponseEntity.ok("Message sent to queue");

}

}

@Component

public class MessageConsumer {

@RabbitListener(queues = "messageQueue")

public void receiveMessage(MessageDTO message) {

if (message.getType().equals("email")) {

sendEmail(message.getContent());

} else if (message.getType().equals("sms")) {

sendSMS(message.getContent());

}

}

}