黑砂博客

1、设置自启动应用 修改deconfig文件下的“CONFIG_INIT_ENTRYPOINT”参数即可 2、消息队列使用 以下是Nuttx系统中使用queue_create函数创建队列的示例代码...

背景 如今，分布式架构已经成为事实上的架构模范，这使得通过 REST API 和 消息中间件来降低微服务之间的耦合变得必然。就消息中间件而言࿰...

文章目录 一、解释信号量 1.1 概念的引入 1.2 信号量操作和使用接口 二、信号量使用场景 2.1 引入环形队列&&生产消费问题 2.2 代码实现 2.3...

阻塞队列 一、基础概念 1.1 生产者消费者概念 生产者消费者是设计模式的一种。让生产者和消费者基于一个容器来解决强耦合问题。 生产者 消费者彼此之间不会...

目录 一、生产者如何提高吞吐量 二、生产者提高吞吐量代码示例 一、生产者如何提高吞吐量 设置批次大小，batch.size 默认 16K。 设置等待时...

1、下载安装包 下载地址：https://rocketmq.apache.org/download  2、 解压、配置环境变量 ROCKETMQ_HOME=RocketMQ安装地址  3、 用cmd页面启...

“消息”是在两台计算机间传送的数据单位。消息可以非常简单，例如只包含文本字符串；也可以更复杂，可能包含嵌入对象。队列是先进先出的一种数据结构。“消息...

1 下载，配置，启动 kafka 下载链接 配置修改 在config目录下的server文件和zookeeper文件，其中分别修改kafka的日志保存路径和zookeeper...

目录 一、生产者自定义分区器代码示例 1.1、自定义分区器类 1.2、生产者发送消息代码（生产者的配置中添加分区器参数） 1.3、测试 ...

不同的使用场景对生产者API的使用和配置会有直接的影响。 一、生产者发送消息流程 1、发送原理  在消息发送的过程中，涉及到了两个线程——main和Sende...