SpringBoot即时通讯如何实现消息多级回复？
- > listMessages(@RequestParam Long receiverId, @RequestParam Long parentId) {
List
猜你喜欢：环信超级社区
热搜词：
视频会议系统
中央美术学院集训
视频出海技术
网络可视化
招聘
org.springframework.boot
spring-boot-starter-websocket
org.mybatis.spring.boot
mybatis-spring-boot-starter
2.1.3
org.springframework.boot
spring-boot-starter-data-redis
mysql
mysql-connector-java
runtime
```
2. 配置数据库和Redis
```yaml
spring:
datasource:
url: jdbc:mysql://localhost:3306/im?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC
username: root
password: root
redis:
host: localhost
port: 6379
```
3. 创建消息表和用户表
```sql
CREATE TABLE `message` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`sender_id` bigint(20) NOT NULL,
`receiver_id` bigint(20) NOT NULL,
`parent_id` bigint(20) DEFAULT NULL,
`content` text NOT NULL,
`create_time` datetime NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
CREATE TABLE `user` (
`id` bigint(20) NOT NULL AUTO_INCREMENT,
`username` varchar(50) NOT NULL,
`password` varchar(50) NOT NULL,
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;
```
4. 创建消息实体类（Message）
```java
public class Message {
private Long id;
private Long senderId;
private Long receiverId;
private Long parentId;
private String content;
private Date createTime;
// 省略getter和setter方法
}
```
5. 创建消息Mapper接口（MessageMapper）
```java
@Mapper
public interface MessageMapper {
List selectMessagesByReceiverIdAndParentId(Long receiverId, Long parentId);
}
```
6. 创建消息Service实现类（MessageService）
```java
@Service
public class MessageService {
@Autowired
private MessageMapper messageMapper;
public List selectMessagesByReceiverIdAndParentId(Long receiverId, Long parentId) {
return messageMapper.selectMessagesByReceiverIdAndParentId(receiverId, parentId);
}
}
```
7. 创建消息Controller（MessageController）
```java
@RestController
@RequestMapping("/message")
public class MessageController {
@Autowired
private MessageService messageService;
@GetMapping("/list")
public ResponseEntity