[RocketMQ] Consumer消费者启动主要流程源码 (六)

news2024/10/6 4:01:07

客户端常用的消费者类是DefaultMQPushConsumer,

在这里插入图片描述

DefaultMQPushConsumer的构造器以及start方法的源码。

1.创建DefaultMQPushConsumer实例

最终都是调用下面四个参数的构造函数:

在这里插入图片描述

/**
 * 创建DefaultMQPushConsumer实例
 *
 * @param namespace                    namespace地址
 * @param consumerGroup                消费者组
 * @param rpcHook                      在每个远程处理命令之前执行的RPC钩子
 * @param allocateMessageQueueStrategy 消费者之间消息分配的策略算法
 */
public DefaultMQPushConsumer(final String namespace, final String consumerGroup, RPCHook rpcHook,
                             AllocateMessageQueueStrategy allocateMessageQueueStrategy) {
    this.consumerGroup = consumerGroup;
    this.namespace = namespace;
    this.allocateMessageQueueStrategy = allocateMessageQueueStrategy;
    //创建DefaultMQPushConsumerImpl实例
    defaultMQPushConsumerImpl = new DefaultMQPushConsumerImpl(this, rpcHook);
}

指定了命名空间、生产者组、RPC钩子和消费者之间消息分配的策略算法的构造器, 创建了一个DefaultMQPushConsumerImpl实例, DefaultMQPushConsumer可以看作是DefaultMQPushConsumerImpl的包装类, 给开发人员用的。DefaultMQPushConsumer可以看作为DefaultMQPushConsumerImpl的门面。

在这里插入图片描述

public DefaultMQPushConsumerImpl(DefaultMQPushConsumer defaultMQPushConsumer, RPCHook
 rpcHook) {
    this.defaultMQPushConsumer = defaultMQPushConsumer;
    this.rpcHook = rpcHook;
    // consumer 状态错误时采用定时任务定时执行拉取请求的时间间隔
    this.pullTimeDelayMillsWhenException = defaultMQPushConsumer.getPullTimeDelayMillsWhenException();
}

创建了DefaultMQPushConsumer实例之后, 设置一些属性, 比如namesrvAddr、consumeFromWhere、注册messageListener消息监听器等等。这些都是简单的属性赋值操作, 除了subscribe方法。

1.1 subscribe订阅

subscribe方法表示Consumer订阅的自己感兴趣的Topic, 并且支持对消息进行过滤, 过滤表达式支持TAG和SQL92两种类型, 他们都会被解析为SubscriptionData对象, 最终将topic与SubscriptionData的关系维护到RebalanceImpl内部的subscriptionInner这个map集合中。

在这里插入图片描述

/**
 * DefaultMQPushConsumer的方法
 * <p>
 * 订阅topic，支持消息过滤表达式
 *
 * @param topic         订阅的topic
 * @param subExpression 订阅表达式。它仅支持或操作，如“tag1 | | tag2 | | tag3”，如果为 null 或 *，则表示订阅全部
 */
@Override
public void subscribe(String topic, String subExpression) throws MQClientException {
    //调用defaultMQPushConsumerImpl的subscribe方法
    this.defaultMQPushConsumerImpl.subscribe(withNamespace(topic), subExpression);
}

在这里插入图片描述

/**
 * DefaultMQPushConsumerImpl的方法
 * <p>
 * 订阅topic
 */
public void subscribe(String topic, String subExpression) throws MQClientException {
    try {
        //解析订阅表达式，构建SubscriptionData
        SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, subExpression);
        //将topic与SubscriptionData的关系维护到RebalanceImpl内部的subscriptionInner这个map集合中
        this.rebalanceImpl.getSubscriptionInner().put(topic, subscriptionData);
        if (this.mQClientFactory != null) {
            //如果mQClientFactory不为null，则发送心跳信息给所有broker。
            this.mQClientFactory.sendHeartbeatToAllBrokerWithLock();
        }
    } catch (Exception e) {
        throw new MQClientException("subscription exception", e);
    }
}

2.start启动消费者

start方法内部会执行很多初始化操作。

在这里插入图片描述

/**
 * DefaultMQPushConsumer的方法
 * <p>
 * 启动消费者
 */
@Override
public void start() throws MQClientException {
    //根据namespace和consumerGroup设置消费者组
    setConsumerGroup(NamespaceUtil.wrapNamespace(this.getNamespace(), this.consumerGroup));
    //默认消费者实现启动
    this.defaultMQPushConsumerImpl.start();
    //消息轨迹跟踪服务，默认null
    if (null != traceDispatcher) {
        try {
            traceDispatcher.start(this.getNamesrvAddr(), this.getAccessChannel());
        } catch (MQClientException e) {
            log.warn("trace dispatcher start failed ", e);
        }
    }
}

defaultMQPushConsumerImpl#start方法。

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述

  1. checkConfig方法检查消费者的配置信息: 如果consumerGroup为空, 或者长度大于255个字符, 或者包含非法字符, 或者消费者组名为默认组名DEFAULT_CONSUMER, 或者messageModel为空, 或者consumeFromWhere为空, 或者consumeTimestamp为空, 或者allocateMessageQueueStrategy为空, 满足以上任意条件都校验不通过抛出异常。

  2. 调用copySubscription方法, 拷贝订阅关系, 然后为集群消费模式的消费者配置重试主题用于实现消费重试。

  3. 调用getOrCreateMQClientInstance方法, 根据clientId获取或者创建CreateMQClientInstance实例, 并赋给mQClientFactory变量。

  4. 设置负载均衡服务rebalanceImpl的相关属性。

  5. 创建消息拉取核心对象PullAPIWrapper, 封装了消息拉取以及结果解析逻辑的api。

  6. 根据消息模式设置不同的OffsetStore, 用于实现消费者的消息消费偏移量offset的管理。如果是广播消费模式, 是LocalFileOffsetStore, offset存储在本地磁盘, 如果是集群模式, 是RemoteBrokerOffsetStore, offset存储在远程broker中。

  7. 调用offsetStore.load加载消费偏移量, LocalFileOffsetStore会加载本地磁盘中的数据。

  8. 根据消息监听器MessageListener的类型创建不同的消息消费服务ConsumeMessageService, MessageListenerOrderly类型表示顺序消费, 创建ConsumeMessageOrderlyService, MessageListenerConcurrently类型表示并发消费, 创建ConsumeMessageConcurrentlyService。

  9. 调用consumeMessageService.start启动消息消费服务, 消息拉取服务PullMessageService拉取到消息后, 会构建ConsumeRequest对象交给consumeMessageService去消费。

  10. 注册消费者组和消费者到MQClientInstance中的consumerTable中, 如果没有注册成功, 可能是因为同一个程序中存在同名消费者组的不同消费者, 抛出异常。

  11. mQClientFactory#start启动CreateMQClientInstance, 初始化netty服务、各种定时任务、拉取消息服务、rebalanceService服务等等。CreateMQClientInstance仅会被初始化一次

  12. updateTopicSubscribeInfoWhenSubscriptionChanged方法: 向NameServer拉取并更新当前消费者订阅的topic路由信息。

  13. checkClientInBroker: 随机选择一个Broker, 发送检查客户端tag配置的请求, 主要是检测Broker是否支持SQL92类型的tag过滤以及SQL92的tag语法是否正确。

  14. sendHeartbeatToAllBrokerWithLock方法, 发送心跳给所有broker, Broker接收到后, 发送Code为NOTIFY_CONSUMER_IDS_CHANGED给Group下所有消费者, 要求重新负载均衡。

  15. rebalanceImmediately方法: 唤醒负载均衡服务rebalanceService, 主动进行一次MessageQueue的重平衡。

/**
 * DefaultMQPushConsumerImpl的方法
 * <p>
 * 启动默认消费者实现
 */
public synchronized void start() throws MQClientException {
    //根据服务状态选择走不同的代码分支
    switch (this.serviceState) {
        /*
         * 服务仅仅创建，而不是启动状态，那么启动服务
         */
        case CREATE_JUST:
            log.info("the consumer [{}] start beginning. messageModel={}, isUnitMode={}", this.defaultMQPushConsumer.getConsumerGroup(),
                    this.defaultMQPushConsumer.getMessageModel(), this.defaultMQPushConsumer.isUnitMode());
            //首先修改服务状态为服务启动失败，如果最终启动成功则再修改为RUNNING
            this.serviceState = ServiceState.START_FAILED;
            /*
             * 1 检查消费者的配置信息
             *
             * 如果consumerGroup为空，或者长度大于255个字符，或者包含非法字符（正常的匹配模式为 ^[%|a-zA-Z0-9_-]+$），或者消费者组名为默认组名DEFAULT_CONSUMER
             * 或者messageModel为空，或者consumeFromWhere为空，或者consumeTimestamp为空，或者allocateMessageQueueStrategy为空……等等属性的空校验
             * 满足以上任意条件都校验不通过抛出异常。
             */
            this.checkConfig();
            /*
             * 2 拷贝拷贝订阅关系
             *
             * 为集群消费模式的消费者，配置其对应的重试主题 retryTopic = %RETRY% + consumerGroup
             * 并且设置当前消费者自动订阅该消费者组对应的重试topic，用于实现消费重试。
             */
            this.copySubscription();
            //如果是集群消费模式，如果instanceName为默认值 "DEFAULT"，那么改成 UtilAll.getPid() + "#" + System.nanoTime()
            if (this.defaultMQPushConsumer.getMessageModel() == MessageModel.CLUSTERING) {
                this.defaultMQPushConsumer.changeInstanceNameToPID();
            }
            /*
             * 3 获取MQClientManager实例，然后根据clientId获取或者创建CreateMQClientInstance实例，并赋给mQClientFactory变量
             *
             * MQClientInstance封装了RocketMQ底层网络处理API，Producer、Consumer都会使用到这个类，是Producer、Consumer与NameServer、Broker 打交道的网络通道。
             * 因此，同一个clientId对应同一个MQClientInstance实例就可以了，即同一个应用中的多个producer和consumer使用同一个MQClientInstance实例即可。
             */
            this.mQClientFactory = MQClientManager.getInstance().getOrCreateMQClientInstance(this.defaultMQPushConsumer, this.rpcHook);
            /*
             * 4 设置负载均衡服务的相关属性
             */
            this.rebalanceImpl.setConsumerGroup(this.defaultMQPushConsumer.getConsumerGroup());
            this.rebalanceImpl.setMessageModel(this.defaultMQPushConsumer.getMessageModel());
            this.rebalanceImpl.setAllocateMessageQueueStrategy(this.defaultMQPushConsumer.getAllocateMessageQueueStrategy());
            this.rebalanceImpl.setmQClientFactory(this.mQClientFactory);

            /*
             * 5 创建消息拉取核心对象PullAPIWrapper，封装了消息拉取及结果解析逻辑的API
             */
            this.pullAPIWrapper = new PullAPIWrapper(
                    mQClientFactory,
                    this.defaultMQPushConsumer.getConsumerGroup(), isUnitMode());
            //为PullAPIWrapper注册过滤消息的钩子函数
            this.pullAPIWrapper.registerFilterMessageHook(filterMessageHookList);

            /*
             * 6 根据消息模式设置不同的OffsetStore，用于实现消费者的消息消费偏移量offset的管理
             */
            if (this.defaultMQPushConsumer.getOffsetStore() != null) {
                this.offsetStore = this.defaultMQPushConsumer.getOffsetStore();
            } else {
                //根据不用的消费模式选择不同的OffsetStore实现
                switch (this.defaultMQPushConsumer.getMessageModel()) {
                    case BROADCASTING:
                        //如果是广播消费模式，则是LocalFileOffsetStore，消息消费进度即offset存储在本地磁盘中。
                        this.offsetStore = new LocalFileOffsetStore(this.mQClientFactory, this.defaultMQPushConsumer.getConsumerGroup());
                        break;
                    case CLUSTERING:
                        //如果是集群消费模式，则是RemoteBrokerOffsetStore，消息消费进度即offset存储在远程broker中。
                        this.offsetStore = new RemoteBrokerOffsetStore(this.mQClientFactory, this.defaultMQPushConsumer.getConsumerGroup());
                        break;
                    default:
                        break;
                }
                this.defaultMQPushConsumer.setOffsetStore(this.offsetStore);
            }
            /*
             * 7 加载消费偏移量，LocalFileOffsetStore会加载本地磁盘中的数据，RemoteBrokerOffsetStore则是一个空实现。
             */
            this.offsetStore.load();
            /*
             * 8 根据消息监听器的类型创建不同的消息消费服务
             */
            if (this.getMessageListenerInner() instanceof MessageListenerOrderly) {
                //如果是MessageListenerOrderly类型，则表示顺序消费，创建ConsumeMessageOrderlyService
                this.consumeOrderly = true;
                this.consumeMessageService =
                        new ConsumeMessageOrderlyService(this, (MessageListenerOrderly) this.getMessageListenerInner());
            } else if (this.getMessageListenerInner() instanceof MessageListenerConcurrently) {
                //如果是MessageListenerConcurrently类型，则表示并发消费，创建ConsumeMessageOrderlyService
                this.consumeOrderly = false;
                this.consumeMessageService =
                        new ConsumeMessageConcurrentlyService(this, (MessageListenerConcurrently) this.getMessageListenerInner());
            }
            //启动消息消费服务
            this.consumeMessageService.start();
            /*
             * 9 注册消费者组和消费者到MQClientInstance中的consumerTable中
             */
            boolean registerOK = mQClientFactory.registerConsumer(this.defaultMQPushConsumer.getConsumerGroup(), this);
            if (!registerOK) {
                //如果没注册成功，那么可能是因为同一个程序中存在同名消费者组的不同消费者
                this.serviceState = ServiceState.CREATE_JUST;
                this.consumeMessageService.shutdown(defaultMQPushConsumer.getAwaitTerminationMillisWhenShutdown());
                throw new MQClientException("The consumer group[" + this.defaultMQPushConsumer.getConsumerGroup()
                        + "] has been created before, specify another name please." + FAQUrl.suggestTodo(FAQUrl.GROUP_NAME_DUPLICATE_URL),
                        null);
            }
            /*
             * 10 启动CreateMQClientInstance客户端通信实例
             * netty服务、各种定时任务、拉取消息服务、rebalanceService服务
             */
            mQClientFactory.start();
            log.info("the consumer [{}] start OK.", this.defaultMQPushConsumer.getConsumerGroup());
            this.serviceState = ServiceState.RUNNING;
            break;
        /**
         * 服务状态是其他的，那么抛出异常，即start方法仅能调用一次
         */
        case RUNNING:
        case START_FAILED:
        case SHUTDOWN_ALREADY:
            throw new MQClientException("The PushConsumer service state not OK, maybe started once, "
                    + this.serviceState
                    + FAQUrl.suggestTodo(FAQUrl.CLIENT_SERVICE_NOT_OK),
                    null);
        default:
            break;
    }
    /*
     * 11 后续处理
     */
    /*
     * 向NameServer拉取并更新当前消费者订阅的topic路由信息
     */
    this.updateTopicSubscribeInfoWhenSubscriptionChanged();
    /*
     * 随机选择一个Broker，发送检查客户端tag配置的请求，主要是检测Broker是否支持SQL92类型的tag过滤以及SQL92的tag语法是否正确
     */
    this.mQClientFactory.checkClientInBroker();
    /*
     * 发送心跳信息给所有broker
     */
    this.mQClientFactory.sendHeartbeatToAllBrokerWithLock();
    /*
     * 唤醒负载均衡服务rebalanceService，进行重平衡
     */
    this.mQClientFactory.rebalanceImmediately();
}

2.1 copySubscription拷贝订阅关系

该方法将defaultMQPushConsumer中的订阅关系Map集合subscription中的数据拷贝到RebalanceImpl的subscriptionInner中。

然后为集群消费模式的消费者配置重试主题用于实现消费重试。

/**
 * DefaultMQPushConsumerImpl的方法
 * <p>
 * 拷贝订阅关系
 *
 * @throws MQClientException
 */
private void copySubscription() throws MQClientException {
    try {
        //将订阅关系拷贝到RebalanceImpl的subscriptionInner中
        Map<String, String> sub = this.defaultMQPushConsumer.getSubscription();
        if (sub != null) {
            for (final Map.Entry<String, String> entry : sub.entrySet()) {
                final String topic = entry.getKey();
                final String subString = entry.getValue();
                SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(topic, subString);
                this.rebalanceImpl.getSubscriptionInner().put(topic, subscriptionData);
            }
        }
        //如果messageListenerInner为null，那么将defaultMQPushConsumer的messageListener赋给DefaultMQPushConsumerImpl的messageListenerInner
        //在defaultMQPushConsumer的registerMessageListener方法中就已经赋值了
        if (null == this.messageListenerInner) {
            this.messageListenerInner = this.defaultMQPushConsumer.getMessageListener();
        }
        //消息消费模式
        switch (this.defaultMQPushConsumer.getMessageModel()) {
            //广播消费模式，消费失败消息会丢弃
            case BROADCASTING:
                break;
            //集群消费模式，支持消费失败重试
            //自动订阅该消费者组对应的重试topic，默认就是这个模式
            case CLUSTERING:
                //获取当前消费者对应的重试主题 retryTopic = %RETRY% + consumerGroup
                final String retryTopic = MixAll.getRetryTopic(this.defaultMQPushConsumer.getConsumerGroup());
                //当前消费者自动订阅该消费者组对应的重试topic，用于实现消费重试
                SubscriptionData subscriptionData = FilterAPI.buildSubscriptionData(retryTopic, SubscriptionData.SUB_ALL);
                this.rebalanceImpl.getSubscriptionInner().put(retryTopic, subscriptionData);
                break;
            default:
                break;
        }
    } catch (Exception e) {
        throw new MQClientException("subscription exception", e);
    }
}

3.总结

Consumer消费者启动的主要流程:

  1. rebalanceService: 消费者负载均衡服务, 用于确定消费者的消息队列以及负载均衡, 同时触发pullMessageService拉取消息的入口。MQClientInstance启动, 同一个服务器的所有Consumer使用同一个实例。
  2. pullMessageService: 拉取消息服务, 由MQClientInstance启动, 同一个服务器的所有Consumer使用同一个实例。
  3. consumeMessageService: 消费者消费消息服务, 消息拉取到后, 交给这个服务。DefaultMQPushConsumerImpl启动, 每个Consumer持有一个实例。
  4. OffsetStore: 管理消费点位的上报持久化, DefaultMQPushConsumerImpl启动, 每个Consumer持有一个实例。

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

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

相关文章

调用聚合数据API实现手机号码归属地查询

调用聚合数据API实现手机号码归属地查询

调用聚合数据API实现手机号码归属地查询 1&#xff0e;作者介绍2&#xff0e;相关介绍2.1 什么是聚合数据&#xff1f;2.2 API介绍2.3 手机号码归属地 3&#xff0e;实验过程3.1如何调用聚合数据API3.2代码实现3.3实验结果3.4问题分析 1&#xff0e;作者介绍 吝红凯&#xff0…
阅读更多...
Python+requests+unittest+excel搭建接口自动化测试框架

Python+requests+unittest+excel搭建接口自动化测试框架

一、框架结构&#xff1a; 工程目录 代码&#xff1a;基于python2编写 二、Case文件设计 三、基础包 base 3.1 封装get/post请求&#xff08;runmethon.py&#xff09; import requests import json class RunMethod:def post_main(self,url,data,headerNone):res Noneif h…
阅读更多...
【C++】一些关于visual stdio,vscode,Mingw的思考 |bug

【C++】一些关于visual stdio,vscode,Mingw的思考 |bug

文章目录 今天在做YOLOV8的C部署时遇到的一些问题&#xff1a; 在进行一系列的操作之后会生成解决方案文件sln: 当然按道理到这一步之后&#xff0c;应该使用make命令进行下一步操作&#xff08;但是我确实不会make命令&#xff0c;所以准备进sln来生成解决方案&#xff09;&…
阅读更多...
缓存和数据库一致性问题，看这篇就够了

缓存和数据库一致性问题，看这篇就够了

阅读本文大约需要 10 分钟。 如何保证缓存和数据库一致性&#xff0c;这是一个老生常谈的话题了。 但很多人对这个问题&#xff0c;依旧有很多疑惑&#xff1a; 到底是更新缓存还是删缓存&#xff1f; 到底选择先更新数据库&#xff0c;再删除缓存&#xff0c;还是先删除缓存…
阅读更多...
消息队列详解

消息队列详解

文章目录 1、什么是消息队列2、使用场景3、消息队列与传统设计的区别1、传统设计2、并行处理调优3、消息队列 4、三大优点1、异步2、削峰3、解耦 5、缺点1、增加了系统复杂性。2、事务问题。3、可用性 6、MQ常见问题1、消息堆积问题怎么解决2、重复消费问题怎么解决3、如果避免…
阅读更多...
消息队列Message Queue 0基础学习

消息队列Message Queue 0基础学习

一、定义 消息队列&#xff1a;一般我们会简称它为MQ(Message Queue)。Message Query&#xff08;MQ&#xff09;&#xff0c;消息队列中间件&#xff0c;很多初学者认为&#xff0c;MQ通过消息的发送和接受来实现程序的异步和解耦&#xff0c;mq主要用于异步操作&#xff0c;…
阅读更多...
高效精细的企业发票管理：探索优质方案助力您提升财务效率

高效精细的企业发票管理：探索优质方案助力您提升财务效率

随着企业逐渐规范化&#xff0c;财务工作流程暴露了不足&#xff0c;在企业员工报销管理工作中常遇到以下问题&#xff1a; 1. 报销发票种类繁多&#xff0c;管理麻烦费时&#xff1b; 2. 手动合计报销金额费时费力、并且易出错&#xff1b; 3. 报销流程繁杂&#xff0c;填写…
阅读更多...
【软考网络管理员】2023年软考网管初级常见知识考点（5）-以太网技术

【软考网络管理员】2023年软考网管初级常见知识考点（5）-以太网技术

涉及知识点 CSMA/CD技术&#xff0c;以太网帧结构&#xff0c;冲突域和广播域&#xff0c;高速以太网&#xff0c;交换式以太网&#xff0c;软考网络管理员常考知识点&#xff0c;软考网络管理员网络安全&#xff0c;网络管理员考点汇总。 文章目录 涉及知识点前言一、CSMA/CD…
阅读更多...
【CV】常见的损失函数及应用举例：交叉熵、对比、余弦、Dice、Focal Loss

【CV】常见的损失函数及应用举例：交叉熵、对比、余弦、Dice、Focal Loss

目录 前言均方误差&#xff08;MSE&#xff09;交叉熵损失&#xff08;Cross-Entropy Loss&#xff09;对比损失&#xff08;Contrastive Loss&#xff09;余弦相似度损失&#xff08;Cosine Similarity Loss&#xff09;交叉熵损失加权的Dice损失&#xff08;Dice Loss&#x…
阅读更多...
【接口自动化测试】如何进行流程封装和基于加密接口的测试用例设计？

【接口自动化测试】如何进行流程封装和基于加密接口的测试用例设计？

接口测试仅仅掌握 Requests 或者其他一些功能强大的库的用法&#xff0c;是远远不够的&#xff0c;还需要具备能根据公司的业务流程以及需求去定制化一个接口自动化测试框架的能力。所以&#xff0c;接下来&#xff0c;我们主要介绍下接口测试用例分析以及通用的流程封装是如何…
阅读更多...
何为SaaS？国内做的好的SaaS平台有哪些？

何为SaaS？国内做的好的SaaS平台有哪些？

国内做得好的saas平台有哪些啊&#xff1f; 什么是SaaS平台&#xff1f; SaaS是Software as a Service的缩写&#xff0c;意为软件即服务。 它是指将软件应用程序部署在云计算服务器上&#xff0c;通过网络提供给用户的一种模式。这个模式下&#xff0c;用户无需花费大量的资…
阅读更多...
LNMP架构搭建

LNMP架构搭建

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一、LNMP概述1.LNMP的特点2.LNMP工作原理 二、安装Nginx 服务1.安装需要的依赖包2.创建运行用户3.编译安装4.优化路径5.添加 Nginx 系统服务 三、安装mysql服务1.安…
阅读更多...
机房如何选购STS静态转换开关，采购配置并上架投入使用

机房如何选购STS静态转换开关，采购配置并上架投入使用

环境： 1.机房交换机设备 2.STS静态转换开关 3.16安4平方电源插头 4.6平方输入连接线 5.大功率接线器（3进3出） 6.PDU（C14插头） 问题描述： 机房如何选购STS静态转换开关，采购配置并上架投入使用 目前痛点 机房有些设备单电源，无法接入UPS，停电了就无法正常工作，为…
阅读更多...
Java-String、StringBuffer、StringBuilder区别及相关面试题

Java-String、StringBuffer、StringBuilder区别及相关面试题

目录 一、引言二、String类的基本介绍2.1 创建String对象2.2 字符串的拼接和连接2.3 字符串的比较2.4 字符串的截取和替换2.5 字符串的查找和匹配2.6 创建格式化字符串API文档 三、StringBuffer类的基本介绍3.1 创建StringBuffer对象3.2 字符串的拼接和连接3.3 字符串的插入和删…
阅读更多...
DDD概念以及微服务划分

DDD概念以及微服务划分

目录 DDD简介&#xff1a; DDD与微服务的区别&#xff1a; DDD核心概念&#xff1a; 如何划分微服务边界&#xff1a; DDD简介&#xff1a; DDD 是 Domain-Driven Design 的缩写&#xff0c;称为领域驱动设计。它是为了解决划分业务边界的问题,是一种架构模式,也是一种划分…
阅读更多...
Node.js安装教程，2023最新版，保姆级安装教程

Node.js安装教程，2023最新版，保姆级安装教程

Node.js安装教程2023最新版 资源准备 在官网中下载对应版本的node.js 官方连接&#xff1a;https://nodejs.org/en/download Node.js安装配置 下载完成安装包后&#xff0c;打开安装程序 配置好安装路径&#xff0c;无脑下一步至这个页面&#xff0c;这个不需要勾选 就这样…
阅读更多...
从《新华三2023十大技术趋势白皮书》，看见前沿技术的“实体”回归

从《新华三2023十大技术趋势白皮书》，看见前沿技术的“实体”回归

文|智能相对论 作者|李永华 在“新技术革命”的全球预期下&#xff0c;前沿技术创新的步伐不断加速。 下一步&#xff0c;哪些技术趋势将凸显出来&#xff0c;哪些场景将被数字经济深度改变&#xff0c;哪些场景将带来如同科幻世界般的技术应用……这些是从产业界到普罗大众…
阅读更多...
BurpSuite安装教程以及环境配置（附安装包）

BurpSuite安装教程以及环境配置（附安装包）

前言 Burp Suite 是用于攻击web 应用程序的集成平台。它包含了许多Burp工具&#xff0c;这些不同的burp工具通过协同工作&#xff0c;有效的分享信息&#xff0c;支持以某种工具中的信息为基础供另一种工具使用的方式发起攻击。 它主要用来做安全性渗透测试&#xff0c;可以实…
阅读更多...
通过使用Mybatis插件来实现数据的分页功能

通过使用Mybatis插件来实现数据的分页功能

目录 背景一、SpringBoot的后端1、手动拼接SQL来实现2、使用Mybatis插件来实现 二、Vue-cli的前端:请求响应跟踪 三、在使用Mybatis插件进行多表查询(表数大于2)出现的问题1. SQL解决2.后端查询方式改变成嵌套查询 四、 分页总结 背景 分页: 如果一次性的查询全部数据, 响应时…
阅读更多...
【MOOC 作业】第5章 链接层

【MOOC 作业】第5章 链接层

不是标答也不是参考答案 仅从个人理解出发去做题 1、(20分) 在某网络中标识为 A 到 E 的 5 个结点以星形与一台交换机连接&#xff0c;考虑在该网络环境中某个正在学习的交换机的运行情况。假定&#xff1a;该交换机表初始为空。B 向 E 发送一个帧&#xff0c;此时交换机将该数…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023