SpringMVC的websocket实现一对一聊天
时间: 2023-05-25 15:03:07 浏览: 75
1. 引入相关依赖
在pom.xml文件中引入以下依赖：
```
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-websocket</artifactId>
<version>5.2.9.RELEASE</version>
</dependency>
```
2. 配置WebSocket
在SpringMVC配置文件中配置WebSocket：
```
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
@Override
public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
registry.addHandler(chatWebSocketHandler(), "/chat");
}
@Bean
public WebSocketHandler chatWebSocketHandler() {
return new ChatWebSocketHandler();
}
}
```
上述代码中，我们通过`@EnableWebSocket`注解启用WebSocket，并通过`registerWebSocketHandlers`方法注册`chatWebSocketHandler`来处理所有连接到`/chat`的WebSocket请求。
3. 创建WebSocketHandler
接下来，创建一个WebSocketHandler类，命名为`ChatWebSocketHandler`：
```
public class ChatWebSocketHandler extends TextWebSocketHandler {
private Map<String, WebSocketSession> sessionMap = new ConcurrentHashMap<>();
@Override
public void afterConnectionEstablished(WebSocketSession session) throws Exception {
String username = session.getPrincipal().getName();
sessionMap.put(username, session);
}
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
String username = session.getPrincipal().getName();
String recipientUsername = getRecipientUsername(message);
String textMessage = getTextMessage(message);
WebSocketSession recipientSession = sessionMap.get(recipientUsername);
if (recipientSession == null) {
throw new IllegalArgumentException("Recipient " + recipientUsername + " not found");
}
TextMessage text = new TextMessage(username + ": " + textMessage);
recipientSession.sendMessage(text);
}
@Override
public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
String username = session.getPrincipal().getName();
sessionMap.remove(username);
}
private String getRecipientUsername(WebSocketMessage<?> message) {
String payload = (String) message.getPayload();
return payload.substring(0, payload.indexOf(':'));
}
private String getTextMessage(WebSocketMessage<?> message) {
String payload = (String) message.getPayload();
return payload.substring(payload.indexOf(':') + 2);
}
}
```
上述代码中，我们创建了一个WebSocketHandler类，并重写了`afterConnectionEstablished`、`handleMessage`和`afterConnectionClosed`方法。在`afterConnectionEstablished`方法中，我们将客户端Session保存在一个Map中，以便后续处理时可以根据用户名找到对应的Session；在`handleMessage`方法中，我们从WebSocket消息中获取发送者用户名、接收者用户名和消息内容，并使用接收者用户名获取接收者Session，然后将消息发送给接收者；在`afterConnectionClosed`方法中，我们从Map中删除已经断开连接的Session。
4. 创建WebSocket客户端
最后，创建一个Web页面来展示WebSocket实时通讯效果，代码如下：
```
<!DOCTYPE html>
<html>
<head>
<title>WebSocket Chat</title>
<script type="text/javascript">
var socket = new WebSocket("ws://localhost:8080/chat");
socket.onopen = function() {
console.log("WebSocket connection established.");
}
socket.onmessage = function(event) {
console.log(event.data);
var chatMessage = document.createElement("p");
chatMessage.innerText = event.data;
document.getElementById("chat").appendChild(chatMessage);
}
socket.onclose = function(event) {
console.log("WebSocket connection closed (" + event.code + ")");
}
function sendMessage() {
var recipient = document.getElementById("recipient").value;
var message = document.getElementById("message").value;
var payload = recipient + ": " + message;
socket.send(payload);
}
</script>
</head>
<body>
<div id="chat"></div>
<br>
<input type="text" placeholder="Recipient" id="recipient"><br>
<input type="text" placeholder="Message" id="message"><br>
<button onclick="sendMessage()">Send</button>
</body>
</html>
```
上述代码中，我们通过`WebSocket`对象创建了一个WebSocket客户端，并监听了`onopen`、`onmessage`和`onclose`事件。当WebSocket连接成功建立后，会调用`onopen`方法；当收到消息时，会调用`onmessage`方法，在页面上显示收到的消息；当WebSocket连接断开时，会调用`onclose`方法。同时，页面上提供了输入框和发送按钮，点击发送按钮后，会从输入框中获取接收者和消息内容，然后通过WebSocket发送到服务器。
至此，SpringMVC的WebSocket实现一对一聊天就完成了。如果需要群聊功能，只需要稍作修改即可。
相关推荐
最新推荐
SpringMVC整合websocket实现消息推送及触发功能
主要为大家详细介绍了SpringMVC整合websocket实现消息推送及触发功能，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
SpringMVC实现前端后台交互传递数据
本篇文章主要介绍了SpringMVC实现前端后台传递数据的方法，具有一定的参考价值，感兴趣的小伙伴们可以参考一下。
SpringMVC自定义拦截器实现过程详解
主要介绍了SpringMVC自定义拦截器实现过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
SpringMVC拦截器实现登录认证
主要介绍了SpringMVC拦截器实现登录认证的相关资料,具有一定的参考价值，感兴趣的小伙伴们可以参考一下
详解SpringMVC使用MultipartFile实现文件的上传
本篇文章主要介绍了SpringMVC使用MultipartFile实现文件的上传，本地的文件上传到资源服务器上，比较好的办法就是通过ftp上传。这里是结合SpringMVC+ftp的形式上传的，有兴趣的可以了解一下。
RTL8188FU-Linux-v5.7.4.2-36687.20200602.tar(20765).gz
REALTEK 8188FTV 8188eus 8188etv linux驱动程序稳定版本， 支持AP,STA 以及AP+STA 共存模式。 稳定支持linux4.0以上内核。
管理建模和仿真的文件
管理Boualem Benatallah引用此版本：布阿利姆·贝纳塔拉。管理建模和仿真。约瑟夫-傅立叶大学-格勒诺布尔第一大学，1996年。法语。NNT：电话：00345357HAL ID：电话：00345357https://theses.hal.science/tel-003453572008年12月9日提交HAL是一个多学科的开放存取档案馆，用于存放和传播科学研究论文，无论它们是否被公开。论文可以来自法国或国外的教学和研究机构，也可以来自公共或私人研究中心。L’archive ouverte pluridisciplinaire
爬虫与大数据分析：挖掘数据价值，洞察趋势
# 1. 爬虫基础与技术**
爬虫，又称网络蜘蛛，是一种自动化的程序，用于从互联网上抓取数据。其工作原理是模拟浏览器行为，通过发送请求并解析响应来获取网页内容。
爬虫技术涉及多种技术，
解释一下下面每句话的含义@RequestMapping(value = "gcGl") public String gcGl(Gcgl gcGl, Model model) { List<Gcgl> list = gcglService.findList(gcGl); if (list!=null&&list.size()>0) { model.addAttribute("gcGl", list.get(0)); }else { model.addAttribute("gcGl", gcGl); } return "modules/tjxx/gc08glForm"; }
这段代码是一个Java方法，用于处理HTTP请求，具体含义如下：
- @RequestMapping(value = "gcGl")：这是一个注解，表示该方法会处理名为"gcGl"的请求，即当用户访问该请求时，会调用该方法。
- public String gcGl(Gcgl gcGl, Model model)：这是方法的声明，它有两个参数：一个是Gcgl类型的gcGl，另一个是Model类型的model。方法的返回值是一个字符串类型。
- List<Gcgl> list = gcglService.findList(gcGl)：这行代码调用了一个名为findList的方法，该方法接受一个
c++校园超市商品信息管理系统课程设计说明书(含源代码) (2).pdf
校园超市商品信息管理系统课程设计旨在帮助学生深入理解程序设计的基础知识，同时锻炼他们的实际操作能力。通过设计和实现一个校园超市商品信息管理系统，学生掌握了如何利用计算机科学与技术知识解决实际问题的能力。在课程设计过程中，学生需要对超市商品和销售员的关系进行有效管理，使系统功能更全面、实用，从而提高用户体验和便利性。
学生在课程设计过程中展现了积极的学习态度和纪律，没有缺勤情况，演示过程流畅且作品具有很强的使用价值。设计报告完整详细，展现了对问题的深入思考和解决能力。在答辩环节中，学生能够自信地回答问题，展示出扎实的专业知识和逻辑思维能力。教师对学生的表现予以肯定，认为学生在课程设计中表现出色，值得称赞。
整个课程设计过程包括平时成绩、报告成绩和演示与答辩成绩三个部分，其中平时表现占比20%，报告成绩占比40%，演示与答辩成绩占比40%。通过这三个部分的综合评定，最终为学生总成绩提供参考。总评分以百分制计算，全面评估学生在课程设计中的各项表现，最终为学生提供综合评价和反馈意见。
通过校园超市商品信息管理系统课程设计，学生不仅提升了对程序设计基础知识的理解与应用能力，同时也增强了团队协作和沟通能力。这一过程旨在培养学生综合运用技术解决问题的能力，为其未来的专业发展打下坚实基础。学生在进行校园超市商品信息管理系统课程设计过程中，不仅获得了理论知识的提升，同时也锻炼了实践能力和创新思维，为其未来的职业发展奠定了坚实基础。
校园超市商品信息管理系统课程设计的目的在于促进学生对程序设计基础知识的深入理解与掌握，同时培养学生解决实际问题的能力。通过对系统功能和用户需求的全面考量，学生设计了一个实用、高效的校园超市商品信息管理系统，为用户提供了更便捷、更高效的管理和使用体验。
综上所述，校园超市商品信息管理系统课程设计是一项旨在提升学生综合能力和实践技能的重要教学活动。通过此次设计，学生不仅深化了对程序设计基础知识的理解，还培养了解决实际问题的能力和团队合作精神。这一过程将为学生未来的专业发展提供坚实基础，使其在实际工作中能够胜任更多挑战。