rocketmqrpc
社区干货
如何解决使用RocketMQ的消息轨迹信息无法查看问题
```2. 生产者示例代码```javapackage org.example;import java.util.Date;import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq.client.exception.MQClientException;import org.apache.rocketmq.client.producer.DefaultMQProducer;import org.apache.rocketmq.client.producer.SendResult;import org.apache.rocketmq....
打造新一代云原生"消息、事件、流"统一消息引擎的融合处理平台 | 社区征文
RocketMQ基于大规模云计算环境的实践经验(例如,阿里(双十一、双十二)、携程(过年高峰期)),辅助了成千上万的企业完成数字化转型,从而实现了从互联网消息中间件到云原生消息中间件的发展变革。RocketMQ与其他消息中间... 比如RabbitMQ无法水平扩展单队列能力、Kafka扩容需要大量数据拷贝和均衡。这些现有解决方案都不适用于为大规模客户提供弹性服务的公共云环境。可选用 JDBC 做消息持久化,通过简单的 xml 配置信息即可实现 JDBC 消息存储。使用文件系统做持久化的情况下,可获得更高效的 I/O 读写。* Broker Store 目录结构``` storePathRootDir=/cache1/rocketmq/broker/data ├── abort // 该文件在 Broker 启动后会自动创建,正常关闭 Broker,该文件会自动消失。若在没有启动 Broker 的情况下,发现这个文件是存...
演讲预告 | 字节跳动云原生大数据的探索与实践
=&rk3s=8031ce6d&x-expires=1715876458&x-signature=oDiHLfCJ4GbMQMsVr%2BCVYAJuuvk%3D) **RocketMQ****在字节跳动的应用与实践****沈辉****|字节跳动基础架构研发工程师**
特惠活动
rocketmqrpc-优选内容
rocketmqrpc-相关内容
普通消息
MQClientException;import org.apache.rocketmq.client.producer.DefaultMQProducer;import org.apache.rocketmq.client.producer.SendResult;import org.apache.rocketmq.common.message.Message;import org.apache.rocketmq.remoting.RPCHook;import org.apache.rocketmq.remoting.common.RemotingHelper;public class RocketMQProducer { //设置为您在火山引擎消息队列 RocketMQ版控制台上创建的 GID,以及替换为RocketMQ实...
步骤三:生产消费普通消息
下载并安装 RocketMQ 客户端 Java SDK 后,运行以下示例代码,异步发送普通消息。 成功发送消息之后,如果可以通过消息查询功能检索到这条消息,表示消息已成功发送到服务端。查询消息的操作步骤请参考消息查询。 Java import java.util.Date;import org.apache.rocketmq.acl.common.AclClientRPCHook;import org.apache.rocketmq.acl.common.SessionCredentials;import org.apache.rocketmq.client.exception.MQClientException;im...
通过 RocketMQ 消费 Canal Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费 Canal Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal Proto 格式的数据。 前提条件已注册... import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely; import org.apache.rocketmq.remoting.RPCHook; import org.apac...
通过 RocketMQ 消费火山引擎 Proto 格式的订阅数据
数据库传输服务 DTS 的数据订阅服务支持使用 RocketMQ 客户端消费火山引擎 Proto 格式的订阅数据。本文以订阅云数据库 MySQL 版实例为例,介绍如何使用 Go 和 Java 语言消费 Canal 格式的数据。 前提条件已注册火山... import org.apache.rocketmq.common.message.MessageExt; import org.apache.rocketmq.client.consumer.rebalance.AllocateMessageQueueAveragely; import org.apache.rocketmq.remoting.RPCHook; import org.apa...
RocketMQ 消费者使用建议
消费速率慢处理RocketMQ 的每个消费者的能力不同,线上经常会发生消费堆积的问题。您可以通过以下方式处理: 提高消费并行度绝大部分消息消费行为都属于 IO 密集型,即操作数据库或者调用 RPC。这类消费行为的消费速度依赖于后端数据库或者外系统的吞吐量,通过增加消费并行度,可以提高总的消费吞吐量,但是并行度增加到一定程度,反而会下降。所以,应用必须要设置合理的并行度。 您可以通过以下方式修改消费并行度: 同一个 ConsumerG...
DescribeAccessKeys
调用 DescribeAccessKeys 接口查询 RocketMQ 密钥列表。 注意事项请求频率:该接口请求频率限制为 40 次/秒;单用户请求频率限制为 8 次/秒。 使用说明此接口用于查看指定实例的 RocketMQ 密钥列表,也可用于查看某一... "AclConfigJson": "{\"topicPerms\":{\"RMQ_SYS_TRACE_TOPIC\":\"PUB\",\"rocketmq123\":\"PUBSUB\"},\"groupPerms\":{\"GID_test\":\"PUBSUB\"}}", "Actived": true, ...
DescribeSecretKey
调用 DescribeSecretKey 接口查看指定 RocketMQ 密钥的 AccessKey Secret。 注意事项请求频率:该接口请求频率限制为 100 次/秒;单用户请求频率限制为 20 次/秒。 使用说明创建密钥并设置密钥权限之后,还需要查看详细的密钥信息,用于代码的鉴权参数配置。您可以调用此接口,根据 AccessKey ID 查看对应的 AccessKey Secret。 请求参数参数 参数类型 是否必选 示例值 说明 InstanceId String 是 rocketmq-cnai1f0c29ca****...
CreateAccessKey
调用 CreateAccessKey 创建 RocketMQ 密钥。 注意事项请求频率:该接口请求频率限制为 10 次/秒;单用户请求频率限制为 2 次/秒。 使用说明火山引擎消息队列 RocketMQ版通过密钥管理 Topic 权限,密钥由 AccessKey ID 与对应的 AccessKey Secret 组成,用于访问实例、生产消费时的鉴权与身份认证。此接口用于创建密钥。 说明 所有 RocketMQ 实例默认开启 ACL 访问控制,无需手动开启或关闭。 创建密钥后,密钥默认为已启用状态。若不再...
ListInstances
调用接口 ListInstances 查看当前账号在当前地域下的所有 RocketMQ 实例信息。 注意事项请求频率:该接口请求频率限制为 20 次/秒;单用户请求频率限制为 5 次/秒。 请求参数参数 参数类型 是否必选 示例值 说明... { "NormType": "rocketmq.n1.x2.medium" }, "CreateTime": 1650892326, "DeployDefer": false, "DeployRMQProxy": false, ...
