基于Java实现互联网实时聊天系统(附源码)

基于Java实现互联网实时聊天系统

该项目是一个使用Java语言和Spring框架实现的互联网实时聊天系统，具有以下特点：

• 基于WebSocket协议，实现客户端与服务端的实时双向通信。
• 使用Spring Boot构建，集成Spring MVC和Spring WebSocket组件。
• 使用MySQL数据库存储聊天记录和用户信息。

项目结构

• chat-server：服务端代码，包含Spring Boot应用程序。
• chat-client：客户端代码，使用Vue.js和Websocket技术实现。

实现步骤

以下是实现该项目的步骤：

1. 创建Spring Boot应用程序。

2. 添加Spring WebSocket组件的依赖。

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

1. 添加MySQL数据库的依赖及配置。

xml
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>

properties
spring.datasource.url=jdbc:mysql://localhost:3306/chat?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2B8
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.jpa.database-platform=org.hibernate.dialect.MySQL5InnoDBDialect
spring.jpa.hibernate.ddl-auto=update
spring.jpa.show-sql=true

1. 添加WebSocket配置类。

```java
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {

   @Override
   public void configureMessageBroker(MessageBrokerRegistry config) {
       config.enableSimpleBroker("/topic");
       config.setApplicationDestinationPrefixes("/app");
   }

   @Override
   public void registerStompEndpoints(StompEndpointRegistry registry) {
       registry.addEndpoint("/websocket").setAllowedOrigins("*").withSockJS();
   }

}
```

1. 添加消息实体类和持久化实体类。

```java
// 消息实体类
@Data
public class ChatMessage {

   private String sender;
   private String content;
   private String type;

}

// 持久化实体类
@Entity
@Table(name = "chat_record")
@Data
public class ChatRecord {

   @Id
   @GeneratedValue(strategy = GenerationType.IDENTITY)
   private Long id;

   private String sender;

   private String receiver;

   private String content;

   private LocalDateTime sendTime;

}
```

1. 添加控制器类。

```java
@RestController
@RequestMapping("/chat")
public class ChatController {

   @Autowired
   private ChatRecordRepository chatRecordRepository;

   @MessageMapping("/send")
   @SendTo("/topic/messages")
   public ChatMessage send(ChatMessage message) {
       LocalDateTime sendTime = LocalDateTime.now();
       message.setType("CHAT");
       message.setSendTime(sendTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
       ChatRecord chatRecord = new ChatRecord();
       chatRecord.setSender(message.getSender());
       chatRecord.setReceiver("ALL");
       chatRecord.setContent(message.getContent());
       chatRecord.setSendTime(sendTime);
       chatRecordRepository.save(chatRecord);
       return message;
   }

}
```

1. 添加客户端代码。

```html

```

1. 启动应用程序，使用浏览器访问客户端页面。

示例说明

以下是两个示例：

示例一：发送消息

1. 启动应用程序，并使用浏览器访问客户端页面。
2. 输入用户名，点击确定。
3. 在输入框中输入消息内容，按下Enter键发送消息。
4. 可以看到发送的消息出现在消息列表中。

示例二：查看聊天记录

1. 启动应用程序，并使用浏览器访问客户端页面。
2. 输入用户名，点击确定。
3. 可以看到历史聊天记录出现在消息列表中。