import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
@Override
public boolean send(Message data) throws Exception {
	if(data == null){
		return false;
	}
	try{
		SendResult sr = producer.send(data);
		if(sr.getSendStatus() != SendStatus.SEND_OK){
			logger.warn(String.format("Message(%s) has been sent successfully, but send status is %s.", 
					data.getTopic(), sr.getSendStatus()));
		}
	}catch(Exception e){
		if(needFaultTolerant){
			putInErrorQueue(data);
		}
		throw e;
	}
	return true;
}
 

import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public boolean sendMixMessage(User user) {
	
	Message message = new Message(TOPIC, TAG, user.getUserId().toString(), JSON.toJSONString(user).getBytes());
	
	try {
		SendResult sendResult = producer.send(message);
		if (SendStatus.SEND_OK.equals(sendResult.getSendStatus())) {
			logger.info("send mix message successfully");
			return true;
		} else {
			logger.info("send mix message unsuccessfully");
			return false;
		}
	} catch (Exception e) {
		logger.info("send mix message unsuccessfully, {}", e.getMessage());
		return false;
	}
}
 

import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
@Override
public void push(List<Span> spanList) {
    byte[] bytes = JSON.toJSONBytes(spanList);
    Message message = new Message(DstConstants.ROCKET_MQ_TOPIC,bytes);
    try {
        SendResult sendResult = defaultMQProducer.send(message);
        if(sendResult.getSendStatus()!= SendStatus.SEND_OK){
            logger.error("send mq message return ["+sendResult.getSendStatus()+"]");
        }
    } catch (Exception e) {
        logger.error("fail to send message.",e);
    }
}
 

import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
/**
 *  发送数据到MQ方法  
 * 
 * @param Topic   队列名称
 * @param Tags	     标签名称
 * @param body	  发送的数据  推荐 JSOM 或者 XML 结构
 * @param Encoding  数据编码格式  默认UTF-8
 * @return   响应信息进行了内部处理  确认已经保存到 MQ 并且    日志已经记录  只要值不是NULL 就是成功发送
 * @throws UnsupportedEncodingException  转换字符集出错  请检查是否可以转换 
 */
public SendResult send(String Topic, String Tags, String body, String Encoding)
		throws UnsupportedEncodingException
{

	String loggerString = MessageFormat.format(
			"将要发送到Mq的数据    Topic={0}   Tags={1}   body={2}  Encoding={3} ", Topic, Tags, body,
			Encoding);

	if (Encoding == null || "".equals(Encoding))
	{
		Encoding = "UTF-8";
	}

	if (Tags == null || "".equals(Tags))
	{
		Tags = "*";
	}

	LOGGER.info(loggerString);

	Message me = new Message();
	// 标示
	me.setTopic(Topic);
	// 标签
	me.setTags(Tags);
	// 内容
	me.setBody(body.getBytes(Encoding));
	// 发送信息到MQ SendResult 是当前发送的状态 官方说 不出异常 就是成功
	SendResult sendResult = null;
	try
	{
		sendResult = producer.send(me);
	}
	catch (Exception e)
	{
		LOGGER.error(" 发送 数据给MQ出现异常  " + loggerString, e);
	}
	// 当消息发送失败时如何处理 getSendStatus 获取发送的状态
	if (sendResult == null || sendResult.getSendStatus() != SendStatus.SEND_OK)
	{
		LOGGER.info(loggerString + "发送消息失败" + " MQ状态值  SendResult=" + sendResult);
		sendResult = null;
	}
	LOGGER.info("发送到MQ成功" + sendResult);
	return sendResult;
}
 

import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public void sendBytesMessage(String topic, String tags, byte[] body){
	SendResult result =  sendBytesMessage(topic, tags, body, errorHandler);
	if(result.getSendStatus()!=SendStatus.SEND_OK){
		throw BaseException.formatMessage("发送消息失败!(%s)", result.getSendStatus());
	}
}
 

import com.alibaba.rocketmq.client.producer.SendStatus; //导入依赖的package包/类
public void sendRawMessage(Message message){
	SendResult result = sendRawMessage(message, errorHandler);
	if(result.getSendStatus()!=SendStatus.SEND_OK){
		throw BaseException.formatMessage("发送消息失败!(%s)", result.getSendStatus());
	}
}