跳过导航链接
A B C E G I L M N O P R S T V 

A

accessKey - 类 中的变量cn.springlet.rocketmq.config.MqConfig
阿里云 accessKey
AutoConfiguration - cn.springlet.rocketmq中的类
自动配置相关
AutoConfiguration() - 类 的构造器cn.springlet.rocketmq.AutoConfiguration
 

B

BaseMessageListenerHandler<T> - cn.springlet.rocketmq.consumer中的接口
消息业务 各服务实现此类 分发业务消息
baseMessageListenerHandler - 类 中的变量cn.springlet.rocketmq.consumer.MqMessageListener
 
buildConsumer() - 类 中的方法cn.springlet.rocketmq.consumer.ConsumerClient
 
buildMessage(String, String, MsgKeyEnum, Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
构建消息 ,可自定义构建消息
buildMessage(String, String, MsgKeyEnum, Object) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
构建消息 ,可自定义构建消息
buildProducer() - 类 中的方法cn.springlet.rocketmq.producer.ProducerClient
 
businessOpt(T, Message) - 接口 中的方法cn.springlet.rocketmq.consumer.BaseMessageListenerHandler
具体 tag 的业务操作

C

cn.springlet.rocketmq - 程序包 cn.springlet.rocketmq
 
cn.springlet.rocketmq.annotation - 程序包 cn.springlet.rocketmq.annotation
 
cn.springlet.rocketmq.config - 程序包 cn.springlet.rocketmq.config
 
cn.springlet.rocketmq.consumer - 程序包 cn.springlet.rocketmq.consumer
 
cn.springlet.rocketmq.enums - 程序包 cn.springlet.rocketmq.enums
 
cn.springlet.rocketmq.log - 程序包 cn.springlet.rocketmq.log
 
cn.springlet.rocketmq.producer - 程序包 cn.springlet.rocketmq.producer
 
cn.springlet.rocketmq.util - 程序包 cn.springlet.rocketmq.util
 
config - 类 中的变量cn.springlet.rocketmq.producer.ProducerService
 
consume(Message, ConsumeContext) - 类 中的方法cn.springlet.rocketmq.consumer.MqMessageListener
 
ConsumerClient - cn.springlet.rocketmq.consumer中的类
rocketMq 消息消费者配置
ConsumerClient() - 类 的构造器cn.springlet.rocketmq.consumer.ConsumerClient
 
consumerError(Message, Exception) - 类 中的静态方法cn.springlet.rocketmq.log.LogUtil
消息消费失败
consumerSuccess(Message, MsgKeyEnum) - 类 中的静态方法cn.springlet.rocketmq.log.LogUtil
消息消费成功

E

EnableSpringletRocketMq - cn.springlet.rocketmq.annotation中的注释类型
自动配置
equalsValue(Object, Object) - 接口 中的静态方法cn.springlet.rocketmq.enums.MsgKeyEnum
值比较
error(Message, Exception) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
error日志

G

getAccessKey() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getBodyObj(MsgKeyEnum, Message, Class<B>) - 接口 中的方法cn.springlet.rocketmq.consumer.BaseMessageListenerHandler
获取 消息参数对象
getBusinessType() - 接口 中的方法cn.springlet.rocketmq.enums.MsgKeyEnum
获取业务类型
getDesc() - 接口 中的方法cn.springlet.rocketmq.enums.MsgKeyEnum
描述
getGroupId() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getId() - 接口 中的方法cn.springlet.rocketmq.enums.MsgKeyEnum
获取 唯一id
getInstanceId() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getMqProperties() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
基础配置信息
getMsgKey() - 接口 中的方法cn.springlet.rocketmq.enums.MsgKeyEnum
获取 msgKey
getMsgKeyEnum(String, Class<E>) - 接口 中的静态方法cn.springlet.rocketmq.enums.MsgKeyEnum
根据 msgKey 获取枚举
getMsgKeyEnumClass() - 接口 中的方法cn.springlet.rocketmq.consumer.BaseMessageListenerHandler
获取业务类型
getNameSrvAddr() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getSecretKey() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getSendTimeOut() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getSerializeMessageBody(Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
 
getTag() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
getTopic() - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
groupId - 类 中的变量cn.springlet.rocketmq.config.MqConfig
消息groupId 每个环境、每个服务需要新增一个group 共 n * n 个group 例 GID-test-cutepet-product-group

I

init() - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
 
instanceId - 类 中的变量cn.springlet.rocketmq.config.MqConfig
阿里云 实例 ID

L

LogUtil - cn.springlet.rocketmq.log中的类
rocketmq 日志处理
LogUtil() - 类 的构造器cn.springlet.rocketmq.log.LogUtil
 

M

messageListener - 类 中的变量cn.springlet.rocketmq.consumer.ConsumerClient
 
MqConfig - cn.springlet.rocketmq.config中的类
rocketMq 配置
MqConfig() - 类 的构造器cn.springlet.rocketmq.config.MqConfig
 
mqConfig - 类 中的变量cn.springlet.rocketmq.consumer.ConsumerClient
 
mqConfig - 类 中的变量cn.springlet.rocketmq.producer.ProducerClient
 
MqMessageListener - cn.springlet.rocketmq.consumer中的类
rocketMq 消息监听器
MqMessageListener() - 类 的构造器cn.springlet.rocketmq.consumer.MqMessageListener
 
MqSendUtil - cn.springlet.rocketmq.util中的类
mq send 静态方法
MqSendUtil() - 类 的构造器cn.springlet.rocketmq.util.MqSendUtil
 
MsgKeyEnum<T> - cn.springlet.rocketmq.enums中的接口
消息 msgKey
MsgSerializeUtil - cn.springlet.rocketmq.util中的类
消息序列化 util
MsgSerializeUtil() - 类 的构造器cn.springlet.rocketmq.util.MsgSerializeUtil
 

N

nameSrvAddr - 类 中的变量cn.springlet.rocketmq.config.MqConfig
实例TCP 协议公网接入地址(实际项目,填写自己阿里云MQ的公网地址)

O

objectDeserialize(byte[], Class<T>) - 类 中的静态方法cn.springlet.rocketmq.util.MsgSerializeUtil
反序列化
objectSerialize(Object) - 类 中的静态方法cn.springlet.rocketmq.util.MsgSerializeUtil
序列化

P

producer - 类 中的变量cn.springlet.rocketmq.producer.ProducerService
 
ProducerClient - cn.springlet.rocketmq.producer中的类
rocketMq 配置
ProducerClient() - 类 的构造器cn.springlet.rocketmq.producer.ProducerClient
 
ProducerService - cn.springlet.rocketmq.producer中的类
rocketMq 消息生产者 发送消息
ProducerService(MqConfig, ProducerBean) - 类 的构造器cn.springlet.rocketmq.producer.ProducerService
 
producerService - 类 中的静态变量cn.springlet.rocketmq.util.MqSendUtil
 

R

receive(Message, MsgKeyEnum, Object) - 类 中的静态方法cn.springlet.rocketmq.log.LogUtil
接收消息

S

secretKey - 类 中的变量cn.springlet.rocketmq.config.MqConfig
阿里云 secretKey
send(Message, Boolean) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
普通消息发送发放 可自定义消息发送
send(Message, Boolean) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
普通消息发送发放 可自定义消息发送
sendDelayMsg(MsgKeyEnum, Object, long) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息 延时消息
sendDelayMsg(MsgKeyEnum, String, Object, long) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息 延时消息
sendDelayMsg(MsgKeyEnum, Object, long) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息 延时消息
sendDelayMsg(MsgKeyEnum, String, Object, long) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息 延时消息
sendError(Message, Exception) - 类 中的静态方法cn.springlet.rocketmq.log.LogUtil
发送消息失败
sendMsg(MsgKeyEnum, Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息
sendMsg(MsgKeyEnum, String, Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息
sendMsg(MsgKeyEnum, Object) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息
sendMsg(MsgKeyEnum, String, Object) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息
sendOneWayDelayMsg(MsgKeyEnum, Object, long) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息 延时消息
sendOneWayDelayMsg(MsgKeyEnum, String, Object, long) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息 延时消息
sendOneWayDelayMsg(MsgKeyEnum, Object, long) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息 延时消息
sendOneWayDelayMsg(MsgKeyEnum, String, Object, long) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息 延时消息
sendOneWayMsg(MsgKeyEnum, Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息
sendOneWayMsg(MsgKeyEnum, String, Object) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息
sendOneWayMsg(MsgKeyEnum, Object) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息
sendOneWayMsg(MsgKeyEnum, String, Object) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息
sendOneWayTimeMsg(MsgKeyEnum, Object, String) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息 定时消息
sendOneWayTimeMsg(MsgKeyEnum, String, Object, String) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送单向消息 定时消息
sendOneWayTimeMsg(MsgKeyEnum, Object, String) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息 定时消息
sendOneWayTimeMsg(MsgKeyEnum, String, Object, String) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送单向消息 定时消息
sendSuccess(Message, String) - 类 中的静态方法cn.springlet.rocketmq.log.LogUtil
发送消息成功
sendTimeMsg(MsgKeyEnum, Object, String) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息 定时消息
sendTimeMsg(MsgKeyEnum, String, Object, String) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
发送消息 定时消息
sendTimeMsg(MsgKeyEnum, Object, String) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息 定时消息
sendTimeMsg(MsgKeyEnum, String, Object, String) - 类 中的静态方法cn.springlet.rocketmq.util.MqSendUtil
发送消息 定时消息
sendTimeOut - 类 中的变量cn.springlet.rocketmq.config.MqConfig
发送消息超时时间
setAccessKey(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setGroupId(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setInstanceId(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setNameSrvAddr(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setSecretKey(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setSendTimeOut(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setTag(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
setTopic(String) - 类 中的方法cn.springlet.rocketmq.config.MqConfig
 
SPLIT - 接口 中的静态变量cn.springlet.rocketmq.enums.MsgKeyEnum
 
success(Message, String) - 类 中的方法cn.springlet.rocketmq.producer.ProducerService
success 日志

T

tag - 类 中的变量cn.springlet.rocketmq.config.MqConfig
标签 每个环境、每个服务需要不同的 tag 共 n * n 个tag 例 test-cutepet-product
topic - 类 中的变量cn.springlet.rocketmq.config.MqConfig
消息topic 共用一个topic

V

valueOf(Class<E>, Object) - 接口 中的静态方法cn.springlet.rocketmq.enums.MsgKeyEnum
找到匹配的那个枚举
A B C E G I L M N O P R S T V 
跳过导航链接

Copyright © 2022. All rights reserved.