RocketMQ入门5.3.2版本（基于java、SpringBoot操作）

一、RocketMQ概述

RocketMQ是一款由阿里巴巴于2012年开源的分布式消息中间件，旨在提供高吞吐量、高可靠性的消息传递服务。主要特点有：

  • 灵活的可扩展性

  • 海量消息堆积能力

  • 支持顺序消息

  • 支持多种消息过滤方式

  • 支持事务消息

  • 支持回溯消费

  • 支持延时消息

RocketMQ的基本概念

Producer（生产者）：

负责生产消息，一般由业务系统负责。一个消息生产者会把业务应用系统里产生的消息发送到Broker服务器RocketMQ提供了3种方式发送消息：同步、异步和单向

同步发送（Sync Send）：

同步发送是指消息发送方在发送一条消息后，在收到服务器返回的响应结果后才发送下一条消息。如果消息成功发送到Broker，则返回发送成功的结果；如果发送失败（如Broker宕机），则抛出异常。

适用于重要通知消息场景：重要通知邮件、金融交易和订单处理等

异步发送（Async Send）：

异步发送是指消息发送方在发送一条消息后，不需要等待服务器响应即可继续发送消息。但需要Broker返回确认信息。

单向发送（One-way Send）：

单向发送是指消息发送方发送一条消息后，不会等待服务器响应，也不需要Broker返回确认信息。这种方式发送消息的过程耗时非常短，常用于对可靠性要求不是很高，但对实时性要求较高的场景。

生产者组（Producer Group）

RocketMQ中一组生产者实例的集合，这些生产者实例可以共同工作以发送消息到同一个或多个主题（Topic）。

Consumer（消费者）：

消息消费的角色，支持分布式集群方式部署。消费者有两种类型：拉取型和推送型支持集群方式和广播方式的消费。

拉取型消费（Pull Consumer）：

在Pull模式下，消费者主动从消息中间件拉取消息。这种模式给了消费者更多的控制权，它们可以根据自己的处理能力和当前状态来决定何时拉取消息、拉取多少消息。

推动型消费（Push Consumer）：

在Push模式下，消息中间件主动将消息推送到消费者（Consumer）端。一旦有消息到达，中间件会立即尝试将消息传递给消费者，而不需要消费者主动请求。

Push消费模式下，消费者首先需要注册一个消费监听器（MessageListener）。当Broker（消息服务器）有消息到达并准备好推送给消费者时，会触发这个监听器，进而开始消费消息。这种机制使得消费者无需主动向Broker请求消息，而是等待Broker将消息推送过来，从而提高了消息消费的实时性和便捷性

消费者组（Consumer Group）

是一个承载多个消费行为一致的消费者的逻辑资源分组，它并不是运行实体，而是一个用于管理和组织消费者的逻辑概念。

消息服务器（Broker）：

Broker是RocketMQ中负责存储消息的核心组件。它接收生产者（Producer）发送的消息，并将其持久化到本地磁盘或分布式存储系统中，确保消息的安全性和可靠性。除了存储消息外，Broker还负责将消息转发给消费者（Consumer）。当消费者发起消息拉取请求时，Broker会根据请求中的信息（如Topic、Queue等）查找并返回相应的消息给消费者。

Master：

Master节点是RocketMQ中的主节点，负责接收客户端（生产者）的写入请求，并将消息持久化到磁盘上。它是消息处理的核心，承担着主要的消息存储和转发任务。

Slave：

Slave节点是RocketMQ中的从节点，它负责从Master节点复制消息数据，并保持与Master节点的同步。Slave节点不直接处理客户端的写入请求，但可以在Master节点故障时接替其工作，提供消息的读取服务。

Broker的集群部署有单Master、多Master、多Master多Slave（同步双写）、多Master多Slave（异步复制）

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

NameServer（名称服务器）：

充当路由消息的提供者，生产者或消费者能够通过名字服务查找各主题相应的Broker IP列表。

NameServer是一个几乎无状态的节点，可集群部署，节点之间无任何信息同步。

无状态

NameServer 几乎不存储任何持久化数据。它主要维护的是Broker的元数据信息，如Broker的地址、主题信息等，但这些信息是可以从Broker动态获取的，因此NameServer本身不需要进行复杂的数据同步或持久化操作。

集群部署：

NameServer支持集群部署，即可以部署多个NameServer实例来提供更高的可用性和容错性。

在集群模式下，生产者和消费者可以随机选择一个或多个NameServer进行查询，这样可以分散查询负载，提高系统整体的性能和可靠性

节点间无信息同步：

NameServer集群中的各个节点之间是相互独立的，它们之间不会进行任何信息的同步或通信。

每个NameServer都独立地从Broker获取最新的元数据信息，并维护自己的数据副本。这种设计简化了NameServer集群的管理和部署，同时也避免了因节点间同步导致的延迟和复杂性。

路由信息提供：

生产者（Producer）和消费者（Consumer）在发送或接收消息前，会先向NameServer查询目标主题（Topic）对应的Broker列表。NameServer会返回包含Broker地址的列表，生产者和消费者随后可以根据这个列表选择具体的Broker进行消息的发送或接收。

Broker注册与发现：

当Broker启动时，它会向NameServer注册自己的信息，包括地址、端口、主题列表等。NameServer会接收这些信息并更新自己的元数据，使得生产者和消费者能够发现新的Broker或Broker的变更

Topic

Topic是生产者在发送消息和消费者在拉取消息时的基本类别。它表示一类消息的集合，每个Topic都包含若干条消息，每条消息只能属于一个Topic。Topic与生产者和消费者之间的关系非常松散，一个Topic可能有0个、一个或多个生产者向其发送消息，同样，一个消费者组可以订阅一个或多个Topic，只要该组的实例保持其订阅一致即可。

Topic的主要作用包括：

  1. 消息分类：通过Topic将不同类型的消息进行区分，便于管理和消费。
  2. 消息路由：生产者发送消息时，会根据Topic将消息路由到相应的Broker上。
  3. 负载均衡：在消费者组中，通过Topic实现消息的负载均衡，使得消息能够均匀地被多个消费者处理。

Tag

Tag是消息的二级分类，可以看作是Topic下的子主题。它为用户提供了额外的灵活性，使得来自同一业务模块的具有不同目的的消息可以具有相同的Topic和不同的Tag。Tag有助于保持代码的清晰和连贯，同时方便RocketMQ提供的查询功能。

Tag的主要作用包括：

  1. 消息细分：在同一Topic下，通过Tag对消息进行进一步细分，使得消费者可以根据需要接收特定类型的消息。
  2. 消费过滤：消费者可以指定Tag来接收特定类型的消息，或者使用通配符（如*）来接收该Topic下的所有消息。提高消息处理效率：通过合理使用Tag，可以减少消费者处理不必要消息的开销，提高消息处理的效率。

Topic与Tag的关系

层级关系：Topic是消息的一级分类，而Tag是消息的二级分类。它们共同构成了消息系统的分类体系。

互补关系：Topic和Tag在消息分类上起到互补作用。Topic用于区分不同类型的消息，而Tag则用于在同一Topic下进一步区分不同目的的消息。

在这里插入图片描述

队列：

RocketMQ的队列是消息存储和传输的实际容器，也是RocketMQ消息的最小存储单元。

在这里插入图片描述

集群消费模式

同一个消费者组（Consumer Group）中的多个消费者实例会共同分担同一个主题（Topic）下的消息。RocketMQ会将消息分发给不同的消费者实例，但保证同一条消息只会被该消费者组中的一个消费者消费。

在这里插入图片描述

特点：

  1. 负载均衡：自动实现消息的负载均衡，提高消息处理效率和吞吐量。
  2. 容错性：如果一个消费者实例出现故障，其他实例可以继续处理消息，保证消息不会丢失。
  3. 消费进度管理：消费进度（即已消费消息的偏移量）会被存储在Broker端，以便在消费者重启后能够从上次消费的位置继续处理消息。

广播消费

同一个消费者组中的每个消费者实例都会收到订阅主题下的每一条消息的一个副本。即每条消息都会被发送到该消费者组中的所有消费者实例上，且每个消费者实例都会独立地消费这条消息。

在这里插入图片描述

特点

  1. 消息广播：每条消息都会被发送到所有消费者实例，确保消息被每个消费者都接收到。
  2. 无消费进度管理：在广播模式下，消费进度不需要被存储和共享，因为每个消费者实例都会消费到完整的消息集合。
  3. 无重试机制：如果消费者消费消息失败，RocketMQ在广播模式下不会自动重试，需要业务方自行处理。

并发消费

特点：

并发消费是指多个消费者实例同时处理消息，每个实例独立地处理一部分消息。

多个消费者实例可以并发地处理来自同一个主题和标签的消息，提高了消息处理的并发度。

顺序消费

RocketMQ 保证在同一个消息队列（Message Queue）中的消息按照发送的顺序被消费。

特点：

顺序消费是指消息按照一定的顺序进行处理，同一个消息队列上的消息按照发送顺序和消费顺序进行处理。顺序消费通常需要保证同一消息队列上只有一个消费者实例处理消息，以确保消息的顺序性。

二、RocketMQ应用

2.1 RocketMQ安装和配置

下载地址https://rocketmq.apache.org/download

在这里插入图片描述

解压

在这里插入图片描述

配置环境变量

在这里插入图片描述

启动nameservver服务

进入安装目录下的bin目录下，执行如下命令

start mqnamesrv.cmd

启动成功效果

启动broker服务

在bin目录下，执行如下命令

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

2.2 java访问Rocketmq工程

配置依赖

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>5.3.2</version>
</dependency>

创建消息生产者

public class Producer {public static void main(String[] args) throws Exception {// 创建一个消息生产者，并设置一个消息生产者组DefaultMQProducer producer = new DefaultMQProducer("producer_group");// 消息发送失败重试次数producer.setRetryTimesWhenSendFailed(3);// 消息没有存储成功是否发送到另外一个brokerproducer.setRetryAnotherBrokerWhenNotStoreOK(true);// 指定 NameServer 地址producer.setNamesrvAddr("localhost:9876");// 初始化 Producer，整个应用生命周期内只需要初始化一次producer.start();// 以下代码是示例，用于发送一条消息try {for (int i = 0; i < 100; i++) {// 创建消息实例，指定主题、标签和消息体Message msg = new Message("TopicTest",// topic"TagA",//  tag("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));//  设置消息持久化msg.setWaitStoreMsgOK(true);// 发送消息SendResult sendResult = producer.send(msg);System.out.printf("%s%n", sendResult);}} catch (Exception e) {e.printStackTrace();} finally {// 关闭生产者producer.shutdown();}}
}

创建消息消费者

public class Consumer {public static void main(String[] args) throws Exception {// 创建一个消息消费者，并设置一个消息消费者组DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer_group");// 指定 NameServer 地址consumer.setNamesrvAddr("localhost:9876");// 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);// 订阅指定 Topic 下的所有消息consumer.subscribe("TopicTest", "*");consumer.setMessageModel(MessageModel.BROADCASTING); // 广播消费// 注册消息监听器consumer.registerMessageListener((List<MessageExt> list, ConsumeConcurrentlyContext context) -> {// 默认 list 里只有一条消息，可以通过设置参数来批量接收消息System.out.println("Receive New Messages: " + list.size());if (list != null) {for (MessageExt ext : list) {try {System.out.println(new Date() + " " + new String(ext.getBody(), "UTF-8"));} catch (UnsupportedEncodingException e) {e.printStackTrace();}}}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;});// 消费者对象在使用之前必须要调用 start 初始化consumer.start();System.out.println("消息消费者已启动");}
}

consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET);

  1. CONSUME_FROM_FIRST_OFFSET：初次从消息队列头部开始消费，即历史消息(还存在broker的)，全部消费一遍，后续再启动接着上次消费的进度开始消费
  2. CONSUME_FROM_LAST_OFFSET：默认策略，初次从该队列最尾开始消费，即跳过历史消息，后续再启动接着上次消费的进度开始消费
  3. CONSUME_FROM_TIMESTAMP：从某个时间点开始消费，默认是半个小时以前，后续再启动着上次消费的进度开始消费

2.3 Spring Boot集成Rocketmq

第一步，引入依赖，完整pom如下

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.4.1</version><relativePath/> <!-- lookup parent in repository --></parent><artifactId>spring_boot_rocketmq_demo</artifactId><packaging>jar</packaging><name>spring_boot_rocketmq_demo Maven Webapp</name><dependencies><!-- Spring Boot Starter --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><!-- RocketMQ Spring Boot Starter --><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.3.2</version></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
</project>

第二步，在resources下编写application.yml

rocketmq:producer:group: my-groupname-server: localhost:9876

第三步，编写生产者

@Service
public class MessageProducer {@Autowiredprivate RocketMQTemplate rocketMQTemplate;public void sendMessage(String topic, String message) {rocketMQTemplate.convertAndSend(topic, message);}@PostConstructpublic void init() {sendMessage("my-topic", "Hello, RocketMQ!");}
}

第四步，编写消费者

@Service
@RocketMQMessageListener(topic = "my-topic", consumerGroup = "my-group" )
public class MessageConsumer implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {System.out.println("接收到消息: " + message);}
}

第五步，编写启动类

@SpringBootApplication
public class RocketMQApplication {public static void main(String[] args) {SpringApplication.run(RocketMQApplication.class, args);}
}

2.4 Rocketmq的顺序消息消费

顺序消费者配置

顺序消息消费者：RocketMQ提供了顺序消息消费者（Orderly Message Consumer），通过指定消费模式为Orderly，可以确保消息按照发送的顺序进行消费。

消费者配置：在消费者端，需要配置为顺序消费者，并确保每个队列只由一个消费者线程消费。这通常是通过设置消费者组的实例数量与Topic的消息队列数量相等来实现的，即每个消费者实例对应一个消息队列。

消息消费控制

单线程消费：在顺序消费者模式下，RocketMQ会保证同一个队列中的消息按照发送的顺序被同一个消费者线程顺序消费。这意味着在消费过程中，前一个消息被完全处理之前，后一个消息不会被消费。

消费状态管理：RocketMQ通过维护消费进度（Consume Offset）来跟踪每个队列的消费情况，确保消息按顺序被消费且不会丢失。

使用spring boot开发顺序消息

第一步，建立生产者，使用syncSendOrderly发送顺序消息

@Service
public class MessageProducer_order {@Autowiredprivate RocketMQTemplate rocketMQTemplate;public void sendMessage(String topic, String message) {rocketMQTemplate.syncSendOrderly(topic, message, "order-key");}@PostConstructpublic void init() {for (int i = 0; i < 100; i++) {sendMessage("my-topic-order", "Hello, RocketMQ-order!" + i);}}
}

第二步，建立消费者，设置consumeMode = ConsumeMode.ORDERLY顺序消费

@Service
@RocketMQMessageListener(topic = "my-topic-order",consumerGroup = "my-group-order",consumeMode = ConsumeMode.ORDERLY
)
public class MessageConsumer_order implements RocketMQListener<String> {@Overridepublic void onMessage(String message) {System.out.println("接收到消息: " + message);}
}

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

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

相关文章

VR线上展厅特点分析与优势

VR线上展厅特点分析与优势

VR线上展厅&#xff1a;特点、优势与实际应用 VR线上展厅&#xff0c;作为虚拟现实&#xff08;VR&#xff09;技术在展示行业的创新应用&#xff0c;正逐步改变着传统的展览方式。通过模拟真实的物理环境&#xff0c;为参观者提供身临其境的展览体验&#xff0c;成为展示行业…
阅读更多...
QT 5.9.2+VTK8.0实现等高线绘制

QT 5.9.2+VTK8.0实现等高线绘制

项目下载链接&#xff1a;QT5.9.2VTK8.0实现等高线绘制资源-CSDN文库 示例如下&#xff1a; 主要代码如下&#xff1a; #include "vtkRenderer.h" #include "vtkRenderWindow.h" #include "vtkRenderWindowInteractor.h" #include "vtkPo…
阅读更多...
MySQL：忘记root密码

MySQL：忘记root密码

修改配置文件&#xff1a; vi /etc/my.cnf## 修改配置文件 ##[mysqld] skip - grant - tables## 重启 ##/etc/init.d/mysqld restart ## 或service mysqld restart## 登录mysqld -u root -p -h 127.0.0.1USE mysql; UPDATE user SET Password password(123456) WHERE User r…
阅读更多...
JSP、HTML和Tomcat

JSP、HTML和Tomcat

9x9上三角乘法表 乘法表的实现 <% page contentType"text/html;charsetUTF-8" language"java" %> <!DOCTYPE html> <html> <head><title>99 上三角乘法表</title><style>body {font-family: monospace;padding…
阅读更多...
常用枚举技巧：基础（一）

常用枚举技巧：基础（一）

文章目录 常用枚举技巧&#xff1a;基础&#xff08;一&#xff09;LeetCode 1. 两数之和思路Golang 代码 LeetCode 2441. 与对应负数同时存在的最大正整数思路Golang 代码 LeetCode 1512. 好数对的数目思路Golang 代码 LeetCode 2001. 可互换矩形的对数思路Golang 代码 LeetCo…
阅读更多...
从混乱到秩序：探索管理系统如何彻底改变工作流程

从混乱到秩序：探索管理系统如何彻底改变工作流程

内容摘要 在许多企业与组织中&#xff0c;工作流程混乱是阻碍发展的“绊脚石”。员工们常常被繁琐的步骤、模糊的职责和沟通不畅等问题搞得焦头烂额&#xff0c;工作效率低下&#xff0c;错误频发。而与之形成鲜明对比的是&#xff0c;一些引入了先进管理系统的团队&#xff0…
阅读更多...
使用SSE解决获取状态不一致问题

使用SSE解决获取状态不一致问题

使用SSE解决获取状态不一致问题 1. 问题描述2. SSE介绍2.1 SSE 的工作原理2.2 SSE 的事件格式规范2.3 SSE与其他技术对比2.4 SSE 的优缺点 3. 实战代码 1. 问题描述 目前做的一个功能是上传多个文件&#xff0c;这个上传文件是整体功能的一部分&#xff0c;文件在上传的过程中…
阅读更多...
华为×小鹏战略合作：破局智能驾驶深水区的商业逻辑深度解析

华为×小鹏战略合作：破局智能驾驶深水区的商业逻辑深度解析

当中国智能电动车竞争进入下半场&#xff0c;头部玩家的合纵连横正在重构产业格局。华为与小鹏汽车近日官宣的“战略合作”&#xff0c;表面看是技术互补的常规操作&#xff0c;实则暗藏改写行业游戏规则的深层商业逻辑。 一、技术破壁&#xff1a;从“单点突破”到“全栈协同”…
阅读更多...
Tailwind CSS 实战：基于 Kooboo 构建 AI 对话框页面（六）：图片上传交互功能

Tailwind CSS 实战：基于 Kooboo 构建 AI 对话框页面（六）：图片上传交互功能

在 《Tailwind CSS 实战&#xff1a;基于 Kooboo 构建 AI 对话框页面&#xff08;五&#xff09;》 中&#xff0c;完成了语音交互功能的优化。本文作为该系列教程的第六篇&#xff0c;将聚焦于图片上传功能的开发。通过集成图片上传与预览能力&#xff0c;我们将进一步完善 AI…
阅读更多...
40. 自动化异步测试开发之编写异步业务函数、测试函数和测试类（类写法）

40. 自动化异步测试开发之编写异步业务函数、测试函数和测试类（类写法）

40. 自动化异步测试开发之编写异步业务函数、测试函数和测试类&#xff08;类写法&#xff09; 一、类结构设计解析 1.1 基类设计 class Base:async_driver None # &#x1f697; 存储浏览器驱动实例async def get(self, url: str http://secure.smartbearsoftware.com/.…
阅读更多...
面向开发者的提示词工程④——文本推断（Inferring）

面向开发者的提示词工程④——文本推断（Inferring）

文章目录 前言一、情感&#xff08;正向/负向&#xff09;二、识别情感类型三、识别愤怒四、从客户评论中提取产品和公司名称五、一次完成多项任务 前言 面向开发者的提示词工程——导读 在这节课中&#xff0c;你将从产品评论和新闻文章中推断情感和主题。 举了个商品评论的例…
阅读更多...
java day15 （数据库）

java day15 （数据库）

进入数据库的学习 DB 因为数据太多了&#xff0c;方便统一管理的软件 操作就不用改代码了&#xff0c;直接改数据库则可&#xff1b; 命令就是sql语句 这些都是关系型数据库&#xff0c;sql可以控制全部&#xff0c;至于具体的环境我以前就有安装过了&#xff1b; 理解&am…
阅读更多...
国标GB28181设备管理软件EasyGBS远程视频监控方案助力高效安全运营

国标GB28181设备管理软件EasyGBS远程视频监控方案助力高效安全运营

一、方案背景​ 在商业快速扩张的背景下&#xff0c;连锁店门店数量激增&#xff0c;分布范围广。但传统人工巡检、电话汇报等管理方式效率低下&#xff0c;存在信息滞后、管理盲区&#xff0c;难以掌握店铺运营情况&#xff0c;影响企业效率与安全。网络远程视频监控系统可有…
阅读更多...
Python 字典（dict）的高级用法与技巧

Python 字典（dict）的高级用法与技巧

今天我们继续深入讲解 Python 字典的 高级用法与技巧&#xff0c;包括&#xff1a; defaultdict&#xff1a;带默认值的字典Counter&#xff1a;快速统计工具字典排序&#xff1a;按键或值排序合并字典&#xff08;传统方式和 Python 3.9 新语法&#xff09;嵌套字典的安全访问…
阅读更多...
动静态库的使用（Linux）

动静态库的使用（Linux）

1.库 通俗来说&#xff0c;库就是现有的&#xff0c;可复用的代码&#xff0c;例如&#xff1a;在C/C语言编译时&#xff0c;就需要依赖相关的C/C标准库。本质上来说库是一种可执行代码的二进制形式&#xff0c;可以被操作系统载入内存执行。通常我们可以在windows下看到一些后…
阅读更多...
R²ec: 构建具有推理能力的大型推荐模型，显著提示推荐系统性能！！

R²ec: 构建具有推理能力的大型推荐模型，显著提示推荐系统性能！！

摘要&#xff1a;大型推荐模型通过编码或项目生成将大型语言模型&#xff08;LLMs&#xff09;扩展为强大的推荐工具&#xff0c;而近期在LLM推理方面的突破也同步激发了在推荐领域探索推理的动机。目前的研究通常将LLMs定位为外部推理模块&#xff0c;以提供辅助性思考来增强传…
阅读更多...
【Java后端基础 005】ThreadLocal-线程数据共享和安全

【Java后端基础 005】ThreadLocal-线程数据共享和安全

&#x1f4da;博客主页&#xff1a;代码探秘者 ✨专栏&#xff1a;文章正在持续更新ing… ✅C语言/C&#xff1a;C&#xff08;详细版&#xff09; 数据结构&#xff09; 十大排序算法 ✅Java基础&#xff1a;JavaSE基础 面向对象大合集 JavaSE进阶 Java版数据结构JDK新特性…
阅读更多...
Tesseract配置参数详解及适用场景（PyTesseract进行OCR）

Tesseract配置参数详解及适用场景（PyTesseract进行OCR）

在使用 PyTesseract 进行 OCR 时&#xff0c;合理配置参数是提高识别准确率的关键。以下是 Tesseract 常用参数的详细解释和适用场景。 一、关键参数 &#xff08;1&#xff09;页面分割模式&#xff08;Page Segmentation Mode, --psm&#xff09; 控制 Tesseract 如何分析…
阅读更多...
【Zephyr 系列 12】BLE + NVS + 低功耗融合实战：打造可配置蓝牙信标系统

【Zephyr 系列 12】BLE + NVS + 低功耗融合实战：打造可配置蓝牙信标系统

🧠关键词：Zephyr、BLE 广播、信标、NVS 参数、低功耗、状态机、周期唤醒 📌适合人群：希望实现 BLE 信标类产品（定位标签、资产管理）的开发者 📊预计篇幅：约 5200+ 字 🎯 项目目标 构建一个可广泛应用于资产标签、定位信标、设备标识等场景的蓝牙广播模块，具备：…
阅读更多...
图解浏览器多进程渲染：从DNS到GPU合成的完整旅程

图解浏览器多进程渲染：从DNS到GPU合成的完整旅程

目录 浏览器进程架构的演化 进程和线程关系图示 进程&#xff08;Process&#xff09; 线程&#xff08;Thread&#xff09; 协程&#xff08;Coroutine&#xff09; 进程&线程&协程核心对比 单进程和多进程浏览器 单进程浏览器​编辑 单进程浏览器存在的问题…
阅读更多...
最新文章

Copyright @ 2022~2023