实现一对一聊天功能
功能介绍：实现A和B单独聊天功能，即A发消息给B只能B接收，同样B向A发消息只能A接收。
本篇博客是在上一遍基础上搭建，上一篇博客地址：【WebSocket】---实现游戏公告功能。源码会在其它案例全部写完，在上传到gitHub,到时候会补源码地址。
先看演示效果：
一、案例解析
1、PTPContoller
/** * 功能描述：简单版单人聊天 * 这里没有用到@SendTo("/topic/game_chat")来指定订阅地址，而是通过SimpMessagingTemplate来指定 */@Controllerpublic class PTPContoller { ???@Autowired ???private WebSocketService ws; ???@MessageMapping("/ptp/single/chat") ???public void singleChat(InMessage message) { ???????ws.sendChatMessage(message); ???}}这里和前面的公告消息，最大的区别就是接口上没有通过@SendTo("/topic/game_chat")来发送消息。
（1）@SendTo和SimpMessagingTemplate区别
spring websocket基于注解的@SendTo和@SendToUser虽然方便，但是有局限性，例如我这样子的需求，我想手动的把消息推送给某个人，或者特定一组人，怎么办，
@SendTo只能推送给所有人（它是一个具体地址，一点都不灵活），@SendToUser只能推送给请求消息的那个人，这时，我们可以利用SimpMessagingTemplate这个类
SimpMessagingTemplate有俩个推送的方法
convertAndSend(destination, payload); ???????????//将消息广播到特定订阅路径中，类似@SendTo convertAndSendToUser(user, destination, payload);//将消息推送到固定的用户订阅路径中，类似@SendToUser
2、WebSocketService
import com.jincou.websocket.model.InMessage;import com.jincou.websocket.model.OutMessage;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.messaging.simp.SimpMessagingTemplate;import org.springframework.stereotype.Service;/** * 功能描述：简单消息模板，用来推送消息 */@Servicepublic class WebSocketService { ???@Autowired ???private SimpMessagingTemplate template; ???/** ????* 简单点对点聊天室 ????*/ ???public void sendChatMessage(InMessage message) { ???????//可以看出template最大的灵活就是我们可以获取前端传来的参数来指定订阅地址 ???????//前面参数是订阅地址，后面参数是消息信息 ???????template.convertAndSend("/chat/single/"+message.getTo(), ???????????????new OutMessage(message.getFrom()+" 发送:"+ message.getContent())); ???}3、app.js
其它地方和公告的app.js一样，只有下面两点做了一点修改
function connect() { ???var from = $("#from").val(); ???var socket = new SockJS(‘/endpoint-websocket‘); ???stompClient = Stomp.over(socket); ???stompClient.connect({}, function (frame) { ???????setConnected(true); ???????console.log(‘Connected: ‘ + frame); ???????//1、通过+from就可以灵活的用当前用户的某一信息来指定该用户订阅地址。 ???????stompClient.subscribe(‘/chat/single/‘+from, function (result) { ???????????showContent(JSON.parse(result.body)); ???????}); ???});}function sendName() { ????//2、这里出了发送content信息外，还发送了发送者用户信息，和接受者的信息 ???stompClient.send("/app/ptp/single/chat", {}, JSON.stringify({‘content‘: $("#content").val(), ‘to‘:$("#to").val(), ‘from‘:$("#from").val()}));}4、user.html
其它地方也和之前公告的一样，下面是修改的地方
?<div class="col-md-6"> ???????????<form class="form-inline"> ???????????????<div class="form-group"> ???????????????????<input type="text" id="from" class="form-control" placeholder="我是"> ???????????????????<input type="text" id="to" class="form-control" placeholder="发送给谁"> ???????????????????????????????????????<input type="text" id="content" class="form-control" placeholder="请输入..."> ?????????????????????????????????????????????</div> ???????????????<button id="send" class="btn btn-default" type="submit">发送</button> ???????????</form> ???????</div>
5、再把整个思路缕一缕
以 A 向 B 发送消息为例
（1）form输入框输入：“A”,to输入框输入 “B” 点击“Connect”建立websocket连接
（2）那么的 A 用户的订阅地址就是‘/chat/single/A‘
（3）前端在“content”按钮中输入“你今天吃鸡了吗？”，再点击“发送”按钮
（4）后台通过接受处理就成了：
template.convertAndSend("/chat/single/B",new OutMessage(" A 发送:你今天吃鸡了吗？"));那么 B 向 A 发送性质一模一样。就可以实现一对一聊天。
注意：这个只是演示，并不是真正一对一聊天，一般如果实现一对一聊天，那么form和to都应该是唯一的，比如该用户的userID，这样就可以真正实现一对一聊天了。
想太多，做太少，中间的落差就是烦恼。想没有烦恼，要么别想，要么多做。中校【19】
【WebSocket】---实现一对一聊天功能
原文地址：https://www.cnblogs.com/qdhxhz/p/9452237.html