全部产品
存储与CDN 数据库 安全 应用服务 数加·人工智能 数加·大数据基础服务 互联网中间件 视频服务 阿里云办公 培训与认证 物联网
消息队列 MQ

Java SDK 使用说明

更新时间:2017-08-24 16:05:35

消息队列(MQ)提供 Java SDK 实现消息发布与消息订阅。本文将详细介绍各接口的相关参数以及各接口的使用说明。TCP 接入点域名,请前往查看。

消息收发代码示例:

  1. 普通消息收发
  2. 顺序消息收发
  3. 发送定时消息
  4. 发送延时消息
  5. 发送事务消息

通用参数说明

参数名 参数说明
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

本文导读目录