顺序消息
TCP SDK示例代码 TCP协议下的示例代码请参见以下文档：Java：收发顺序消息 C/C++：收发顺序消息.NET： 收发顺序消息 HTTP SDK示例代码 HTTP协议下的示例代码请参见以下文档：Java：收发顺序消息 Go：收发顺序消息 Python：收发顺序消息 ...
发送消息（多线程）
云消息队列 RocketMQ 版 的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高...
顺序消息
以Java语言为例，收发顺序消息的示例代码如下：完整的消息收发示例代码请参见 RocketMQ 5.x系列SDK（推荐）。顺序消息发送。MessageBuilder messageBuilder=null;Message message=messageBuilder.setTopic("topic")/设置消息索引键，可根据...
发送消息（多线程）
SOFAStack 消息队列的消费者和生产者客户端对象是线程安全的，可以在多个线程之间共享使用。您可以在服务器上（或者多台服务器）部署多个生产者和消费者实例，也可以在同一个生产者或消费者实例里采用多线程发送或接收消息，从而提高消息...
开发HSF应用（SDK）
请参考 ItemServiceImpl.java 文件中的示例代码构建服务接口。public class ItemServiceImpl implements ItemService {@Override public Item getItemById(long id){ Item car=new Item();car.setItemId(1l);car.setItemName("Mercedes ...
开发HSF应用（SDK）
请参考 ItemServiceImpl.java 文件中的示例代码构建服务接口。public class ItemServiceImpl implements ItemService {@Override public Item getItemById(long id){ Item car=new Item();car.setItemId(1l);car.setItemName("Mercedes ...
收发顺序消息
如果发送方有多个生产者或者有多个线程并发发送消息，则此时只能以到达 云消息队列 RocketMQ 版 服务端的时序作为消息顺序的依据，和业务侧的发送顺序未必一致。发送顺序消息的示例代码如下。import com.aliyun.mq.http.MQClient;import ...
收发普通消息
获取Topic的生产者。MQProducer producer;if(instanceId!null&instanceId!{ producer=mqClient.getProducer(instanceId,topic);} else { producer=mqClient.getProducer(topic);} try {/循环发送4条消息。for(int i=0;i;i+){ ...
收发定时消息和延时消息
本文提供使用HTTP协议下的Java SDK收发定时消息和延时消息的示例代码。背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时...
订阅者最佳实践
Group订阅多个Topic的示例代码如下：String topicStr=kafkaProperties.getProperty("topic");String[]topics=topicStr.split(",");for(String topic:topics){ subscribedTopics.add(topic.trim());} consumer.subscribe(subscribedTopics);...
超大消息传输
public void setNeedDeleteMessageObjectOnOSSFlag(boolean flag)具体使用示例代码请参见大消息示例代码中的Demo.java。注意事项 大消息主要消费网络带宽，用该方案发送大消息时，生产者和消费者的网络带宽可能会是瓶颈。大消息网络传输...
Flink消费
背景信息 Flink Log Connector包括两部分，消费者（Flink Log Consumer）和生产者（Flink Log Producer），两者用途区别如下：消费者用于从日志服务中读取数据，支持exactly once语义，支持Shard负载均衡。生产者用于将数据写入日志服务。...
开发HSF应用（Pandora Boot）
HSF服务框架基于接口进行服务通信，当接口定义好之后，生产者将通过该接口实现具体的服务并发布，消费者也是基于此接口订阅和消费服务。public interface HelloService { String echo(String string);} 接口 ...
开发HSF应用（Pandora Boot）
HSF服务框架基于接口进行服务通信，当接口定义好之后，生产者将通过该接口实现具体的服务并发布，消费者也是基于此接口订阅和消费服务。public interface HelloService { String echo(String string);} 接口 ...
消息类型
TCP Java SDK 收发普通消息的示例代码 发送普通消息（三种方式）发送消息（多线程）订阅消息 定时和延时消息 定时消息：Producer 将消息发送到消息队列服务端，但并不期望这条消息立马投递，而是推迟到在当前时间点之后的某一个时间投递到 ...
批量消费
功能原理 批量消费主要分为以下两个阶段：消息从生产者发布至 云消息队列 RocketMQ 版 后，Push消费者中的拉消息线程通过长轮询将消息拉到后台缓存。Push消费者根据缓存情况是否满足任一批量条件，判断是否将消息提交给消费线程完成消费。...
Spring集成
背景信息 云消息队列 RocketMQ 版 支持以下消息类型的生产者和消费者与Spring集成：普通消息的生产者和消费者 事务消息的生产者和消费者 顺序消息的生产者和消费者 说明 云消息队列 RocketMQ 版 暂不支持Spring框架下定时消息和延时消息的...
通过消费组消费数据
创建一个消费组并启动一个消费者线程，该消费者会从指定的Logstore中消费数据。管理消费组的代码示例，请参见 使用Java SDK管理消费组、使用Python SDK管理消费组。import com.aliyun.openservices.loghub.client.ClientWorker;import ...
通过消费组消费数据
创建一个消费组并启动一个消费者线程，该消费者会从指定的Logstore中消费数据。管理消费组的代码示例，请参见 使用Java SDK管理消费组、使用Python SDK管理消费组。import com.aliyun.openservices.loghub.client.ClientWorker;import ...
收发顺序消息
本文提供使用TCP协议下的社区版Java SDK收发顺序消息的示例代码供您参考。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的先入先出FIFO（First In First Out）的顺序进行发布和消费。分区顺序：对于指定的...
收发顺序消息
本文提供使用TCP协议下的Java SDK收发顺序消息的示例代码。前提条件 您已完成以下操作：下载1.2.7或以上版本的Java SDK。更多信息，请参见Java SDK 版本说明。准备环境。更多信息，请参见 准备环境。（可选）日志配置。更多信息，请参见 ...
收发定时消息
本文提供使用TCP协议下的Java SDK收发定时消息的示例代码。背景信息 定时消息可以做到在指定时间戳之后才可被消费者消费，适用于对消息生产和消费有时间窗口要求，或者利用消息触发定时任务的场景。定时消息的概念介绍及使用过程中的注意...
消费者分类
云消息队列 RocketMQ 版 支持PushConsumer和SimpleConsumer这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
如何提升写入效率
线程数设置 SDK默认的异步提交消费者线程数为1；当写入TPS较高时，可以适当调大消费者线程；异步和同步写入优化 异步写：异步写入调用put()方法即可；SDK的内部处理逻辑为：1）将Points放入内部队列；2）消费者线程从内部队列取出小于等于...
Python/Java 参考
本文提供了安全访问服务 Python及Java代码示例。安全访问 Python 代码示例点此下载 安全访问 Java 代码示例点此下载
删除Group后仍然收到消息堆积的告警信息
解决方案 删除 Group 后，如果您不希望继续收到消息堆积的告警信息，请参见以下操作进行处理：确认服务端版本，请根据服务端版本情况执行以下操作：2.2.0及以上版本，请根据以下方式操作：若 Group 中没有存活的消费者线程（存活的消费者...
消息队列 RocketMQ 客户端流控设计
针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*ConcurrentThreadNumber 如果消息并发消费线程...
步骤三：调用SDK收发消息
groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client-java</artifactId><version>5.0.4</version></dependency>生产消息 在已创建的Java工程中，创建发送普通消息程序并运行，示例代码如下：package doc;...
延时消息
这条消息将会在30分钟以后投递给消费者，消费者收到此消息后需要判断对应的订单是否已完成支付。如支付未完成，则关闭订单。如已完成支付则忽略。通过消息触发延时任务的场景。例如，在指定时间段之后向用户发送提醒消息。延时时间设置规则...
协同消费
5 心跳 要实现协同消费的功能，需要通过心跳机制来通知让服务端消费者实例的状态，当前分配的shard和需要释放的shard，超过时间间隔没有收到心跳，则认为消费者实例已经停止。当消费者实例的状态发生改变，服务端会重新分配shard，新的分配...
事务消息
在断网或者是生产者应用重启的特殊情况下，若服务端未收到发送者提交的二次确认结果，或服务端收到的二次确认结果为Unknown未知状态，经过固定时间后，服务端将对消息生产者即生产者集群中任一生产者实例发起消息回查。事务消息回查步骤...
接口和参数说明
云消息队列 RocketMQ 版 提供Java SDK实现消息发送与订阅，订阅方可通过Push或Pull的方式从 云消息队列 RocketMQ 版 获取消息。本文介绍消息发送和订阅的接口和参数说明。背景信息 云消息队列 RocketMQ 版 支持以下两种消息获取方式：Push...
默认接入点收发消息
消费者超过该值没有返回心跳，服务端判断消费者处于非存活状态，服务端将消费者从Group移除并触发Rebalance，默认30s。props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG,30000);设置单次拉取的量，走公网访问时，该参数会有较大影响。...
获取代码示例
本文汇总了 mPaaS 所有的示例代码。示例代码会随功能迭代不定期更新。建议您在接入组件时，下载最新版本的示例代码。示例代码的更新说明和使用方法，请查看对应的 README.md 文件。关于不同版本 SDK 的区别，请参见 发布说明。V10.1.68&10....
功能发布记录
支持领域事件与领域事件消费者代码生成。支持应用服务模型生成API到接口管理并生成controller代码。IDE插件：模型与代码双向联动、比对、合并：支持领域事件属性、领域事件消费者；创建和管理中心应用 管理应用接口 生成代码 扫描上报和...
Demo工程
下载到本地并解压后即可看到本地新增了 mq-demo-master 文件夹，该文件夹包括纯Java、Spring以及Spring Boot的示例代码。更多信息，请参见 rocketmq-demo。下载安装JDK。更多信息，请参见 JDK下载地址。配置Demo工程 将Demo工程文件导入...
使用实例接入点收发消息
消费者超过该值没有返回心跳，服务端判断消费者处于非存活状态，服务端将消费者从Group移除并触发Rebalance，默认30s。props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG,30000);设置单次拉取的量，走公网访问时，该参数会有较大影响。...
标签SDK概览
SDK支持列表 编程语言 SDK下载地址 SDK示例代码 SDK用户指南 Java 仅支持异步调用：SDK for Java(V2)Java（异步）示例代码 SDK用户指南 仅支持同步调用：SDK for Java(V2)Java（同步）示例代码 Node.js SDK for Node.js/TypeScript(V2)Node...
消息队列
任务A作为生产者循环向消息队列发送消息，任务B作为消费者循环从消息队列接收消息，一般情况下，消费者处理数据是要花费很长时间，所以会导致消息产生的速度大于消息处理的速度，使得消息队列溢出。所以可以通过调整任务B优先级大于任务A来...
资源组SDK概览
SDK支持列表 编程语言 SDK下载地址 SDK示例代码 SDK用户指南 Java 仅支持异步调用：SDK for Java(V2)Java（异步）示例代码 SDK用户指南 仅支持同步调用：SDK for Java(V2)Java（同步）示例代码 Node.js SDK for Node.js/TypeScript(V2)Node...
- 产品推荐
- 这些文档可能帮助您