文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

SpringBoot如何使用WebSocket实现点对点消息

2023-07-06 13:29

关注

这篇文章主要介绍“SpringBoot如何使用WebSocket实现点对点消息”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“SpringBoot如何使用WebSocket实现点对点消息”文章能帮助大家解决问题。

一、添加依赖,配置

使用 Spring Security 里的用户。

<dependency>    <groupId>org.springframework.boot</groupId>    <artifactId>spring-boot-starter-security</artifactId></dependency>

我们现在需要配置用户信息和权限配置。

@Configurationpublic 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@EnableWebSocketMessageBrokerpublic 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();    }}

三、编写案例代码

编写实体

@Datapublic class Chat {    // 消息的目标用户    private String to;    // 消息的来源用户    private String from;    // 消息的主体内容    private String content;}

编写Controller

@Controllerpublic 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 类中自动添加了路径前缀。

<!DOCTYPE html><html lang="en"><head>    <meta charset="UTF-8">    <title>单聊</title>    <script src="https://cdn.bootcdn.net/ajax/libs/jquery/3.3.1/jquery.min.js"></script>    <script src="https://cdn.bootcdn.net/ajax/libs/sockjs-client/1.1.2/sockjs.min.js"></script>    <script src="https://cdn.bootcdn.net/ajax/libs/stomp.js/2.3.3/stomp.min.js"></script>    <script>        var stompClient = null;        // 建立一个WebSocket连接        function connect() {            // 首先使用 SockJS 建立连接            var socket = new SockJS('/chat');            // 然后创建一个STOMP实例发起连接请求            stompClient = Stomp.over(socket);            // 连接成功回调            stompClient.connect({}, function (frame) {                // 订阅服务端发送回来的消息                stompClient.subscribe('/user/queue/chat', function (chat) {                    // 将服务端发送回来的消息展示出来                    showGreeting(JSON.parse(chat.body));                });            });        }        // 发送消息        function sendMsg() {            stompClient.send("/app/chat", {},                JSON.stringify({'content':$("#content").val(),                    'to':$("#to").val()}));        }        // 将服务端发送回来的消息展示出来        function showGreeting(message) {            $("#chatsContent")                .append("<div>" + message.from+":"+message.content + "</div>");        }        // 页面加载后进行初始化动作        $(function () {            // 页面加载完毕后自动连接            connect();            $( "#send" ).click(function() { sendMsg(); });        });    </script></head><body><div id="chat">    <div id="chatsContent">    </div>    <div>        请输入聊天内容:        <input type="text" id="content" placeholder="聊天内容">        目标用户:        <input type="text" id="to" placeholder="目标用户">        <button id="send" type="button">发送</button>    </div></div></body></html>

五、验证结果

我们使用了 Spring Security 会自动跳转到默认登录页面。

SpringBoot如何使用WebSocket实现点对点消息

这里我们配置两个用户信息:admin/123,piao/123。

SpringBoot如何使用WebSocket实现点对点消息

SpringBoot如何使用WebSocket实现点对点消息

关于“SpringBoot如何使用WebSocket实现点对点消息”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识,可以关注编程网行业资讯频道,小编每天都会为大家更新不同的知识点。

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯