全部产品
弹性计算 会员服务 网络 安全 移动云 数加·大数据分析及展现 数加·大数据应用 管理与监控 云通信 阿里云办公 培训与认证 智能硬件
存储与CDN 数据库 域名与网站(万网) 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 开发者工具 解决方案 物联网 更多
消息队列 MQ

Java SDK 使用说明

更新时间:2018-06-19 15:39:39

消息队列(MQ)提供 Java SDK 实现消息发布与消息订阅。 本文将详细介绍各接口的相关参数以及各接口的使用说明。

说明:关于 TCP 接入点域名,请参见TCP 接入说明

消息收发代码示例

通用参数说明

参数名 参数说明
ONSAddr 设置 MQ TCP 协议接入点,参考上面表格(推荐)
NAMESRV_ADDR 设置 Name Server 列表(不推荐),与 ONSAddr 二选一
AccessKey 您在阿里云账号管理控制台中创建的 AccessKey,用于身份认证
SecretKey 您在阿里云账号管理控制台中创建的 SecretKey,用于身份认证
OnsChannel 用户渠道,默认为:ALIYUN,聚石塔用户为:CLOUD

发送消息参数说明

参数名 参数说明
ProducerId 您在控制台创建的 Producer ID
SendMsgTimeoutMillis 设置消息发送的超时时间,单位(毫秒),默认:3000
CheckImmunityTimeInSeconds(事务消息) 设置事务消息第一次回查的最快时间,单位(秒)
shardingKey(顺序消息) 顺序消息中用来计算不同分区的值

tcp-java-send

订阅消息参数说明

参数名 参数说明
ConsumerId 您在 MQ 控制台上创建的 Consumer ID
MessageModel 设置 Consumer 实例的消费模式,默认为集群消费(值:CLUSTERING);广播消费(BROADCASTING)
ConsumeThreadNums 设置 Consumer 实例的消费线程数,默认:64
MaxReconsumeTimes 设置消息消费失败的最大重试次数,默认:16
ConsumeTimeout 设置每条消息消费的最大超时时间,超过设置时间则被视为消费失败,等下次重新投递再次消费。 每个业务需要设置一个合理的值,单位(分钟)。 默认:15
suspendTimeMillis(顺序消息) 只适用于顺序消息,设置消息消费失败的重试间隔时间

tcp-java-sub

本文导读目录