B007-springcloud alibaba 消息驱动 Rocketmq

目录

      • MQ简介
        • 什么是MQ
        • MQ的应用场景
          • 异步解耦
          • 流量削峰
        • 常见的MQ产品
      • RocketMQ入门
        • RocketMQ环境搭建
          • 环境准备
          • 安装RocketMQ
          • 启动RocketMQ
          • 测试RocketMQ
          • 关闭RocketMQ
        • RocketMQ的架构及概念
        • RocketMQ控制台安装
      • 消息发送和接收演示
        • 发送消息
        • 接收消息
      • 案例
        • 订单微服务发送消息
        • 用户微服务订阅消息
      • 发送不同类型的消息
        • 普通消息
          • 可靠同步发送
          • 可靠异步发送
          • 单向发送
        • 顺序消息
        • 事务消息?
          • 事务消息交互流程:
          • 事务消息发送步骤:
          • 事务消息回查步骤:
      • 消息消费要注意的细节

MQ简介

什么是MQ

MQ(Message Queue)是一种跨进程的通信机制,用于传递消息。通俗点说,就是一个先进先出的数据结构。
在这里插入图片描述

MQ的应用场景
异步解耦

最常见的一个场景是用户注册后,需要发送注册邮件和短信通知,以告知用户注册成功。传统的做法如下:
在这里插入图片描述
此架构下注册、邮件、短信三个任务全部完成后,才返回注册结果到客户端,用户才能使用账号登录。但是对于用户来说,注册功能实际只需要注册系统存储用户的账户信息后,该用户便可以登录,而后续的注册短信和邮件不是即时需要关注的步骤。

所以实际当数据写入注册系统后,注册系统就可以把其他的操作放入对应的消息队列 MQ 中然后马上返回用户结果,由消息队列 MQ 异步地进行这些操作。架构图如下:
在这里插入图片描述
异步解耦是消息队列 MQ 的主要特点,主要目的是减少请求响应时间和解耦。主要的使用场景就是将比较耗时而且不需要即时(同步)返回结果的操作作为消息放入消息队列。同时,由于使用了消息队列 MQ,只要保证消息格式不变,消息的发送方和接收方并不需要彼此联系,也不需要受对方的影响,即解耦合。

流量削峰

流量削峰也是消息队列 MQ 的常用场景,一般在秒杀或团队抢购(高并发)活动中使用广泛。

在秒杀或团队抢购活动中,由于用户请求量较大,导致流量暴增,秒杀的应用在处理如此大量的访问流量后,下游的通知系统无法承载海量的调用量,甚至会导致系统崩溃等问题而发生漏通知的情况。为解决这些问题,可在应用和下游通知系统之间加入消息队列 MQ。
在这里插入图片描述
秒杀处理流程如下所述:
1.用户发起海量秒杀请求到秒杀业务处理系统。
2.秒杀处理系统按照秒杀处理逻辑将满足秒杀条件的请求发送至消息队列 MQ。
3.下游的通知系统订阅消息队列 MQ 的秒杀相关消息,再将秒杀成功的消息发送到相应用户。
4.用户收到秒杀成功的通知。

常见的MQ产品

目前业界有很多MQ产品,比较出名的有下面这些:

ZeroMQ
号称最快的消息队列系统,尤其针对大吞吐量的需求场景。扩展性好,开发比较灵活,采用C语言实现,实际上只是一个socket库的重新封装,如果做为消息队列使用,需要开发大量的代码。 ZeroMQ仅提供非持久性的队列,也就是说如果down机,数据将会丢失。

RabbitMQ
使用erlang语言开发,性能较好,适合于企业级的开发。但是不利于做二次开发和维护。

ActiveMQ
历史悠久的Apache开源项目。已经在很多产品中得到应用,实现了JMS1.1规范,可以和spring- jms轻松融合,实现了多种协议,支持持久化到数据库,对队列数较多的情况支持不好。

RocketMQ
阿里巴巴的MQ中间件,由java语言开发,性能非常好,能够撑住双十一的大流量,而且使用起来很简单。

Kafka
Kafka是Apache下的一个子项目,是一个高性能跨语言分布式Publish/Subscribe消息队列系统,相对于ActiveMQ是一个非常轻量级的消息系统,除了性能非常好之外,还是一个工作良好的分布式系统。

RocketMQ入门

RocketMQ是阿里巴巴开源的分布式消息中间件,现在是Apache的一个顶级项目。在阿里内部使用非常广泛,已经经过了"双11"这种万亿级的消息流转。

RocketMQ环境搭建

接下来我们先在linux平台下安装一个RocketMQ的服务

环境准备

下载RocketMQ
http://rocketmq.apache.org/release_notes/release-notes-4.4.0

环境要求
Linux 64位操作系统,64bit JDK 1.8+

安装RocketMQ

上传文件到Linux系统的/usr/local/src/目录,解压,移动

unzip rocketmq-all-4.4.0-bin-release.zip
mv rocketmq-all-4.4.0-bin-release /usr/local/rocketmp
启动RocketMQ

进入rocketmq的bin目录

启动NameServer

[root@heima bin]# nohup ./mqnamesrv &
[1] 1467
# 只要进程不报错,就应该是启动成功了,可以查看一下日志
[root@heima bin]# tail -f ~/logs/rocketmqlogs/namesrv.log
# 或查看端口
[root@heima bin]# netstat -an | grep 9876

启动Broker - 先编辑两个文件 vim i esc :wq

[root@heima bin]# vim runserver.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m ...[root@heima bin]# vim runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"[root@heima bin]# nohup ./mqbroker -n localhost:9876 &
测试RocketMQ

1测试消息发送

[root@heima bin]# export NAMESRV_ADDR=localhost:9876
[root@heima bin]# ./tools.sh org.apache.rocketmq.example.quickstart.Producer

2测试消息接收

[root@heima bin]# export NAMESRV_ADDR=localhost:9876
[root@heima bin]# ./tools.sh org.apache.rocketmq.example.quickstart.Consumer
关闭RocketMQ
[root@heima bin]# ./mqshutdown broker
[root@heima bin]# ./mqshutdown namesrv
RocketMQ的架构及概念

在这里插入图片描述
在这里插入图片描述
如上图所示,整体可以分成4个角色,分别是:NameServer,Broker,Producer,Consumer。

Broker(邮递员)
Broker是RocketMQ的核心,负责消息的接收,存储,投递等功能

NameServer(邮局)
消息队列的协调者,Broker向它注册路由信息,同时Producer和Consumer向其获取路由信息

Producer(寄件人)
消息的生产者,需要从NameServer获取Broker信息,然后与Broker建立连接,向Broker发送消息

Consumer(收件人)
消息的消费者,需要从NameServer获取Broker信息,然后与Broker建立连接,从Broker获取消息

Topic(地区)
用来区分不同类型的消息,发送和接收消息前都需要先创建Topic,针对Topic来发送和接收消息

Message Queue(邮件)
为了提高性能和吞吐量,引入了Message Queue,一个Topic可以设置一个或多个Message Queue,这样消息就可以并行往各个Message Queue发送消息,消费者也可以并行的从多个 Message Queue读取消息

Message(邮件内文字)
Message 是消息的载体。

Producer Group
生产者组,简单来说就是多个发送同一类消息的生产者称之为一个生产者组。

Consumer Group
消费者组,消费同一类消息的多个 consumer 实例组成一个消费者组。

RocketMQ控制台安装

1.下载

# 在git上下载下面的工程 rocketmq-console-1.0.0 
https://github.com/apache/rocketmq-externals/releases

2.修改配置文件

# 修改配置文件 rocketmq-console\src\main\resources\application.properties 
server.port=7777 #项目启动后的端口号 
rocketmq.config.namesrvAddr=192.168.109.131:9876 #nameserv的地址,注意防火墙要开启 9876端口

3.打成jar包,并启动

# 进入控制台项目,将工程打成jar包
mvn clean package -Dmaven.test.skip=true # 启动控制台
java -jar target/rocketmq-console-ng-1.0.0.jar

4.访问控制台
在这里插入图片描述

消息发送和接收演示

接下来我们使用Java代码来演示消息的发送和接收

<dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.2</version>
</dependency>
发送消息

消息发送步骤:
1.创建消息生产者, 指定生产者所属的组名
2.指定Nameserver地址
3.启动生产者
4.创建消息对象,指定主题、标签和消息体
5.发送消息
6.关闭生产者

public class RocketMQSendMessageTest {public static void main(String[] args) throws Exception {//1. 创建消息生产者, 指定生产者所属的组名DefaultMQProducer producer = new DefaultMQProducer("myproducer-group");//2. 指定Nameserver地址producer.setNamesrvAddr("192.168.149.128:9876");//3. 启动生产者producer.start();//4. 创建消息对象,指定主题、标签和消息体Message msg = new Message("myTopic", "myTag", ("The RocketMQ Message").getBytes());//5. 发送消息 第二个参数代表超时时间SendResult sendResult = producer.send(msg,10000);System.out.println(sendResult);//6. 关闭生产者producer.shutdown();}
}
接收消息

消息接收步骤:
1.创建消息消费者, 指定消费者所属的组名
2.指定Nameserver地址
3.指定消费者订阅的主题和标签
4.设置回调函数,编写处理消息的方法
5.启动消息消费者

public class RocketMQReceiveMessageTest {public static void main(String[] args) throws MQClientException {//1. 创建消息消费者, 指定消费者所属的组名DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("myconsumer-group");//2. 指定Nameserver地址consumer.setNamesrvAddr("192.168.149.128:9876");//3. 指定消费者订阅的主题和标签consumer.subscribe("myTopic", "*");//4. 设置回调函数,编写处理消息的方法consumer.registerMessageListener(new MessageListenerConcurrently() {@Overridepublic ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> msgs, ConsumeConcurrentlyContext context) {System.out.println("Receive New Messages: " + msgs);//返回消费状态return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;}});//5. 启动消息消费者consumer.start();System.out.println("Consumer Started.");}
}

案例

接下来我们模拟一种场景: 下单成功之后,向下单用户发送短信。设计图如下:
在这里插入图片描述

订单微服务发送消息

1在shop-order 中添加rocketmq的依赖

    <!--rocketmq--><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.2</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.4.0</version></dependency>

2添加配置

# rocketMQ
rocketmq:name-server: 192.168.149.128:9876	#rocketMQ服务的地址producer:group: shop-order # 生产者组

3编写测试代码

    @Autowiredprivate RocketMQTemplate rocketMQTemplate;//下单成功之后,将消息放到mq中   向mq中投递一个下单成功的消息// 参数一:指定topic// 参数二:指定消息体rocketMQTemplate.convertAndSend("order-topic", order);

启动两个项目,浏览器访问进行下单发送消息

用户微服务订阅消息

1shop-user 添加依赖

    <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-spring-boot-starter</artifactId><version>2.0.2</version></dependency><dependency><groupId>org.apache.rocketmq</groupId><artifactId>rocketmq-client</artifactId><version>4.4.0</version></dependency>

2启动类加注解

@EnableDiscoveryClient

3添加配置

spring:cloud:nacos:discovery:server-addr: 127.0.0.1:8848
rocketmq:name-server: 192.168.149.128:9876

4编写消息接收服务

@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "shop-user", topic = "order-topic")
public class SmsService implements RocketMQListener<Order> {@Overridepublic void onMessage(Order order) {log.info("收到一个订单信息{},接下来发送短信", JSON.toJSONString(order));}
}

5启动服务,执行下单操作,观看后台输出

发送不同类型的消息

普通消息

RocketMQ提供三种方式来发送普通消息:可靠同步发送、可靠异步发送和单向发送。

可靠同步发送

同步发送是指消息发送方发出数据后,会在收到接收方发回响应之后才发下一个数据包的通讯方式。
此种方式应用场景非常广泛,例如重要通知邮件、报名短信通知、营销短信系统等。

可靠异步发送

异步发送是指发送方发出数据后,不等接收方发回响应,接着发送下个数据包的通讯方式。发送方通过回调接口接收服务器响应,并对响应结果进行处理。
异步发送一般用于链路耗时较长,对 RT 响应时间较为敏感的业务场景,例如用户视频上传后通知启动转码服务,转码完成后通知推送转码结果等。

单向发送

单向发送是指发送方只负责发送消息,不等待服务器回应且没有回调函数触发,即只发送请求不等待应答。
适用于某些耗时非常短,但对可靠性要求并不高的场景,例如日志收集。

<!--依赖-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId>
</dependency>
<dependency><groupId>junit</groupId><artifactId>junit</artifactId>
</dependency>
@RunWith(SpringRunner.class)
@SpringBootTest(classes = OrderApp.class)
public class MessageTypeTest {@Autowiredprivate RocketMQTemplate rocketMQTemplate;//同步消息@Testpublic void testSyncSend() {//参数一: topic, 如果想添加tag 可以使用"topic:tag"的写法//参数二: 消息内容//参数三: 超时时间SendResult sendResult =rocketMQTemplate.syncSend("test-topic-1", "这是一条同步消息", 10000);System.out.println(sendResult);}//异步消息@Testpublic void testAsyncSend() throws InterruptedException {//参数一: topic, 如果想添加tag 可以使用"topic:tag"的写法//参数二: 消息内容//参数三: 回调函数, 处理返回结果rocketMQTemplate.asyncSend("test-topic-3", "这是一条异步消息", new SendCallback() {//成功响应的回调@Overridepublic void onSuccess(SendResult sendResult) {System.out.println(sendResult);}//异常响应的回调@Overridepublic void onException(Throwable throwable) {System.out.println(throwable);}});System.out.println("=========================");//让线程不要终止Thread.sleep(30000);}//单向消息@Testpublic void testOneWay() {rocketMQTemplate.sendOneWay("test-topic-2", "这是一条单向消息");}
}

三种发送方式的对比
在这里插入图片描述

顺序消息

顺序消息是消息队列提供的一种严格按照顺序来发布和消费的消息类型。
在这里插入图片描述

    //顺序消息@Testpublic void testOneWayOrderly() {for (int i = 0; i < 10; i++) {//第三个参数的作用是用来决定这些消息发送到哪个队列上//一个topic默认4个队列,把消息都放到一个队列里保证消费时的顺序rocketMQTemplate.sendOneWayOrderly("test-topic-5", "这是一条单向消息","xx");}}
事务消息?

RocketMQ提供了事务消息,通过事务消息就能达到分布式事务的最终一致。

事务消息交互流程:

在这里插入图片描述
两个概念:

  • 半事务消息:暂不能投递的消息,发送方已经成功地将消息发送到了RocketMQ服务端,但是服务端未收到生产者对该消息的二次确认,此时该消息被标记成“暂不能投递”状态,处于该种状态下的消息即半事务消息。
  • 消息回查:由于网络闪断、生产者应用重启等原因,导致某条事务消息的二次确认丢失, RocketMQ服务端通过扫描发现某条消息长期处于“半事务消息”时,需要主动向消息生产者询问该消息的最终状态(Commit 或是 Rollback),该询问过程即消息回查。
事务消息发送步骤:
  1. 发送方将半事务消息发送至RocketMQ服务端。
  2. RocketMQ服务端将消息持久化之后,向发送方返回Ack确认消息已经发送成功,此时消息为半事务消息。
  3. 发送方开始执行本地事务逻辑。
  4. 发送方根据本地事务执行结果向服务端提交二次确认(Commit 或是 Rollback),服务端收到 Commit 状态则将半事务消息标记为可投递,订阅方最终将收到该消息;服务端收到 Rollback 状态则删除半事务消息,订阅方将不会接受该消息。
事务消息回查步骤:
  1. 在断网或者是应用重启的特殊情况下,上述步骤4提交的二次确认最终未到达服务端,经过固定时间后服务端将对该消息发起消息回查。
  2. 发送方收到消息回查后,需要检查对应消息的本地事务执行的最终结果。
  3. 发送方根据检查得到的本地事务的最终状态再次提交二次确认,服务端仍按照步骤4对半事务消息进行操作。
    OrderController
orderServiceImpl4.createOrderBefore(order);

OrderServiceImpl4

@Service
public class OrderServiceImpl4 {@Autowiredprivate OrderDao orderDao;@Autowiredprivate RocketMQTemplate rocketMQTemplate;@Autowiredprivate TxLogDao txLogDao;public void createOrderBefore(Order order) {String txId = UUID.randomUUID().toString();//发送半事务消息rocketMQTemplate.sendMessageInTransaction("tx_producer_group","tx_topic",MessageBuilder.withPayload(order).setHeader("txId",txId).build(),order);}//本地事务@Transactionalpublic void createOrder(String txId,Order order){//保存订单orderDao.save(order);//保存事务日志TxLog txLog = new TxLog();txLog.setTxId(txId);txLog.setDate(new Date());txLogDao.save(txLog);}
}

OrderServiceImpl4Listener

@Service
@RocketMQTransactionListener(txProducerGroup = "tx_producer_group")
public class OrderServiceImpl4Listener implements RocketMQLocalTransactionListener {@Autowiredprivate OrderServiceImpl4 orderServiceImpl4;@Autowiredprivate TxLogDao txLogDao;//发送半事务消息成功后 执行本地事务@Overridepublic RocketMQLocalTransactionState executeLocalTransaction(Message msg, Object arg) {String txId = (String) msg.getHeaders().get("txId");try {Order order = (Order) arg;orderServiceImpl4.createOrder(txId, order);return RocketMQLocalTransactionState.COMMIT;} catch (Exception e) {return RocketMQLocalTransactionState.ROLLBACK;}}//rocketMQ未收到上面的确认 进行消息回查@Overridepublic RocketMQLocalTransactionState checkLocalTransaction(Message msg) {String txId = (String) msg.getHeaders().get("txId");TxLog txLog = txLogDao.findById(txId).get();if (txLog != null){//本地事务(订单)成功了return RocketMQLocalTransactionState.COMMIT;} else {return RocketMQLocalTransactionState.ROLLBACK;}}
}

消息消费要注意的细节

@RocketMQMessageListener(consumerGroup = "shop",//消费者组名 topic = "order-topic",//要消费的主题consumeMode = ConsumeMode.CONCURRENTLY, //消费模式 指定是否顺序消费 CONCURRENTLY (同步 默认) ORDERLY (顺序)messageModel = MessageModel.CLUSTERING, //消息模式 BROADCASTING(广播) CLUSTERING (集群,默认)
)
public class SmsService implements RocketMQListener<Order> {}

RocketMQ支持两种消息模式:
广播消费:每个消费者实例都会收到消息,也就是一条消息可以被每个消费者实例处理;
集群消费:一条消息只能被一个消费者实例消费

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

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

相关文章

(done) 解释 python3 torch.utils.data DataLoader

特别注意&#xff1a;DataLoader 返回的迭代器是无尽的&#xff0c;依据如下 (CHATGPT3.5) DataLoader 返回的迭代器默认情况下是无尽的&#xff0c;因为它会无限地循环遍历数据集&#xff0c;以提供批量的数据。在训练神经网络时&#xff0c;通常会使用无尽的迭代器来循环遍历…

LEETCODE 100255. 成为 K 特殊字符串需要删除的最少字符数

整体思路: 1.可以看到这道题是要求是最小的&#xff0c;那么可以想到遍历所有情况 2.把题干已知条件转换为一个数组&#xff0c;那么只需要以数组每个元素为开头遍历所有情况即可。 3.对于一个数考虑其后面的情况&#xff0c;其后每个数等于这个数k和数本身的最小值(遍历累计求…

参数高效微调(PEFT)技术概览

参数高效微调&#xff08;PEFT&#xff09;技术概览 在大型语言模型&#xff08;LLMs&#xff09;的世界里&#xff0c;参数量庞大&#xff0c;通常在70亿至700亿之间。这些模型的自监着训练成本高昂&#xff0c;对公司可能意味着高达1亿美元的支出。而对于资源相对有限的研究…

Codeforces Round 934 (Div. 2) --- C. MEX Game 1 --- 题解

C. MEX Game 1&#xff1a; 题目大意&#xff1a; 思路解析&#xff1a; 重要的是那种只有一个的数字&#xff0c;因为如果这个数字有两个及以上&#xff0c;那么我可以再鲍勃删除之后&#xff0c;再拿&#xff0c;也一定能拿得到&#xff0c;所以瓶颈是只有一个的数字&#x…

爬虫3_爬取翻页URL不变的网站

之前实现了对大学排数据爬取&#xff1a;爬虫2_2019年549所中国大学排名. 近期复现代码&#xff0c;发现原网站升级&#xff0c;在翻页时&#xff0c;发现URL不改变&#xff0c;修改代码&#xff0c;使用网页自动化工具selenium实现对该类网站数据获取。 #-*- coding: UTF-8 -…

活动图高阶讲解-06

31 00:01:52,300 --> 00:02:04,300 刚才讲了&#xff0c;活动里面是动作 32 00:02:04,300 --> 00:02:06,300 这个动作 33 00:02:06,300 --> 00:02:09,300 就可以看作活动的一个 34 00:02:09,300 --> 00:02:13,300 里面的实现的一个行为了 35 00:02:16,300 --&g…

vue项目跳转html页面

1. 把html页面以及相关文件放到public文件夹下&#xff08;目的和index.html同级&#xff09; 2.在vue项目中正常写跳转事件&#xff0c;只是路径写法需要注意

【理解指针(三)】

文章目录 一、数组名的理解&#xff08;1&#xff09;数组的地址与数组首元素地址的区别 二、使用指针访问数组&#xff08;1&#xff09;一维数组传参的本质 三、冒泡排序&#xff08;1&#xff09;什么是冒泡排序&#xff08;2&#xff09;写冒泡排序 四、结束语 一、数组名的…

堆排序(向下调整法,向上调整法详解)

目录 一、 二叉树的顺序结构 二、 堆的概念及结构 三、数组存储、顺序存储的规律 此处可能会有疑问&#xff0c;左右孩子的父节点计算为什么可以归纳为一个结论了&#xff1f; 四、大小堆解释 五、大小堆的实现&#xff08;向上和向下调整法&#xff09; 5.11向上调整法…

Unity Timeline学习笔记(1) - 创建TL和添加动画片段

Timeline在刚出的时候学习了一下&#xff0c;但是因为一些原因一直都没用在工作中使用。 版本也迭代了很久不用都不会用了&#xff0c;抽时间回顾和复习一下&#xff0c;做一个笔记后面可以翻出来看。 创建Timeline 首先我们创建一个场景&#xff0c;放入一个Plane地板&#…

Linux操作系统-08-常用的网络相关命令

1、ping命令 在linux下ping的话会一直ping下去&#xff0c;在windows下的话它会只ping四次就结束&#xff0c; [rootbastion ~]# ping 192.168.0.102 PING 192.168.0.102 (192.168.0.102) 56(84) bytes of data. 64 bytes from 192.168.0.102: icmp_seq1 ttl64 time0.571 ms…

Linux - 线程互斥和互斥锁

文章目录 前言一、为什么要线程互斥原子性 二、互斥锁互斥锁的创建与销毁互斥锁进行互斥 前言 前几节课&#xff0c;我们学习了多线程的基础概念&#xff0c;这节课&#xff0c;我们来对线程互斥和互斥锁的内容进行学习。 一、为什么要线程互斥 首先我们要明白&#xff0c;对…

悲观锁(Pessimistic Locking)是一种数据库锁定机制

悲观锁&#xff08;Pessimistic Locking&#xff09;是一种数据库锁定机制&#xff0c;用于防止多个事务同时修改同一数据记录。以下是关于悲观锁的一些详细信息&#xff1a; 锁定数据&#xff1a;当事务对一条记录进行操作时&#xff0c;悲观锁会阻止其他事务对这条记录进行修…

Matplotlib数据可视化实战-1数据可视化Matplotlib基础

1.1绘图的一般过程&#xff1a; 1.导入相关库 2.生成、读入或计算得到数据&#xff1b; 3.根据需要绘制折线图、散点图、柱状图、饼状图、雷达图、箱线图、三维曲线/曲面以及极坐标系图形&#xff1b; 4.根据需要设置图形属性&#xff1b; 5.显示或保存绘图结果。 例如&…

c语言大小写字母的转换

通过ascll码表我们可以知道大写字母与小写字母相差32个数&#xff08;小写字母比大写字母大&#xff09;。因此&#xff0c;通过相加减32即可转换大小写字母。 #include <stdio.h>int main() {char ch c;char CH A;printf("%c\n", ch - 32);printf("%c…

计算机网络实验——学习记录

1. tun/tap模块&#xff1a;为Linux系统提供网络虚拟功能&#xff0c;tun位于网络OSI模型的三层&#xff08;网络层&#xff09;&#xff0c;tap位于网络的二层&#xff08;数据链路层&#xff09;。 1.1 验证是否包含tun/tap模块&#xff1a;modinfo tun&#xff1b; 1.2 验…

Python进程与线程开发

目录 multiprocessing模块 线程的开发 threading模块 setDaemon 死锁 线程间的通信 multiprocessing模块 运行python的时候&#xff0c;我们都是在创建并运行一个进程&#xff0c;(linux中一个进程可以fork一个子进程&#xff0c;并让这个子进程exec另外一个程序)。在pyt…

全局路径规划算法 - 动态规划算法Python实现

参考博客&#xff1a; &#xff08;1&#xff09;算法数据结构——动态规划算法&#xff08;Dynamic Programming&#xff09;超详细总结加应用案例讲解 &#xff08;2&#xff09;【路径规划】全局路径规划算法——动态规划算法&#xff08;含python实现&#xff09; &#xf…

【上交主办·EI会议】| 2024年模式分析与机器智能国际会议 (ICPAMI 2024)

会议简介 Brief Introduction 2024年模式分析与机器智能国际会议(ICPAMI 2024) 会议时间&#xff1a;2024年8月30日-9月1日 召开地点&#xff1a;中国上海 大会官网&#xff1a;www.icpami.org ICPAMI 2024将围绕“模式分析与机器智能”的最新研究领域展开&#xff0c;为研究人…

(零)OpenOFDM接收端整体思路

一旦捕获射频信号并将其下变频至基带&#xff0c;解码管道就会启动&#xff0c;包括&#xff1a; OFDM&#xff0c;多载波调制的一种。通过频分复用实现高速串行数据的并行传输, 它具有较好的抗多径衰落的能力&#xff0c;能够支持多用户接入。 OFDM主要思想是&#xff1a;将信…