Spring Boot 开发私有即时通信系统（WebSocket）

1/ 概述

利用Spring Boot作为基础框架，Spring Security作为安全框架，WebSocket作为通信框架，实现点对点聊天和群聊天。

2/ 所需依赖

Spring Boot 版本 1.5.3，使用MongoDB存储数据（非必须），Maven依赖如下：

<properties>
 <java.version>1.8</java.version>
 <thymeleaf.version>3.0.0.RELEASE</thymeleaf.version>
 <thymeleaf-layout-dialect.version>2.0.0</thymeleaf-layout-dialect.version>
 </properties>

 <dependencies>

 <!-- WebSocket依赖，移除Tomcat容器 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-websocket</artifactId>
  <exclusions>
  <exclusion>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-tomcat</artifactId>
  </exclusion>
  </exclusions>
 </dependency>

 <!-- 使用Undertow容器 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-undertow</artifactId>
 </dependency>

 <!-- Spring Security 框架 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-security</artifactId>
 </dependency>

 <!-- MongoDB数据库 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-mongodb</artifactId>
 </dependency>

 <!-- Thymeleaf 模版引擎 -->
 <dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-thymeleaf</artifactId>
 </dependency>

 <dependency>
  <groupId>org.projectlombok</groupId>
  <artifactId>lombok</artifactId>
  <version>1.16.16</version>
 </dependency>

 <dependency>
  <groupId>com.alibaba</groupId>
  <artifactId>fastjson</artifactId>
  <version>1.2.30</version>
 </dependency>

 <!-- 静态资源 -->
 <dependency>
  <groupId>org.webjars</groupId>
  <artifactId>webjars-locator</artifactId>
 </dependency>
 <dependency>
  <groupId>org.webjars</groupId>
  <artifactId>sockjs-client</artifactId>
  <version>1.0.2</version>
 </dependency>
 <dependency>
  <groupId>org.webjars</groupId>
  <artifactId>stomp-websocket</artifactId>
  <version>2.3.3</version>
 </dependency>
 <dependency>
  <groupId>org.webjars</groupId>
  <artifactId>bootstrap</artifactId>
  <version>3.3.7</version>
 </dependency>
 <dependency>
  <groupId>org.webjars</groupId>
  <artifactId>jquery</artifactId>
  <version>3.1.0</version>
 </dependency>

 </dependencies>

配置文件内容：

server:
 port: 80

# 若使用MongoDB则配置如下参数
spring:
 data:
 mongodb:
  uri: mongodb://username:password@172.25.11.228:27017
  authentication-database: admin
  database: chat

大致程序结构，仅供参考：

3/ 创建程序启动类，启用WebSocket

使用@EnableWebSocket注解

@SpringBootApplication
@EnableWebSocket
public class Application {

 public static void main(String[] args) {
 SpringApplication.run(Application.class, args);
 }

}

4/ 配置Spring Security

此章节省略。（配置好Spring Security，用户能正常登录即可）

5/ 配置Web Socket（结合第7节的JS看）

@Configuration
@EnableWebSocketMessageBroker
@Log4j
public class WebSocketConfig extends AbstractWebSocketMessageBrokerConfigurer {

 // 此处可注入自己写的Service

 @Override
 public void registerStompEndpoints(StompEndpointRegistry stompEndpointRegistry) {
 // 客户端与服务器端建立连接的点
 stompEndpointRegistry.addEndpoint("/any-socket").withSockJS();
 }

 @Override
 public void configureMessageBroker(MessageBrokerRegistry messageBrokerRegistry) {
 // 配置客户端发送信息的路径的前缀
 messageBrokerRegistry.setApplicationDestinationPrefixes("/app");
 messageBrokerRegistry.enableSimpleBroker("/topic");
 }

 @Override
 public void configureWebSocketTransport(final WebSocketTransportRegistration registration) {
 registration.addDecoratorFactory(new WebSocketHandlerDecoratorFactory() {
  @Override
  public WebSocketHandler decorate(final WebSocketHandler handler) {
  return new WebSocketHandlerDecorator(handler) {
   @Override
   public void afterConnectionEstablished(final WebSocketSession session) throws Exception {
   // 客户端与服务器端建立连接后，此处记录谁上线了
   String username = session.getPrincipal().getName();
   log.info("online: " + username);
   super.afterConnectionEstablished(session);
   }

   @Override
   public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
   // 客户端与服务器端断开连接后，此处记录谁下线了
   String username = session.getPrincipal().getName();
   log.info("offline: " + username);
   super.afterConnectionClosed(session, closeStatus);
   }
  };
  }
 });
 super.configureWebSocketTransport(registration);
 }
}

6/ 点对点消息，群消息

@Controller
@Log4j
public class ChatController {

 @Autowired
 private SimpMessagingTemplate template;

 // 注入其它Service

 // 群聊天
 @MessageMapping("/notice")
 public void notice(Principal principal, String message) { 
 // 参数说明 principal 当前登录的用户， message 客户端发送过来的内容
 // principal.getName() 可获得当前用户的username 

 // 发送消息给订阅 "/topic/notice" 且在线的用户
 template.convertAndSend("/topic/notice", message); 
 }

 // 点对点聊天
 @MessageMapping("/chat")
 public void chat(Principal principal, String message){
 // 参数说明 principal 当前登录的用户， message 客户端发送过来的内容（应该至少包含发送对象toUser和消息内容content）
 // principal.getName() 可获得当前用户的username

 // 发送消息给订阅 "/user/topic/chat" 且用户名为toUser的用户
 template.convertAndSendToUser(toUser, "/topic/chat", content);
 }

}

7/ 客户端与服务器端交互

 var stompClient = null;

 function connect() {
  var socket = new SockJS('/any-socket');
  stompClient = Stomp.over(socket);
  stompClient.connect({}, function (frame) {
   // 订阅 /topic/notice 实现群聊
   stompClient.subscribe('/topic/notice', function (message) {
    showMessage(JSON.parse(message.body));
   });
   // 订阅 /user/topic/chat 实现点对点聊
   stompClient.subscribe('/user/topic/chat', function (message) {
    showMessage(JSON.parse(message.body));
   });
  });
 }

 function showMessage(message) {
  // 处理消息在页面的显示
 }

 $(function () {
  // 建立websocket连接
  connect();
  // 发送消息按钮事件
  $("#send").click(function () {
   if (target == "TO_ALL"){
    // 群发消息
    // 匹配后端ChatController中的 @MessageMapping("/notice")
    stompClient.send("/app/notice", {}, '消息内容');
   }else{
    // 点对点消息，消息中必须包含对方的username
    // 匹配后端ChatController中的 @MessageMapping("/chat")
    var content = "{'content':'消息内容','receiver':'anoy'}";
    stompClient.send("/app/chat", {}, content);
   }
  });
 });

8/ 效果测试

登录三个用户：Anoyi、Jock、超级管理员。

群消息测试，超级管理员群发消息：

点对点消息测试，Anoyi给Jock发送消息，只有Jock收到消息，Anoyi和超级管理员收不到消息：

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# spring  # boot  # 即时通讯  # springboot  # websocket  # socket  # SpringBoot开发案例之打造私有云网盘的实现  # Spring实现类私有方法的几个问题(亲测通用解决方案)  # 客户端  # 点对点  # 发送消息  # 后端  # 线了  # 所需  # 配置文件  # 大家多多  # 移除  # 收不到  # 仅供参考  # jquery  # bootstrap  # plain  # stomp  # lombok  # alibaba  # webjars  # fastjson  # client 

相关文章： 广州网站制作公司哪家好一点,广州欧莱雅百库网络科技有限公司官网？  如何在Windows虚拟主机上快速搭建网站？  如何获取免费开源的自助建站系统源码？  香港服务器网站推广：SEO优化与外贸独立站搭建策略  公司门户网站制作流程,华为官网怎么做？  制作网站的软件免费下载,免费制作app哪个平台好？  建站VPS配置与SEO优化指南：关键词排名提升策略  如何在IIS7中新建站点？详细步骤解析  在线ppt制作网站有哪些软件,如何把网页的内容做成ppt？  如何挑选优质建站一级代理提升网站排名？  如何在企业微信快速生成手机电脑官网？  常州企业网站制作公司,全国继续教育网怎么登录？  如何快速查询网址的建站时间与历史轨迹？  韩国网站服务器搭建指南：VPS选购、域名解析与DNS配置推荐  小说建站VPS选用指南：性能对比、配置优化与建站方案解析  如何在万网自助建站中设置域名及备案？  网页设计与网站制作内容,怎样注册网站？  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱？  平台云上自助建站如何快速打造专业网站？  深圳网站制作案例,网页的相关名词有哪些？  如何快速上传自定义模板至建站之星？  移动端手机网站制作软件,掌上时代，移动端网站的谷歌SEO该如何做？  设计网站制作公司有哪些,制作网页教程？  如何快速搭建个人网站并优化SEO？  台州网站建设制作公司,浙江手机无犯罪记录证明怎么开？  太原网站制作公司有哪些,网约车营运证查询官网？  建站之星安装失败：服务器环境不兼容？  免费视频制作网站,更新又快又好的免费电影网站？  浅谈Javascript中的Label语句  宝塔建站助手安装配置与建站模板使用全流程解析  高端云建站费用究竟需要多少预算？  如何使用Golang安装API文档生成工具_快速生成接口文档  专业网站设计制作公司,如何制作一个企业网站，建设网站的基本步骤有哪些？  建站之星如何实现五合一智能建站与营销推广？  阿里云网站制作公司,阿里云快速搭建网站好用吗？  如何通过多用户协作模板快速搭建高效企业网站？  高防网站服务器：DDoS防御与BGP线路的AI智能防护方案  建站10G流量真的够用吗？如何应对访问高峰？  宁波免费建站如何选择可靠模板与平台？  ,石家庄四十八中学官网？  建站之星客服服务时间及联系方式如何？  香港服务器租用每月最低只需15元？  香港服务器网站搭建教程-电商部署、配置优化与安全稳定指南  青岛网站设计制作公司,查询青岛招聘信息的网站有哪些？  电商平台网站制作流程,电商网站如何制作？  如何将凡科建站内容保存为本地文件？  实例解析angularjs的filter过滤器  武汉网站如何制作,黄黄高铁武穴北站途经哪些村庄？  如何确保西部建站助手FTP传输的安全性？  如何快速搭建高效WAP手机网站？