cn.springlet.rocketmq.producer

类 ProducerService

java.lang.Object

cn.springlet.rocketmq.producer.ProducerService

@Component
public class ProducerService
extends Object

rocketMq 消息生产者 发送消息

作者:

springlet

字段概要

字段

限定符和类型	字段和说明
private MqConfig	config
private com.aliyun.openservices.ons.api.bean.ProducerBean	producer

构造器概要

构造器

构造器和说明
ProducerService(MqConfig config, com.aliyun.openservices.ons.api.bean.ProducerBean producer)

方法概要

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

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

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

字段详细资料

config

private final MqConfig config

producer

private final com.aliyun.openservices.ons.api.bean.ProducerBean producer

构造器详细资料

ProducerService

public ProducerService(MqConfig config,
                       com.aliyun.openservices.ons.api.bean.ProducerBean producer)

方法详细资料

sendMsg

public void sendMsg(MsgKeyEnum msgKey,
                    Object messageBody)

发送消息

参数:

messageBody - 消息体

msgKey - 消息key

sendDelayMsg

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

发送消息 延时消息

参数:

msgKey - 消息key

messageBody - 消息体

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

sendTimeMsg

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

发送消息 定时消息

参数:

msgKey - 消息key

messageBody - 消息体

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

sendOneWayMsg

public void sendOneWayMsg(MsgKeyEnum msgKey,
                          Object messageBody)

发送单向消息

参数:

messageBody - 消息体

msgKey - 消息key

sendOneWayDelayMsg

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

发送单向消息 延时消息

参数:

msgKey - 消息key

messageBody - 消息体

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

sendOneWayTimeMsg

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

发送单向消息 定时消息

参数:

msgKey - 消息key

messageBody - 消息体

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

sendMsg

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

发送消息

参数:

messageBody - 消息体

msgKey - 消息key

msgTag - 消息tag

sendDelayMsg

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

发送消息 延时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

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

sendTimeMsg

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

发送消息 定时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

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

sendOneWayMsg

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

发送单向消息

参数:

messageBody - 消息体

msgKey - 消息key

msgTag - 消息tag

sendOneWayDelayMsg

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

发送单向消息 延时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

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

sendOneWayTimeMsg

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

发送单向消息 定时消息

参数:

msgKey - 消息key

msgTag - 消息tag

messageBody - 消息体

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

send

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

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

参数:

msg - 消息

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

buildMessage

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

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

参数:

topic -

msgTag - 为空，默认取本服务的tag

msgKey -

messageBody -

返回:

getSerializeMessageBody

private byte[] getSerializeMessageBody(Object messageBody)

error

private void error(com.aliyun.openservices.ons.api.Message msg,
                   Exception e)

error日志

参数:

msg -

e -

success

private void success(com.aliyun.openservices.ons.api.Message msg,
                     String messageId)

success 日志

参数:

msg -

messageId -