iis服务器助手广告广告
返回顶部
首页 > 资讯 > 精选 >SpringBoot中怎么使用WebSocket实现点对点消息
  • 753
分享到

SpringBoot中怎么使用WebSocket实现点对点消息

2023-06-08 05:06:09 753人浏览 独家记忆
摘要

本篇内容介绍了“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();    }}

三、编写案例代码

1、编写实体

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

2、编写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实现点对点消息”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注编程网网站,小编将为大家输出更多高质量的实用文章!

--结束END--

本文标题: SpringBoot中怎么使用WebSocket实现点对点消息

本文链接: https://www.lsjlt.com/news/251793.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑,方便收藏和打印~

下载Word文档
猜你喜欢
  • SpringBoot中怎么使用WebSocket实现点对点消息
    本篇内容介绍了“SpringBoot中怎么使用WebSocket实现点对点消息”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!一、添加依赖,配...
    99+
    2023-06-08
  • SpringBoot如何使用WebSocket实现点对点消息
    这篇文章主要介绍“SpringBoot如何使用WebSocket实现点对点消息”的相关知识,小编通过实际案例向大家展示操作过程,操作方法简单快捷,实用性强,希望这篇“SpringBoot如何使用WebSocket实现点对点消息”文章能帮助大...
    99+
    2023-07-06
  • SpringBoot怎么使用WebSocket实现群发消息
    这篇文章主要介绍了SpringBoot怎么使用WebSocket实现群发消息的相关知识,内容详细易懂,操作简单快捷,具有一定借鉴价值,相信大家阅读完这篇SpringBoot怎么使用WebSocket实现群发消息文章都会有所收获,下面我们一起...
    99+
    2023-06-08
  • C#利用RabbitMQ实现点对点消息传输
    目录消息队列模型RabbitMQ设置RabbitMQ动态库安装RabbitMQ.Client相关知识点示例效果图核心代码消息队列模型 所有 MQ 产品从模型抽象上来说都是一样的过程...
    99+
    2024-04-02
  • springboot怎么集成websocket实现消息推送
    要在Spring Boot中集成WebSocket实现消息推送,可以按照以下步骤进行操作: 添加依赖:在`pom.xml`文件中添...
    99+
    2023-10-26
    springboot websocket
  • 怎么在HTML5中利用WebSocket实现点对点聊天
    这期内容当中小编将会给大家带来有关怎么在HTML5中利用WebSocket实现点对点聊天,文章内容丰富且以专业的角度为大家分析和叙述,阅读完这篇文章希望大家可以有所收获。首先在系统启动的时候调用InitServlet方法public&nbs...
    99+
    2023-06-09
  • C#如何利用RabbitMQ实现点对点消息传输
    这篇文章主要介绍C#如何利用RabbitMQ实现点对点消息传输,文中介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们一定要看完!消息队列模型所有 MQ 产品从模型抽象上来说都是一样的过程:消费者(consumer)订阅某个队列。生产者(...
    99+
    2023-06-15
  • HTML5 WebSocket怎么实现消息推送
    这篇“HTML5 WebSocket怎么实现消息推送”文章的知识点大部分人都不太理解,所以小编给大家总结了以下内容,内容详细,步骤清晰,具有一定的借鉴价值,希望大家阅读完这篇文章能有所收获,下面我们一起来看...
    99+
    2024-04-02
  • Springboot+Netty+Websocket实现消息推送实例是怎样的
    Springboot+Netty+Websocket实现消息推送实例是怎样的,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。 前言We...
    99+
    2024-04-02
  • springboot 使用websocket技术主动给前端发送消息的实现
    目录使用websocket技术主动给前端发送消息WebSocketConfigWebSocketServerwebsocket基础入门-前端发送消息项目结构如下图使用websocke...
    99+
    2024-04-02
  • SpringBoot怎么整合WebSocket实现后端向前端发送消息
    这篇文章主要讲解了“SpringBoot怎么整合WebSocket实现后端向前端发送消息”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“SpringBoot怎么整合WebSocket实现后端向...
    99+
    2023-07-05
  • Springboot中RocketMQ怎么实现广播消息
    这篇文章主要介绍“Springboot中RocketMQ怎么实现广播消息”,在日常操作中,相信很多人在Springboot中RocketMQ怎么实现广播消息问题上存在疑惑,小编查阅了各式资料,整理出简单好用的操作方法,希望对大家解答”Spr...
    99+
    2023-07-02
  • 怎么在springboot中用redis实现消息队列
    本篇内容主要讲解“怎么在springboot中用redis实现消息队列”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“怎么在springboot中用redis实现消息队列”吧!准备阶段安装redi...
    99+
    2023-06-19
  • Redis 使用 List 实现消息队列的优缺点
    目录什么是消息队列消息队列满足哪些特性消息有序性重复消息处理可靠性List 实现消息队列LPUSHRPOP实时消费问题重复消费消息可靠性需要注意的是Redission 实战添加依赖J...
    99+
    2024-04-02
  • Spring Cloud中怎么使用Redis实现点赞和取消点赞功能
    Spring Cloud中怎么使用Redis实现点赞和取消点赞功能,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。一、Redis 缓存设计及实现...
    99+
    2024-04-02
  • Swoole webSocket客服IM消息系统怎么实现
    这篇文章主要讲解了“Swoole webSocket客服IM消息系统怎么实现”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Swoole webSocket客服IM消息系统...
    99+
    2023-07-05
  • Android怎么实现未读消息小红点显示
    今天小编给大家分享一下Android怎么实现未读消息小红点显示的相关知识点,内容详细,逻辑清晰,相信大部分人都还太了解这方面的知识,所以分享这篇文章给大家参考一下,希望大家阅读完这篇文章后有所收获,下面我们一起来了解一下吧。使用 fragm...
    99+
    2023-06-29
  • SpringBoot中怎么使用WebSocket
    在Spring Boot中使用WebSocket可以通过以下步骤实现: 首先添加WebSocket依赖: 在pom.xml文件中添...
    99+
    2024-03-07
    SpringBoot WebSocket
  • Redis中怎么实现点赞、取消点赞功能
    Redis中怎么实现点赞、取消点赞功能,相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。一、Redis 缓存设计及实现1.1 Redis 安装及运...
    99+
    2024-04-02
  • 消息推送实现|使用WebSocket主动推送消息到客户端方案
    一. 前言 在开发中,我们经常会遇到这样一类需求:需要在网页上显示天气预报,股票数据或者实时排行榜单等实时变化的数据。对于此类需求,一种较为原始的做法就是让客户端每隔一段时间主动去轮询服务器。但这种做法有一个很大的弊端:如果客户端的数量很大...
    99+
    2023-09-18
    websocket 服务器 网络协议
软考高级职称资格查询
编程网,编程工程师的家园,是目前国内优秀的开源技术社区之一,形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容,为IT开发者提供了一个发现、使用、并交流开源技术的平台。
  • 官方手机版

  • 微信公众号

  • 商务合作