cn.springlet.rocketmq.util

类 MqSendUtil

java.lang.Object

cn.springlet.rocketmq.util.MqSendUtil

public class MqSendUtil
extends Object

mq send 静态方法

作者:

springlet

字段概要

字段

限定符和类型	字段和说明
private static ProducerService	producerService

构造器概要

构造器

构造器和说明
MqSendUtil()

方法概要

限定符和类型	方法和说明
static com.aliyun.openservices.ons.api.Message	buildMessage(String topic, String msgTag, MsgKeyEnum msgKey, Object messageBody) 构建消息 ,可自定义构建消息
private static void	init()
static com.aliyun.openservices.ons.api.SendResult	send(com.aliyun.openservices.ons.api.Message msg, Boolean isOneWay) 普通消息发送发放 可自定义消息发送
static void	sendDelayMsg(MsgKeyEnum msgKey, Object messageBody, long delayTime) 发送消息 延时消息
static void	sendDelayMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody, long delayTime) 发送消息 延时消息
static void	sendMsg(MsgKeyEnum msgKey, Object messageBody) 发送消息
static void	sendMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody) 发送消息
static void	sendOneWayDelayMsg(MsgKeyEnum msgKey, Object messageBody, long delayTime) 发送单向消息 延时消息
static void	sendOneWayDelayMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody, long delayTime) 发送单向消息 延时消息
static void	sendOneWayMsg(MsgKeyEnum msgKey, Object messageBody) 发送单向消息
static void	sendOneWayMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody) 发送单向消息
static void	sendOneWayTimeMsg(MsgKeyEnum msgKey, Object messageBody, String datetime) 发送单向消息 定时消息
static void	sendOneWayTimeMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody, String datetime) 发送单向消息 定时消息
static void	sendTimeMsg(MsgKeyEnum msgKey, Object messageBody, String datetime) 发送消息 定时消息
static void	sendTimeMsg(MsgKeyEnum msgKey, String msgTag, Object messageBody, String datetime) 发送消息 定时消息

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

producerService

private static volatile ProducerService producerService

构造器详细资料

MqSendUtil

public MqSendUtil()

方法详细资料

init

private static void init()

sendMsg

public static void sendMsg(MsgKeyEnum msgKey,
                           Object messageBody)

发送消息

参数:

messageBody - 消息体

msgKey - 消息key

sendDelayMsg

public static void sendDelayMsg(MsgKeyEnum msgKey,
                                Object messageBody,
                                long delayTime)

发送消息 延时消息

参数:

msgKey - 消息key

messageBody - 消息体

delayTime - 最大延迟时间为7天. 延迟投递: 延迟3s投递, 设置为: 3000;

sendTimeMsg

public static void sendTimeMsg(MsgKeyEnum msgKey,
                               Object messageBody,
                               String datetime)

发送消息 定时消息

参数:

msgKey - 消息key

messageBody - 消息体

datetime - 最大延迟时间为7天. 定时投递: 支持格式 DateUtil.parse(CharSequence)

sendOneWayMsg

public static void sendOneWayMsg(MsgKeyEnum msgKey,
                                 Object messageBody)

发送单向消息

参数:

messageBody - 消息体

msgKey - 消息key

sendOneWayDelayMsg

public static void sendOneWayDelayMsg(MsgKeyEnum msgKey,
                                      Object messageBody,
                                      long delayTime)

发送单向消息 延时消息

参数:

msgKey - 消息key

messageBody - 消息体

delayTime - 最大延迟时间为7天. 延迟投递: 延迟3s投递, 设置为: 3000;

sendOneWayTimeMsg

public static void sendOneWayTimeMsg(MsgKeyEnum msgKey,
                                     Object messageBody,
                                     String datetime)

发送单向消息 定时消息

参数:

msgKey - 消息key

messageBody - 消息体

datetime - 最大延迟时间为7天. 定时投递: 支持格式 DateUtil.parse(CharSequence)

sendMsg

public static void sendMsg(MsgKeyEnum msgKey,
                           String msgTag,
                           Object messageBody)

发送消息

参数:

messageBody - 消息体

msgKey - 消息key

msgTag - 消息tag

sendDelayMsg

public static void sendDelayMsg(MsgKeyEnum msgKey,
                                String msgTag,
                                Object messageBody,
                                long delayTime)

发送消息 延时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

delayTime - 最大延迟时间为7天. 延迟投递: 延迟3s投递, 设置为: 3000;

sendTimeMsg

public static void sendTimeMsg(MsgKeyEnum msgKey,
                               String msgTag,
                               Object messageBody,
                               String datetime)

发送消息 定时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

datetime - 最大延迟时间为7天. 定时投递: 支持格式 DateUtil.parse(CharSequence)

sendOneWayMsg

public static void sendOneWayMsg(MsgKeyEnum msgKey,
                                 String msgTag,
                                 Object messageBody)

发送单向消息

参数:

messageBody - 消息体

msgTag - 消息tag

msgKey - 消息key

sendOneWayDelayMsg

public static void sendOneWayDelayMsg(MsgKeyEnum msgKey,
                                      String msgTag,
                                      Object messageBody,
                                      long delayTime)

发送单向消息 延时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

delayTime - 最大延迟时间为7天. 延迟投递: 延迟3s投递, 设置为: 3000;

sendOneWayTimeMsg

public static void sendOneWayTimeMsg(MsgKeyEnum msgKey,
                                     String msgTag,
                                     Object messageBody,
                                     String datetime)

发送单向消息 定时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

datetime - 最大延迟时间为7天. 定时投递: 支持格式 DateUtil.parse(CharSequence)

send

public static com.aliyun.openservices.ons.api.SendResult send(com.aliyun.openservices.ons.api.Message msg,
                                                              Boolean isOneWay)

普通消息发送发放 可自定义消息发送

参数:

msg - 消息

isOneWay - 是否单向发送 单项消息没有返回信息

buildMessage

public static com.aliyun.openservices.ons.api.Message buildMessage(String topic,
                                                                   String msgTag,
                                                                   MsgKeyEnum msgKey,
                                                                   Object messageBody)

构建消息 ,可自定义构建消息

参数:

topic -

msgTag -

msgKey -

messageBody -

返回: