Kafka、RabbitMQ、RocketMQ对比

news2024/11/16 18:20:50

Kafka、RabbitMQ、RocketMQ对比

概述

  • Kafka：由LinkedIn开发，后成为Apache项目，主要用于构建实时数据管道和流应用。
  • RabbitMQ：由VMware开发，基于AMQP协议，适用于复杂的消息路由场景。
  • RocketMQ：由阿里巴巴开发，设计用于处理大规模消息传递，特别是在高并发场景下。

核心特性对比

1. 架构

  • Kafka
    • 基于分布式文件系统，支持水平扩展。
    • 使用发布/订阅模型。
    • 支持多副本机制，保证数据可靠性。
  • RabbitMQ
    • 基于Erlang语言开发，支持多种消息协议。
    • 支持复杂的路由规则，如直接、主题、头部和通配符等。
    • 支持消息持久化和事务。
  • RocketMQ
    • 基于主从复制模型，支持高可用性和水平扩展。
    • 支持事务消息，确保消息的最终一致性。
    • 提供丰富的API和管理工具。

2. 性能

  • Kafka
    • 高吞吐量，适合大数据处理。
    • 低延迟，适合实时数据流处理。
  • RabbitMQ
    • 中等吞吐量，适合复杂的消息路由和事务处理。
    • 较高的延迟，适合对消息顺序有严格要求的场景。
  • RocketMQ
    • 高吞吐量，适合高并发场景。
    • 低延迟，适合实时消息传递。

3. 可靠性

  • Kafka
    • 支持多副本机制，保证数据可靠性。
    • 支持数据压缩，减少存储成本。
  • RabbitMQ
    • 支持消息持久化，确保消息不丢失。
    • 支持镜像队列，提高可用性。
  • RocketMQ
    • 支持主从复制，保证数据一致性。
    • 支持事务消息，确保消息的最终一致性。

4. 使用场景

1. 实时数据流处理

  • Kafka
    • 实现原理：
      • 分布式文件系统：Kafka使用分布式文件系统存储消息，支持水平扩展。
      • 发布/订阅模型：生产者将消息发布到Topic，消费者订阅Topic获取消息。
      • 多副本机制：每个Partition有多个副本，提高数据可靠性和可用性。
      • 批量发送和压缩：支持批量发送消息和消息压缩，减少网络开销和存储成本。
      • 零拷贝技术：利用零拷贝技术提高数据传输效率。
    • 适用场景：
      • 日志收集：收集和分析服务器日志，需要高吞吐量和低延迟。
      • 监控数据处理：实时监控系统性能指标，需要快速处理大量数据。
      • 大数据处理：构建数据仓库和ETL流程，需要处理大规模数据流。

2. 复杂消息路由

  • RabbitMQ
    • 实现原理：
      • 基于AMQP协议：支持多种消息协议，如AMQP、STOMP等。
      • 多种交换机类型：支持Direct、Fanout、Topic和Headers等多种交换机类型，实现灵活的消息路由。
      • 消息持久化和事务：支持消息持久化和事务处理，确保消息的可靠性和一致性。
      • 镜像队列：可以将Queue的副本分布到多个节点，提高可用性和可靠性。
    • 适用场景：
      • 订单处理：需要复杂的路由规则，将订单消息路由到不同的处理队列。
      • 支付通知：需要确保消息的顺序和可靠性，支持事务处理。
      • 延迟消息：需要定时发送消息，如邮件发送、定时任务等。

3. 高并发场景

  • RocketMQ
    • 实现原理：
      • 主从复制模型：每个Message Queue有多个副本，提高数据可靠性和可用性。
      • 事务消息：支持事务消息，确保消息的最终一致性。
      • 高性能设计：支持高吞吐量和低延迟，适用于高并发场景。
      • 丰富的API和管理工具：提供丰富的API和管理工具，方便运维和监控。
    • 适用场景：
      • 电商大促：需要处理大量并发请求，确保消息的可靠性和一致性。
      • 秒杀活动：需要快速响应用户请求，处理高并发流量。
      • 实时消息传递：如即时通讯、推送通知等，需要低延迟和高可靠性。

4. 微服务通信

  • Kafka
    • 实现原理：
      • 发布/订阅模型：支持多个生产者和消费者，实现解耦。
      • 多副本机制：提高数据可靠性和可用性。
      • 高吞吐量：支持高吞吐量，适用于大规模微服务架构。
    • 适用场景：
      • 服务间异步通信：微服务之间通过Kafka进行异步通信，提高系统的可扩展性和可靠性。
      • 事件驱动架构：基于事件驱动的微服务架构，Kafka作为事件总线。

5. 数据仓库和ETL

  • Kafka
    • 实现原理：
      • 分布式文件系统：支持大规模数据存储和处理。
      • 高吞吐量：支持高吞吐量，适用于大数据处理。
      • 消息压缩：减少存储和传输成本。
    • 适用场景：
      • 数据仓库：构建数据仓库，收集和处理各种数据源的数据。
      • ETL流程：提取、转换和加载数据，Kafka作为数据传输管道。

6. 银行和金融行业

  • RabbitMQ
    • 实现原理：
      • 消息持久化和事务：确保消息的可靠性和一致性。
      • 复杂路由规则：支持多种交换机类型，实现灵活的消息路由。
    • 适用场景：
      • 银行转账：需要确保消息的顺序和可靠性，支持事务处理。
      • 股票交易：需要快速处理大量交易消息，确保消息的可靠性和一致性。

7. 实时监控和告警

  • Kafka
    • 实现原理：
      • 高吞吐量：支持高吞吐量，适用于实时数据处理。
      • 低延迟：支持低延迟，适用于实时监控和告警。
    • 适用场景：
      • 系统监控：实时监控系统性能指标，及时发现和处理问题。
      • 日志告警：实时分析日志数据，触发告警通知。

8. 即时通讯和推送通知

  • RocketMQ
    • 实现原理：
      • 低延迟：支持低延迟，适用于实时消息传递。
      • 事务消息：确保消息的最终一致性。
    • 适用场景：
      • 即时通讯：实时传递用户消息，确保消息的可靠性和一致性。
      • 推送通知：实时推送通知，如订单状态更新、促销活动等。

9. 物联网和边缘计算

  • Kafka
    • 实现原理：
      • 分布式文件系统：支持大规模数据存储和处理。
      • 高吞吐量：支持高吞吐量，适用于物联网设备产生的大量数据。
    • 适用场景：
      • 物联网设备数据收集：收集和处理物联网设备产生的数据。
      • 边缘计算：在边缘设备上进行数据处理和分析，减少数据传输延迟。

10. 机器学习和数据分析

  • Kafka
    • 实现原理：
      • 高吞吐量：支持高吞吐量，适用于大规模数据处理。
      • 分布式文件系统：支持大规模数据存储和处理。
    • 适用场景：
      • 数据流处理：实时处理和分析数据流，支持机器学习和数据分析。
      • 特征工程：提取和处理特征数据，支持机器学习模型训练。

工作原理详细说明

Kafka 工作原理

1. 基本概念
  • Topic：消息的主题，生产者将消息发布到特定的Topic。
  • Partition：每个Topic可以分为多个Partition，每个Partition是一个有序的队列。
  • Broker：Kafka集群中的节点，负责存储和转发消息。
  • Producer：生产者，向Broker发送消息。
  • Consumer：消费者，从Broker拉取消息。
  • Consumer Group：消费者组，同一组内的消费者互斥地消费消息。
2. 消息存储
  • Partition：每个Partition是一个有序的、不可变的消息序列，新消息追加到Partition的末尾。
  • Offset：每个消息在Partition中有一个唯一的Offset，用于标识消息的位置。
  • Replication：每个Partition可以有多个副本，分布在不同的Broker上，以提高可靠性和可用性。
3. 生产者
  • 消息发送：生产者将消息发送到指定的Topic和Partition。
  • 负载均衡：生产者可以通过哈希算法或轮询方式选择Partition，实现负载均衡。
  • 消息确认：生产者可以配置不同的确认级别，如acks=0、acks=1、acks=all，以控制消息的可靠性。
4. 消费者
  • 消费模式：消费者以Pull模式从Broker拉取消息。
  • 消费组：同一消费组内的消费者互斥地消费消息，不同消费组的消费者可以并行消费。
  • 消费进度：消费者通过Offset记录消费进度，可以手动或自动提交Offset。
5. 高可用性
  • 多副本机制：每个Partition有多个副本，其中一个为主副本（Leader），其他为从副本（Follower）。
  • 故障转移：当Leader失效时，Kafka会自动选举一个新的Leader继续服务。
6. 性能优化
  • 批量发送：生产者可以批量发送消息，减少网络开销。
  • 压缩：消息可以被压缩，减少存储和传输成本。
  • 零拷贝：Kafka利用零拷贝技术，提高数据传输效率。

RabbitMQ 工作原理

1. 基本概念
  • Message：消息，包含数据和元数据。
  • Queue：队列，存储消息的地方。
  • Exchange：交换机，负责接收生产者的消息并将其路由到一个或多个队列。
  • Binding：绑定，定义了Exchange和Queue之间的关系。
  • Routing Key：路由键，用于Exchange根据规则将消息路由到队列。
2. 消息路由
  • Direct Exchange：直连交换机，根据精确的Routing Key将消息路由到队列。
  • Fanout Exchange：扇出交换机，将消息广播到所有绑定的队列。
  • Topic Exchange：主题交换机，根据模式匹配的Routing Key将消息路由到队列。
  • Headers Exchange：头交换机，根据消息头中的字段将消息路由到队列。
3. 生产者
  • 消息发送：生产者将消息发送到指定的Exchange。
  • 消息确认：生产者可以配置消息确认机制，确保消息成功发送到Exchange。
4. 消费者
  • 消费模式：消费者以Push模式从Queue接收消息。
  • 消费确认：消费者在处理完消息后发送确认，Queue才会删除该消息。
  • 消息重试：如果消费者处理消息失败，可以配置消息重试机制。
5. 高可用性
  • 镜像队列：可以将Queue的副本分布到多个节点，提高可用性和可靠性。
  • 故障转移：当某个节点失效时，RabbitMQ会自动将消息路由到其他节点。
6. 性能优化
  • 持久化：消息可以被持久化到磁盘，确保消息不丢失。
  • 预取计数：可以配置预取计数，限制每个消费者未确认的消息数量，提高处理速度。

RocketMQ 工作原理

1. 基本概念
  • Topic：消息的主题，生产者将消息发布到特定的Topic。
  • Message Queue：每个Topic可以分为多个Message Queue，类似于Kafka的Partition。
  • Broker：RocketMQ集群中的节点，负责存储和转发消息。
  • Producer：生产者，向Broker发送消息。
  • Consumer：消费者，从Broker拉取消息。
  • Name Server：命名服务器，管理Broker的注册信息和路由信息。
2. 消息存储
  • Message Queue：每个Message Queue是一个有序的队列，新消息追加到队列的末尾。
  • Offset：每个消息在Message Queue中有一个唯一的Offset，用于标识消息的位置。
  • 主从复制：每个Message Queue有多个副本，分布在不同的Broker上，以提高可靠性和可用性。
3. 生产者
  • 消息发送：生产者将消息发送到指定的Topic和Message Queue。
  • 负载均衡：生产者可以通过哈希算法或轮询方式选择Message Queue，实现负载均衡。
  • 消息确认：生产者可以配置不同的确认级别，以控制消息的可靠性。
4. 消费者
  • 消费模式：消费者以Pull模式从Broker拉取消息。
  • 消费组：同一消费组内的消费者互斥地消费消息，不同消费组的消费者可以并行消费。
  • 消费进度：消费者通过Offset记录消费进度，可以手动或自动提交Offset。
5. 事务消息
  • 半消息：生产者发送半消息，Broker接收到后返回确认。
  • 消息回查：Broker定期检查半消息的状态，如果生产者没有提交最终状态，Broker会回查生产者。
  • 消息提交：生产者根据业务逻辑提交消息的最终状态（提交或回滚）。
6. 高可用性
  • 主从复制：每个Message Queue有多个副本，其中一个为主副本（Master），其他为从副本（Slave）。
  • 故障转移：当Master失效时，RocketMQ会自动选举一个新的Master继续服务。
7. 性能优化
  • 批量发送：生产者可以批量发送消息，减少网络开销。
  • 压缩：消息可以被压缩，减少存储和传输成本。
  • 零拷贝：RocketMQ利用零拷贝技术，提高数据传输效率。

架构图

1. Kafka 架构图

架构说明
  • Producer：生产者将消息发送到指定的Topic。
  • Broker：Kafka集群中的节点，负责存储和管理消息。
  • Topic：消息的主题，生产者和消费者通过Topic进行消息的发布和订阅。
  • Partition：Topic被划分为多个分区，每个分区是一个有序的队列。
  • Consumer：消费者从指定的Topic和Partition中消费消息。
  • Consumer Group：消费者组，同一组内的消费者互斥地消费消息。
架构图
Producer
Broker
Topic
Partition 1
Partition 2
Consumer Group 1
Consumer Group 2

2. RabbitMQ 架构图

架构说明

Producer：生产者将消息发送到Exchange。
Exchange：交换机，根据不同的策略将消息路由到一个或多个Queue。
Queue：消息队列，存储待处理的消息。
Binding：绑定，定义了Exchange和Queue之间的关系。
Consumer：消费者从Queue中消费消息。

架构图
Producer
Exchange
Queue 1
Queue 2
Binding
Binding
Consumer 1
Consumer 2

3. RocketMQ 架构图

架构说明

Producer：生产者将消息发送到Name Server。
Name Server：名称服务器，负责路由信息的管理和更新。
Broker：消息服务器，负责存储和管理消息。
Topic：消息的主题，生产者和消费者通过Topic进行消息的发布和订阅。
Consumer：消费者从Broker中消费消息。
Consumer Group：消费者组，同一组内的消费者互斥地消费消息。
Producer
Name Server
Broker
Topic
Partition 1
Partition 2
Consumer Group 1
Consumer Group 2

使用Java的示例

Kafka 示例

1. 添加依赖
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>3.0.0</version>
</dependency>
2. 生产者示例
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;

import java.util.Properties;

public class KafkaProducerExample {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

        KafkaProducer<String, String> producer = new KafkaProducer<>(props);
        for (int i = 0; i < 100; i++) {
            ProducerRecord<String, String> record = new ProducerRecord<>("my-topic", "key-" + i, "value-" + i);
            producer.send(record);
        }
        producer.close();
    }
}
3. 消费者示例
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.KafkaConsumer;

import java.time.Duration;
import java.util.Collections;
import java.util.Properties;

public class KafkaConsumerExample {
    public static void main(String[] args) {
        Properties props = new Properties();
        props.put("bootstrap.servers", "localhost:9092");
        props.put("group.id", "test-group");
        props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
        props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

        KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
        consumer.subscribe(Collections.singletonList("my-topic"));

        while (true) {
            for (ConsumerRecord<String, String> record : consumer.poll(Duration.ofMillis(100))) {
                System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
            }
        }
    }
}

RabbitMQ 示例

1. 添加依赖
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.14.2</version>
</dependency>
2. 生产者示例
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class RabbitMQProducerExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection();
             Channel channel = connection.createChannel()) {
            String queueName = "my-queue";
            channel.queueDeclare(queueName, false, false, false, null);
            for (int i = 0; i < 100; i++) {
                String message = "Message " + i;
                channel.basicPublish("", queueName, null, message.getBytes());
                System.out.println(" [x] Sent '" + message + "'");
            }
        }
    }
}
3. 消费者示例
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DeliverCallback;

public class RabbitMQConsumerExample {
    public static void main(String[] args) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        Connection connection = factory.newConnection();
        Channel channel = connection.createChannel();

        String queueName = "my-queue";
        DeliverCallback deliverCallback = (consumerTag, delivery) -> {
            String message = new String(delivery.getBody(), "UTF-8");
            System.out.println(" [x] Received '" + message + "'");
        };
        channel.basicConsume(queueName, true, deliverCallback, consumerTag -> { });
    }
}

RocketMQ 示例

1. 添加依赖
<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.9.3</version>
</dependency>
2. 生产者示例
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

public class RocketMQProducerExample {
    public static void main(String[] args) throws Exception {
        DefaultMQProducer producer = new DefaultMQProducer("my-producer-group");
        producer.start();
        for (int i = 0; i < 100; i++) {
            Message msg = new Message("my-topic", "TagA", ("Hello RocketMQ " + i).getBytes());
            SendResult sendResult = producer.send(msg);
            System.out.printf("%s%n", sendResult);
        }
        producer.shutdown();
    }
}
3. 消费者示例
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

public class RocketMQConsumerExample {
    public static void main(String[] args) throws Exception {
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("my-consumer-group");
        consumer.subscribe("my-topic", "*");
        consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
            for (MessageExt msg : msgs) {
                System.out.printf("Receive message: %s %n", new String(msg.getBody()));
            }
            return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
        });
        consumer.start();
        System.out.printf("Consumer Started.%n");
    }
}

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

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

相关文章

VScode-Java开发常用插件

VScode-Java开发常用插件

中文——界面易读 字体主题——代码可观 头注释——项目信息明了 java开发包——java必备 git协作开发——版本控制
阅读更多...
jmeter常用配置元件介绍总结之逻辑控制器

jmeter常用配置元件介绍总结之逻辑控制器

系列文章目录 安装jmeter jmeter常用配置元件介绍总结之逻辑控制器 逻辑控制器1.IF控制器2.事务控制器3.循环控制器4.While控制器5.ForEach控制器6.Include控制器7.Runtime控制器8.临界部分控制器9.交替控制器10.仅一次控制器11.简单控制器12.随机控制器13.随机顺序控制器14.吞…
阅读更多...
探索 HTML 和 CSS 实现的蜡烛火焰

探索 HTML 和 CSS 实现的蜡烛火焰

效果演示 这段代码是一个模拟蜡烛火焰的HTML和CSS代码。它创建了一个具有动态效果的蜡烛火焰动画&#xff0c;包括火焰的摆动、伸缩和光晕的闪烁。 HTML <div class"holder"><div class"candle"><div class"blinking-glow"&g…
阅读更多...
机器学习 - 为 Jupyter Notebook 安装新的 Kernel

机器学习 - 为 Jupyter Notebook 安装新的 Kernel

https://ipython.readthedocs.io/en/latest/install/kernel_install.html 当使用jupyter-notebook --no-browser 启动一个 notebook 时&#xff0c;默认使用了该 jupyter module 所在的 Python 环境作为 kernel&#xff0c;比如 C:\devel\Python\Python311。 如果&#xff0c…
阅读更多...
SwiftUI-基础入门

SwiftUI-基础入门

开发OS X 图形应用界面时有三种实现方式&#xff1a;XIB、Storyboard、SwiftUI。Storyboard基于XIB做了优化&#xff0c;但XIB基本被放弃了&#xff0c;而SwiftUI是苹果公司后来开发的一套编程语言&#xff0c;用来平替Objective-C。虽然现在Swift 6 还是有些不完善的地方&…
阅读更多...
androidstudio入门到放弃配置

androidstudio入门到放弃配置

b站视频讲解传送门 android_studio安装包&#xff1a;https://developer.android.google.cn/studio?hlzh-cn 下载安装 开始创建hello-world 1.删除缓存 文件 下载gradle文件压缩&#xff1a;gradle-8.9用自己创建项目时自动生成的版本即可&#xff0c;不用和我一样 https://…
阅读更多...
如何在pycharm中 判断是否成功安装pytorch环境

如何在pycharm中 判断是否成功安装pytorch环境

1、在电脑开始端&#xff0c;找到 2、打开后 在base环境下 输入conda env list 目前我的环境中没有pytorch 学习视频&#xff1a;【Anaconda、Pytorch、Pycharm到底是什么关系?什么是环境?什么是包?】https://www.bilibili.com/video/BV1CN411s7Ue?vd_sourcefad0750b8c6…
阅读更多...
昆明华厦眼科医院举办中外专家眼科技术研讨会

昆明华厦眼科医院举办中外专家眼科技术研讨会

9月13日&#xff0c;“睿智迭代&#xff0c;增效赋能”Menicon Z Night中外专家研讨会在昆明华厦眼科医院成功举办。此次会议由目立康公司与昆明华厦眼科医院携手共筑&#xff0c;标志着双方合作迈向新的高度。 昆明华厦眼科医院总经理王若镜首先发表了热情洋溢的致辞&#xff…
阅读更多...
HarmonyOS ArkUI(基于ArkTS) 开发布局 （上）

HarmonyOS ArkUI(基于ArkTS) 开发布局 （上）

一 ArkUI(基于ArkTS)概述 基于ArkTS的声明式开发范式的方舟开发框架是一套开发极简、高性能、支持跨设备的UI开发框架&#xff0c;提供了构建应用UI所必需的能力 点击详情 特点 开发效率高&#xff0c;开发体验好 代码简洁&#xff1a;通过接近自然语义的方式描述UI&#x…
阅读更多...
【STM32】项目实战——OV7725/OV2604摄像头颜色识别检测（开源）

【STM32】项目实战——OV7725/OV2604摄像头颜色识别检测（开源）

本篇文章分享关于如何使用STM32单片机对彩色摄像头&#xff08;OV7725/OV2604&#xff09;采集的图像数据进行分析处理&#xff0c;最后实现颜色的识别和检测。 目录 一、什么是颜色识别 1、图像采集识别的一些基本概念 1. 像素&#xff08;Pixel&#xff09; 2. 分辨率&am…
阅读更多...
SpringCloud-使用FFmpeg对视频压缩处理

SpringCloud-使用FFmpeg对视频压缩处理

在现代的视频处理系统中&#xff0c;压缩视频以减小存储空间、加快传输速度是一项非常重要的任务。FFmpeg作为一个强大的开源工具&#xff0c;广泛应用于音视频的处理&#xff0c;包括视频的压缩和格式转换等。本文将通过Java代码示例&#xff0c;向您展示如何使用FFmpeg进行视…
阅读更多...
大数据学习14之Scala面向对象--至简原则

大数据学习14之Scala面向对象--至简原则

1.类和对象 1.1基本概念 面向对象&#xff08;Object Oriented&#xff09;是一种编程思想&#xff0c;面向对象主要是把事物给对象化&#xff0c;包括其属性和行为。面向对象编程更贴近实际生活的思想&#xff0c;总体来说面向对象的底层还是面向过程&#xff0c;面向过程抽象…
阅读更多...
pipx安装提示找不到包

pipx安装提示找不到包

执行&#xff1a; pipx install --include-deps --force "ansible6.*"WARNING: Retrying (Retry(total4, connectNone, readNone, redirectNone, statusNone)) after connection broken by NewConnectionError(<pip._vendor.urllib3.connection.HTTPSConnection …
阅读更多...
‘conda‘ 不是内部或外部命令，也不是可运行的程序或批处理文件，Miniconda

‘conda‘ 不是内部或外部命令，也不是可运行的程序或批处理文件，Miniconda

下载了conda&#xff0c;但是在cmd里执行conda --version会显示’conda’ 不是内部或外部命令&#xff0c;也不是可运行的程序或批处理文件。 原因是环境变量里没有添加conda&#xff0c;无法识别路径。 需要在系统环境变量里添加如下路径&#xff1a; 保存之后重新打开cmd&am…
阅读更多...
【Qt】使用QString的toLocal8Bit()导致的问题

【Qt】使用QString的toLocal8Bit()导致的问题

问题 使用Qt发送一个Http post请求的时候&#xff0c;服务一直返回错误和失败信息。同样的url以及post参数&#xff0c;复制黏贴到postman里就可以发送成功。就感觉很神奇。 原因 最后排查出原因是因为参数中含有汉字而导致的编码问题。 在拼接post参数时&#xff0c;使用了…
阅读更多...
设计一致性的关键：掌握 Axure 母版使用技巧

设计一致性的关键：掌握 Axure 母版使用技巧

设计一致性的关键&#xff1a;掌握 Axure 母版使用技巧 前言 在快节奏的产品开发周期中&#xff0c;设计师们一直在寻找能够提升工作效率和保持设计一致性的方法。 Axure RP&#xff0c;作为一款强大的原型设计工具&#xff0c;其母版功能为设计师们提供了一个强大的解决方案…
阅读更多...
鸿蒙next ui安全区域适配（刘海屏、摄像头挖空等）

鸿蒙next ui安全区域适配（刘海屏、摄像头挖空等）

目录 相关api 团结引擎对于鸿蒙的适配已经做了安全区域的适配&#xff0c;也考虑到了刘海屏和摄像机挖孔的情况&#xff0c;在团结引擎内可以直接使用Screen.safeArea 相关api 团结引擎对于鸿蒙的适配已经做了安全区域的适配&#xff0c;也考虑到了刘海屏和摄像机挖孔的情况&am…
阅读更多...
Android OpenGL ES详解——实例化

Android OpenGL ES详解——实例化

目录 一、实例化 1、背景 2、概念 实例化、实例数量 gl_InstanceID 应用举例 二、实例化数组 1、概念 2、应用举例 三、应用举例——小行星带 1、不使用实例化 2、使用实例化 四、总结 一、实例化 1、背景 假如你有一个有许多模型的场景&#xff0c;而这些模型的…
阅读更多...
前端传数组 数据库存Json : [1,2,3]格式

前端传数组 数据库存Json : [1,2,3]格式

一、前端正常传数组&#xff0c;但是value.toString() 即可 const empIds ref([1,2,3]) empIds.value empIds.value.toString() await updateApiRules(empIds.value) // 接口传参 二、后端用String类型接收后转换 String[] empIds updateDO.getEmpId().split("&#x…
阅读更多...
《Java核心技术 卷I》用户图形界面鼠标事件

《Java核心技术 卷I》用户图形界面鼠标事件

鼠标事件 如果只希望用户能够点击按钮或菜单&#xff0c;那么就不需要显式地处理鼠标事件&#xff0c;鼠标操作将由用户界面中的各种组件内部处理&#xff0c;不过&#xff0c;如果希望用户能使用鼠标画图&#xff0c;就需要捕获鼠标移动&#xff0c;点击和拖动事件。 本节&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023