SpringBoot中怎么使用WebSocket实现点对点消息
本篇内容介绍了“SpringBoot中怎么使用WebSocket实现点对点消息”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
专注于为中小企业提供成都网站建设、网站建设服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业东昌府免费做网站提供优质的服务。我们立足成都,凝聚了一批互联网行业人才,有力地推动了成百上千企业的稳健成长,帮助中小企业通过网站建设实现规模扩充和转变。
一、添加依赖,配置
使用 Spring Security 里的用户。
org.springframework.boot spring-boot-starter-security
我们现在需要配置用户信息和权限配置。
@Configuration public class WebSecurityConfig extends WebSecurityConfigurerAdapter { // 指定密码的加密方式 @SuppressWarnings("deprecation") @Bean PasswordEncoder passwordEncoder(){ // 不对密码进行加密 return NoOpPasswordEncoder.getInstance(); } // 配置用户及其对应的角色 @Override protected void configure(AuthenticationManagerBuilder auth) throws Exception { auth.inMemoryAuthentication() .withUser("admin").password("123").roles("ADMIN","USER") .and() .withUser("hangge").password("123").roles("USER"); } // 配置 URL 访问权限 @Override protected void configure(HttpSecurity http) throws Exception { http.authorizeRequests() // 开启 HttpSecurity 配置 .anyRequest().authenticated() // 用户访问所有地址都必须登录认证后访问 .and().formLogin().permitAll(); // 开启表单登录 } }
二、编写WebSocket 配置
@Configuration @EnableWebSocketMessageBroker public class WebSocketConfig implements WebSocketMessageBrokerConfigurer { @Override public void configureMessageBroker(MessageBrokerRegistry config) { // 设置消息代理的前缀,如果消息的前缀为"/queue",就会将消息转发给消息代理(broker) // 再由消息代理广播给当前连接的客户端 //也可设置多个 broker,如:config.enableSimpleBroker("/topic","/queue"); config.enableSimpleBroker("/queue"); // 下面方法可以配置一个或多个前缀,通过这些前缀过滤出需要被注解方法处理的消息。 // 例如这里表示前缀为"/app"的destination可以通过@MessageMapping注解的方法处理 // 而其他 destination(例如"/topic""/queue")将被直接交给 broker 处理 config.setApplicationDestinationPrefixes("/app"); } @Override public void registerStompEndpoints(StompEndpointRegistry registry) { // 定义一个前缀为"/chart"的endpoint,并开启 sockjs 支持。 // sockjs 可以解决浏览器对WebSocket的兼容性问题,客户端将通过这里配置的URL建立WebSocket连接 registry.addEndpoint("/chat").withSockJS(); } }
三、编写案例代码
1、编写实体
@Data public class Chat { // 消息的目标用户 private String to; // 消息的来源用户 private String from; // 消息的主体内容 private String content; }
2、编写Controller
@Controller public class DemoController { @Autowired SimpMessagingTemplate messagingTemplate; // 处理来自"/app/chat"路径的消息 @MessageMapping("/chat") public void chat(Principal principal, Chat chat) { // 获取当前登录用户的用户名 String from = principal.getName(); // 将用户设置给chat对象的from属性 chat.setFrom(from); // 再将消息发送出去,发送的目标用户就是 chat 对象的to属性值 messagingTemplate.convertAndSendToUser(chat.getTo(), "/queue/chat", chat); } }
四、编写页面
在 resources/static 目录下创建 chat2.html 页面作为点对点的聊天页面。
连接成功后,订阅的地址为“/user/queue/chat”,该地址比服务端配置的地址多了“/user”前缀,这是因为 SimpMessagingTemplate 类中自动添加了路径前缀。
单聊 请输入聊天内容: 目标用户:
五、验证结果
我们使用了 Spring Security 会自动跳转到默认登录页面。
这里我们配置两个用户信息:admin/123,piao/123。
“SpringBoot中怎么使用WebSocket实现点对点消息”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!
网站题目:SpringBoot中怎么使用WebSocket实现点对点消息
当前网址:http://scyanting.com/article/iepehg.html