从零到Kafka：万字带你体验Spring Boot整合消息驱动的奇妙之旅

news2024/12/24 10:15:31

Spring Boot与Kafka从零开始整合指南

  • 准备工作
    • 创建项目
  • Spring Boot与Kafka的初次邂逅
    • 配置
    • 生产者
    • 消费者
    • 模拟测试
  • 消息处理
    • 生产者发送消息
    • 消费者处理消息
    • 自定义序列化器

在这里插入图片描述

主页传送门：📀 传送

准备工作

Spring boot:

  • ｜ 基于Spring的开源框架，用于简化新Spring应用的初始搭建以及开发过程
    特性:
    ｜ 快速开发、轻量级、无代码生成和独立运行等特性
    优势:
    ｜ 简化配置，提供自动配置，减少开发时间
    应用场景：
    ｜ 适用于微服务架构、云原生应用等场景

环境搭建

安装jdk:
｜ 安装适合的JDK版本，为Spring Boot和Kafka提供运行环境
安装Maven：
｜ 安装Maven，为Spring Boot项目提供构建工具
安装Zookeeper：
｜ 安装Zookeeper，为Kafka提供协调服务
安装Kafka：
｜ 安装Kafka，为Spring Boot提供消息队列服务
环境变量：
｜ 配置JDK、Maven、Zookeeper和Kafka的环境变量，确保环境变量的正确性

kafka：

｜ 分布式流处理平台，由LinkedIn公司开发并开源
特性：
｜ 高吞吐量、可扩展性、持久性和容错性等特性
优势：
｜ 处理大量实时数据，支持离线处理和实时处理
应用场景：
｜ 大数据实时处理、日志收集、消息系统等

代码实现
创建Spring Boot项目：
｜ 使用Spring Initializr创建Spring Boot项目
添加依赖：
｜ 在项目的pom.xml文件中添加Spring Boot Kafka的依赖
配置Kafka参数：
｜ 在application.properties或application.yml文件中配置Kafka的相关参数
编写生产者代码：
｜ 编写生产者代码，实现数据的发送
编写消费者代码：
｜ 编写消费者代码，实现数据的接收

请添加图片描述

  Kafka不会安装的可以看这篇：kafka安装与启动

Kafka术语：

  Kafka 是一个分布式流处理平台，它使用了一些特定的术语来描述其架构和组件。以下是一些常见的 Kafka 术语：

  1. Broker：Kafka 集群中的每个服务器节点都被称为 Broker。每个 Broker 存储了消息的一部分数据，处理客户端的读写请求。

  2. Topic：消息的类别称为 Topic。在 Topic 中，消息被发布和存储，并且 Kafka 集群中的 Broker 存储了一个或多个 Topic 的数据（用户只需指定消息的 Topic 即可生产或消费数据而不必关心数据存于何处）。

  3. Partition：每个 Topic 被分割成一个或多个分区，每个分区是消息的线性有序序列。Partition 的数量是可配置的，每个消息会被分配到一个特定的分区中。

  4. Offset：Offset 是分区中每条消息的唯一标识符，它表示消息在分区中的位置。消费者可以通过指定 Offset 来读取消息。

  5. Producer：生产者，负责向 Kafka Broker 发布消息到指定的 Topic。

  6. Consumer：消费者，从 Kafka Broker 拉取消息并处理它们的客户端。

  7. Consumer Group：消费者可以组成一个消费者组来消费一个 Topic 中的消息。每个消费者组可以有多个消费者，但每个分区只能由一个消费者组中的一个消费者来消费。

  8. Replication：Kafka 提供了数据的冗余备份机制，允许将分区的副本存储在多个 Broker 上，以提高数据的可靠性和容错性。

  9. Leader 和 Follower：每个分区都有一个 Leader 和零个或多个 Followers。Leader 负责处理读写请求，而 Followers 则同步 Leader 的数据以实现备份和容错。

  10. ZooKeeper：Kafka 使用 ZooKeeper 来进行集群协调和管理，包括选举 Broker 的 Leader、维护 Topic、Partition 的状态等。

创建项目

本文以 idea 2020.3 为例创建项目

  1. 使用Spring Initializr创建一个SpringBoot程序
    在这里插入图片描述
    next
    在这里插入图片描述
    一路next

  2. 添加依赖
    在这里插入图片描述

  配置完成之后点击Finish。

依赖说明：

  • Lombok简化实体类开发。

  • Spring Web 项目集成web开发所有依赖，包括Spring MVC，内置tomcat等。

  • Spring for Apache Kafka 是 Spring和Kafka的集成依赖。

  1. 查看pom依赖
    在这里插入图片描述
    也可以根据自己需要自主添加适配版本的kafka依赖
<!--kafka-->
<dependency>
    <groupId>org.springframework.kafka</groupId>
    <artifactId>spring-kafka</artifactId>
    <version>your version</version>
</dependency>

  爆红是因为是第一次集成Kafka，配置下maven，下载好Kafka的相关依赖后红色就会消失。

  到此就创建好了一个集成了Kafka的SpringBoot Web项目。

Spring Boot与Kafka的初次邂逅

  创建好项目，加好必要的依赖之后就可以开始在配置文件中（application.yml 或application.properties）加kafka配置的变量了。

配置

  在application.properties/application.yml中添加 kafka 配置变量

application.yml：

kafka:
    # kafka ip
    bootstrap-servers: 127.0.0.1:9092
    # -------------- producer  ----------------
    producer:
      retries: 3 #
      acks: 1 #
      batch-size: 16384 #
      buffer-memory: 33554432 #
      key-serializer: org.apache.kafka.common.serialization.StringSerializer
      # value-serializer: com.itheima.demo.config.MySerializer
      value-serializer: org.apache.kafka.common.serialization.StringSerializer

    #---------------- consumer  --------------------
    consumer:
      group-id: javagroup #
      enable-auto-commit: false #
      auto-commit-interval: 100  #

      # earliest:
      # latest:
      # none:topic
      auto-offset-reset: earliest
      #
      max-poll-records: 500
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      #      value-deserializer: com.itheima.demo.config.MyDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

application.properties:

# Kafka集群的地址（集群配多个的时候中间用逗号隔开）
spring.kafka.bootstrap-servers=127.0.0.1:9092
# 发送失败时的重试次数，默认为3次
spring.kafka.producer.retries=3
# 消息确认的方式，1表示只需要leader节点确认即可，其他值表示需要所有副本节点确认。
spring.kafka.producer.acks=1
# 批量发送的消息数量（字节单位）
spring.kafka.producer.batch-size=16384 
# 32MB的批处理缓冲区
spring.kafka.producer.buffer-memory=33554432
# 键的序列化类
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
# 值的序列化类
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
# 默认消费者组(消费者组的ID，同一个消费者组内的消费者会消费相同的主题分区)
spring.kafka.consumer.group-id=crm-user-service
# 最早未被消费的offset
spring.kafka.consumer.auto-offset-reset=earliest
# 批量一次最大拉取数据量
spring.kafka.consumer.max-poll-records=4000
# 是否自动提交
spring.kafka.consumer.enable-auto-commit=true
# 自动提交时间间隔，单位ms
spring.kafka.consumer.auto-commit-interval=1000

生产者

  创建一个KafkaController， 向测试主题发送消息

/**
 * 生产者
 * @author ztt
 * @date 2023/8/5 15:38
 */
@RestController
@RequestMapping("/kafkaMsg")
public class KafkaController {

    @Resource
    private KafkaTemplate<String, String> kafkaTemplate;
	
	//主题
    private final static String TOPIC_NAME = "testTopic";

    @PostMapping("/sendMsg")
    public String sendMsg() {
        kafkaTemplate.send(TOPIC_NAME,"fffff");
        return "send success";
    }
}

消费者

  创建一个TestConsumer ， 接收消息并处理消息


/**
 * 消费者
 * @author ztt
 * @date 2023/8/5 15:41
 */
@Component
@Slf4j
public class TestConsumer {
    @KafkaListener(topics = "testTopic", groupId = "testGroup")
    public void listenGroup(ConsumerRecord<String, String> record) {

		// 参数: 从topic中收到的值
        log.info("接收到发送消息:" + record);
    }
}

模拟测试

@RunWith(SpringRunner.class)
@SpringBootTest
public class TestDemo {

    @Resource
    private KafkaTemplate<String, String> kafkaTemplate;
	
	private final static Integer countNum = 10;

    @Test
    public void testSend(){
        for (int i = 0; i < countNum ; i++) {
            Map<String, Object> map = new LinkedHashMap<>();
            map.put("num", i);
            //向主题推送数据
            kafkaTemplate.send("testTopic", JSONObject.toJSONString(map));
        }
    }
}

消息处理

  在Kafka中，消息的处理通常涉及到两个主要组件：生产者和消费者。生产者负责将消息发送到Kafka主题，而消费者则从主题中读取这些消息并进行逻辑处理。

基本概念
工作原理：
｜ 通过Topic和Partition的方式存储和分发消息
组件:
｜ 由Producer、Broker、Consumer和Zookeeper四个组件组成
应用场景：
｜ 日志收集、实时数据处理、事件驱动

生产者发送信息原理
消息生产：
｜ 生产者将消息发送到指定的Topic
分区策略：
｜ 生产者可以选择随机或者按照特定的key进行分区
异步发送：
｜ 生产者发送消息后，不需要等待Broker的确认就可以继续发送下一条消息
批量发送：
｜ 生产者可以将多条消息打包成一条消息进行发送，以提高吞吐量
消息确认：
｜ 生产者可以通过回调函数或者轮询的方式获取消息是否被成功发送的信息

Broker接收信息原理
消息接收：
｜ Broker接收来自生产者的消息
分区存储：
｜ Broker将接收到的消息存储在对应的Partition中
消息复制：
｜ Broker会将每个Partition的消息复制到其他Broker上，以实现数据的冗余和高可用
消息确认：
｜ Broker向生产者发送确认信息，表示消息已经被成功接收
消息删除：
｜ 当一个Partition的消息被所有的消费者都消费后，Broker会删除这个消息

消费者接收信息原理
订阅Topic：
｜ 消费者需要订阅自己感兴趣的Topic
分区分配：
｜ 消费者会被分配到Topic的一个或多个Partition上
拉取消息：
｜ 消费者从Broker上拉取自己负责的Partition的消息
消息处理：
｜ 消费者处理从Broker拉取到的消息
消息确认：
｜ 消费者向Broker发送确认信息，表示消息已经被成功处理

消费者组原理：
｜ 消费者组是一组共享主题的消费者，他们共同消费主题的数据
作用：
｜ 消费者组可以实现负载均衡和故障转移
配置：
｜ 消费者可以通过配置来选择加入或者退出消费者组
消费模式：
｜ 消费者组支持并发消费和顺序消费两种模式
协调器：
｜ 消费者组需要一个协调器来管理消费者的状态和分配任务

Streams原理：
｜ 用于构建流处理应用的库
处理模型：
｜ 从输入的Topic中读取数据，经过一系列的转换操作，然后写入到输出的Topic中
状态存储：
｜ 将处理过程中的状态存储在Kafka的Topic中，以实现状态的持久化和容错
窗口操作：
｜ 对数据进行窗口操作，如滑动窗口、会话窗口等
集成与扩展：
｜ 可以与其他流处理库（如Flink）进行集成，也可以自定义扩展功能

Connect原理：
｜ 用于连接不同系统和应用的工具
连接器类型：
｜ Kafka Connect提供了多种类型的连接器，如数据库连接器、文件系统连接器等
数据传输格式：
｜ Kafka Connect支持多种数据传输格式，如JSON、Avro等
任务调度：
｜ Kafka Connect使用Apache Storm或者Flink作为任务调度器，来执行连接器的任务
配置管理：
｜ Kafka Connect使用Confluent Control Center进行配置管理和监控

安全原理
认证机制：
｜ Kafka支持基于SASL/PLAINTEXT、SASL/SCRAM-SHA-256等多种认证机制
权限控制：
｜ Kafka通过配置ACL（Access Control List）来实现对Topic和Partition的访问控制
SSL/TLS加密：
｜ Kafka支持通过SSL/TLS协议来加密网络通信，保证数据的安全性
审计日志：
｜ Kafka记录了所有的操作日志，可以用来进行审计和故障排查
防火墙设置：
｜ Kafka服务器可以通过配置防火墙来限制外部访问

请添加图片描述

生产者发送消息

  使用KafkaTemplate或者Producer实例来发送消息到主题

KafkaTemplate是一个方便的高级封装，代码如下：


public class KafkaTemplateDemo {

    private static final String TOPIC = "testTopicA";

    @Resource
    private KafkaTemplate<String, String> kafkaTemplate;

    public void sendMessage(String message) {
        kafkaTemplate.send(TOPIC, message);
        System.out.println("发送消息: " + message);
    }
}

Producer接口是Kafka原生API中用于发送消息的主要接口, 代码如下：

public class KafkaProducerDemo {

    private static final String TOPIC = "testTopicB";

    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

        // 创建 Producer 实例
        try (Producer<String, String> producer = new org.apache.kafka.clients.producer.KafkaProducer<>(props)) {
            // 生产消息
            String message = "Hello, Kafka!";
            producer.send(new ProducerRecord<>(TOPIC, message));
            System.out.println("发送消息: " + message);
        }
    }
}

消费者处理消息

  使用@KafkaListener注解或KafkaConsumer实例来订阅Kafka主题，并在相应的方法中处理接收到的消息。

使用@KafkaListener注解来创建一个消费者并订阅Kafka的主题

public class KafkaListenerDemo{

    @KafkaListener(topics = "testTpoic", groupId = "testGroup")
    public void listen(String message) {
        // 处理收到的消息
        System.out.println("接收消息: " + message);
        // 逻辑处理接收到的消息
        // 。。。省略逻辑处理接收到的信息
    }
}

使用KafkaConsumer类手动创建一个Kafka消费者

public class SimpleKafkaConsumerDemo {

    public static void main(String[] args) {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "127.0.0.1");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "testGroup");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");

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

        try {
            while (true) {
                ConsumerRecords<String, String> records = consumer.poll(100);
                records.forEach(record -> {
                    System.out.println("接收消息: " + record.value());
                    // 逻辑来处理接收到的消息
                });
            }
        } finally {
            consumer.close();
        }
    }
}

自定义序列化器

  在Kafka 中，可以自定义消息的序列化和反序列化过程，以便按照需求对消息进行定制化处理。一般来说，Kafka 使用的默认序列化器是基于字节数组的序列化和反序列化。但有时候为了处理更复杂的消息格式需要自定义序列化器来处理。

  在Kafka中，如果需要使用自定义的序列化器，可以实现org.apache.kafka.common.serialization.Serializer接口。

示例： 假设处理自定义的对象Person：

创建一个Person类：

@Getter
@Setter
public class Person implements Serializable {
    private String name;
    private int age;
    @Override
    public String toString() {
        return "Person{name='" + name + "', age=" + age + '}';
    }
}

然后，实现Serializer接口及对应的configure和serialize方法：

public class PersonSerializer implements Serializer<Person> {

    @Override
    public void configure(Map<String, ?> configs, boolean isKey) {
        // 用于获取配置信息。
    }

    @Override
    public byte[] serialize(String topic, Person data) {
        if (data == null) {
            return null;
        }

        try (ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
             ObjectOutputStream objectOutputStream = new ObjectOutputStream(byteArrayOutputStream)) {
            objectOutputStream.writeObject(data);
            return byteArrayOutputStream.toByteArray();
        } catch (IOException e) {
            throw new RuntimeException("实例化人出错", e);
        }
    }

    @Override
    public void close() {
        // 执行资源释放等操作。
    }
}

实现 Deserializer 接口

public class PersonDeserializer implements Deserializer<CustomObject> {

    @Override
    public CustomObject deserialize(String topic, byte[] data) {
        // 在这里实现将字节数组反序列化为 CustomObject 对象的逻辑
        // 返回反序列化后的 CustomObject 对象
        return /* 实现反序列化逻辑 */;
    }

    @Override
    public void close() {
        // 关闭资源的逻辑
    }
}

生产者端配置：

Properties props = new Properties();
props.put("bootstrap.servers", "127.0.0.1");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "com.test.util.PersonSerializer"); // 指定自定义序列化器类的完整路径
Producer<String, Person> producer = new KafkaProducer<>(props);

消费者端配置：

Properties props = new Properties();
props.put("bootstrap.servers", "127.0.0.1");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "com.test.util.PersonDeserializer"); // 指定自定义反序列化器类的完整路径
props.put("group.id", "testGroup");

Consumer<String, Person> consumer = new KafkaConsumer<>(props);

在这里插入图片描述

  如果喜欢的话，欢迎 🤞关注 👍点赞 💬评论 🤝收藏  🙌一起讨论
  你的支持就是我✍️创作的动力！					  💞💞💞

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

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

相关文章

scipy 笔记：scipy.spatial.distance

scipy 笔记：scipy.spatial.distance

1 pdist 计算n维空间中观测点之间的成对距离。 scipy.spatial.distance.pdist(X, metriceuclidean, *, outNone, **kwargs) 1.1 主要参数 X一个m行n列的数组&#xff0c;表示n维空间中的m个原始观测点metric使用的距离度量out输出数组。如果非空&#xff0c;压缩的距离矩阵…
阅读更多...
每日一题：LeetCode-103/107.二叉树的(层序/锯齿形层序)遍历

每日一题：LeetCode-103/107.二叉树的(层序/锯齿形层序)遍历

每日一题系列&#xff08;day 04&#xff09; 前言&#xff1a; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f308; &#x1f50e…
阅读更多...
interface previously declared 的bug问题

interface previously declared 的bug问题

其实就是重复定义了&#xff0c;只需要加如下的代码即可&#xff1a; 其中把APB的部分改成自己的接口名字就好了。
阅读更多...
『亚马逊云科技产品测评』活动征文｜EC2 实例安装 docker 与配套软件部署前后端分离的医疗管理后台系统

『亚马逊云科技产品测评』活动征文｜EC2 实例安装 docker 与配套软件部署前后端分离的医疗管理后台系统

授权声明&#xff1a;本篇文章授权活动官方亚马逊云科技文章转发、改写权&#xff0c;包括不限于在 Developer Centre, 知乎&#xff0c;自媒体平台&#xff0c;第三方开发者媒体等亚马逊云科技官方渠道 目录 一、AWS 产品类别选择 &#xff08;1&#xff09;应用服务器选择…
阅读更多...
【接口技术】实验1：简易汇编程序调试

【接口技术】实验1：简易汇编程序调试

实验1 简易汇编程序调试 一、实验目的 1&#xff1a;掌握在集成开发软件环境中汇编程序的编写、调试方法。 2&#xff1a;学会用DOS功能调用&#xff08;1号和2号&#xff09;完成输入和输出。 二、实验内容 1-1&#xff1a; 在以BUF为首地址的字节存储区存放有若干个无符…
阅读更多...
02 RANSAC算法 及 Python 实现

02 RANSAC算法 及 Python 实现

文章目录 02 RANSAC算法 及 Python 实现2.1 简介2.2 算法流程2.3 RANSAC 算法实现直线拟合2.4 利用 RANSAC 算法减少 ORB 特征点误匹配 02 RANSAC算法 及 Python 实现 2.1 简介 RANSAC &#xff08;Random Sample Consensus&#xff0c;随机抽样一致&#xff09;算法的 基本假…
阅读更多...
网络通信基础概念介绍

网络通信基础概念介绍

网络通信基础概念介绍 局域网LAN 局域网&#xff0c;即 Local Area Network&#xff0c;简称LAN。 局域网内的主机之间能方便的进行网络通信&#xff0c;又称为内网&#xff1b;局域网和局域网之间在没有连接的情况下&#xff0c;是无法通信的。 局域网是指在一个相对较小的…
阅读更多...
Android设计模式--外观模式

Android设计模式--外观模式

弈之为术&#xff0c;在人自悟 一&#xff0c;定义 外观模式要求一个子系统的外部与其内部的通信必须通过一个统一的对象进行。提供一个高层次的接口&#xff0c;使得子系统更易于使用。 外观模式在开发中的使用频率是非常高的&#xff0c;尤其是在第三方的SDK里面&#xff0…
阅读更多...
redis运维(二十)redis 的扩展应用 lua(二)

redis运维(二十)redis 的扩展应用 lua(二)

一 redis 的扩展应用 lua redis lua脚本语法 ① 什么是脚本缓存 redis 缓存lua脚本 说明&#xff1a; 重启redis,脚本缓存会丢失 下面讲解 SCRIPT ... 系列 SCRIPT ② LOAD 语法&#xff1a;SCRIPT LOAD lua代码 -->载入一个脚本,只是预加载,不执行思考1&#xff1…
阅读更多...
leetcode中“辅助栈”类题目和“单调栈”类题目的异同

leetcode中“辅助栈”类题目和“单调栈”类题目的异同

1 总结 1 栈中元素的特性 2 单调栈存在一次性连续删除多个栈顶的情况&#xff0c;但是普通的栈&#xff0c;一次只pop掉一个栈顶元素 2 LC1209. 删除字符串中的所有相邻重复项 II - 普通辅助栈 class Solution {public String removeDuplicates(String s, int k) {int ns.l…
阅读更多...
OSG粒子系统与阴影-爆炸模拟（3）

OSG粒子系统与阴影-爆炸模拟（3）

爆炸模拟示例 爆炸模拟示例的代码如程序清单11-4 所示&#xff1a; /* 爆炸模拟示例 */ void explosion_11_4() {osg::ref_ptr<osgViewer::Viewer> viewer new osgViewer::Viewer();osg::ref_ptr<osg::GraphicsContext::Traits> traits new osg::GraphicsContex…
阅读更多...
Linux：Ubuntu虚拟机安装详解：VMware下的逐步指南

Linux：Ubuntu虚拟机安装详解：VMware下的逐步指南

目录 1. centOS系统 2. ubuntu系统 1. 下载Ubuntu映像 step1 step2 step3 2. 新建虚拟机 step1 step2 Step3 step4 step5 step6 内存 内核 映像 显示 网络 3. 网络配置 NAT模式 本机IP获取 ​编辑 bridge模式 4. 开启虚拟机 5. 虚拟机常用配置 语言 …
阅读更多...
Servlet简单原理图

Servlet简单原理图

阅读更多...
物联网后端个人第十二周总结

物联网后端个人第十二周总结

学习工作进度 物联网方面 1.模拟设备通过规则引擎将数据通过mqtt进行转发 在物联网平台上实现模拟设备通过规则引擎将数据通过mqtt进行转发已经全部完成了&#xff0c;所使用的物联网平台在这方面有不少的问题和bug&#xff0c;也可能是没有按照开发者的想法对平台进行使用才导…
阅读更多...
文章解读与仿真程序复现思路——电网技术EI\CSCD\北大核心《考虑系统一次频率响应特性的新型电力系统源网荷储协调鲁棒规划》

文章解读与仿真程序复现思路——电网技术EI\CSCD\北大核心《考虑系统一次频率响应特性的新型电力系统源网荷储协调鲁棒规划》

这篇文章的标题涉及到新型电力系统的源&#xff08;发电源&#xff09;、网&#xff08;电网&#xff09;、荷&#xff08;负荷&#xff0c;即用电需求&#xff09;以及储&#xff08;储能系统&#xff09;的协调鲁棒规划&#xff0c;其中考虑了系统的一次频率响应特性。 让我…
阅读更多...
软件设计师：计算机组成与体系结构之计算机基础知识

软件设计师：计算机组成与体系结构之计算机基础知识

计算机基础知识 数据的表示 码制及进制转换 原码&#xff1a;将数值转成二进制反码&#xff1a;正数与原码完全相同&#xff1b;负数&#xff0c;除了符号位其他位取反补码&#xff1a;正数与原码完全相同&#xff1b;负数&#xff0c;在补码的基础上加1移码&#xff1a;补码…
阅读更多...
CUDA编程二、C++和cuda混合编程的一些基础知识点

CUDA编程二、C++和cuda混合编程的一些基础知识点

目录 一、C运行过程 1、C编译过程 2、代码运行示例 单文件 多文件 a、编译所有cpp文件&#xff0c;但是不链接 b、链接所有的.o文件 c、运行程序 CMake编译 代码 使用方法 编译过程 代码运行 二、C和cuda混合编程 cuda 单文件 cuda和C多文件 手动分步编译 C…
阅读更多...
TDA笔记：夏克林老师，南洋理工大学

TDA笔记：夏克林老师，南洋理工大学

TDA比传统的统计方法有优势&#xff1a;benchmark中展现了这种优势 laplacian矩阵 多种单纯复形构造方式&#xff0c;可以构造出不同表征 二部图&#xff1a;Dowker complex Tor algebra可以用到多大数据 目前较新
阅读更多...
python教程：正常shell与反弹shell

python教程：正常shell与反弹shell

嗨喽&#xff0c;大家好呀~这里是爱看美女的茜茜呐 正常shell需要先在攻击端开机情况下开启程序,然后攻击端运行程序,才能连接 反弹shell,攻击端是服务端,被攻击端是客户端 正常shell,攻击端是客户端,被攻击端是服务端 反弹shell,先启用服务端,再启用客户端 反弹shell的好处…
阅读更多...
OPPO VOOC快充原理

OPPO VOOC快充原理

1 USB 3.0标准A插头 USB 3.0连接器是基于USB 2.0改进而来的&#xff0c;这个设计给USB 3.0连接器带来了一些潜在风险&#xff0c;如果USB 3.0设备插入主机的速度太慢&#xff0c;3.0的针脚还没来得及被识别到&#xff0c;就会被主机判定成USB 2.0的设备。 Figure 1-1 USB 3.0标…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023