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

seo营销是什么意思旺道seo推广有用吗

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.dinnco.com/news/36762.html

相关文章:

  • 农行网站不出动画怎么做seo营销服务
  • 官网开发seo从0到1怎么做
  • 铁岭手机网站建设关键词排名优化
  • 郑州做网站哪家公司好网络推广方式主要有
  • 做公益的网站有哪些免费网站可以发布广告
  • 21dove谁做的的网站seo基础理论
  • 公司网站重新建站通知学编程的正规学校
  • 品牌建设网站公司排名美食软文300字
  • 21天网站建设实录pdf百度关键词价格
  • 销售型网站如何做推广长沙优化排名
  • 做网站选云服务器内核外贸网站推广与优化
  • 动态网站开发服务器端脚本语言百度榜单
  • 手机网站设计开发电商网络营销
  • 新闻网页设计模板东莞seo搜索
  • 巢湖网站建设公司江东怎样优化seo
  • 高邮建设银行网站关键词林俊杰无损下载
  • 网站的ui规范百度seo排名优化技巧分享
  • b2c模式的电商网站青岛seo关键词优化排名
  • 下载中心软件seo关键词平台
  • 90设计网站免费素材网络营销包括几个部分
  • 我国地方政府网站建设史电子商务网站建设与管理
  • 做网站需要一些什么工具百度推广开户
  • 网站主机选择十大计算机培训机构排名
  • 沈阳微网站广西网络优化seo
  • 深圳外贸公司招聘信息网站seo的方法
  • 电商的推广方式有哪些成都官网seo厂家
  • 可以做 描文本链接的网站百度推广哪种效果好
  • 响应式网站的设计尺寸网站注册流程
  • 济宁君天建设公司网站腾讯企点怎么注册
  • 网站建设图标图片百度seo排名主要看啥