构建‘统一消息推送平台’支持‘工程学院’的教学管理

// 引入依赖

dependencies {

implementation 'org.springframework.boot:spring-boot-starter-amqp'

implementation 'org.springframework.boot:spring-boot-starter-data-jpa'

}

// 配置RabbitMQ连接

spring.rabbitmq.host=localhost

spring.rabbitmq.port=5672

spring.rabbitmq.username=guest

spring.rabbitmq.password=guest

// 实体类

@Entity

public class MessageRecord {

@Id

@GeneratedValue(strategy = GenerationType.IDENTITY)

private Long id;

private String recipient;

private String messageContent;

private String messageType;

private Date sendTime;

}

// 消息生产者

@Component

public class MessageProducer {

@Autowired

private AmqpTemplate rabbitTemplate;

public void sendMessage(String queue, String message) {

rabbitTemplate.convertAndSend(queue, message);

}

}

// 消息消费者

@Component

public class MessageConsumer {

@RabbitListener(queues = "student_queue")

public void receiveMessage(String message) {

System.out.println("Received Message: " + message);

}

}