ActiveMQ入门案例（queue模式和topic模式）

目录

前言：为什么使用消息中间件？

异步通信

缓冲

解耦

前提：安装并启动activemq

一、点对点（point to point， queue）

1.1 创建maven项目

1.2 Pom依赖

1.2 JmsProduce 消息生产者

1.3 JmsConsumer1 消息消费者1

1.4 JmsConsumer2 消息消费者2

 1.5 测试

        1.5.1 启动两个消费者

        1.5.2 启动生产者 

二、发布/订阅（publish/subscribe，简称pub/sub，topic）

1.1 创建maven项目

1.2 Pom依赖

1.2 JmsProduce 消息生产者

1.3 JmsConsumer1 消息消费者1

1.4 JmsConsumer2 消息消费者2

 1.5 测试

        1.5.1 启动两个消费者

        1.5.2 启动生产者发送6条消息

三、上述两种模式对比

前言：为什么使用消息中间件？

  • 异步通信

        异步化提升性能。有些业务不想也不需要立即处理消息。消息队列提供了异步处理机制，允许用户把一个消息放入队列，但并不立即处理它。想向队列中放入多少消息就放多少，然后在需要的时候再去处理它们。

  • 缓冲

        流量削峰。在任何重要的系统中，都会有需要不同的处理时间的元素。消息队列通过一个缓冲层来帮助任务最高效率的执行，该缓冲有助于控制和优化数据流经过系统的速度。以调节系统响应时间。

  • 解耦

        降低耦合度。降低工程间的强依赖程度，针对异构系统进行适配。在项目启动之初来预测将来项目会碰到什么需求，是极其困难的。通过消息系统在处理过程中间插入了一个隐含的、基于数据的接口层，两边的处理过程都要实现这一接口，当应用发生变化时，可以独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束。

前提：安装并启动activemq

ActiveMQ介绍及linux下安装ActiveMQ-CSDN博客

一、点对点（point to point， queue）

消息生产者生产消息发送到queue中，然后消息消费者从queue中取出并且消费消息。
消息被消费以后，queue中不再有存储，所以消息消费者不可能消费到已经被消费的消息。Queue支持存在多个消费者，但是对一个消息而言，只会有一个消费者可以消费。

1.1 创建maven项目

1.2 Pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.dolphin</groupId><artifactId>activemq_demo</artifactId><version>1.0-SNAPSHOT</version><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target></properties><dependencies><!--   activemq所需要的jar包配置     --><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency><dependency><groupId>org.apache.xbean</groupId><artifactId>xbean-spring</artifactId><version>3.16</version></dependency><!--    下面是junit/log4j等基础通用配置    --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.25</version></dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.16.18</version><scope>provided</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency></dependencies>
</project>

1.3 JmsProduce 消息生产者

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.jms.core.MessagePostProcessor;import javax.jms.*;public class JmsProduce {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String QUEUE_NAME = "queue01";public static void main(String[] args) throws JMSException {//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Queue queue = session.createQueue(QUEUE_NAME);//5、创建消息的生产者MessageProducer messageProducer = session.createProducer(queue);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面for (int i = 1;i<=6;i++) {//7 创建消息TextMessage textMessage = session.createTextMessage("message---" + i);//理解为一个字符串//8 通过messageProducer发送给mqmessageProducer.send(textMessage);}//9 关闭资源messageProducer.close();session.close();connection.close();System.out.println("*****消息发布完成");}
}

1.4 JmsConsumer1 消息消费者1

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;
import java.io.IOException;public class JmsConsumer1 {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String QUEUE_NAME = "queue01";public static void main(String[] args) throws JMSException, IOException {System.out.println("1号消费者");//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Queue queue = session.createQueue(QUEUE_NAME);//5、创建消息的消费者MessageConsumer messageConsumer = session.createConsumer(queue);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面/***  两种消费方式（一）*  1 同步阻塞方式（receive()）*  订阅者或接受者调用MessageConsumer的receive()方法来接收消息，receive方法在能够接收到消息之前(或者超时之前)将一直阻塞。while(true) {//超过4秒没有消息跳出循环关闭监听//TextMessage textMessage = (TextMessage) messageConsumer.receive(4000L);//没有消息也会一直阻塞等待消息TextMessage textMessage = (TextMessage) messageConsumer.receive();if (null != textMessage) {System.out.println("*****消费者接受到消息"+textMessage.getText());} else {break;}}//9 关闭资源messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");*//*** 两种消费方式（二）* 2 异步非阻塞方式（监听器onMessage()）* 订阅者或接受者通过MessageConsumer的setMessageListener(MessageListener listener)注册一个消息监听器。* 当消息到达之后，系统自动调用监听器MessageListener的OnMessage(Message message)方法*/messageConsumer.setMessageListener(new MessageListener() {@Overridepublic void onMessage(Message message) {if (null != message && message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;try {System.out.println("*****消费者接受到消息"+textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}}});System.in.read();  //进程处于运行状态messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");}
}

1.5 JmsConsumer2 消息消费者2

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;
import java.io.IOException;public class JmsConsumer1 {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String QUEUE_NAME = "queue01";public static void main(String[] args) throws JMSException, IOException {System.out.println("1号消费者");//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Queue queue = session.createQueue(QUEUE_NAME);//5、创建消息的消费者MessageConsumer messageConsumer = session.createConsumer(queue);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面/***  两种消费方式（一）*  1 同步阻塞方式（receive()）*  订阅者或接受者调用MessageConsumer的receive()方法来接收消息，receive方法在能够接收到消息之前(或者超时之前)将一直阻塞。while(true) {//超过4秒没有消息跳出循环关闭监听//TextMessage textMessage = (TextMessage) messageConsumer.receive(4000L);//没有消息也会一直阻塞等待消息TextMessage textMessage = (TextMessage) messageConsumer.receive();if (null != textMessage) {System.out.println("*****消费者接受到消息"+textMessage.getText());} else {break;}}//9 关闭资源messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");*//*** 两种消费方式（二）* 2 异步非阻塞方式（监听器onMessage()）* 订阅者或接受者通过MessageConsumer的setMessageListener(MessageListener listener)注册一个消息监听器。* 当消息到达之后，系统自动调用监听器MessageListener的OnMessage(Message message)方法*/messageConsumer.setMessageListener(new MessageListener() {@Overridepublic void onMessage(Message message) {if (null != message && message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;try {System.out.println("*****消费者接受到消息"+textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}}});System.in.read();  //进程处于运行状态messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");}
}

 1.6 测试

        1.6.1 启动两个消费者

查看消费者数量2

        1.6.2 启动生产者 

这里生产了6个消息均被消费，且是轮询消费，结果如下

二、发布/订阅（publish/subscribe，简称pub/sub，topic）

发布订阅模式需要进行注册、订阅，根据注册消费对应的消息。多个生产者可以将消息写到同一个 Topic 中，多种消息可以被同一个消费者消费。一个生产者生产的消息，同样也可以被多个消费者消费，只要他们进行过消息订阅。

Queue支持存在多个消费者，对一个消息而言，可以有多个消费者共同消费。（如：微信公众号）

代码和上边案例一样，将queue改为topic，具体如下，这里直接在上边项目中修改

2.1 创建maven项目

2.2 Pom依赖

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.dolphin</groupId><artifactId>activemq_demo</artifactId><version>1.0-SNAPSHOT</version><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.8</maven.compiler.source><maven.compiler.target>1.8</maven.compiler.target></properties><dependencies><!--   activemq所需要的jar包配置     --><dependency><groupId>org.apache.activemq</groupId><artifactId>activemq-all</artifactId><version>5.15.9</version></dependency><dependency><groupId>org.apache.xbean</groupId><artifactId>xbean-spring</artifactId><version>3.16</version></dependency><!--    下面是junit/log4j等基础通用配置    --><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.25</version></dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.3</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.16.18</version><scope>provided</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope></dependency></dependencies>
</project>

2.3 JmsProduce 消息生产者

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;
import org.springframework.jms.core.MessagePostProcessor;import javax.jms.*;public class JmsProduce_Topic {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String TOPIC_NAME = "topic-weixin";public static void main(String[] args) throws JMSException {//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Topic topic = session.createTopic(TOPIC_NAME);//5、创建消息的生产者MessageProducer messageProducer = session.createProducer(topic);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面for (int i = 1;i<=6;i++) {//7 创建消息TextMessage textMessage = session.createTextMessage("TOPIC_NAME---" + i);//理解为一个字符串//8 通过messageProducer发送给mqmessageProducer.send(textMessage);}//9 关闭资源messageProducer.close();session.close();connection.close();System.out.println("*****消息发布完成");}
}

2.4 JmsConsumer1 消息消费者1

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;
import java.io.IOException;public class JmsConsumer1 {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String TOPIC_NAME = "topic-weixin";public static void main(String[] args) throws JMSException, IOException {System.out.println("1号消费者");//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Topic topic = session.createTopic(TOPIC_NAME);//5、创建消息的消费者MessageConsumer messageConsumer = session.createConsumer(topic);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面messageConsumer.setMessageListener(message -> {if (null != message && message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;try {System.out.println("*****1号消费者接受到消息："+textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}});System.in.read();  //进程处于运行状态messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");}
}

2.5 JmsConsumer2 消息消费者2

package com.dolphin;import org.apache.activemq.ActiveMQConnectionFactory;import javax.jms.*;
import java.io.IOException;public class JmsConsumer2 {public static final String ACTIVEMQ_URL = "tcp://192.168.190.200:61616";public static final String TOPIC_NAME = "topic-weixin";public static void main(String[] args) throws JMSException, IOException {System.out.println("2号消费者");//1 创建连接工厂，按照规定的url地址，采用默认用户名和密码 admin/adminActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory(ACTIVEMQ_URL);//2 通过连接工厂，获得链接connection并启动访问Connection connection = activeMQConnectionFactory.createConnection();connection.start();//3、创建会话session//两个参数，第一个叫事务/第二个叫签收Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//4、创建目的地（具体是队列还是主题topic）Topic topic = session.createTopic(TOPIC_NAME);//5、创建消息的消费者MessageConsumer messageConsumer = session.createConsumer(topic);//6、 通过使用messageProducer生产3条消息发送到MQ的队列里面messageConsumer.setMessageListener(message -> {if (null != message && message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;try {System.out.println("*****2号消费者接受到消息："+textMessage.getText());} catch (JMSException e) {e.printStackTrace();}}});System.in.read();  //进程处于运行状态messageConsumer.close();session.close();connection.close();System.out.println("*****消息消费完成");}
}

 2.6 测试

        2.6.1 启动两个消费者

查看消费者数量2

        2.6.2 启动生产者发送6条消息

三、上述两种模式对比

比较项目Topic模式队列Queue模式队列
工作模式“订阅-发布模式”，如果当前没有订阅者，消息将会被丢弃。如果有多个订阅者，那么这些订阅者都会收到消息“负载均衡”模式，如果当前没有消费者，消息也不会丢弃；如果有多个消费者，那么一条消息也只会发送给其中一个消费者，并且要求消费者ack信息
有无状态无状态Queue数据默认会在mq服务器上以文件形式保存，比如ActiveMQ一般保存在$AMQ_HOME\data\kr-store\data下面。也可以配置成DB存储
传递完整性如果没有订阅者，消息会被丢弃消息不会丢弃
处理效率由于消息要按照订阅者的数量进行复制，所以处理性能会随着订阅者的增加而明显降低，并且还要结合不同消息协议自身的性能差异由于一条消息只发给一个消费者，所以就算消费者再多，性能也不会有明显降低。当然不同消息协议的具体性能也是有差异的

四、消息持久化设置

1. queue默认是持久化

设置非持久化

  message..setJMSDeliveryMode(DeliveryMode.NON_PERSISTENT); 生产者配置

2. topic默认非持久化

设置为持久化

2.1 生产者创建连接之前设置持久化

2.2 生产者创建连接之前设置持久化，并对应修改代码

启动消费者端这里会显示在线的持久化订阅者

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

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

相关文章

深入理解Java中Stream流常用方法及示例

深入理解Java中Stream流常用方法及示例

深入理解Java中Stream流常用方法及示例 一、介绍二、举例说明1. filter方法2. map方法3. sorted方法4. forEach方法5. reduce方法6. collect方法7. flatMap方法8. anyMatch和allMatch方法9. findFirst和findAny方法10. skip和limit方法11. distinct方法 一、介绍 Java 8引入的…
阅读更多...
背 单 词 (考研词汇闪过)

背 单 词 (考研词汇闪过)

单词&#xff1a; 买考研词汇闪过 研究艾宾浩斯遗忘曲线 https://www.bilibili.com/video/BV18Y4y1h7YR/?spm_id_from333.337.search-card.all.click&vd_source5cbefe6dd70d6d84830a5891ceab2bf9 单词方法 闪记背两排&#xff08;5min&#xff09;重复一遍&#xff08;2mi…
阅读更多...
Pixel-GS：用于3D高斯溅射的具有像素感知梯度的密度控制

Pixel-GS：用于3D高斯溅射的具有像素感知梯度的密度控制

Pixel-GS: Density Control with Pixel-aware Gradient for 3D Gaussian Splatting Pixel-GS&#xff1a;用于3D高斯溅射的具有像素感知梯度的密度控制 Zheng Zhang  Wenbo Hu†  Yixing Lao   老宜兴市郑张文博胡 † Tong He  Hengshuang Zhao† 赵同和恒双 †1122113311 …
阅读更多...
Web前端 Javascript笔记1

Web前端 Javascript笔记1

为什么学习 JavaScript? JavaScript 是 web 开发人员必须学习的 3 门语言中的一门&#xff1a; HTML 定义了网页的内容CSS 描述了网页的布局JavaScript 控制了网页的行为 JavaScript 是可插入 HTML 页面的编程代码。 JavaScript 插入 HTML 页面后&#xff0c;可由所有的现代浏…
阅读更多...
BTS441RGATMA1 N沟道 43V 17A高侧电源开关芯片 英飞凌

BTS441RGATMA1 N沟道 43V 17A高侧电源开关芯片 英飞凌

BTS441RGATMA1是一款由Infineon Technologies制造的高侧开关电源芯片。 直 接 联 系 客 服 价 格 比 商 城 下 单 更 便 宜 BTS441RGATMA1具有以下功能&#xff1a; 高端电源开关&#xff1a;BTS441RGATMA1是一种N通道功率场效应晶体管&#xff08;FET&#xff09;&#xff…
阅读更多...
图像处理与视觉感知---期末复习重点（7）

图像处理与视觉感知---期末复习重点（7）

文章目录 一、图像压缩1.1 三种冗余1.2 模型1.3 信息测量 二、无误差压缩2.1 哈夫曼编码2.1.1 步骤2.1.2 例题 2.2 算术编码 三、变换编码 一、图像压缩 1.1 三种冗余 1. 三种基本的是数据冗余为&#xff1a;编码冗余、像素间冗余、心理视觉冗余。 2. 编码冗余&#xff1a;如果…
阅读更多...
途游游戏，科锐国际（计算机类），快手，CVTE，得物，蓝禾，奇安信，顺丰，康冠科技，金证科技24春招内推

途游游戏，科锐国际（计算机类），快手，CVTE，得物，蓝禾，奇安信，顺丰，康冠科技，金证科技24春招内推

途游游戏&#xff0c;科锐国际&#xff08;计算机类&#xff09;&#xff0c;快手&#xff0c;CVTE&#xff0c;得物&#xff0c;蓝禾&#xff0c;奇安信&#xff0c;顺丰&#xff0c;康冠科技&#xff0c;金证科技24春招内推 ①得物 【岗位】技术&#xff0c;设计&#xff0c;…
阅读更多...
⭐Unity 里调用弹出电脑系统文件选择窗 (选择图片/文件)

⭐Unity 里调用弹出电脑系统文件选择窗 (选择图片/文件)

今天遇到的需求要从Uinty里调用选择程序外的图片&#xff0c;类似手机环境下拿图库的照片一样。 效果如下: 话不多说 直接上代码&#xff01; 1.编辑器模式下 using System.Collections; using System.Collections.Generic; using UnityEngine; using System.IO; using Syst…
阅读更多...
vue中预览docx、xlsx、pptx、pdf

vue中预览docx、xlsx、pptx、pdf

前言&#xff1a;其实本来是要做全类型文件预览的&#xff0c;但是一直找不到合适的doc,xlx,ppt预览插件。要是有可以使用的&#xff0c;可以评论推荐给我 我使用的node版本&#xff1a;v18.19.1 参考官网&#xff1a;preview 文件预览 | ran 引入方式&#xff1a; //安装组…
阅读更多...
瀑布流布局

瀑布流布局

瀑布流布局&#xff1a;瀑布流&#xff0c;又称瀑布流式布局&#xff0c;是比较流行的一种页面布局&#xff0c;视觉表现为参差不齐的多栏布局。 问题概述: 一次性生成&#xff0c;不需要再次增加&#xff0c;排序顺序由上倒下&#xff0c;由左到右 解决方案&#xff1a; //…
阅读更多...
深度分析thinkphp类的自动加载

深度分析thinkphp类的自动加载

类的自动加载是框架中非常重要的特性&#xff0c;它允许你在使用类时无需手动包含或引入对应的文件。类的自动加载实现起来很简单&#xff0c;只需这样的一个函数spl_autoload_register就能实现。但框架都有各自的加载规范&#xff0c;并不是所有类都能被自动加载&#xff0c;因…
阅读更多...
fatal: Need to specify how to reconcile divergent branches.

fatal: Need to specify how to reconcile divergent branches.

报错 hint: You have divergent branches and need to specify how to reconcile them. hint: You can do so by running one of the following commands sometime before hint: your next pull: hint: hint: git config pull.rebase false # merge (the default strategy) hi…
阅读更多...
最优算法100例之41-用两个栈实现队列

最优算法100例之41-用两个栈实现队列

专栏主页：计算机专业基础知识总结（适用于期末复习考研刷题求职面试）系列文章https://blog.csdn.net/seeker1994/category_12585732.html 题目描述 用两个栈实现队列 题解报告 stack<int> stack1; stack<int> stack2; void push(int node) {stack1.push(node);…
阅读更多...
2024-4-11-arm作业

2024-4-11-arm作业

汇编实现三个灯的闪烁 源代码&#xff1a; .text .global _start _start: 时钟使能LDR r0,0x50000A28ldr r1,[r0]orr r1,r1,#(0x1<<4)str r1,[r0]设置PE10输出LDR r0,0x50006000ldr r1,[r0]bic r1,r1,#(0x3<<20)orr r1,r1,#(0x1<<20)str r1,[r0]设置PE1…
阅读更多...
飞机降落蓝桥杯[2023蓝桥省赛B组]

飞机降落蓝桥杯[2023蓝桥省赛B组]

2023蓝桥省赛B组 B题 飞机降落 题解 标准深搜板子题&#xff0c;难度不大 #include<bits/stdc.h> using namespace std; #define MAX 10 struct node{int t,d,l;//t:飞机到达时间 d:飞机最大盘旋时间 l:飞机降落所需时间bool v;//标记此架飞机是否被搜索过 用于剪枝 };…
阅读更多...
OpenResty，Nginx实现接口验签与黑名单控制

OpenResty，Nginx实现接口验签与黑名单控制

介绍 nginx与openresty是两种优秀知名的7层负载均衡软件&#xff0c;nginx以其出色的性能和稳定性成为首选&#xff0c;而openresty则是在Nginx基础上构建的&#xff0c;支持嵌入Lua语言&#xff0c;大幅提升了开发效率。 安装OpenResty 版本 openresty-1.25.3.1-win64下载地…
阅读更多...
brpc: bthread使用

brpc: bthread使用

使用bthread并发编程 #include <gflags/gflags.h> #include <butil/logging.h> #include <bthread/bthread.h>static void* func(void* args) {std::string* num static_cast<std::string*>(args);for(int i 0; i < 5; i) {LOG(INFO) << *…
阅读更多...
mybatis的一对多

mybatis的一对多

业务&#xff1a;通常主表从表 查询&#xff0c;一对多关系&#xff0c;通常是先查主表&#xff0c;然后拿主表的 关联字段与从表关联。在代码中 通常用for 循环等方法给 从表的数据赋值&#xff0c;很麻烦&#xff0c;&#xff0c;&#xff0c;很麻烦。。。。 用mybatis的…
阅读更多...
一个PDF文件含有多篇不同的内容，如何把这些内容分离出来？

一个PDF文件含有多篇不同的内容，如何把这些内容分离出来？

一&#xff0c;PDF的含义 PDF&#xff0c;全称Portable Document Format&#xff0c;即便携式文档格式&#xff0c;是一种由Adobe Systems开发的文件格式&#xff0c;用于呈现文档&#xff0c;包括文本、图像、向量图形、字体、颜色、页面布局等&#xff0c;并可在不同的操作系…
阅读更多...
FPGA在医疗的应用，以4K医疗内窥镜为例

FPGA在医疗的应用，以4K医疗内窥镜为例

前言 随着技术的发展&#xff0c;医学影像作为科学技术的主要成就之一&#xff0c;在无创诊断和治疗领域已经有了多种应用。其中一个应用是内窥镜&#xff0c;在20世纪90年代&#xff0c;当利用电荷耦合装置将图像传输到显示器上成为可能时&#xff0c;内窥镜变得更加广泛。为…
阅读更多...
最新文章

Copyright @ 2022~2023