wang.bigbird.domain.framework.data.rocketmq.service.impl

类 RocketmqProducerServiceImpl

java.lang.Object

wang.bigbird.domain.framework.data.rocketmq.service.impl.RocketmqProducerServiceImpl

所有已实现的接口:

RocketmqProducerService

@Service
public class RocketmqProducerServiceImpl
extends Object
implements RocketmqProducerService

rocketmq生产者服务

作者:

Bigbird

构造器概要

构造器

构造器和说明
RocketmqProducerServiceImpl()

方法概要

限定符和类型	方法和说明
void	destroy()
<T> void	sendAsync(String producerGroupName, String topic, String tag, T message, boolean newProducer, org.apache.rocketmq.client.producer.SendCallback sendCallback) 异步发送消息
<T> void	sendMqOneway(String producerGroupName, String topic, String tag, T message, boolean newProducer) 投递消息，不考虑是否发送成功
<T> void	sendSync(String producerGroupName, String topic, String tag, T message, boolean newProducer) 同步发送消息

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

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

构造器详细资料

RocketmqProducerServiceImpl

public RocketmqProducerServiceImpl()

方法详细资料

sendSync

public <T> void sendSync(String producerGroupName,
                         String topic,
                         String tag,
                         T message,
                         boolean newProducer)
                  throws UnsupportedEncodingException,
                         org.apache.rocketmq.client.exception.MQBrokerException,
                         org.apache.rocketmq.remoting.exception.RemotingException,
                         InterruptedException,
                         org.apache.rocketmq.client.exception.MQClientException

从接口复制的说明: RocketmqProducerService

同步发送消息

指定者:

sendSync 在接口中 RocketmqProducerService

参数:

producerGroupName - 生产者组名，组的意义在于集群模式下，当一个节点挂掉，可以依靠组内其他节点继续工作。

topic - 主题，Message都有topic这一属性，Producer发送指定topic的消息，Consumer订阅Topic下的消息。通过Topic字段，Producer会获取消息投递的路由信息，决定发送给哪个Broker，topic如果不存在会自动创建。

tag - 标签，不同的消费组，订阅同一topic不同的tag，拉取不同的消息并消费，在topic内部对消息进行隔离。

message - 消息内容，Producer要发送的实际消息内容，以字节数组形式进行存储，message消息有一定大小限制。

newProducer - 是否新建一个生产者。

抛出:

UnsupportedEncodingException

org.apache.rocketmq.client.exception.MQBrokerException

org.apache.rocketmq.remoting.exception.RemotingException

InterruptedException

org.apache.rocketmq.client.exception.MQClientException

sendAsync

public <T> void sendAsync(String producerGroupName,
                          String topic,
                          String tag,
                          T message,
                          boolean newProducer,
                          org.apache.rocketmq.client.producer.SendCallback sendCallback)
                   throws UnsupportedEncodingException,
                          org.apache.rocketmq.client.exception.MQClientException,
                          org.apache.rocketmq.remoting.exception.RemotingException,
                          InterruptedException

从接口复制的说明: RocketmqProducerService

异步发送消息

指定者:

sendAsync 在接口中 RocketmqProducerService

参数:

producerGroupName - 生产者组名，组的意义在于集群模式下，当一个节点挂掉，可以依靠组内其他节点继续工作。

topic - 主题，Message都有topic这一属性，Producer发送指定topic的消息，Consumer订阅Topic下的消息。通过Topic字段，Producer会获取消息投递的路由信息，决定发送给哪个Broker，topic如果不存在会自动创建。

tag - 标签，不同的消费组，订阅同一topic不同的tag，拉取不同的消息并消费，在topic内部对消息进行隔离。

message - 消息内容，Producer要发送的实际消息内容，以字节数组形式进行存储，message消息有一定大小限制。

newProducer - 是否新建一个生产者。

sendCallback - 接受消息发送结果的处理器。

抛出:

UnsupportedEncodingException

org.apache.rocketmq.client.exception.MQClientException

org.apache.rocketmq.remoting.exception.RemotingException

InterruptedException

sendMqOneway

public <T> void sendMqOneway(String producerGroupName,
                             String topic,
                             String tag,
                             T message,
                             boolean newProducer)
                      throws UnsupportedEncodingException,
                             org.apache.rocketmq.client.exception.MQClientException,
                             org.apache.rocketmq.remoting.exception.RemotingException,
                             InterruptedException

从接口复制的说明: RocketmqProducerService

投递消息，不考虑是否发送成功

指定者:

sendMqOneway 在接口中 RocketmqProducerService

参数:

producerGroupName - 生产者组名，组的意义在于集群模式下，当一个节点挂掉，可以依靠组内其他节点继续工作。

topic - 主题，Message都有topic这一属性，Producer发送指定topic的消息，Consumer订阅Topic下的消息。通过Topic字段，Producer会获取消息投递的路由信息，决定发送给哪个Broker，topic如果不存在会自动创建。

tag - 标签，不同的消费组，订阅同一topic不同的tag，拉取不同的消息并消费，在topic内部对消息进行隔离。

message - 消息内容，Producer要发送的实际消息内容，以字节数组形式进行存储，message消息有一定大小限制。

newProducer - 是否新建一个生产者。

抛出:

UnsupportedEncodingException

org.apache.rocketmq.client.exception.MQClientException

org.apache.rocketmq.remoting.exception.RemotingException

InterruptedException

destroy

@PreDestroy
public void destroy()