com.alibaba.rocketmq.common.message.Message.<init>()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(15.7k)|赞(0)|评价(0)|浏览(620)

本文整理了Java中com.alibaba.rocketmq.common.message.Message.<init>()方法的一些代码示例，展示了Message.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.<init>()方法的具体详情如下：
包路径：com.alibaba.rocketmq.common.message.Message
类名称：Message
方法名：<init>

Message.<init>介绍

暂无

代码示例

代码示例来源：origin: kuangye098/rocketmq

  1. private static Message buildMessage(final int messageSize) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic("BenchmarkTest");
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 10) {
  7.       sb.append("hello baby");
  8.     }
  10.     msg.setBody(sb.toString().getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.     return msg;
  13.   }
  14. }

代码示例来源：origin: kuangye098/rocketmq

  1. private static Message buildMessage(final int messageSize) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic("BenchmarkTest");
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 10) {
  7.       sb.append("hello baby");
  8.     }
  10.     msg.setBody(sb.toString().getBytes(RemotingHelper.DEFAULT_CHARSET));
  12.     return msg;
  13.   }
  14. }

代码示例来源：origin: kuangye098/rocketmq

  1. private static Message buildMessage(final String topic, final int messageSize) throws UnsupportedEncodingException {
  2.     Message msg = new Message();
  3.     msg.setTopic(topic);
  5.     StringBuilder sb = new StringBuilder();
  6.     for (int i = 0; i < messageSize; i += 11) {
  7.       sb.append("hello jodie");
  8.     }
  9.     msg.setBody(sb.toString().getBytes(MixAll.DEFAULT_CHARSET));
  10.     return msg;
  11.   }
  12. }

代码示例来源：origin: majinkai/skye

  1. public void send(List<Span> spans) {
  2.   try {
  3.     for (Span span : spans) {
  4.       LOG.debug("Ready for send {}", span);
  5.       Message message = new Message(Header.MQ_TOPIC, Header.MQ_TAG, Serializer.ser(span));
  6.       SendResult sendResult = producer.send(message);
  7.       LOG.debug("SendResult={}", sendResult);
  8.     }
  9.   } catch (Exception e) {
  10.     LOG.error("Send message exception", e);
  11.   }
  12. }

代码示例来源：origin: coffeewar/enode-master

  1. /**
  2.    * 发送数据的接口
  3.    *
  4.    * @param keySet 本批次包含的keyset
  5.    * @param data 本批次的轨迹数据
  6.    */
  7.   private void sendTraceDataByMQ(Set<String> keySet, final String data, String currentRegionId) {
  8.     String topic = OnsTraceConstants.traceTopic + currentRegionId;
  9.     final Message message = new Message(topic, data.getBytes());
  10.     message.setKeys(keySet);
  11.     try {
  12.       traceProducer.send(message, new SendCallback() {
  13.         @Override
  14.         public void onSuccess(SendResult sendResult) {
  15.         }
  16.         @Override
  17.         public void onException(Throwable e) {
  18.           //todo 对于发送失败的数据，如何保存，保证所有轨迹数据都记录下来
  19.           clientlog.info("send trace data ,the traceData is " + data);
  20.         }
  21.       }, 5000);
  22.     } catch (Exception e) {
  23.       clientlog.info("send trace data,the traceData is" + data);
  24.     }
  25.   }
  26. }

代码示例来源：origin: kuangye098/rocketmq

  1. public static void main(String[] args) throws MQClientException, InterruptedException {
  3.     DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
  5.     producer.start();
  7.     for (int i = 0; i < 10000000; i++)
  8.       try {
  9.         {
  10.           Message msg = new Message("TopicTest",// topic
  11.               "TagA",// tag
  12.               "OrderID188",// key
  13.               ("Hello MetaQ").getBytes(RemotingHelper.DEFAULT_CHARSET));// body
  14.           SendResult sendResult = producer.send(msg);
  15.           System.out.println(sendResult);
  16.         }
  18.       } catch (Exception e) {
  19.         e.printStackTrace();
  20.       }
  22.     producer.shutdown();
  23.   }
  24. }

代码示例来源：origin: kuangye098/rocketmq

  1. public static void main(String[] args) throws MQClientException, InterruptedException {
  2.     DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
  3.     producer.start();
  5.     try {
  6.       for (int i = 0; i < 6000000; i++) {
  7.         Message msg = new Message("TopicFilter7",// topic
  8.             "TagA",// tag
  9.             "OrderID001",// key
  10.             ("Hello MetaQ").getBytes(RemotingHelper.DEFAULT_CHARSET));// body
  12.         msg.putUserProperty("SequenceId", String.valueOf(i));
  14.         SendResult sendResult = producer.send(msg);
  15.         System.out.println(sendResult);
  16.       }
  17.     } catch (Exception e) {
  18.       e.printStackTrace();
  19.     }
  21.     producer.shutdown();
  22.   }
  23. }

代码示例来源：origin: kuangye098/rocketmq

  1. public static void main(String[] args) throws MQClientException, InterruptedException {
  3.     DefaultMQProducer producer = new DefaultMQProducer("ProducerGroupName");
  5.     producer.start();
  7.     for (int i = 0; i < 1; i++)
  8.       try {
  9.         {
  10.           Message msg = new Message("TopicTest1",// topic
  11.               "TagA",// tag
  12.               "key113",// key
  13.               ("Hello MetaQ").getBytes(RemotingHelper.DEFAULT_CHARSET));// body
  14.           SendResult sendResult = producer.send(msg);
  15.           System.out.println(sendResult);
  17.           QueryResult queryMessage =
  18.               producer.queryMessage("TopicTest1", "key113", 10, 0, System.currentTimeMillis());
  19.           for (MessageExt m : queryMessage.getMessageList()) {
  20.             System.out.println(m);
  21.           }
  22.         }
  24.       } catch (Exception e) {
  25.         e.printStackTrace();
  26.       }
  28.     producer.shutdown();
  29.   }
  30. }

代码示例来源：origin: songxinjianqwe/EShop-SOA

  1. @Transactional
  2. @Override
  3. public void check() {
  4.   List<Long> all = mapper.findMessageIdsByStatusCreatedAfter(Arrays.asList(MessageStatus.UNCONSUMED, MessageStatus.CONSUME_FAILED), MQProducerConfig.CHECK_GAP);
  5.   Message checkMessage = new Message();
  6.   checkMessage.setTopic(config.getTopic());
  7.   checkMessage.setTags(config.getCheckKeys());
  8.   checkMessage.setBody(ProtoStuffUtil.serialize(all));
  9.   try {
  10.     producer.send(checkMessage);
  11.   } catch (Exception e) {
  12.     log.info("发送check消息失败，暂不做处理，不会影响数据一致性");
  13.     e.printStackTrace();
  14.   }
  15. }

代码示例来源：origin: songxinjianqwe/EShop-SOA

  1. @Override
  2. public void commit(OrderDO order, String paymentPassword) {
  3.   Message message = new Message();
  4.   message.setTopic(config.getTopic());
  5.   message.setBody(ProtoStuffUtil.serialize(order));
  6.   TransactionSendResult result = null;
  7.   try {
  8.     result = this.producer.sendMessageInTransaction(message, executor, paymentPassword);
  9.     log.info("事务消息发送结果：{}", result);
  10.     log.info("TransactionState:{} ", result.getLocalTransactionState());
  11.     // 因为无法获得executor中抛出的异常，只能模糊地返回订单支付失败信息。
  12.     // TODO 想办法从executor中找到原生异常
  13.   } catch (Exception e) {
  14.     log.info("AccountService抛出异常...");
  15.     e.printStackTrace();
  16.   }
  17.   if (result.getLocalTransactionState() == LocalTransactionState.ROLLBACK_MESSAGE) {
  18.     throw new OrderPaymentException(order.getId());
  19.   }
  20. }

代码示例来源：origin: songxinjianqwe/EShop-SOA

  1. @Transactional
  2. @Override
  3. public void reSend(List<ProducerTransactionMessageDO> messages) {
  4.   for (ProducerTransactionMessageDO messageDO : messages) {
  5.     if (messageDO.getSendTimes() == config.getRetryTimes()) {
  6.       messageDO.setUpdateTime(LocalDateTime.now());
  7.       messageDO.setMessageStatus(MessageStatus.OVER_CONFIRM_RETRY_TIME);
  8.       mapper.updateByPrimaryKeySelective(messageDO);
  9.       continue;
  10.     }
  11.     Message message = new Message();
  12.     message.setTopic(config.getTopic());
  13.     message.setBody(messageDO.getBody());
  14.     try {
  15.       SendResult result = producer.send(message);
  16.       messageDO.setSendTimes(messageDO.getSendTimes() + 1);
  17.       messageDO.setUpdateTime(LocalDateTime.now());
  18.       mapper.updateByPrimaryKeySelective(messageDO);
  19.       log.info("发送重试消息完毕,Message:{},result:{}", message, result);
  20.     } catch (Exception e) {
  21.       e.printStackTrace();
  22.       log.info("发送重试消息时失败! Message:{}", message);
  23.     }
  24.   }
  25. }

代码示例来源：origin: dubboclub/dubbo-plus

  1. @Override
  2.   public void push(List<Span> spanList) {
  3.     byte[] bytes = JSON.toJSONBytes(spanList);
  4.     Message message = new Message(DstConstants.ROCKET_MQ_TOPIC,bytes);
  5.     try {
  6.       SendResult sendResult = defaultMQProducer.send(message);
  7.       if(sendResult.getSendStatus()!= SendStatus.SEND_OK){
  8.         logger.error("send mq message return ["+sendResult.getSendStatus()+"]");
  9.       }
  10.     } catch (Exception e) {
  11.       logger.error("fail to send message.",e);
  12.     }
  13.   }
  14. }

代码示例来源：origin: coffeewar/enode-master

  1. private Message createEQueueMessage(IApplicationMessage message) {
  2.     TopicTagData topicTagData = _messageTopicProvider.getPublishTopic(message);
  3.     String appMessageData = _jsonSerializer.serialize(message);
  4.     ApplicationDataMessage appDataMessage = new ApplicationDataMessage(appMessageData, message.getClass().getName());
  6.     String data = _jsonSerializer.serialize(appDataMessage);
  8.     Message mqMessage =  new Message(topicTagData.getTopic(), //topic
  9.         //_typeNameProvider.getTypeName(message.getClass()), //tags
  10.         topicTagData.getTag(), //tag
  11.         message.id(), // keys
  12.         RocketMQMessageTypeCode.ApplicationMessage.getValue(), // flag
  13.         BitConverter.getBytes(data), // body
  14.         true);
  16.     if (message.getStartDeliverTime() > 0) {
  17.       mqMessage.putUserProperty(CommandService.RocketMQSystemPropKey.STARTDELIVERTIME, String.valueOf(message.getStartDeliverTime()));
  18.     }
  20.     return mqMessage;
  21.   }
  22. }

代码示例来源：origin: coffeewar/enode-master

  1. private Message buildCommandMessage(ICommand command, boolean needReply) {
  2.     Ensure.notNull(command.getAggregateRootId(), "aggregateRootId");
  3.     String commandData = _jsonSerializer.serialize(command);
  4.     TopicTagData topicTagData = _commandTopicProvider.getPublishTopic(command);
  5.     String replyAddress = needReply && _commandResultProcessor != null ? parseAddress(_commandResultProcessor.getBindingAddress()) : null;
  6. //        String replyAddress = null;
  7.     String messageData = _jsonSerializer.serialize(new CommandMessage(commandData, replyAddress, command.getClass().getName()));
  9.     byte[] body = BitConverter.getBytes(messageData);
  11.     String key = buildRocketMQMessageKey(command);
  13.     Message message = new Message(topicTagData.getTopic(),
  14.         topicTagData.getTag(),
  15.         key,
  16.         RocketMQMessageTypeCode.CommandMessage.ordinal(), body, true);
  18.     if (command.getStartDeliverTime() > 0) {
  19.       message.putUserProperty(RocketMQSystemPropKey.STARTDELIVERTIME, String.valueOf(command.getStartDeliverTime()));
  20.     }
  22.     return message;
  23.   }

代码示例来源：origin: coffeewar/enode-master

  1. private Message createRocketMQMessage(DomainEventStreamMessage eventStream) {
  2.   Ensure.notNull(eventStream.aggregateRootId(), "aggregateRootId");
  3.   EventStreamMessage eventMessage = createEventMessage(eventStream);
  4.   TopicTagData topicTagData = _eventTopicProvider.getPublishTopic(null);
  5.   String data = _jsonSerializer.serialize(eventMessage);
  6.   String key = buildRocketMQMessageKey(eventStream);
  7.   byte[] body = BitConverter.getBytes(data);
  8.   return new Message(topicTagData.getTopic(),
  9.       topicTagData.getTag(),
  10.       key,
  11.       RocketMQMessageTypeCode.DomainEventStreamMessage.getValue(), body, true);
  12. }

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

  1. public boolean sendMessageBack(final MessageExt msg) {
  2.   try {
  3.     Message newMsg = new Message(MixAll.getRetryTopic(this.defaultMQPushConsumer.getConsumerGroup()), msg.getBody());
  4.     String originMsgId = MessageAccessor.getOriginMessageId(msg);
  5.     MessageAccessor.setOriginMessageId(newMsg, UtilAll.isBlank(originMsgId) ? msg.getMsgId() : originMsgId);
  6.     newMsg.setFlag(msg.getFlag());
  7.     MessageAccessor.setProperties(newMsg, msg.getProperties());
  8.     MessageAccessor.putProperty(newMsg, MessageConst.PROPERTY_RETRY_TOPIC, msg.getTopic());
  9.     MessageAccessor.setReconsumeTime(newMsg, String.valueOf(msg.getReconsumeTimes()));
  10.     MessageAccessor.setMaxReconsumeTimes(newMsg, String.valueOf(this.defaultMQPushConsumer.getMaxReconsumeTimes()));
  11.     newMsg.setDelayTimeLevel(3 + msg.getReconsumeTimes());
  12.     this.defaultMQPushConsumer.getDefaultMQPushConsumerImpl().getmQClientFactory().getDefaultMQProducer().send(newMsg);
  13.     return true;
  14.   } catch (Exception e) {
  15.     log.error("sendMessageBack exception, group: " + this.consumerGroup + " msg: " + msg.toString(), e);
  16.   }
  17.   return false;
  18. }

代码示例来源：origin: kuangye098/rocketmq

  1. public boolean sendMessageBack(final MessageExt msg) {
  2.   try {
  3.     Message newMsg = new Message(MixAll.getRetryTopic(this.defaultMQPushConsumer.getConsumerGroup()), msg.getBody());
  4.     String originMsgId = MessageAccessor.getOriginMessageId(msg);
  5.     MessageAccessor.setOriginMessageId(newMsg, UtilAll.isBlank(originMsgId) ? msg.getMsgId() : originMsgId);
  6.     newMsg.setFlag(msg.getFlag());
  7.     MessageAccessor.setProperties(newMsg, msg.getProperties());
  8.     MessageAccessor.putProperty(newMsg, MessageConst.PROPERTY_RETRY_TOPIC, msg.getTopic());
  9.     MessageAccessor.setReconsumeTime(newMsg, String.valueOf(msg.getReconsumeTimes()));
  10.     MessageAccessor.setMaxReconsumeTimes(newMsg, String.valueOf(this.defaultMQPushConsumer.getMaxReconsumeTimes()));
  11.     newMsg.setDelayTimeLevel(3 + msg.getReconsumeTimes());
  12.     this.defaultMQPushConsumer.getDefaultMQPushConsumerImpl().getmQClientFactory().getDefaultMQProducer().send(newMsg);
  13.     return true;
  14.   } catch (Exception e) {
  15.     log.error("sendMessageBack exception, group: " + this.consumerGroup + " msg: " + msg.toString(), e);
  16.   }
  17.   return false;
  18. }

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

  1. public void sendMessageBack(MessageExt msg, int delayLevel, final String brokerName)
  2.     throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
  3.   try {
  4.     String brokerAddr = (null != brokerName) ? this.mQClientFactory.findBrokerAddressInPublish(brokerName)
  5.         : RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());
  6.     this.mQClientFactory.getMQClientAPIImpl().consumerSendMessageBack(brokerAddr, msg,
  7.         this.defaultMQPushConsumer.getConsumerGroup(), delayLevel, 5000, this.defaultMQPushConsumer.getMaxReconsumeTimes());
  8.   } catch (Exception e) {
  9.     log.error("sendMessageBack Exception, " + this.defaultMQPushConsumer.getConsumerGroup(), e);
  10.     Message newMsg = new Message(MixAll.getRetryTopic(this.defaultMQPushConsumer.getConsumerGroup()), msg.getBody());
  11.     String originMsgId = MessageAccessor.getOriginMessageId(msg);
  12.     MessageAccessor.setOriginMessageId(newMsg, UtilAll.isBlank(originMsgId) ? msg.getMsgId() : originMsgId);
  13.     newMsg.setFlag(msg.getFlag());
  14.     MessageAccessor.setProperties(newMsg, msg.getProperties());
  15.     MessageAccessor.putProperty(newMsg, MessageConst.PROPERTY_RETRY_TOPIC, msg.getTopic());
  16.     MessageAccessor.setReconsumeTime(newMsg, String.valueOf(msg.getReconsumeTimes() + 1));
  17.     MessageAccessor.setMaxReconsumeTimes(newMsg, String.valueOf(this.defaultMQPushConsumer.getMaxReconsumeTimes()));
  18.     newMsg.setDelayTimeLevel(3 + msg.getReconsumeTimes());
  19.     this.mQClientFactory.getDefaultMQProducer().send(newMsg);
  20.   }
  21. }

代码示例来源：origin: kuangye098/rocketmq

  1. public void sendMessageBack(MessageExt msg, int delayLevel, final String brokerName)
  2.     throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
  3.   try {
  4.     String brokerAddr = (null != brokerName) ? this.mQClientFactory.findBrokerAddressInPublish(brokerName)
  5.         : RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());
  6.     this.mQClientFactory.getMQClientAPIImpl().consumerSendMessageBack(brokerAddr, msg,
  7.         this.defaultMQPushConsumer.getConsumerGroup(), delayLevel, 5000, this.defaultMQPushConsumer.getMaxReconsumeTimes());
  8.   } catch (Exception e) {
  9.     log.error("sendMessageBack Exception, " + this.defaultMQPushConsumer.getConsumerGroup(), e);
  10.     Message newMsg = new Message(MixAll.getRetryTopic(this.defaultMQPushConsumer.getConsumerGroup()), msg.getBody());
  11.     String originMsgId = MessageAccessor.getOriginMessageId(msg);
  12.     MessageAccessor.setOriginMessageId(newMsg, UtilAll.isBlank(originMsgId) ? msg.getMsgId() : originMsgId);
  13.     newMsg.setFlag(msg.getFlag());
  14.     MessageAccessor.setProperties(newMsg, msg.getProperties());
  15.     MessageAccessor.putProperty(newMsg, MessageConst.PROPERTY_RETRY_TOPIC, msg.getTopic());
  16.     MessageAccessor.setReconsumeTime(newMsg, String.valueOf(msg.getReconsumeTimes() + 1));
  17.     MessageAccessor.setMaxReconsumeTimes(newMsg, String.valueOf(this.defaultMQPushConsumer.getMaxReconsumeTimes()));
  18.     newMsg.setDelayTimeLevel(3 + msg.getReconsumeTimes());
  19.     this.mQClientFactory.getDefaultMQProducer().send(newMsg);
  20.   }
  21. }

代码示例来源：origin: com.alibaba.rocketmq/rocketmq-client

  1. public void sendMessageBack(MessageExt msg, int delayLevel, final String brokerName, String consumerGroup)
  2.     throws RemotingException, MQBrokerException, InterruptedException, MQClientException {
  3.   try {
  4.     String brokerAddr = (null != brokerName) ? this.mQClientFactory.findBrokerAddressInPublish(brokerName)
  5.         : RemotingHelper.parseSocketAddressAddr(msg.getStoreHost());
  6.     if (UtilAll.isBlank(consumerGroup)) {
  7.       consumerGroup = this.defaultMQPullConsumer.getConsumerGroup();
  8.     }
  9.     this.mQClientFactory.getMQClientAPIImpl().consumerSendMessageBack(brokerAddr, msg, consumerGroup, delayLevel, 3000,
  10.         this.defaultMQPullConsumer.getMaxReconsumeTimes());
  11.   } catch (Exception e) {
  12.     log.error("sendMessageBack Exception, " + this.defaultMQPullConsumer.getConsumerGroup(), e);
  13.     Message newMsg = new Message(MixAll.getRetryTopic(this.defaultMQPullConsumer.getConsumerGroup()), msg.getBody());
  14.     String originMsgId = MessageAccessor.getOriginMessageId(msg);
  15.     MessageAccessor.setOriginMessageId(newMsg, UtilAll.isBlank(originMsgId) ? msg.getMsgId() : originMsgId);
  16.     newMsg.setFlag(msg.getFlag());
  17.     MessageAccessor.setProperties(newMsg, msg.getProperties());
  18.     MessageAccessor.putProperty(newMsg, MessageConst.PROPERTY_RETRY_TOPIC, msg.getTopic());
  19.     MessageAccessor.setReconsumeTime(newMsg, String.valueOf(msg.getReconsumeTimes() + 1));
  20.     MessageAccessor.setMaxReconsumeTimes(newMsg, String.valueOf(this.defaultMQPullConsumer.getMaxReconsumeTimes()));
  21.     newMsg.setDelayTimeLevel(3 + msg.getReconsumeTimes());
  22.     this.mQClientFactory.getDefaultMQProducer().send(newMsg);
  23.   }
  24. }

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com