阿里云文档 2023-09-13

消息队列RocketMQ版客户端如何设置消费线程数_云消息队列 RocketMQ 4.x系列_云消息队列 RocketMQ 版(RocketMQ)

云消息队列 RocketMQ 版所提供的TCP Java SDK支持多线程消费,且适用于所有消息类型,本文介绍如何设置消费线程数的方法。

阿里云文档 2023-07-25

如何使用多线程发送消息

云消息队列 RocketMQ 版的消费者和生产者客户端对象是线程安全的,可以在多个线程之间共享使用。

文章 2022-12-28 来自:开发者社区

开箱即用!动态修改RocketMQ线程池

前言上一篇文章中提到了动态修改RocketMQ线程池,那我们如何才能够通过管理页面对不同消费者组的线程池进行管理自由的随着业务波动进行平滑修改,降低线程池参数修改的成本。另外,从功能性以及健壮性而言还有许多值得我们思考的地方,科宇通过查看线程池运行时指标、负载报警、配置日志管理来提高我们对线程池的管理。SpringBoot RocketMQ 实践版本信息:rocketmq-spring-boot....

开箱即用!动态修改RocketMQ线程池
文章 2022-09-07 来自:开发者社区

读完 RocketMQ 源码,我学会了如何优雅的创建线程

RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时、高可靠的消息发布与订阅服务。这篇文章,笔者整理了 RocketMQ 源码中创建线程的几点技巧,希望大家读完之后,能够有所收获。1 创建单线程首先我们先温习下常用的创建单线程的两种方式:实现 Runnable 接口继承 Thread 类▍一、实现 Runnable 接口图中,MyRunnable 类实现了 Runn....

读完 RocketMQ 源码,我学会了如何优雅的创建线程
文章 2022-05-13 来自:开发者社区

Kafka/RocketMQ 多线程消费时如何保证消费顺序?

上两篇文章都在讨论顺序消息的一些知识,看到有个读者的留言如下:这个问题问得非常棒,由于在之前的文章中并没有提及到,因此我在这篇文章中单独讲解,本文将从消费顺序性这个问题出发,深度剖析 Kafka/RocketMQ 消费线程模型。Kafkakafka 的消费类 KafkaConsumer 是非线程安全的,因此用户无法在多线程中共享一个 KafkaConsumer 实例,且 KafkaConsume....

Kafka/RocketMQ 多线程消费时如何保证消费顺序?
问答 2021-01-01 来自:开发者社区

消息队列RocketMQ版消费者出现 rebalanceService 线程是什么原因?

消费者出现 rebalanceService 线程。

问答 2021-01-01 来自:开发者社区

消息队列RocketMQ版查看消费者状态—连接详情,看到消费者存在消费线程被卡组和现象是什么原因?

消息队列RocketMQ版查看消费者状态—连接详情,看到消费者存在消费线程被卡组和现象是什么原因?

问答 2021-01-01 来自:开发者社区

消息队列RocketMQ版在消费者线程当中看到 rebalanceservice 线程是正常的吗?

消息队列RocketMQ版在消费者线程当中看到 rebalanceservice 线程是正常的吗?

问答 2020-03-28 来自:开发者社区

消息队列 RocketMQ 版客户端如何设置消费线程数?

消息队列 RocketMQ 版客户端如何设置消费线程数?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。