当前位置: 首页 > news >正文

惠州微网站推广方案家具设计师培训

惠州微网站推广方案,家具设计师培训,网页制作h5,程序员外包公司是什么意思优点: 批量发送消息可以提高rocketmq的生产者性能和吞吐量。 使用场景: 发送大量小型消息时;需要降低消息发送延迟时;需要提高生产者性能时; 注意事项: 消息列表的大小不能超过broker设置的最大消息大小;消息列表…

优点:

批量发送消息可以提高rocketmq的生产者性能和吞吐量。

使用场景:

  1. 发送大量小型消息时;
  2. 需要降低消息发送延迟时;
  3. 需要提高生产者性能时;

注意事项:

  1. 消息列表的大小不能超过broker设置的最大消息大小;
  2. 消息列表的大小不能超过生产证设置的maxMessageSize 参数,此参数默认为 4MB;
  3. 批量发送消息不支持消息事务;
  4. 如果代码在发送消息列表时发生异常,则可能会发生部分消息发送成功,部分消息发送失败的情况。如果要确保所有消息都已成功发送,则需要增加错误处理逻辑和消息重试机制;


批量发送消息为什么要限制maxMessageSize❓

消息列表的大小不能超过生产者设置的maxMessageSize参数,主要是为了避免消息发送延迟和消息过大导致broker出现性能问题。如果尝试发送大于maxMessageSize的消息,RocketMQ会抛出MessageTooLargeException异常,并且消息不会被发送到broker。

如果开发者在开发时遇到了消息列表大小超过maxMessageSize的情况,可以考虑以下几种处理方式:

    1. 提升maxMessageSize参数的大小,这样可以容纳更大的消息列表。但是,需要注意在提升参数大小时,要考虑到RocketMQ broker的性能和网络带宽等因素。
    2. 考虑将消息列表进行拆分,然后分批发送。这样可以避免一次发送过多的消息。
    3. 计算消息的大小并进行压缩。可以使用一些压缩算法,如 LZ4、Snappy 等,对消息进行压缩,以减小消息的大小。
    4. 对超过 maxMessageSize 的消息进行过滤或其他处理。可以通过业务逻辑对消息进行分组或分类,对超过 maxMessageSize 的消息进行过滤或其他处理,以避免发送超出限制的消息。

代码实现

package com.resource.sync.rocketmq;import java.util.Iterator;
import java.util.List;/*** @description:消息分割,在rocketmq中,一次性发送消息的长度不可超过4mb,此时我们需要进行切割,确保消息长度小于4mb**/
public class ListSplitter<T> implements Iterator<List<T>> {/*** 分割数据大小*/private int sizeLimit;/*** 分割数据列表*/private final List<T> messages;/*** 分割索引*/private int currIndex;public ListSplitter(int sizeLimit, List<T> messages) {this.sizeLimit = sizeLimit;this.messages = messages;}@Overridepublic boolean hasNext() {return currIndex < messages.size();}@Overridepublic List<T> next() {int nextIndex = currIndex;int totalSize = 0;for (; nextIndex < messages.size(); nextIndex++) {T t = messages.get(nextIndex);totalSize = totalSize + t.toString().length();if (totalSize > sizeLimit) {break;}}List<T> subList = messages.subList(currIndex, nextIndex);currIndex = nextIndex;return subList;}
}
    private final int maxMessageSize = 1024 * 1024 * 4;/*** 消息分割(批量发送)*/private void bulkSendMsg(List<Message<String>> messageList) {// 限制数据大小ListSplitter splitter = new ListSplitter(maxMessageSize, messageList);while (splitter.hasNext()) {List<Message> nextList = splitter.next();syncBulkSendMessage("topic", nextList);}}/*** @param topic* @param list* @description:发送实时消息(批量)*/public void syncBulkSendMessage(String topic, List<Message> list) {SendResult sendResult = null;try {sendResult = rocketMQTemplate.syncSend(topic, list);if (sendResult.getSendStatus() != SendStatus.SEND_OK) {log.error("BULK_ROCKET_MQ_DISTRIBUTION_ERROR.RESULT_STATUS:{},MSG_ID:{}", sendResult.getSendStatus(), sendResult.getMsgId());}if (sendResult.getSendStatus() == SendStatus.SEND_OK) {log.info("BULK_SEND_MSG_SUCCESS.MSG_ID:{}", sendResult.getMsgId());}} catch (Exception e) {log.error("BULK_ROCKET_MQ_DISTRIBUTION_ERROR:{}", e);}}

http://www.yayakq.cn/news/147506/

相关文章:

  • 教研室网站建设深圳小程序网站开发公司
  • 网站首页制作浩森宇特网站开发工程师和软件工程
  • 专业的广州手机网站建设网站需要展示什么名字
  • 做网站广告网页公司网站制作 步骤
  • 网站开发用php还是.net好安徽省建设工程资料上传网站
  • 温州产品推广网站网站顶部导航代码
  • dw做的网站链接写软文平台
  • 微信网页宣传网站怎么做的不利于网站收录
  • 山东岩海建设资源有限公司网站系统总裁
  • 陕西交通建设集团公司网站网上花店网页制作素材
  • 电商网站建设方案道客巴巴金华网站建设yw126
  • qq代刷网站推广免费肥猫网站建设
  • 购物网站宣传方案西地那非片的副作用
  • 网站营销做网站 什么后缀
  • 苏州网站建设公司crm管理系统的优缺点
  • 网站制作商家入驻徐州最新消息今天
  • 合肥网站建设=388元山西企业模板建站
  • 江油网站网站建设廊坊建设网站的公司
  • 怎么封闭网站网站运营的具体工作包括哪些
  • it网站建设干嘛的商务网站的主要存在形式
  • 鄂州网站seo网站直接登陆wordpress
  • 大连大连建设工程信息网站做译员的网站
  • 梅州英文网站建设微信开放平台怎么申请
  • 餐饮网站建设设计价格搭建个人博客wordpress
  • 网站建设教程网站开发项目流程图模板
  • 行政审批网站开发文档网站制作背景
  • 网站快备佛山市住房建设局网站
  • 做网站需要哪些工程师乡镇信息公开网站建设制度
  • 网站在线统计代码做二手网站好的名字
  • 同城信息网站建设DW做旅游网站毕业设计