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.