好资源导航 » 文章资讯 » SpringBoot的WebSocket实现单聊群聊

SpringBoot的WebSocket实现单聊群聊

2023-07-05 04:01:03 63

本文实例为大家分享了SpringBoot的WebSocket实现单聊群聊，供大家参考，具体内容如下

说在开头

在HTTP协议中，所有的请求都是由客户端发送给服务端，然后服务端发送请求
要实现服务器向客户端推送消息有几种methods:

1、轮询

大量无效请求，浪费资源

2、长轮询

有新数据再推送，但这会导致连接超时，有一定隐患

3、Applet和Flash

过时，安全隐患，兼容性不好

消息群发

创建新项目:

添加依赖：


org.springframework.boot
spring-boot-starter-web


org.springframework.boot
spring-boot-starter-websocket


org.webjars
sockjs-client
1.1.2


org.webjars
jquery
3.3.1


org.webjars
stomp-websocket
2.3.3


org.webjars
webjars-locator-core

创建WebSocket配置类:WebSocketConfig

@Configuration
@EnableWebSocketMessageBroker//注解开启webSocket消息代理
publicclassWebSocketConfigimplementsWebSocketMessageBrokerConfigurer{
/**
*配置webSocket代理类
*@paramregistry
*/
@Override
publicvoidconfigureMessageBroker(MessageBrokerRegistryregistry){
registry.enableSimpleBroker("/topic");//代理消息的前缀
registry.setApplicationDestinationPrefixes("/app");//处理消息的方法前缀
}
@Override
publicvoidregisterStompEndpoints(StompEndpointRegistryregistry){
registry.addEndpoint("/chat").withSockJS();//定义一个/chat前缀的endpioint,用来连接
}
}

创建Bean

/**
*群消息类
*/
publicclassMessage{
privateStringname;
privateStringcontent;
//省略getter&setter
}

定义controller的方法:

/**
*MessageMapping接受前端发来的信息
*SendTo发送给信息WebSocket消息代理，进行广播
*@parammessage页面发来的json数据封装成自定义Bean
*@return返回的数据交给WebSocket进行广播
*@throwsException
*/
@MessageMapping("/hello")
@SendTo("/topic/greetings")
publicMessagegreeting(Messagemessage)throwsException{
returnmessage;
}




Title







用户名



连接
断开连接






发送

群聊进行中

私聊

既然是私聊，就要有对象目标，也是用户，可以用SpringSecurity引入
所以添加额外依赖：


org.springframework.boot
spring-boot-starter-security

配置SpringSecurity

@Configuration
publicclassWebSecurityConfigextendsWebSecurityConfigurerAdapter{
@Bean
PasswordEncoderpasswordEncoder(){
returnnewBCryptPasswordEncoder();
}
@Override
protectedvoidconfigure(AuthenticationManagerBuilderauth)throwsException{
auth.inMemoryAuthentication()
.withUser("panlijie").roles("admin").password("$2a$10$5Pf0KhCdnrpMxP5aRrHvMOsvV2fvfWJqk0SEDa9vQ8OWwV8emLFhi")
.and()
.withUser("suyanxia").roles("user").password("$2a$10$5Pf0KhCdnrpMxP5aRrHvMOsvV2fvfWJqk0SEDa9vQ8OWwV8emLFhi");
}
@Override
protectedvoidconfigure(HttpSecurityhttp)throwsException{
http.authorizeRequests()
.anyRequest().authenticated()
.and()
.formLogin()
.permitAll();
}
}

在原来的WebSocketConfig配置类中修改：也就是多了一个代理消息前缀:"/queue"

@Configuration
@EnableWebSocketMessageBroker//注解开启webSocket消息代理
publicclassWebSocketConfigimplementsWebSocketMessageBrokerConfigurer{
/**
*配置webSocket代理类
*@paramregistry
*/
@Override
publicvoidconfigureMessageBroker(MessageBrokerRegistryregistry){
registry.enableSimpleBroker("/topic","/queue");//代理消息的前缀
registry.setApplicationDestinationPrefixes("/app");//处理消息的方法前缀
}
@Override
publicvoidregisterStompEndpoints(StompEndpointRegistryregistry){
registry.addEndpoint("/chat").withSockJS();//定义一个/chat前缀的endpioint,用来连接
}
}

创建Bean:

publicclassChat{
privateStringto;
privateStringfrom;
privateStringcontent;
//省略getter&setter
}

添加controller方法：

/**
*点对点发送信息
*@paramprincipal当前用户的信息
*@paramchat发送的信息
*/
@MessageMapping("chat")
publicvoidchat(Principalprincipal,Chatchat){
//获取当前对象设置为信息源
Stringfrom=principal.getName();
chat.setFrom(from);
//调用convertAndSendToUser("用户名","路径","内容");
simpMessagingTemplate.convertAndSendToUser(chat.getTo(),"/queue/chat",chat);
}

创建页面：




Title

请输入聊天内容发送

暂结！

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

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

返回顶部
514930285
czq8825@qq.com

SpringBoot的WebSocket实现单聊群聊

说在开头

消息群发

私聊

热门推荐

随机推荐