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

小程序商城哪家好些宁波seo网络推广外包报价

小程序商城哪家好些,宁波seo网络推广外包报价,乡镇网站模板,外管局网站先支后收怎么做报告一、概述 RocketMQ可以一次性发送一组消息,那么这一组消息会被当做一个消息进行消费。 二、案例代码 2.1、pom 同系列五 2.2、RocketMQConstant 同系列五 2.3、BatchConsumer package org.star.batch.consumer;import cn.hutool.core.util.StrUtil; import lom…

一、概述

        RocketMQ可以一次性发送一组消息,那么这一组消息会被当做一个消息进行消费。

二、案例代码

2.1、pom

        同系列五

2.2、RocketMQConstant

        同系列五

2.3、BatchConsumer

package org.star.batch.consumer;import cn.hutool.core.util.StrUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
import org.apache.rocketmq.common.message.MessageExt;
import org.star.constants.RocketMQConstant;import java.util.List;/*** @Author: 一叶浮萍归大海* @Date: 2023/8/30 09:40* @Description: 批量消息消费者*/
@Slf4j
public class BatchConsumer {public static void main(String[] args) throws Exception {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("BatchConsumerGroup");consumer.setNamesrvAddr(RocketMQConstant.NAME_SERVER_ADDR);consumer.subscribe("BatchTopic","*");consumer.setMessageListener(new MessageListenerConcurrently() {@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> list, ConsumeConcurrentlyContext context) {if (CollectionUtils.isNotEmpty(list)) {String body = StrUtil.utf8Str(list.get(0).getBody());log.info(Thread.currentThread().getName() + " 收到消息 body:{}",body);}return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});consumer.start();log.info("BatchConsumer start success!");}}

2.4、BatchProducer

package org.star.batch.producer;import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.star.constants.RocketMQConstant;import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.List;/*** @Author: 一叶浮萍归大海* @Date: 2023/8/30 09:31* @Description: 批量消息生产者* 批量消息是指将多条消息合并成一个批量消息,一次发送出去,这样的好处是可以减少网络IO,提升吞吐量。* 注意事项:* 1、消息大小不能超过4MB,虽然源码注释不能超过1MB,但是实际使用不超过4MB即可,建议保持在1MB左右* 2、相同的Topic* 3、相同的waitStoreMsgOK* 4、不能是延迟消息,事务消息等*/
@Slf4j
public class BatchProducer {public static void main(String[] args) throws Exception {DefaultMQProducer producer = new DefaultMQProducer("BatchProducerGroup");producer.setNamesrvAddr(RocketMQConstant.NAME_SERVER_ADDR);producer.start();log.info("BatchProducer start success");List<Message> messages = new ArrayList<>();for (int i = 0; i < 3; i++) {Message message = new Message("BatchTopic", ("我是批量消息,消息编号[" + i + "]").getBytes(StandardCharsets.UTF_8));messages.add(message);}SendResult result = producer.send(messages);log.info("BatchProducer sendStatus:{},queueId:{},msgId:{}", result.getSendStatus(), result.getMessageQueue().getQueueId(), result.getMsgId());producer.shutdown();}}

2.5、控制台打印

# 生产者端
22:49:44.236 [main] INFO org.star.batch.producer.BatchProducer - BatchProducer start success
22:49:45.625 [main] INFO org.star.batch.producer.BatchProducer - BatchProducer sendStatus:SEND_OK,queueId:0,msgId:C0A81FB287E018B4AAC20F32C5870000,C0A81FB287E018B4AAC20F32C5880001,C0A81FB287E018B4AAC20F32C5880002# 消费者端
22:47:20.127 [main] INFO org.star.batch.consumer.BatchConsumer - BatchConsumer start success!
22:49:45.644 [ConsumeMessageThread_2] INFO org.star.batch.consumer.BatchConsumer - ConsumeMessageThread_2 收到消息 body:我是批量消息,消息编号[1]
22:49:45.644 [ConsumeMessageThread_3] INFO org.star.batch.consumer.BatchConsumer - ConsumeMessageThread_3 收到消息 body:我是批量消息,消息编号[2]
22:49:45.644 [ConsumeMessageThread_1] INFO org.star.batch.consumer.BatchConsumer - ConsumeMessageThread_1 收到消息 body:我是批量消息,消息编号[0]

http://www.hengruixuexiao.com/news/23890.html

相关文章:

  • 改行做网站2022黄页全国各行业
  • 网站怎么做关键词优化成都高端网站建设哪家好
  • 国外公司网站设计广西壮族自治区
  • .net 做网站百度搜索优化怎么做
  • 建设企业网站所遵循的一般原则网络推广优化工具
  • rar在线解压缩网站厦门人才网个人会员
  • 网站设计项目明细淮南网站seo
  • 品牌网络营销策划青岛百度推广优化
  • 广东专业网站客服软件定制西安网站建设排名
  • 如何法院网站建设商品促销活动策划方案
  • 爱藏网一家专业做收藏品的网站免费发布广告信息平台
  • 网站建设销售怎么样优化排名seo
  • wordpress主题图片百度推广关键词怎么优化
  • 绍兴网站建设郑州网站seo优化
  • 企业网站建设的核心全球十大搜索引擎排名及网址
  • 怎么做网站demo百度推广引流
  • 做网站公司哪个好营销软件培训
  • wordpress 加速插件宁波网站seo公司
  • 做网站开发需要学什么软件绍兴seo公司
  • 携程电子商务网站建设上海网络推广营销策划方案
  • 响应式模板网站建设网站流量查询网站统计查询
  • 如何建设网站的管理平台做网站推广一般多少钱
  • 工信部备案网站查询宁波网站建设公司
  • 驰业网站建设中国教育培训网
  • wordpress新建网站seo企业站收录
  • 类似开发次元世界seo是什么意思电商
  • 站酷设计网站首页win10优化大师怎么样
  • 主流网站类型广告公司联系方式
  • 做消费信贷网站价格网上推销产品的软件
  • 宣城网站优化网页设计友情链接怎么做