Spring Boot中使用webSocket实现消息实时推送

news2025/7/21 12:25:30

在写这篇博客之前,我翻过许多资料,读过CSDN上的有关于webSocket的许多关于webSocket的相关博文,但是并未找到一个比较完善的,大多数是残缺不堪,讲了相关概念,但是在实际demo过程中,大多数是直接省略的许多代码,然后你直接拿过来,绝大多少是运行不了的,也就是说还得自己琢磨,但是我知道作为一个开发者,虽然这样并不是很麻烦,但是还是比较折磨人的,毕竟大家最希望的事,你提供完整的代码,我直接拿来就用。

这篇博客,就是教你如何使用webSocket完成一对多的通讯,一对一的通讯,以及自己和自己说话,我敢说,如果你学完这篇博客,你根据这篇博客中我提供demo进行开发,可以独立完成一个web在线聊天系统,具体的实现得看你自己怎么去研究了。

什么是webSocket?

WebSocket 是一种在 Web 应用程序中实现双向通信的协议。它允许服务器端和客户端之间建立持久的连接,并通过这个连接进行实时的双向通讯。与传统的 HTTP 请求-响应模式不同,WebSocket 提供了一种更高效、实时的通讯方式。

要实现通过 WebSocket 实现服务器端和客户端的双向通讯,可以遵循以下步骤:

  • 建立 WebSocket 连接:客户端通过 JavaScript 创建一个 WebSocket 对象,并指定服务器的 WebSocket 端点(URL)。客户端通过调用 WebSocket 对象的 onopen 事件监听器来处理 WebSocket 连接成功建立的事件。
  • 发送和接收消息:客户端和服务器端可以通过 WebSocket 对象的 send 方法和 onmessage 事件监听器来发送和接收消息。客户端可以使用 send 方法将消息发送给服务器端,而服务器端可以使用 onmessage 事件监听器来处理接收到的消息。
  • 关闭 WebSocket 连接:客户端和服务器端可以通过调用 WebSocket 对象的 close 方法来主动关闭 WebSocket 连接。另外,WebSocket 连接也可以由服务器端或网络故障等原因自动关闭。
    在这里插入图片描述

webSocket 案例

导入相关依赖

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
            <exclusions>
                <exclusion>
                    <groupId>org.junit.vintage</groupId>
                    <artifactId>junit-vintage-engine</artifactId>
                </exclusion>
            </exclusions>
        </dependency>


        <dependency>
            <!-- websocket -->
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
        </dependency>
        <dependency>
            <!-- fastjson -->
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>

配置一个WebSocketConfig

@Configuration
public class WebSocketConfig {
    /**
     * 注入一个ServerEndpointExporter,该Bean会自动注册使用@ServerEndpoint注解申明的websocket endpoint
     */
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

创建一个MyMessage实体类

用来接收相关信息

public class MyMessage {

    private String userId;

    private String message;


    public String getUserId() {
        return userId;
    }

    public void setUserId(String userId) {
        this.userId = userId;
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public MyMessage(String userId, String message) {
        this.userId = userId;
        this.message = message;
    }

    public MyMessage() {
    }

    @Override
    public String toString() {
        return "MyMessage{" +
                "userId='" + userId + '\'' +
                ", message='" + message + '\'' +
                '}';
    }
}

创建一个枚举类WebState

其实使用枚举类的话在这个demo中是多余的,我之所以创建枚举类是用来定义错误码的,也就是说为了看起来更加规范,至于为啥我在一个demo中就定义枚举类对象,这其实是多此一举了,甚至我定义的枚举类参数,我很多都没用到,实际上,也就是让项目看起来更加规范罢了。

public enum WebState {
    /**
     * 连接成功
     */
    CONNECTED("200","连接成功"),
    /**
     * 连接失败
     */
    DISCONNECTED("400","连接失败"),
    /**
     * 连接中
     */
    CONNECTING("199","正在连接"),
    /**
     * 断开连接
     */
    DISCONNECTING("401","连接已断开"),

    /**
     * 未知错误
     */

    UNKNOWN_ERROR("-1","未知错误"),

    /**
     * 成功
     */
    SUCCESS("200","成功"),
    /**
     * 失败
     */
    FAIL("400","失败"),
    /**
     * 参数不合法
     */
    PARAM_ERROR("201","参数不合法"),

    /**
     * 数据库异常
     */
    DATABASE_ERROR("202","数据库异常")


    ;


    /**
     * 错误码
     */
    private String state;
    /**
     * 错误消息
     */
    private String msg;
    WebState(String state, String msg) {
        this.state = state;
        this.msg = msg;
    }

    public String getState() {
        return state;
    }

    public String getMsg() {
        return msg;
    }
}

实现自己对自己说话

/**
 * 前后端交互的类实现消息的接收推送(自己发送给自己)
 *
 * @ServerEndpoint(value = "/test/one") 前端通过此URI和后端交互,建立连接
 */
@Slf4j
@ServerEndpoint(value = "/test/one")
@Component
public class OneWebSocket {

    /**
     * 记录当前在线连接数
     */
    private static AtomicInteger onlineCount = new AtomicInteger(0);

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        onlineCount.incrementAndGet(); // 在线数加1
        log.info("检测到状态码{},对应信息:{},有新连接加入:{},当前在线人数为:{}",WebState.CONNECTED.getState(),WebState.CONNECTED.getMsg(),session.getId(), onlineCount.get());
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose(Session session) {
        onlineCount.decrementAndGet(); // 在线数减1
        log.info("有一连接关闭:{},当前在线人数为:{}", session.getId(), onlineCount.get());
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("服务端收到客户端[{}]的消息:{}", session.getId(), message);
        this.sendMessage("Hello, " + message, session);
    }

    @OnError
    public void onError(Session session, Throwable error) {
        log.error("发生错误,错误参数为{},错误原因为{}", WebState.UNKNOWN_ERROR.getState(),WebState.UNKNOWN_ERROR.getMsg());
        error.printStackTrace();
    }

    /**
     * 服务端发送消息给客户端
     */
    private void sendMessage(String message, Session toSession) {
        try {
            log.info("服务端给客户端[{}]发送消息{}", toSession.getId(), message);
            toSession.getBasicRemote().sendText(message);
        } catch (Exception e) {
            log.error("服务端发送消息给客户端失败:{}", e);
        }
    }
}

配套自己对自己说话的前端,在Resources目录下新建一个static文件夹,存放index.html以及index.html链接的其他html文件

<!DOCTYPE HTML>
<html>
<head>
    <title>My WebSocket</title>
</head>

<body>
<input id="text" type="text" />
<br>

<a href="oneToOne.html">oneToOne</a>
<br>
<a href="oneToMany.html">oneToMany</a>
<br>
<button onclick="send()">Send</button>
<br>
<button onclick="closeWebSocket()">Close</button>
<div id="message"></div>
</body>

<script type="text/javascript">
    var websocket = null;

    //判断当前浏览器是否支持WebSocket, 主要此处要更换为自己的地址
    if ('WebSocket' in window) {
        websocket = new WebSocket("ws://localhost:8021/test/one");
    } else {
        alert('Not support websocket')
    }

    //连接发生错误的回调方法
    websocket.onerror = function() {
        setMessageInnerHTML("error");
    };

    //连接成功建立的回调方法
    websocket.onopen = function(event) {
        //setMessageInnerHTML("open");
    }

    //接收到消息的回调方法
    websocket.onmessage = function(event) {
        setMessageInnerHTML(event.data);
    }

    //连接关闭的回调方法
    websocket.onclose = function() {
        setMessageInnerHTML("close");
    }

    //监听窗口关闭事件,当窗口关闭时,主动去关闭websocket连接,防止连接还没断开就关闭窗口,server端会抛异常。
    window.onbeforeunload = function() {
        websocket.close();
    }

    //将消息显示在网页上
    function setMessageInnerHTML(innerHTML) {
        document.getElementById('message').innerHTML += innerHTML + '<br/>';
    }

    //关闭连接
    function closeWebSocket() {
        websocket.close();
    }

    //发送消息
    function send() {
        var message = document.getElementById('text').value;
        websocket.send(message);
    }
</script>
</html>

在这里插入图片描述

前端测试:
在这里插入图片描述

一对一说话

/**
 * 前后端交互的类实现消息的接收推送(自己发送给另一个人)
 *
 * @ServerEndpoint(value = "/test/oneToOne") 前端通过此URI 和后端交互,建立连接
 */
@Slf4j
@ServerEndpoint(value = "/test/oneToOne")
@Component
public class OneToOneWebSocket {

    /** 记录当前在线连接数 */
    private static AtomicInteger onlineCount = new AtomicInteger(0);

    /** 存放所有在线的客户端 */
    private static Map<String, Session> clients = new ConcurrentHashMap<>();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        onlineCount.incrementAndGet(); // 在线数加1
        clients.put(session.getId(), session);
        log.info("有新连接加入:{},当前在线人数为:{}", session.getId(), onlineCount.get());
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose(Session session) {
        onlineCount.decrementAndGet(); // 在线数减1
        clients.remove(session.getId());
        log.info("有一连接关闭:{},当前在线人数为:{}", session.getId(), onlineCount.get());
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message
     *            客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        log.info("服务端收到客户端[{}]的消息[{}]", session.getId(), message);
        try {
            //MyMessage myMessage = new MyMessage();
            //myMessage.setUserId(session.getId());
            //myMessage.setMessage(message);
              MyMessage myMessage = JSON.parseObject(message, MyMessage.class);
            if (myMessage != null) {
                Session toSession = clients.get(myMessage.getUserId());
                if (toSession != null) {
                    this.sendMessage(myMessage.getMessage(), toSession);
                }
            }
        } catch (Exception e) {
            log.error("解析失败:{}", e);
        }
    }

    @OnError
    public void onError(Session session, Throwable error) {
        log.error("发生错误");
        error.printStackTrace();
    }

    /**
     * 服务端发送消息给客户端
     */
    private void sendMessage(String message, Session toSession) {
        try {
            log.info("服务端给客户端[{}]发送消息[{}]", toSession.getId(), message);
            toSession.getBasicRemote().sendText(message);
        } catch (Exception e) {
            log.error("服务端发送消息给客户端失败:{}", e);
        }
    }

}

对比上边的index.html很容易就可以发现,这个html就仅仅是变化了一个链接,其他的地方都没变化。

<!DOCTYPE HTML>
<html>
<head>
    <title>My WebSocket</title>
</head>

<body>
<input id="text" type="text" />
<button onclick="send()">Send</button>
<button onclick="closeWebSocket()">Close</button>
<div id="message"></div>
</body>

<script type="text/javascript">
    var websocket = null;

    //判断当前浏览器是否支持WebSocket, 主要此处要更换为自己的地址
    if ('WebSocket' in window) {
        websocket = new WebSocket("ws://localhost:8021/test/oneToOne");
    } else {
        alert('Not support websocket')
    }

    //连接发生错误的回调方法
    websocket.onerror = function() {
        setMessageInnerHTML("error");
    };

    //连接成功建立的回调方法
    websocket.onopen = function(event) {
        //setMessageInnerHTML("open");
    }

    //接收到消息的回调方法
    websocket.onmessage = function(event) {
        setMessageInnerHTML(event.data);
    }

    //连接关闭的回调方法
    websocket.onclose = function() {
        setMessageInnerHTML("close");
    }

    //监听窗口关闭事件,当窗口关闭时,主动去关闭websocket连接,防止连接还没断开就关闭窗口,server端会抛异常。
    window.onbeforeunload = function() {
        websocket.close();
    }

    //将消息显示在网页上
    function setMessageInnerHTML(innerHTML) {
        document.getElementById('message').innerHTML += innerHTML + '<br/>';
    }

    //关闭连接
    function closeWebSocket() {
        websocket.close();
    }

    //发送消息
    function send() {
        var message = document.getElementById('text').value;
        websocket.send(message);
    }
</script>
</html>

一对一聊天有个条件,也就是说,我们需要指定我们需要聊天的对象,在这里我们需要传递的值是参数是json的,也就是前端我们在传递的时候需要进行处理一下:
{"message":"你好", "userId":1},无论你是谁,我都指定只向1号用户发送消息。这样就可以实现一对一发送消息了。

PS: {“message”:“你好”, “userId”:1},很重要,由于是测试,并未实际处理。注意如果在一对一中不以JSON传参,那会报错

在这里插入图片描述
1号用户接收到:
在这里插入图片描述
在这里插入图片描述

一对多

这个一对多,主要的是多打开几个框进行验证,需要注意的是本demo中,如果是作者发消息,那么作者是收不到消息的,但是只要是通过oneToMany登录的所有用户,他都可以收到消息,除自己本人以外,其他人都可以收到这条消息。

/**
 *
 * 前后端交互的类实现消息的接收推送(自己发送给所有人(不包括自己))
 *
 * @ServerEndpoint(value = "/test/oneToMany") 前端通过此URI 和后端交互,建立连接
 */
@Slf4j
@ServerEndpoint(value = "/test/oneToMany")
@Component
public class OneToManyWebSocket {

    /** 记录当前在线连接数 */
    private static AtomicInteger onlineCount = new AtomicInteger(0);

    /** 存放所有在线的客户端 */
    private static Map<String, Session> clients = new ConcurrentHashMap<>();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        onlineCount.incrementAndGet(); // 在线数加1
        clients.put(session.getId(), session);
        log.info("有新连接加入:{},当前在线人数为:{}", session.getId(), onlineCount.get());
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose(Session session) {
        onlineCount.decrementAndGet(); // 在线数减1
        clients.remove(session.getId());
        log.info("有一连接关闭:{},当前在线人数为:{}", session.getId(), onlineCount.get());
    }

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

    @OnError
    public void onError(Session session, Throwable error) {
        log.error("发生错误");
        error.printStackTrace();
    }

    /**
     * 群发消息
     *
     * @param message
     *            消息内容
     */
    private void sendMessage(String message, Session fromSession) {
        for (Map.Entry<String, Session> sessionEntry : clients.entrySet()) {
            Session toSession = sessionEntry.getValue();
            // 排除掉自己
            if (!fromSession.getId().equals(toSession.getId())) {
                log.info("服务端给客户端[{}]发送消息{}", toSession.getId(), message);
                toSession.getAsyncRemote().sendText(message);
            }
        }
    }
}

将上一个页面的访问后端地址改为: websocket = new WebSocket("ws://localhost:8021/test/oneToMany");

在这里插入图片描述
在这里插入图片描述
2,4号客户端接受到3号客户端消息:
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1157185.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

【优选算法系列】第一节.哈希表简介(1. 两数之和and面试题 01.02. 判定是否互为字符重排)

文章目录 前言一、哈希表简介二、两数之和 2.1 题目描述 2.2 题目解析 2.2.1 算法原理 2.2.2 代码编写三、判定是否互为字符重排 3.1 题目描述 3.2 题目解析 3.2.1 算法原理 3.2.2 代码编写总结 前言 一…

企业中台如何进行测试(上篇)

企业的信息化建设比较合理的规划是专业套装软件 灵活的SaaS应用 定制化的开发平台 基础的平台支撑&#xff0c;而企业在进行建设时&#xff0c;往往都是从业务软件开始&#xff0c;而忽略平台的建设&#xff0c;但平台却是支撑企业业务系统整合的基础&#xff0c;从企业整体…

HDFS 读写架构

一、组成架构 1、NameNode(NN) : 集群的Master&#xff0c;它是一个主管&#xff0c;管理者 (1) 管理HDFS的命名空间 (2) 配置副本策略 (3) 管理数据块(Block)映射信息 (4) 处理客户端读写请求 2、DataNode(DN) : 集群的Slave。NN下达命令&#xff0c;DataNode执行实际操作。…

SCADA、HMI RTU、DCS和PLC有什么区别?

PLC专注于具有离散开关信号的离散自动化&#xff0c;用于工厂装配线和装瓶线等。PLC有多种尺寸&#xff0c;意味着不同的 I/O 和程序容量。最小的尺寸通常称为纳米PLC、微型PLC &#xff0c;以及具有固定 I/O的迷你 PLC&#xff0c;用于小型独立应用。 DCS专注于模拟信号过程控…

台达PLC通讯协议 Modbus ASCII协议格式说明

文章目录 背景说明通讯帧通讯命令字16进制数据元和ASCII的转换通讯数据地址台达通讯协议举例 背景说明 该协议是根据台达研发的基于CANopen现场总线的多轴运动控制器DVP10MC11T&#xff0c;其内部包含标准PLC模块和MC运动控制模块两大模块。参考手册名称是《DELTA_IA-PLC_DVP-…

Unity2D中瓦片地图的创建与绘制教程

Unity2D中瓦片地图的创建与绘制 素材切割创建地图创建瓦片绘制地图瓦片调色板画笔拓展素材资源链接 素材切割 选中以下素材&#xff0c;以Tiles为例&#xff08;素材链接在文章最下方&#xff09; 修改素材属性。 将Sprite Mode属性改为Multiple多张&#xff08;不然切割不了&…

千万富翁就住你隔壁

这是好书分享系列的第1篇&#xff0c;如果觉得对你有帮助&#xff0c;欢迎分享给你的朋友或家人。如果想继续收到本系列推文&#xff0c;请点击下方公众号关注我。 最近在微信读书的新书榜里&#xff0c;看到一本之前在国外网站看到别人推荐的书&#xff0c;《邻家的百万富翁》…

我是如何进行日志降本的

最近行业里流行降本增效。本文就一个现实中经常发生的日志成本的案例进行讨论&#xff0c;讨论该如何降本。 背景 假如存在一家IoT公司&#xff0c;它拥有1亿的在线设备&#xff08;长连接着云端&#xff09;。这些设备每21秒会向云端发送心跳&#xff0c;以进行连接的保活。假…

基于社会群体算法的无人机航迹规划-附代码

基于社会群体算法的无人机航迹规划 文章目录 基于社会群体算法的无人机航迹规划1.社会群体搜索算法2.无人机飞行环境建模3.无人机航迹规划建模4.实验结果4.1地图创建4.2 航迹规划 5.参考文献6.Matlab代码 摘要&#xff1a;本文主要介绍利用社会群体算法来优化无人机航迹规划。 …

【opencv+图像处理】Image Processing in OpenCV 1-2基本图形绘制

&#x1f349; 博主微信 cvxiayixiao &#x1f353; 【Segment Anything Model】计算机视觉检测分割任务专栏。 链接 &#x1f351; 【公开数据集预处理】特别是医疗公开数据集的接受和预处理&#xff0c;提供代码讲解。链接 &#x1f348; 【opencv图像处理】opencv代码库讲解…

Hadoop HDFS(分布式文件系统)

一、Hadoop HDFS(分布式文件系统) 为什么要分布式存储数据 假设一个文件有100tb&#xff0c;我们就把文件划分为多个部分&#xff0c;放入到多个服务器 靠数量取胜&#xff0c;多台服务器组合&#xff0c;才能Hold住 数据量太大&#xff0c;单机存储能力有上限&#xff0c;需要…

小学辅导虚拟资料项目拆解 - 沉睡者IT

最近我看到了一个很不错的项目&#xff0c;它几乎没有成本&#xff0c;操作起来也不难&#xff0c;而且相对稳定的回报率。 这个项目适合新手小白或者工作室类型的团队。 之前分享的一些项目&#xff0c;比如天涯神贴、别墅设计图、古籍电子书、宝宝起名&#xff0c;都属于这个…

rcore 笔记 第一个裸机程序

文章目录 环境应用程序与基本执行环境应用程序执行环境与基本操作平台执行应用程序应用程序执行环境目标平台与目标三元组 移除标准库依赖移除 println! 宏提供 panic_handler 功能应对致命错误移除 main 函数 编译运行内核指令程序内存布局与编译流程 内核第一条指令编写内核第…

黑马 小兔鲜儿 uniapp 小程序开发- 用户模块- 07

小兔鲜儿 - 用户模块07 在用户登录/注册成功后&#xff0c;展示会员信息&#xff0c;更新会员信息。 会员中心页(我的) 主要实现两部分业务&#xff1a; 渲染当前登录会员的昵称和头像&#xff0c;从 Store 中获取。猜你喜欢分页加载&#xff0c;可封装成组合式函数实现复用…

态路小课堂丨如何为QSFP-DD800G光模块选择合适的光纤跳线

TARLUZ态路 在之前2篇文章中&#xff0c;我们介绍了关于800G光模块的封装、光口类型等内容。本文态路通信将为您介绍“如何为QSFP-DD800G光模块选择合适的光纤跳线”。方便您在800G数据中心网络互连场景中快速完成链路布线。 文章1&#xff1a; 三款800G光模块方案介绍—SR8/…

C++标准模板(STL)- 类型支持 (复合类型类别,is_member_pointer,is_reference,is_compound)

类型特性 类型特性定义一个编译时基于模板的结构&#xff0c;以查询或修改类型的属性。 试图特化定义于 <type_traits> 头文件的模板导致未定义行为&#xff0c;除了 std::common_type 可依照其所描述特化。 定义于<type_traits>头文件的模板可以用不完整类型实例…

职场好物:乐歌M9S升降办公电脑台,告别久坐办公,升职加薪就选它

办公是现代生活不可避免的组成部分&#xff0c;科技的快速发展&#xff0c;给了我们更多新的生活方式&#xff0c;促使我们更加关注自己的身体状况&#xff0c;我们挨过了饭都吃不饱的年代&#xff0c;随着办公人群的不断扩张&#xff0c;不知道你有没有发现身边人或多或少都有…

代码随想录算法训练营第三十九天 | LeetCode 343. 整数拆分、96. 不同的二叉搜索树

代码随想录算法训练营第三十九天 | LeetCode 343. 整数拆分、96. 不同的二叉搜索树 文章链接&#xff1a;整数拆分 不同的二叉搜索树 视频链接&#xff1a;整数拆分 不同的二叉搜索树 1. LeetCode 343. 整数拆分 1.1 思路 给我们一个数&#xff0c;如何去拆成若…

力扣第62题 不同路径 c++ 动态规划 dp二维 + dp一维 解法

题目 62. 不同路径 中等 相关标签 数学 动态规划 组合数学 一个机器人位于一个 m x n 网格的左上角 &#xff08;起始点在下图中标记为 “Start” &#xff09;。 机器人每次只能向下或者向右移动一步。机器人试图达到网格的右下角&#xff08;在下图中标记为 “Fini…

Kubernetes异常?别担心,100个命令来解救你

关注【云原生百宝箱】公众号&#xff0c;快速掌握云原生 这篇文章是关于使用 Kubectl 进行 Kubernetes 诊断的指南。作者列出了 100 个 Kubectl 命令&#xff0c;这些命令对于诊断 Kubernetes 集群中的问题非常有用。这些问题包括但不限于&#xff1a; 集群信息Pod 诊断服务诊断…