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,一经查实,立即删除!

相关文章

背 单 词 (考研词汇闪过)

单词&#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: 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 …

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

BTS441RGATMA1是一款由Infineon Technologies制造的高侧开关电源芯片。 直 接 联 系 客 服 价 格 比 商 城 下 单 更 便 宜 BTS441RGATMA1具有以下功能&#xff1a; 高端电源开关&#xff1a;BTS441RGATMA1是一种N通道功率场效应晶体管&#xff08;FET&#xff09;&#xff…

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

文章目录 一、图像压缩1.1 三种冗余1.2 模型1.3 信息测量 二、无误差压缩2.1 哈夫曼编码2.1.1 步骤2.1.2 例题 2.2 算术编码 三、变换编码 一、图像压缩 1.1 三种冗余 1. 三种基本的是数据冗余为&#xff1a;编码冗余、像素间冗余、心理视觉冗余。 2. 编码冗余&#xff1a;如果…

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

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

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; //…

最优算法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作业

汇编实现三个灯的闪烁 源代码&#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…

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

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

mybatis的一对多

业务&#xff1a;通常主表从表 查询&#xff0c;一对多关系&#xff0c;通常是先查主表&#xff0c;然后拿主表的 关联字段与从表关联。在代码中 通常用for 循环等方法给 从表的数据赋值&#xff0c;很麻烦&#xff0c;&#xff0c;&#xff0c;很麻烦。。。。 用mybatis的…

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

一&#xff0c;PDF的含义 PDF&#xff0c;全称Portable Document Format&#xff0c;即便携式文档格式&#xff0c;是一种由Adobe Systems开发的文件格式&#xff0c;用于呈现文档&#xff0c;包括文本、图像、向量图形、字体、颜色、页面布局等&#xff0c;并可在不同的操作系…

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

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

怎么做预约小程序_探索我们的全新预约小程序

在繁忙的现代生活中&#xff0c;无论是想预约一次美容护理&#xff0c;还是预定一家心仪的餐厅&#xff0c;亦或是安排一次专业的咨询服务&#xff0c;我们都希望能够在最短的时间内完成这些操作&#xff0c;节省时间和精力。如今&#xff0c;一款全新的预约小程序应运而生&…

C语言——实践小游戏(贪吃蛇)代码版

大家好久不见&#xff0c;我是残念我回来了&#xff0c;希望在你看完之后&#xff0c;能对你有所帮助&#xff0c;有什么不足请指正&#xff01;共同学习交流 本文由&#xff1a;残念ing原创CSDN首发&#xff0c;如需要转载请通知 个人主页&#xff1a;残念ing-CSDN博客&#x…

从 Oracle 到 MySQL 数据库的迁移之旅

文章目录 引言一、前期准备工作1.搭建新的MySQL数据库2 .建立相应的数据表2.1 数据库兼容性分析2.1.1 字段类型兼容性分析2.1.2 函数兼容性分析2.1.3 是否使用存储过程&#xff1f;存储过程的个数&#xff1f;复杂度&#xff1f;2.1.4 是否使用触发器&#xff1f;个数&#xff…

Paper Reading: MixTeacher:半监督目标检测中利用混合尺度教师挖掘有前景的标签

目录 简介目标/动机工作重点方法训练 实验总结 简介 题目&#xff1a;《MixTeacher: Mining Promising Labels with Mixed Scale Teacher for Semi-Supervised Object Detection》&#xff0c; CVPR 2023 日期&#xff1a;2023.3.16 单位&#xff1a;腾讯&#xff0c;上海交…

竞赛 图像识别-人脸识别与疲劳检测 - python opencv

文章目录 0 前言1 课题背景2 Dlib人脸识别2.1 简介2.2 Dlib优点2.3 相关代码2.4 人脸数据库2.5 人脸录入加识别效果 3 疲劳检测算法3.1 眼睛检测算法3.3 点头检测算法 4 PyQt54.1 简介4.2相关界面代码 5 最后 0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是…

Android MVVM架构学习——ViewModel DataBinding

关于MVVM架构&#xff0c;我并不想花篇幅去做重复性的描述&#xff0c;网上一搜都是一堆讲解&#xff0c;大家可以自行了解&#xff0c;我所做的只是以最简单的例子&#xff0c;最有效的步骤&#xff0c;从零开始&#xff0c;去实现一个相对有点学习参考价值的项目。 先来看本…

计算机网络——NAT技术

目录 前言 前篇 引言 SNAT&#xff08;Source Network Address Translation&#xff09;源网络地址转换 SNAT流程 确定性标记 DNAT&#xff08;Destination Network Address Translation&#xff0c;目标网络地址转换&#xff09; NAT技术重要性 前言 本博客是博主用于…