springBoot集成webSocket并使用postMan进行测试

这篇具有很好参考价值的文章主要介绍了springBoot集成webSocket并使用postMan进行测试。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

简单描述

简单来讲,webSocket是一种在http协议基础上的另一种新协议,叫ws协议。

http协议是单工通信,客户端发起请求,服务端收到请求并处理,返回给客户端,然后客户端收到服务端的请求。

ws协议是全双工通信,客户端发起请求后,相当于搭建了一个通道,在不断开的情况下,在这期间,服务端可以把请求发给客户端,客户端也可以在这期间处理别的事情,不必等待服务端的响应。

webSockt实现

此次webSocket实现不包含前端代码,将使用postMan来实现前端的功能。

依赖

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

配置类

@Configuration
public class WebSocketConfig {

    @Bean
    public ServerEndpointExporter serverEndpointExporter(){
        return new ServerEndpointExporter();
    }
}

webSocketServer

package com.czf.study.wevSocket;

import lombok.extern.slf4j.Slf4j;
import org.junit.platform.commons.util.StringUtils;
import org.springframework.stereotype.Component;

import javax.websocket.*;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author zfChen
 * @create 2022/11/14 15:11
 */
@ServerEndpoint("/websocket/{userId}")
@Component
@Slf4j
public class WebSocketServer {
    /**静态变量,用来记录当前在线连接数。应该把它设计成线程安全的。*/
    private static int onlineCount = 0;
    /**concurrent包的线程安全集合,也可以map改成set,用来存放每个客户端对应的MyWebSocket对象。*/
    private static ConcurrentHashMap<String,WebSocketServer> webSocketMap = new ConcurrentHashMap<>();
    /**与某个客户端的连接会话,需要通过它来给客户端发送数据*/
    private Session session;
    /**接收userId*/
    private String userId="";

    /**
     * 连接建立成功调用的方法*/
    @OnOpen
    public void onOpen(Session session,@PathParam("userId") String userId) {
        this.session = session;
        this.userId=userId;

        if(!webSocketMap.containsKey(userId)){
            //加入集合中
            webSocketMap.put(userId,this);
            //在线数加1
            addOnlineCount();
        }

        log.info("用户连接:"+userId+",当前在线人数为:" + getOnlineCount());

        try {
            sendMessage("连接成功");
        } catch (IOException e) {
            log.error("用户:"+userId+",网络异常!!!!!!");
        }
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose() {
        if(webSocketMap.containsKey(userId)){
            webSocketMap.remove(userId);
            //从集合中删除
            subOnlineCount();
        }
        log.info("用户退出:"+userId+",当前在线人数为:" + getOnlineCount());
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息*/
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("【websocket消息】收到客户端发来的消息:{}", message);
    }

    /**
     *
     * @param session
     * @param error
     */
    @OnError
    public void onError(Session session, Throwable error) {
        log.error("用户错误:"+this.userId+",原因:"+error.getMessage());
        error.printStackTrace();
    }
    /**
     * 实现服务器主动推送
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
    }

    /**
     * 发送自定义消息
     * */
    public static void sendInfo(String message,@PathParam("userId") String userId) throws IOException {
        log.info("发送消息到:"+userId+",报文:"+message);
        if(StringUtils.isNotBlank(userId)&&webSocketMap.containsKey(userId)){
            webSocketMap.get(userId).sendMessage(message);
        }else{
            log.error("用户"+userId+",不在线!");
        }
    }

    public static synchronized int getOnlineCount() {
        return onlineCount;
    }

    public static synchronized void addOnlineCount() {
        WebSocketServer.onlineCount++;
    }

    public static synchronized void subOnlineCount() {
        WebSocketServer.onlineCount--;
    }
}


服务端发请求接口

外面创建一个接口,模拟服务端发请求给客户端

@RestController
public class DemoController {

    @RequestMapping("/push/{toUserId}")
    public ResponseEntity<String> pushToWeb(String message, @PathVariable String toUserId) throws IOException {
        WebSocketServer.sendInfo(message,toUserId);
        return ResponseEntity.ok("MSG SEND SUCCESS");
    }
}

测试

使用postMan创建webSocket请求

postman ws请求,websocket,java,网络协议,学习

输入webSocket的地址,1表示userId=1

postman ws请求,websocket,java,网络协议,学习

此时控制台输出

2022-11-15 11:51:43.009  INFO 28972 --- [nio-8787-exec-5] com.czf.study.wevSocket.WebSocketServer  : 用户连接:1,当前在线人数为:1

接下来,模拟服务端给客户端发送请求,建立一个http请求

postman ws请求,websocket,java,网络协议,学习

控制台输出

2022-11-15 11:53:48.235  INFO 28972 --- [nio-8787-exec-4] com.czf.study.wevSocket.WebSocketServer  : 发送消息到:1,报文:hello

客户端收到请求

postman ws请求,websocket,java,网络协议,学习

双人聊天室

webSocket经常被用作聊天室,两个客户端,通过一个服务端分发请求,进行沟通。

在此案例中,通过/来区分,前一个是消息,后一个是发送的对象。

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息*/
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("【websocket消息】收到客户端发来的消息:{}", message);
        String[] split = message.split("/");
        try {
            sendInfo(split[0],split[1]);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

比如

postman ws请求,websocket,java,网络协议,学习

2号用户收到1号发送的消息

postman ws请求,websocket,java,网络协议,学习

同样的,2号也可以发送消息给1号。文章来源地址https://www.toymoban.com/news/detail-788317.html

到了这里,关于springBoot集成webSocket并使用postMan进行测试的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 使用Postman进行简单压力测试

    使用Postman可以对服务端接口进行简单的压力测试,步骤如下: 1.配置好一个请求接口,保存在一个collection中; 2.点击Tests,添加断言检查点; 3.点击Runner按钮,打开Collection Runner界面; 4.选择刚才添加过请求的Collection,设置测试参数; 5.点击Start Test按钮,开始测试。图中圈

    2024年02月16日
    浏览(53)
  • 使用PostMan进行接口、压力测试

    一、安装 下载地址:https://www.postman.com/ 选择对应系统版本 二、接口测试 选择Collections,创建测试窗口 创建接口测试 三、压力测试 创建测试集 编写脚本 为了检查每次请求都能满足时延要求,需要对每次的请求,增加test脚本,用以检验请求的耗时 在Tests中增加检测脚本,如

    2024年02月15日
    浏览(58)
  • 如何使用PostMan进行并发测试?

    👀(Postman 的 runner 实际上是串行执行的,因此不能作为并发测试, 只是批量测试,本文如下称为并发的是错误的) 要在Postman中对POST请求进行压力测试,可以按照以下步骤进行操作: 打开Postman应用程序并创建一个新的请求集合(Collection)。 在请求集合中创建一个新的请求,

    2024年02月03日
    浏览(50)
  • 使用PostMan进行API测试

    PostMan的安装 貌似下载和使用 PostMan 必须要翻墙-.- 因为现在提供两种形态的App: chrome 的插件  (已经快要被废弃了,推荐使用独立App) 独立的App 而且在使用时需要登录账号,我这边是直接登录的 Google 账号-。-貌似有其它方式,但是我并没有去尝试。 下载完毕解压后直接运

    2024年01月17日
    浏览(72)
  • 使用Postman进行接口自动化测试

    我们先思考一下,如果需要达到自动化接口测试的效果,那么我们在基本的模拟请求上还需要做哪些呢? 以下我粗略概括为 3 个问题(欢迎更多补充与建议): 如何判断接口是否请求成功 如何进行接口批量、定期测试 如何处理依赖接口问题(比如商品下单的接口必须要求

    2024年01月18日
    浏览(56)
  • 使用Postman+JMeter进行简单的接口测试

    以前每次学习接口测试都是百度,查看相关人员的实战经验,没有结合自己公司项目接口真正具体情况。 这里简单分享一下公司项目Web平台的一个查询接口,我会使用2种工具Postman和JMeter如何对同一个接口做调试。 准备工作 首先,登录公司平台,通过谷歌浏览器右键—更多

    2024年02月01日
    浏览(40)
  • 如何使用postman进行接口测试(实战项目分享)

    Postman是我们测试人员比较常用的一款接口测试工具,功能强大又易上手。 在这里分享一个入门级的接口测试练手项目:  三十多个接口,常见的接口请求方式POST、GET、PUT、DELETE都有涵盖; 有token鉴权,可设置变量进行token调用; 可用于接口自动化测试; 此项目安装部署方便

    2024年02月16日
    浏览(43)
  • 使用GraphQL在Postman中进行API测试

    GraphQL 是一种用于API的开源数据查询和操作语言,用于API的查询语言和运行时。它使客户端能够精确地指定其数据需求,并获得预测性地结果。GraphQL旨在提高API的效率、灵活性和可靠性。 Postman 是一款用于API开发的强大工具,它支持REST和GraphQL API。Postman还提供了一个用户友好

    2024年02月12日
    浏览(34)
  • 如何使用Postman进行一次完整的接口测试?

    在对接口进行测试之前,得先了解一下接口的相关概念以及为什么要对接口进行测试 那么,什么是接口呢? 接口主要用于外部系统与系统之间以及内部各个子系统之间的交互点,定义特定的交互点,然后通过这些交互点来通过一些特殊的规则也就是协议,来进行数据之间的

    2024年04月16日
    浏览(29)
  • 使用PostMan工具进行接口测试时传递Map类型参数的方法

    Step 1: 设置Header Step 2: 设置参数体 以json格式写好数据 Step 3:Controller层方法体参数设置 测试结果:

    2024年02月16日
    浏览(56)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包