RocketMQ快速入门:集成java客户端实现各类消息发送|异步、同步、顺序、单向、延迟、事务(五)附带源码

0. 引言

前面的章节中,我们已经针对rocketmq的基本概念和消息发送、消费流程进行了讲解,但实际在开发中如何实现rocketmq的接入、实现消息发送、消费还没有落实,那么今天,我们继续来学习如何基于java client集成rocketMQ

1. 集成rocketMQ

1、spring或其他java框架集成rocektmq很简单,只需要引入rocketmq依赖即可, 这里的版本号与你的rocketmq保持一致

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.8.0</version>
</dependency>

1.1 消息同步发送

官方文档:https://rocketmq.apache.org/zh/docs/4.x/producer/02message1/

1.1.1 实现步骤

1、实现消息发送需要利用生产者类DefaultMQProducer实现,以下示例简单消息的同步发送

public static void main(String[] args) throws MQClientException, MQBrokerException, RemotingException, InterruptedException {// 声明groupDefaultMQProducer producer = new DefaultMQProducer("group_test");// 声明namesrv地址producer.setNamesrvAddr("localhost:9876");// 启动实例producer.start();// 设置消息的topic,tag以及消息体Message msg = new Message("topic_test", "tag_test", "消息内容".getBytes(StandardCharsets.UTF_8));// 发送消息,并设置10s连接超时SendResult send = producer.send(msg, 10000);System.out.println("发送结果:"+send);// 关闭实例producer.shutdown();}

2、当然,实际生产中,最好不要每次发送消息都创建新的生产者,于是我们需要将其封装成一个bean,实现起来也很简单

@Configuration
public class RocketMQConfig {// 配置项大家自定义即可@Value("${rocketmq.name-server}")private String nameSrvAddr;@Value("${rocketmq.producer.group}")private String producerGroup;private DefaultMQProducer producer;@Beanpublic DefaultMQProducer mqProducer(){producer = new DefaultMQProducer(producerGroup);producer.setNamesrvAddr(nameSrvAddr);try {producer.start();} catch (MQClientException e) {e.printStackTrace();}return producer;}}

3、调用:

 @Resourceprivate DefaultMQProducer mqProducer;@GetMapping("send2")public String send2(){org.apache.rocketmq.common.message.Message msg = new org.apache.rocketmq.common.message.Message("topic_test", "tag_test", "消息内容".getBytes(StandardCharsets.UTF_8));try {mqProducer.send(msg, 1000);} catch (Exception e) {e.printStackTrace();return "fail";}return "success";}

4、因为没有实现DefaultMQProducer的自动关闭,如果要进一步优化,大家可以利用InitializingBean, DisposableBean两个接口实现afterPropertiesSetdestroy,实现资源的自动启动、自动关闭,比如通过destroy实现producer的自动关闭:

    @Overridepublic void destroy() {if (Objects.nonNull(this.producer)) {this.producer.shutdown();}}

5、发送结果如下所示
在这里插入图片描述
SendResult [sendStatus=SEND_OK, msgId=7F00000135DA18B4AAC20E15FE090000, offsetMsgId=C0A8F40100002A9F000000000000C307, messageQueue=MessageQueue [topic=topic_test, brokerName=broker, queueId=15], queueOffset=7]

1.1.1 消息重试设置

实际生产时,可能因为网络波动等不确定原因,导致服务连接出现短时问题,如果恰巧这时我们发送了消息,就会导致发送失败。所以一般我们还会设置消息的重试,只需要调用setRetryTimesWhenSendFailed方法即可

// 设置发送失败时重试次数
producer.setRetryTimesWhenSendFailed(2);

1.2 消息异步发送

消息同步发送可以保证顺序性,但是部分场景我们无需考虑发送次序,并且同步发送如果前面的发送阻塞了,反而会影响后续的发送效率。于是异步发送就产生了。

1、通过查看DefaultMQProducer类可以看到,发送方法中有一个SendCallback参数,这实际就是异步发送的回调方法参数,通过他我们就可以实现异步发送了
在这里插入图片描述

2、实现代码

import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.apache.rocketmq.remoting.exception.RemotingException;import java.nio.charset.StandardCharsets;/*** @author benjamin_5* @Description* @date 2024/2/25*/
public class Producer2AsyncDemo {public static void main(String[] args) throws MQClientException, MQBrokerException, RemotingException, InterruptedException {DefaultMQProducer producer = new DefaultMQProducer("group_test");producer.setNamesrvAddr("127.0.0.1:9876");// 启动实例producer.start();for (int i = 0; i < 10; i++) {Message msg = new Message("topic_test", "tag_test", ("hello "+ i).getBytes(StandardCharsets.UTF_8));producer.send(msg, new SendCallback() {@Overridepublic void onSuccess(SendResult sendResult) {System.out.println(new String(msg.getBody(), StandardCharsets.UTF_8)+"发送结果:"+sendResult);}@Overridepublic void onException(Throwable e) {System.out.println("异常:"+e);e.printStackTrace();}});}// 等待发送完再结束主线程Thread.sleep(10000);producer.shutdown();}
}

3、通过观察发送结果,我们也能看出是无序的异步发送
在这里插入图片描述

1.3 消息单向发送

单向消息主要适用于非核心日志等允许消息丢失的场景,其方法是没有返回值的,也就是拿不到响应结果,当然好处就是:快!

单向消息支持同步和异步,通过参数可以了解
在这里插入图片描述
示例代码如下:

public class Producer5OneWayDemo {public static void main(String[] args) throws Exception{// 声明groupDefaultMQProducer producer = new DefaultMQProducer("group_test");// 声明namesrv地址producer.setNamesrvAddr("localhost:9876");// 设置重试次数producer.setRetryTimesWhenSendFailed(2);// 启动实例producer.start();// 设置消息的topic,tag以及消息体Message msg = new Message("topic_test", "tag_test", "单向消息".getBytes(StandardCharsets.UTF_8));// 发送消息producer.sendOneway(msg);// 关闭实例producer.shutdown();}
}

1.4 消息顺序发送

官方文档:https://rocketmq.apache.org/zh/docs/4.x/producer/03message2

顺序消息在对流程有严格顺序要求的业务场景有广泛应用,比如订单的创建、付款、发货、签收,这几个状态流程必须保持顺序。

而顺序消息的实现也分成两部分:顺序发送、顺序消费。本章我们主要针对顺序发送进行讲解,顺序消费我们将在下一章继续说明。这里需要注意的是,顺序发送不等于同步发送,虽然同步发送也保持一定的顺序性,但想象如果多个线程发送多个同步消息,那消息还具有顺序性吗? 这就不一定了。那顺序发送就是单线程的同步发送吗?

1、单线程的同步发送其实也不能满足顺序性,比如如下的场景,生产者单线程同步发送了两条消息A1,A2, MQ会将其负载到不同的队列存储,然后消费者可能有多个,消费时就容易产生同时从这两个队列消费,从而就不能保证A1一定在A2之前被消费掉。于是单线程的同步发送其实并不能保证顺序性,那么怎么处理呢?

在这里插入图片描述

2、既然会发送到不同的队列导致同时消费的可能性,那我们就确保同一数据发送到同一队列,比如同一订单的创建、付款、签收都发送到一个队列中,如此来保证发送的顺序性

在这里插入图片描述

3、所以,顺序发送的重点,也在于让同类消息发送到同一队列上,rocketmq中是通过队列选择器MessageQueueSelector来实现的

我们查看send方法,需要提供3个参数:消息、队列选择器和一个arg。前两个参数可以理解,那么这个arg是什么呢,其实就是我们用于区分消息类型的标识,比如为了防止上述的混淆,我们要将同一订单的不同状态的消息都发送到同一个队列中,那么我们就可以以订单号作为这个标识,其目的就是将同一类型的消息通过这个标识进行区分。
在这里插入图片描述

4、在发送消息之间,我们需要创建队列,并且将队列指定为顺序队列,即创建队列时指定–order参数为true
(1)我们需要通过namesrv内置的mqadmin工具来实现指定
(2)进入namesrv,在其安装目录的bin目录下执行(如果你和我一样是通过docker安装的rocketmq,那直接进入docker namesrv的容器即可, 进入后的当前目录就是bin目录)

./mqadmin updateTopic -c DefaultCluster -t topic_order -o true -n localhost:9876

-n NameServer的地址和端口
-c 指定集群名称
-t 指定主题名称
-w 指定队列的数量,如果要保证全局顺序性,可以设置队列数为1,以此来避免多队列产生的非顺序性问题

在这里插入图片描述
5、其次如果需要保证严格的顺序性,还需要在namesrv中配置orderMessageEnablereturnOrderTopicConfigToBroker 是 true

(注:默认配置文件为namesrv.properties(通过./mqnamesrv -p即可查看配置文件路径),也可通过创建自定义配置文件namesrv.conf, 启动namesrv时指定配置文件nohup sh bin/mqnamesrv -c conf/namesrv.conf &, 本文示例无需配置该项也可保证顺序性,但生产时建议配置)

orderMessageEnable=true
returnOrderTopicConfigToBroker=true

6、整体的顺序发送代码如下,这里我简单使用一个orderId作为区分标识(也叫区分键),将奇数和偶数消息分别视为一种消息,大家实际应用时可以根据自己的业务调整。

其MessageQueueSelector对象的定义,主要是实现其select方法,这里就是通过arg参数,做取余运算,进行队列的选择。当然大家也可以用arg的hashcode来作为标识处理

 public static void main(String[] args) throws Exception{DefaultMQProducer producer = new DefaultMQProducer("group_test");// 声明namesrv地址producer.setNamesrvAddr("localhost:9876");// 设置重试次数producer.setRetryTimesWhenSendFailed(2);// 启动实例producer.start();// 设置消息的topic,tag以及消息体Message msg = new Message("topic_test", "tag_test", "消息内容".getBytes(StandardCharsets.UTF_8));// 要求发送顺序:i为偶数先发,然后按照由小到大顺序发送for (int i = 0; i < 10; i++) {// 模拟偶数、奇数分别属于一类消息int orderId = i % 2;SendResult result = producer.send(msg, new MessageQueueSelector() {/**** @param list 消息队列集合* @param message 消息* @param arg send方法中传入的第三参数,即orderId参数,orderId可以是Object类型* @return*/@Overridepublic MessageQueue select(List<MessageQueue> list, Message message, Object arg) {Integer orderId = (Integer) arg;int index = orderId % list.size();return list.get(index);}}, orderId);System.out.println("发送结果:"+result.toString());}producer.shutdown();}

7、提前用顺序消费的代码来消费验证下

public class Consumer2OrderDemo {public static void main(String[] args) throws InterruptedException, MQClientException {DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group_test");consumer.setNamesrvAddr("127.0.0.1:9876");// 集群消费模式consumer.setMessageModel(MessageModel.CLUSTERING);// 设置topicconsumer.subscribe("topic_order", "*");// 注册回调函数,处理消息consumer.registerMessageListener(new MessageListenerOrderly() {@Overridepublic ConsumeOrderlyStatus consumeMessage(List<MessageExt> list, ConsumeOrderlyContext consumeOrderlyContext) {byte[] body = list.get(0).getBody();System.out.println("接收消息:"+new String(body, StandardCharsets.UTF_8));return ConsumeOrderlyStatus.SUCCESS;}});// 启动消费者实例consumer.start();Thread.sleep(10000);}
}

消费到的消息如下所示,可以看到奇偶是分别保持顺序的,即:0,2,4,6,8 和1,3,5,7,9
在这里插入图片描述

最后总结一下,顺序发送的前提要满足两点:

  • 单一生产者:不同的生产者部署在不同的服务器,哪怕使用相同的区分键,也可能导致不同生产者之间的消息无法区分顺序性
  • 串行发送:多线程发送可能会导致并发发送,从而导致破坏消息顺序性

因此rocketmq的顺序消息,实际是基于队列的顺序消息,不同队列之间的消息是不满足顺序性的。这一点大家要注意。

1.5 消息批量发送

官方文档:https://rocketmq.apache.org/zh/docs/4.x/producer/05message4

批量消息相对比较简单,从发送方法中可以看到支持集合形式的message对象
在这里插入图片描述
因此我们只需要传入List即可

public class Producer4BatchDemo {public static void main(String[] args) throws Exception {try {DefaultMQProducer producer = new DefaultMQProducer("group_test");// 声明namesrv地址producer.setNamesrvAddr("localhost:9876");// 设置重试次数producer.setRetryTimesWhenSendFailed(2);producer.start();String topic = "topic_test";List<Message> messages = new ArrayList<>();messages.add(new Message(topic, "Tag",  "消息1".getBytes()));messages.add(new Message(topic, "Tag",  "消息2".getBytes()));messages.add(new Message(topic, "Tag",  "消息3".getBytes()));SendResult send = producer.send(messages);System.out.println("发送结果:"+send);producer.shutdown();} catch (Exception e) {e.printStackTrace();}}
}

需要注意的是:
(1)批量消息的大小不能超过 1MiB(否则需要自行分割)
(2)同一批 batch 中 topic 必须相同
(3)批量消息是不支持延迟消息的

1.6 消息延迟发送

官方文档:https://rocketmq.apache.org/zh/docs/4.x/producer/04message3

rocketMQ的延迟消息时间不能自定义,但是可以在预设的16个等级中选择,也能够满足我们大部分的业务场景
在这里插入图片描述
延迟消息的发送,只需要在message中指定延迟时间等级即可,通过setDelayTimeLevel方法实现,示例代码如下

public class Producer6ScheduledDemo {public static void main(String[] args) {try {DefaultMQProducer producer = new DefaultMQProducer("group_test");// 声明namesrv地址producer.setNamesrvAddr("localhost:9876");// 设置重试次数producer.setRetryTimesWhenSendFailed(2);producer.start();int totalMessagesToSend = 100;for (int i = 0; i < totalMessagesToSend; i++) {Message message = new Message("topic_test", ("延迟消息 " + i).getBytes());message.setDelayTimeLevel(3);// Send the messageSendResult send = producer.send(message);System.out.println("发送结果:"+send);}producer.shutdown();} catch (Exception e) {e.printStackTrace();}}
}

1.7 事务消息发送

rocketmq的一大特性就是支持事务消息,他的原理是利用half message来实现的,这个具体原理我们后续单独讲解,今天先关注他的使用

事务消息的发送不再使用 DefaultMQProducer,而是使用 TransactionMQProducer 进行发送,我们还可以设置事务回查的线程池,当然如果不设置也会默认生成一个

1、首先需要实现 TransactionListener 接口,并传入 TransactionMQProducer

事务消息和数据库事务类似,也是通过两阶段提交的形式来实现的,所以其实现方法中要重写executeLocalTransactioncheckLocalTransaction方法

executeLocalTransaction方法是用于执行消费消息以及后续的其他事务事件,然后返回一个事物状态,用于告诉rocketmq这条事务消息是可以正常提交了还是需要回滚。

2、在讲具体实现代码前我们先理清楚几个概念,帮助大家理解为什么要书写这些代码,首先查看状态枚举LocalTransactionState可以知道,executeLocalTransaction方法返回值一共有3种状态:

  • COMMIT_MESSAGE

提交状态,事务正常进行,一般是本地事务执行成功后进行设置。告知broker提交该事务消息,然后消费者可以消费该消息,当然此时消费者已经执行完本地事务了,再消费可以根据业务逻辑进行后续的逻辑处理,如果没有相关逻辑了忽略消息即可

  • ROLLBACK_MESSAGE

回滚状态,事务撤回,broker将删除当前half消息,一般是本地事务执行失败后进行设置

  • UNKNOW

未知状态,固定时间后Broker端会通过checkLocalTransaction方法进行消息回查,根据回查结果来判断该消息是提交还是回滚

3、要理解checkLocalTransaction方法,我们还得先理解什么是消息回查

有一种场景:当本地事务执行完成后,在返回COMMIT_MESSAGE或ROLLBACK_MESSAGE状态时,因为网络波动或者broker服务挂了,导致broker没有正常收到这个状态,从而没有及时把half message进行提交或回滚,这时就需要有个定时巡查机制,来检查这些没有正常收到提交状态的消息的实际状态到底是什么,这个巡查机制就是消息回查。因此checkLocalTransaction方法中就要书写检查本地事务状态的方法,比如事务是对订单提交消息的消费,那么就去查询订单状态,如果已经是提交状态那么就返回COMMIT_MESSAGE,否则就返回ROLLBACK_MESSAGE

最后总结一下,executeLocalTransaction方法用于书写消费消息,执行本地事务的代码,并最终返回一个状态,本地事务执行成功则返回COMMIT_MESSAGE状态,执行失败则返回ROLLBACK_MESSAGEUNKNOW状态实际书写时是基本用不到的。checkLocalTransaction状态用于消息状态回查,需要在该方法中提供一个查询本地事务执行状态的方法,然后返回实际执行状态,本地事务执行成功返回COMMIT,执行失败返回ROLLBACK

4、实现代码,申明TransactionListener接口,实现executeLocalTransactioncheckLocalTransaction方法,生产中可以将TransactionListenerImpl申明为bean, 然后引入其他dao类或者service类处理本地事务

class TransactionListenerImpl implements TransactionListener {@Overridepublic LocalTransactionState executeLocalTransaction(Message msg, Object arg) {// TODO 执行本地事务(书写你自己的本地事务逻辑)try{String body = new String(msg.getBody());int i = Integer.parseInt(body);// 模拟偶数执行成功,奇数执行失败if(i % 2 == 0){System.out.println("本地事务执行成功:"+body);// 执行成功return LocalTransactionState.COMMIT_MESSAGE;}else{System.out.println("本地事务执行失败:"+body);// 执行失败return LocalTransactionState.ROLLBACK_MESSAGE;}}catch (Exception e){e.printStackTrace();// 执行失败return LocalTransactionState.ROLLBACK_MESSAGE;}}@Overridepublic LocalTransactionState checkLocalTransaction(MessageExt msg) {// TODO 去缓存或者数据库查询当前消息的实际状态// 模拟查询到状态为1Integer status = 1;// 不同实际状态对应的消息状态if (null != status) {switch (status) {case 1:return LocalTransactionState.COMMIT_MESSAGE;case 2:return LocalTransactionState.ROLLBACK_MESSAGE;default:return LocalTransactionState.COMMIT_MESSAGE;}}return LocalTransactionState.COMMIT_MESSAGE;}}

6、消息发送方法,事务消息不能再用DefaultMQProducer了,得用TransactionMQProducer

这里额外申明了回查线程池executorService,当然如果不申明rocektmq也会默认创建一个的

public static void main(String[] args) throws MQClientException, InterruptedException {TransactionListener transactionListener = new TransactionListenerImpl();TransactionMQProducer producer = new TransactionMQProducer("please_rename_unique_group_name");ExecutorService executorService = new ThreadPoolExecutor(2, 5, 100, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(2000), new ThreadFactory() {@Overridepublic Thread newThread(Runnable r) {Thread thread = new Thread(r);thread.setName("transaction-msg-check-thread");return thread;}});producer.setExecutorService(executorService);producer.setTransactionListener(transactionListener);producer.setNamesrvAddr("localhost:9876");producer.start();String[] tags = new String[] {"TagA", "TagB", "TagC", "TagD", "TagE"};for (int i = 0; i < 10; i++) {try {Message msg =new Message("topic_test", tags[i % tags.length], "KEY" + i,(""+i).getBytes());SendResult sendResult = producer.sendMessageInTransaction(msg, null);System.out.printf("%s%n", sendResult);Thread.sleep(10);} catch (MQClientException e) {e.printStackTrace();}}for (int i = 0; i < 100000; i++) {Thread.sleep(1000);}producer.shutdown();}

7、执行消息发送结果
在这里插入图片描述
8、消费消息,可以看到只有偶数消息正常提交消费了,奇数都被回滚了
在这里插入图片描述

3. 总结

至此我们针对java client实现各类消息发送的方法就梳理完成了,但实际工作中,我们现在更加常用的是基于springboot框架,而rocektmq也有专门针对springboot框架进行集成,实现起来更加简单,下一期我们重点讲解springboot集成实现消息发送

本文演示源码见:https://gitee.com/wuhanxue/wu_study/tree/master/demo/rocketmq_demo

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/854480.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

火车头采集中英文翻译教程

火车头采集怎么实现数据中文翻译成英文&#xff0c;或英文翻译成中文&#xff1f; 火车头采集没有自带的翻译功能&#xff0c;但可以使用插件功能来实现&#xff1a;导入翻译插件&#xff08;例如谷歌翻译插件&#xff0c;百度翻译插件等&#xff09;&#xff0c;然后在火车头…

视频媒介VS文字媒介

看到一篇蛮有思考意义的文章就摘录下来了&#xff0c;也引起了反思 目录 一、视频的定义 二、”视频媒介“与”文字媒介”作对比 1.形象 VS 抽象 2.被动 VS 主动 三、视频的缺点-【更少】的思考 1.看视频为啥会导致【更少的思考】 2.内容的【浅薄化】 3.内容的【娱乐化…

西安市工业倍增引导基金子基金申报条件流程和材料程序指南(2024年)

一、基本情况 产业投资基金是以产业发展为首要目标&#xff0c;围绕经济社会发展规划和产业发展政策&#xff0c;发挥“有效市场”作用&#xff0c;支持重点领域、重点产业、重点区域&#xff08;如&#xff1a;全市六大支柱产业、五大新兴产业领域成熟期重点规模以上企业以及“…

分布式+可移植,上云后降本增效的关键

试想一下&#xff1a;如果没有云计算&#xff0c;商业将会是什么样子&#xff1f; 云计算和多云战略的出现为全球企业带来了革命性的变化。然而&#xff0c;虽然技术已经发展了这么多年&#xff0c;但“多云”所固有的复杂性仍然是企业面临的主要痛点。选择多云战略的企业&…

【尚庭公寓SpringBoot + Vue 项目实战】用户管理(十五)

【尚庭公寓SpringBoot Vue 项目实战】用户管理&#xff08;十五&#xff09; 文章目录 【尚庭公寓SpringBoot Vue 项目实战】用户管理&#xff08;十五&#xff09;1、业务介绍2、接口实现2.1、根据条件分页查询用户列表2.2、根据ID更新用户状态 1、业务介绍 用户管理共包含两…

辐射传输方程和图形学渲染方程的区别

文章目录 概述辐射传输方程图形学渲染方程主要区别小结 概述 因为最近在看NeRFs相关的论文,所以接触到一些图形学内容, 在一篇介绍Radiance Filed 文章中&#xff0c;看到了关于图形渲染方程的内容&#xff0c;但搜索下来&#xff0c;文中给出的方程形式和其他地方的似乎不一致…

关于生成式人工智能的发展

近年来&#xff0c;人工智能的发展引起了广泛关注&#xff0c;尤其是在深度学习领域&#xff0c;以深度神经网络为代表的人工智能技术已经取得了重大突破。然而&#xff0c;深度神经网络也有其局限性。深度学习技术在处理一些复杂问题时表现良好&#xff0c;但在解决更广泛的任…

PS系统教学20

油漆桶工具 作用&#xff1a;上色工具的一种 上一些纯色、图案 纯色 新建图层填充区域的源设置为前景色设置前景色为想要的颜色左键单机填充&#xff08;altdelete&#xff09;如果要添加背景色&#xff08;Ctrldelete&#xff09;也可以与选区工具结合使用 可以与快速选择…

大模型日报2024-06-17

大模型日报 2024-06-17 大模型资讯 大模型产品 大模型论文 VideoGPT: 图像与视频编码器结合的视频理解 摘要: VideoGPT结合图像和视频编码器的优势&#xff0c;提升视频理解性能。通过自适应池化策略处理视频&#xff0c;改进多项视频基准测试表现&#xff0c;并引入VCGBench-D…

【React】如何使用npm run start命令运行两个服务

我们开发前端项目时&#xff0c;有时候需要本地 mock 数据&#xff0c;这样就需要启动两个服务&#xff0c;一个是接口服务&#xff0c;一个是前端项目。可以安装一个插件来帮助我们通过一个命令启动两个服务。 方法一 添加& npm run server 注意&#xff1a;Windows系统…

牛客热题:最长回文子串

&#x1f4df;作者主页&#xff1a;慢热的陕西人 &#x1f334;专栏链接&#xff1a;力扣刷题日记 &#x1f4e3;欢迎各位大佬&#x1f44d;点赞&#x1f525;关注&#x1f693;收藏&#xff0c;&#x1f349;留言 文章目录 牛客热题&#xff1a;最长回文子串题目链接方法一&am…

鸿蒙开发:【启动本地PageAbility】

启动本地PageAbility PageAbility相关的能力通过featureAbility提供&#xff0c;启动本地Ability通过featureAbility中的startAbility接口实现。 表1 featureAbility接口说明 接口名接口描述startAbility(parameter: StartAbilityParameter)启动Ability。startAbilityForRes…

Linux之网络编程

Linux之网络编程 TCP协议 TCP(Transmission ControlProtocol) : 传输控制协议&#xff0c;是一个 面向连接的、可靠的、基于字节流的传输层的协议。TCP 协议建立的是一种点到点的&#xff0c;一对一的可靠连接协议 特点&#xff1a; 数据无丢失数据无失序数据无错误数据无重…

振动分析-3-基于Python的FFT幅值修正与能量修正

幅值修正与能量修正过程&#xff08;更正&#xff09; 参考什么是泄漏&#xff1f; 参考什么是窗函数? 参考使用python实现快速傅里叶变换&#xff08;FFT&#xff09; 参考频谱泄露和窗函数以及加窗后幅度修正和python代码实现 1 快速傅里叶变换(FFT) 离散傅里叶变换(discr…

84. 柱状图中最大的矩形(hard)

单调栈&#xff1a; 就是说&#xff1a;固定高度&#xff0c;寻找最长宽度&#xff0c;如何找最长宽度&#xff0c;需要从heights[i] 这一个元素开始向左向右两边寻找heights[j] <heights[i]的j元素&#xff0c;也就是找两边第一小于heights[i]的元素。此过程中就是利用到单…

PCA 在图像分析上的应用

同一物体旋转角度求取 直接上代码&#xff1a; import cv2, os import numpy as np import timedef perform_pca(image, num_components):# 将图像转换为浮点型img_float np.float32(image)img_flatten img_float.reshape(-1, 2)# 计算均值和协方差矩阵mean, eigenvectors …

java面试(企业场景)

设计模式 工厂方法模式 简单工厂模式 简单工厂包括以下角色&#xff1a; 抽象产品&#xff1a;定义了产品的规范&#xff0c;描述了产品的主要特性和功能具体产品&#xff1a;实现或者继承抽象产品的子类具体工厂&#xff1a;提供了创建产品的机会&#xff0c;调用者通过该…

跨链协议中Cosmos IBC、Polkadot/XCM、Celer Network的区别以及用途

跨链协议是实现不同区块链之间通信和价值转移的关键技术。Cosmos IBC、Polkadot/XCM 和 Celer Network 是三个在跨链领域内具有代表性的协议&#xff0c;它们各自有着独特的设计理念和应用场景。下面是这三个协议的详细对比&#xff1a; Cosmos IBC (Inter-Blockchain Communi…

【C++进阶学习】第二弹——继承(下)——挖掘继承深处的奥秘

继承&#xff08;上&#xff09;&#xff1a;【C进阶学习】第一弹——继承&#xff08;上&#xff09;——探索代码复用的乐趣-CSDN博客 前言&#xff1a; 在前面我们已经讲了继承的基础知识&#xff0c;让大家了解了一下继承是什么&#xff0c;但那些都不是重点&#xff0c;今…

Flask-RESTPlus

Flask-RESTPlus库教程 Flask-RESTPlus 是一个用于构建RESTful APIs的Flask扩展&#xff0c;它提供了一些有用的工具来简化API的开发和文档编写。Flask-RESTPlus 包含Swagger文档生成器&#xff0c;使得API文档更加直观和易于维护。 官方文档链接 Flask-RESTPlus官方文档 架…