消息队列（一）-- RabbitMQ入门（1）

初识 RabbitMQ

  • 核心思想：接收并转发消息。可以把它想象成一个邮局。
    在这里插入图片描述
    producer：生产者
    queue：队列
    consumer：消费者
  • 什么是消息队列
    MQ（Message Queue）：本质是队列，FIFO先入先出，只不过队列中存放的内容是 message 而已，还是一种跨进程的通信机制，用于上下游传递消息。在互联网架构中，MQ是一种非常常见的上下游“逻辑解耦+物理解耦”的消息通信服务。使用了MQ之后，消息发送上游只需要依赖MQ，不用依赖其他服务。

在这里插入图片描述
消息队列起到的作用主要为：允许入列、存储消息及消息出列。

  • 消息队列的特性

    • 业务无关
    • FIFO：先进先出
    • 容灾：可以把消息进行持久化，即便未发出去或发送消息的过程突然断电、服务宕机，等恢复服务后把之前的消息重新发送，保证了可靠性。
    • 性能：消息队列的吞吐量上去之后，整个系统内部通信效率也会提高。

  • 为什么要使用消息队列

    • 系统解耦：当系统A发送一个消息到多个系统，中间使用消息队列后，不用每个系统都调用一遍，减少处理时间，提高维护性。
    • 异步调用：可以通过消息，异步调用多个业务模块，大大提升整体程序的运行速度。
    • 流量削峰：当系统出现流量高峰时，可以把请求放到消息队列里，再以服务器能处理的速度发给各个系统，从而减少不必要的物理资源扩充。

  • MQ的分类

    • ActiveMQ
      • 优点：单击吞吐量万级，时效性 ms 级，可用性高，基于主从架构实现高可用性，较低概率丢失数据。
      • 缺点：官方社区现在对 ActiveMQ 5.x 维护越来越少，高吞吐量场景较少使用。
    • Kafka
      • 大数据的杀手锏，谈到大数据领域内的消息传输，则绕不开 Kafka，为大数据而生的消息中间件，支持百万级 TPS 的吞吐量，在数据采集、传输、存储的过程中发挥着举足轻重的作用。
      • 优点：性能卓越，单击写入 TPS 约在百万条/秒，最大的优点就是吞吐量高。时效性 ms 级，可用性非常高。kafka 是分布式的，一个数据多个副本，少量机器宕机不会丢失数据，不会导致不可用。消费者采用 pull 方式获取消息，消息有序，通过控制能够保证所有消息被消费且仅被消费一次。有优秀的第三方Kafka Web 管理界面 Kafka-Manager。在日志领域比较成熟，被多家公司和多个开源项目使用。功能较为简单，主要支持简单的 MQ 功能，在大数据领域的实时计算以及日志采集被大规模使用。
      • 缺点：Kafka 单击超过 64 个队列/分区， Load 会发生明显的飙高现象，队列越多，load 越高，发送消息响应时间变长，使用短轮询方式，实时性能取决于轮询间隔时间，消费失败不支持重试；支持消息顺序，但是一台代理宕机后，就会产生消息乱序，社区更新较慢。
    • RocketMQ
      • RocketMQ 出自阿里巴巴的开源产品，用 Java 语言实现，在设计时参考了 Kafka，并做出了自己的一些改进。被阿里巴巴吧广泛应用在订单，交易，充值，流计算，消息推送，日志流式处理，binglog分发等场景。
      • 优点：单击吞吐量十万级，可用性非常高，分布式架构，消息可以做到 0 丢失，MQ功能较为完善，扩展性好，支持10亿级别的消息堆积，不会因为堆积导致性能下降，源码是Java，可以自己阅读源码，定制自己公司的 MQ。
      • 缺点：支持的客户端语言不多，目前是Java及C++，其中C++不成熟；社区活跃度一般，没有在 MQ 核心中去实现 JMS 等接口，有些系统要迁移需要修改大量代码。
    • RabbitMQ
      • 2007年发布，是一个在AMQP（Advanced Message Queuing Protocol 高级消息队列协议）基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。
      • 优点：由于 Erlang 语言的高并发特性，性能较好；吞吐量到万级，MQ 功能比较完备，健壮、稳定、易用、跨平台，支持多种语言，如：Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript等。支持AJAX，文档齐全，开源提供的管理界面非常棒，用起来很好用，社区活跃度高，更新频率相当高。
      • 缺点：商业版需要收费，学习成本较高。

  • MQ 的选择

    • Kafka：大量数据的互联网服务的数据收集业务，有日志采集功能，首选 Kafka。
    • RocketMQ：金融互联网领域，对于可靠性要求很高的场景，尤其是电商里面的订单扣款，以及业务削峰等。RoketMQ 在稳定性上更值得信赖，在阿里双11经历了多次考验。
    • RabbitMQ：结合 Erlang语言本身的并发优势，性能好，时效性微秒级，社区活跃度也比较高，管理界面用起来十分方便。如果数据量没那么大，中小型公司优先选择功能比较完备的 RabbitMQ。

  • RabbitMQ 核心概念
    在这里插入图片描述
    四大核心概念：生产者 Publisher、交换机 Exchage、队列 Queue、消费者Consumer。
    在这里插入图片描述

    • Broker：接受和分发消息的应用，RabbitMQ Server就是 Message Broker
    • connection：publisher / consumer 与 broker 之间的 TCP 连接
    • Channel：信道，在connection 内部建立的逻辑连接，每个connection可以包含多个信道，每次发消息只会占用一个信道。几乎所有的操作都在信道上进行。Channel 极大减少了操作系统建立 TCP connection 的开销。
    • message：消息，由 properties 和 body 组成，properties 为对消息进行额外的修饰，包括优先级、队列延迟、消息其他属性等；body 为消息实体。
    • Virtual host：虚拟主机，顶层隔离。出于多租户和安全因素设计的，在Broker里可以包含多个 Virtual host ，而一个 Virtual host 里又可以包含多个 Exchange 和 Queue。 同一个虚拟主机下，不能有重复的交换机和 queue。
    • Exchange：交换机，接收生产者的消息的，然后根据指定的路由器去把消息转发到所绑定的队列上。
    • binding：绑定交换机和队列
    • routing key：路由键，路由规则，虚拟机可以用它来确定这个消息如何进行一个路由。
    • queue：队列，消费者只需要监听队列来消费消息，不需要关注消息来自哪个Exchange
    • Exchange 和 Message Queue 存在着绑定的关系，一个 Exchange 可以绑定多个消息对类。

  • RabbitMQ 六大模式
    在这里插入图片描述

  • 消息流转过程
    在这里插入图片描述

RabbitMQ 的安装和启动

  • 下载安装包
    先通过 uname -a 命令查询 Linux 版本，然后下载对应的安装包
    在这里插入图片描述
    然后根据 Linux 版本，在 PackageCloud 查看RabbitMQ与Erlang 支持的版本，及官网https://www.rabbitmq.com/查看RabbitMQ与Erlang对应版本
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
    结合上面，选择并下载RabbitMQ 3.10.0 及 Erlang 23.3.x 版本。
    在这里插入图片描述
    在这里插入图片描述
    下载完后，通过如 SecureFX 文件上传工具上传到 Linux 服务器上
    在这里插入图片描述
  • 安装
    安装 Erlang
    rpm -ivh erlang-23.3.4.11-1.el7.x86_64.rpm
    在这里插入图片描述
    安装 RabbitMQ（yum命令需要Linux服务器联网）
    yum install rabbitmq-server-3.10.0-1.el7.noarch.rpm
    在这里插入图片描述
  • 常用命令
    添加开机启动
    chkconfig rabbitmq-server on
    在这里插入图片描述
    启动服务
    service rabbitmq-server start
    查看服务状态
    service rabbitmq-server status
    如下图，如果是active (running)则启动完成（activating 为正在启动中，稍微等待重新查看服务状态）
    在这里插入图片描述
    停止服务
    service rabbitmq-server stop
    开启 web 管理插件（需先停止服务）
    rabbitmq-plugins enable rabbitmq_management
    如出现如下错误，
    在这里插入图片描述
    将主机名配置修改和上图显式的名称vim /etc/hosts
    在这里插入图片描述
    然后再执行，成功后启动服务
    在这里插入图片描述
    防火墙开发15672端口
    firewall-cmd --zone=public --permanent --add-port=15672/tcp
    firewall-cmd --reload
    浏览器访问
    在这里插入图片描述
  • 添加新用户
    创建账号
    rabbitmqctl add_user admin 123456
    设置用户角色
    rabbitmqctl set_user_tags admin administrator
    设置用户权限
    set_permissions [-p ]
    rabbitmqctl set_permissions -p “/” admin “.*” “.*” “.*”
    用户admin具有 “/” 这个 virtual host 中所有资源的配置、写、读权限
    当前用户和角色
    rabbitmqctl list_users

Hello World

简单队列模式
在这里插入图片描述

打开IDEA，创建一个空项目
在这里插入图片描述
然创建一个Module
在这里插入图片描述
在这里插入图片描述
在pom.xml文件添加依赖

    <!--指定jdk编译版本--><build><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><configuration><source>8</source><target>8</target></configuration></plugin></plugins></build><dependencies><!--rabbitmq依赖客户端--><dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.8.0</version></dependency><!--操作文件流的一个依赖--><dependency><groupId>commons-io</groupId><artifactId>commons-io</artifactId><version>2.6</version></dependency></dependencies>
  • 消息生产者
package com.ql.rabbitmq.one;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 生产者：发消息*/
public class Producer {//队列名称public static final String QUEUE_NAME = "hello";//发消息public static void main(String[] args) throws IOException, TimeoutException {//创建一个连接工厂ConnectionFactory factory = new ConnectionFactory();//工厂IP 连接RabbitMQ的队列factory.setHost("192.168.1.130");//factory.setPort(15672);//用户名factory.setUsername("admin");//密码factory.setPassword("123456");//创建连接Connection connection = factory.newConnection();//获取信道Channel channel = connection.createChannel();/*** 生成队列* 1.队列名称* 2.队列里面的消息是否持久化（磁盘） 默认消息存储在内存中* 3.该队列是否只供一个消费者进行消费 是否进行消息共享，true可以多个消费者消费， false:只能一个消费者消费* 4.是否自动删除 最后一个消费者端开连接以后 该队列是否自动删除 true自动删除 false不自动删除* 5.其他参数*/channel.queueDeclare(QUEUE_NAME, false, false, false, null);//发消息String message = "hello world";//初次使用/*** 发送一个消息* 1.发送到哪个交换机* 2.路由的Key值是哪个 本次是队列的名称* 3.其他参数信息* 4.发送消息的消息体*/channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println("消息发送完毕");}}

运行测试（注，Linux放开5672端口），看到已经有一条消息。
在这里插入图片描述

  • 消息消费者
package com.ql.rabbitmq.one;import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 消费者 接收消息的*/
public class Consumer {//队列的名称public static final String QUEUE_NAME = "hello";//接收消息public static void main(String[] args) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.1.130");factory.setUsername("admin");factory.setPassword("123456");Connection connection = factory.newConnection();Channel channel = connection.createChannel();//声明 接收消息DeliverCallback deliverCallback = (consumerTag, message) -> {System.out.println(new String(message.getBody()));};//取消消息时的回调CancelCallback cancelCallback = consumerTag -> {System.out.println("消息消费被中断");};/*** 消费者消费消息* 1.消费哪个队列* 2.消费成功之后是否要自动应答 true 代表的自动应答 false 代表手动应答* 3.消费者成功消费的回调* 4.消费者取消消费的回调*/channel.basicConsume(QUEUE_NAME, true, deliverCallback, cancelCallback);}
}

Work Queues

工作队列模式（又称任务队列）的主要思想是，当有资源密集型任务，把任务封装为消息，并将其发送到队列，由一个或多个工作线程将任务轮询弹出并执行。
在这里插入图片描述

轮询分发消息

  • 抽取连接工厂工具类
package com.ql.rabbitmq.utils;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 此类为连接工厂创建信道的工具类*/
public class RabbitMqUtils {//得到一个连接的channelpublic static Channel getChannel() throws IOException, TimeoutException {//创建连接工厂ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.1.130");factory.setUsername("admin");factory.setPassword("123456");Connection connection = factory.newConnection();Channel channel = connection.createChannel();return channel;}
}
  • 工作线程代码
package com.ql.rabbitmq.two;import com.ql.rabbitmq.utils.RabbitMqUtils;
import com.rabbitmq.client.CancelCallback;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 这是一个工作线程（相当于之前消费者）*/
public class Worker01 {//队列的名称public static final String QUEUE_NAME = "hello";//接受消息public static void main(String[] args) throws IOException, TimeoutException {Channel channel = RabbitMqUtils.getChannel();DeliverCallback deliverCallback = (consumerTag, message)->{System.out.println("接收到的消息："+new String(message.getBody()));};CancelCallback cancelCallback = (consumerTag)->{System.out.println(consumerTag+"消费者取消消费接口的回调");};channel.basicConsume(QUEUE_NAME, true, deliverCallback, cancelCallback);}
}

  • 启动2个工作线程
    先启动一个
    在这里插入图片描述
    在这里插入图片描述
    然后IDEA运行配置里开启允许多个实例，再运行
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述

  • 生产者代码

package com.ql.rabbitmq.two;import com.ql.rabbitmq.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.TimeoutException;/*** 生产者 发送大量的消息*/
public class Task01 {//队列的名称public static final String QUEUE_NAME = "hello";public static void main(String[] args) throws IOException, TimeoutException {Channel channel = RabbitMqUtils.getChannel();//队列的声明channel.queueDeclare(QUEUE_NAME, false, false, false, null);//从控制台当中接受信息Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String message = scanner.next();channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println("发送消息完成："+ message);}}
}

运行测试
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

消息应答

消费者完成一个任务可能需要一段时间，如果其中一个消费者处理一个长的任务并仅完成了部分后突然挂掉了，会发生什么情况？RabbitMQ 一旦向消费者传递一条消息，便立即将该消息标记为删除，这种情况下，突然有个消息挂掉了，将会丢失正在处理的消息。
为了保证消息在发送过程中不丢失，RabbitMQ 引入消息应答机制，消息应答就是：消费者在接收到消息并且处理该消息之后，告诉 RabbitMQ 它已经处理了，RabbitMQ 可以把该消息删除了。

  • 自动应答
    消息发送后立即被认为已经发送成功，这种模式需要在高吞吐量和数据传输安全性方面做权衡。因为这种模式如果消息在接收到之前，消费者出现连接或 channel 关闭，消息就会丢失。另一方面，这种模式消费者没有对传递的信息数量进行限制，这样有可能发生消息的积压导致内存溢出等。所以这种模式仅适合在消费者可以高效并以某种速率能够处理这些消息的情况下使用。

  • 手动应答

    • Channel.basicAck(用于肯定确认)
      RabbitMQ 已知道该消息并且成功的处理消息，可以将其丢弃了
    • Channel.basicNack(用于否定确认)
    • Channel.basicRejeck(用于否定确认)
      与 Channel.basicNack 少一个参数
      不处理该消息了直接拒绝，可以将其丢弃

  • Multiple 批量应答
    手动应答的好处是可以批量应答并且减少网络拥堵
    Channel.basicAck(deliveryTag, Multiple)
    Multiple：
    true 代表批量应答 channel 上未应答的消息。比如说 channel 上有传送tag的消息 5、6、7、8 当前 tag 是 8 ，那么此时 5-8 的消息都会被确认收到消息应答
    false 不批量应答（强烈推荐）。上面情形，只会应答 8 的消息。

  • 消息自动重新入队
    如果消费者由于某些原因失去连接（其通道已关闭、连接已关闭或TCP 连接丢失），导致消息未发送ACK 确认，RabbitMQ 将了解到消息未完全处理，并将对其重新排队。如果此时其他消费者可以处理，它将很快将其重新分发给另一个消费者。这样，即使某个消费者偶尔死亡，也可以确保不会丢失任何消息。
    在这里插入图片描述

  • 消息手动应答代码

生产者Task2

package com.ql.rabbitmq.three;import com.ql.rabbitmq.utils.RabbitMqUtils;
import com.rabbitmq.client.Channel;import java.io.IOException;
import java.util.Scanner;
import java.util.concurrent.TimeoutException;/*** 消息在手动应答时不丢失、放回队列中重新消费*/
public class Task2 {//队列名称public static final String TASK_QUEUE_NAME = "ack_queue";public static void main(String[] args) throws IOException, TimeoutException {Channel channel = RabbitMqUtils.getChannel();//声明队列channel.queueDeclare(TASK_QUEUE_NAME, false, false, false, null);//从控制台中输入信息Scanner scanner = new Scanner(System.in);while (scanner.hasNext()){String message = scanner.next();channel.basicPublish("", TASK_QUEUE_NAME, null, message.getBytes("UTF-8"));System.out.println("生产者发出消息："+message);}}
}

消费者Work03

package com.ql.rabbitmq.three;import com.ql.rabbitmq.utils.RabbitMqUtils;
import com.ql.rabbitmq.utils.SleepUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 消息在手动应答时不丢失，放回队列重新消费*/
public class Work03 {//队列名称public static final String TASK_QUEUE_NAME = "ack_queue";//接收消息public static void main(String[] args) throws IOException, TimeoutException {Channel channel = RabbitMqUtils.getChannel();System.out.println("C1等待接收消息处理时间较短");DeliverCallback deliverCallback = (consumerTag , message)->{//沉睡1SSleepUtils.sleep(1);System.out.println("接收到的消息："+new String(message.getBody(), "UTF-8"));//手动应答/*** 1.消息的标记 tag* 2.是否批量应答*/channel.basicAck(message.getEnvelope().getDeliveryTag(), false);};//采用手动应答boolean autoAck = false;channel.basicConsume(TASK_QUEUE_NAME, autoAck, deliverCallback, (consumerTag ->{System.out.println(consumerTag+"消费者取消消费接口回调");}));}
}

消费者Work04

package com.ql.rabbitmq.three;import com.ql.rabbitmq.utils.RabbitMqUtils;
import com.ql.rabbitmq.utils.SleepUtils;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.DeliverCallback;import java.io.IOException;
import java.util.concurrent.TimeoutException;/*** 消息在手动应答时不丢失，放回队列重新消费*/
public class Work04 {//队列名称public static final String TASK_QUEUE_NAME = "ack_queue";//接收消息public static void main(String[] args) throws IOException, TimeoutException {Channel channel = RabbitMqUtils.getChannel();System.out.println("C2等待接收消息处理时间较长");DeliverCallback deliverCallback = (consumerTag , message)->{//沉睡30SSleepUtils.sleep(30);System.out.println("接收到的消息："+new String(message.getBody(), "UTF-8"));//手动应答/*** 1.消息的标记 tag* 2.是否批量应答*/channel.basicAck(message.getEnvelope().getDeliveryTag(), false);};//采用手动应答boolean autoAck = false;channel.basicConsume(TASK_QUEUE_NAME, autoAck, deliverCallback, (consumerTag ->{System.out.println(consumerTag+"消费者取消消费接口回调");}));}
}

睡眠工具类

public class SleepUtils {public static void sleep(int second){try {Thread.sleep(1000*second);} catch (InterruptedException e) {e.printStackTrace();}}
}
  • 手动应答效果演示
    依次启动Task2、Work03、Work04，然后Task2发送两个消息
    在这里插入图片描述
    此时Work03 已收到第一条消息
    在这里插入图片描述
    Work04 收到消息后沉睡30s之后才打印并手动应答，我们在应答前停止Work04
    在这里插入图片描述
    停止Work04 后，第二条消息就会被Work03 重新消费
    在这里插入图片描述

RabbitMQ 持久化

默认情况下 RabbitMQ 退出或由于某种原因崩溃时，它忽视队列和消息。为了确保消息不会丢失，我们需要将队列和消息都标记为持久化。

  • 队列实现持久化
    上面创建的队列都是非持久化的，RabbitMQ 如果重启的话，该队列就会被删除。如果要队列实现持久化，需要在声明队列的时候把 durable 参数设置为持久化
    在这里插入图片描述
    在这里插入图片描述
    注：如果之前声明的队列不是持久化的，需要把原先队列先删除，否则出现如下错误
    在这里插入图片描述
    在管理页面先删除队列，重新启动Task2
    在这里插入图片描述
    刷新管理页面，该队列就会多一个D 的持久化标识。
    在这里插入图片描述
  • 消息持久化
    修改生产者代码
    在这里插入图片描述
    在发布消息时，添加 MessageProperties.PERSISTENT_TEXT_PLAIN 属性
    在这里插入图片描述
    将消息标记为持久化并不能完全保证消息不丢失，尽管它告诉 RabbitMQ 将消息保存到磁盘，但是这里依然存在消息刚准备存储在磁盘的时候，服务关闭等，此时并没有真正写入磁盘。持久化保证并不强，但是对于简单任务队列是足够了，如果需要更强有力的持久化策略，参考后面发布确认知识点。
  • 不公平分发
    轮询分发的缺点：当有两个消费者，其中一个处理任务速度非常快，另一个速度很慢，这个时候还用轮询分发，速度快的消费者大部分时间处于空闲状态，而另一个却在一直在处理任务。
    为了避免这种情况，我们可以在消费者接收消息的时候，设置参数 channel.basicQos(1) 实现不公平分发。（如果设置为0 则轮询分发）
    在这里插入图片描述
    设置完Work03、Work04 后，重启测试
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
  • 预取值
    RabbitMQ的信道上肯定不止只有一个消息，因此这里就存在一个未确认的消息缓冲区，因此希望开发人员能限制此缓冲区的大小，以避免缓冲区里面无限制的未确认消息问题。这个时候就可以通过使用 channel.basicQos() 方法设置“预取计数”值来完成的。该值定义通道上允许的未确认消息的最大数量。一旦数量达到配置的数量，RabbitMQ 将停止在通道上传递更多消息，除非至少有一个未处理的消息被确认。
    上面的不公平分发，相当于安把预取值设置成了1。
    我把上面Work03 、Work04 信道预取值都改成5，然后重启测试
    在这里插入图片描述
    发送多个消息
    在这里插入图片描述
    通过管理界面可看到信道里堆积的消息条数。
    在这里插入图片描述

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

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

相关文章

【【直流电机驱动PWN】】

【【直流电机驱动PWN】】

直流电机驱动PWN 前面都是沙县小吃&#xff0c;这里才是满汉全席 直流电机是一种电能转化成机械能的装置 直流电机有两个电极 当电机正接 电机正转 当电机负接 电机倒转 电机还有步进电机 舵机 无刷电机 空心杯电机 因为电机是一个大功率器件并不太好直接接在IO端口上所以我…
阅读更多...
设备模块调用整合指南

设备模块调用整合指南

描述 不依赖其它事件管理器，直接引入js，全局事件方法（设备对象名+事件名）处理 #1、引入相关js <script src="./utils/lodash.min.js"></script><script src="config/config.js"></script><script src="./plugins/pl…
阅读更多...
脑电信号处理与特征提取——1. 脑电、诱发电位和事件相关电位（胡理）

脑电信号处理与特征提取——1. 脑电、诱发电位和事件相关电位（胡理）

目录 一、 脑电、诱发电位和事件相关电位 1.1 EEG基本知识 1.2 经典的ERPs成分及研究 1.2.1 ERPs命名规则及分类 1.2.2 常见的脑电成分 1.2.3 P300及Oddball范式 1.2.4 N400成分 一、 脑电、诱发电位和事件相关电位 1.1 EEG基本知识 EEG(Electroencephalogram)&#x…
阅读更多...
【Mysql数据库面试01】内连接 左连接 右连接 全连接

【Mysql数据库面试01】内连接 左连接 右连接 全连接

【Mysql数据库】内连接 左连接 右连接 全连接 0.准备1.内连接1.1 SQL(不带where)1.2 SQL&#xff08;带where&#xff09;1.3总结 2.左连接2.1SQL&#xff08;不带where&#xff09;2.2SQL&#xff08;带where&#xff09;2.3总结 3.右连接3.1 SQL&#xff08;不带where&#x…
阅读更多...
CVPR2023新作：基于面部对称性先验的三维生成对抗网络反演方法

CVPR2023新作：基于面部对称性先验的三维生成对抗网络反演方法

Title: 3D GAN Inversion With Facial Symmetry Prior (带面部对称性先验的3D GAN反演) Affiliation: 清华大学 Authors: Fei Yin, Yong Zhang, Xuan Wang, Tengfei Wang, Xiaoyu Li, Yuan Gong, Yanbo Fan, Xiaodong Cun, Ying Shan, Cengiz Oztireli, Yujiu Yang Keywords…
阅读更多...
GDAL C++ API 学习之路 (6) OGRGeometry 几何类 OGRGeometry

GDAL C++ API 学习之路 (6) OGRGeometry 几何类 OGRGeometry

Simplify virtual OGRGeometry *Simplify(double dTolerance) const 简化几何图形 参数: dTolerance -- 简化的距离容差。 返回: 简化的几何图形或 NULL&#xff08;如果发生错误&#xff09; // 创建一个多边形对象OGRLinearRing ring;ring.addPoint(0, 0);ring.addPoint…
阅读更多...
CNN复习

CNN复习

个人的对于CNN总结的一些知识点 对于每一个卷积层来说&#xff0c;其out_channel就是卷积核的个数&#xff1a; 对每个输入的图片&#xff08;就是每一个&#xff08;C,H,W&#xff09;的矩阵&#xff0c;一共有batch_size个&#xff09;&#xff0c;卷积核从第0到第in_channe…
阅读更多...
表单验证：输入的字符串以回车分隔并验证是否有

表单验证：输入的字符串以回车分隔并验证是否有

公司项目开发时&#xff0c;有一个需求&#xff0c;需要对输入的字符串按回车分隔并验证是否有重复项&#xff0c;效果如下&#xff1a; 表单代码&#xff1a; <el-form-item label"IP地址条目&#xff1a;" prop"ipAddressEntry"><el-inputtype&…
阅读更多...
Vue中TodoList案例_静态

Vue中TodoList案例_静态

MyHeader.vue <template><div class"todo-header"><input type"text" placeholder"请输入你的任务名称&#xff0c;按回车键确认"></div> </template><script> export default {name: "MyHeader"…
阅读更多...
Vue 中input 点击复制其内容

Vue 中input 点击复制其内容

Element UI中el-input 组件 &#xff0c;一般使用情况&#xff1a; <el-input type"text" id"put" v-model"value" ></el-input> el-input 添加点击事件,这样添加点击事件是无效的&#xff1a; <el-input click"copy&quo…
阅读更多...
Linux Shell 脚本编程学习之【第3章 正则表达式 （第一部分）】

Linux Shell 脚本编程学习之【第3章 正则表达式 （第一部分）】

第3章 正则表达式 1 正则表达式基础1.1 *符号1.2 “.”符号1.3 “^”符号1.4 “$”符号1.5 “[]”符号1.6 “\”符号1.7 “\<\>”符号1.8 “\{\}”符号 2 正则表达式扩展2.1 “?”符号2.2 “”符号2.3“()”符合和“ | ”符号 3 通配&#xff08;Globbing&#xff09; 1…
阅读更多...
生产环境Session解决方案、Session服务器之Redis

生产环境Session解决方案、Session服务器之Redis

目录 一、服务器配置 二、安装nginx 三、安装配置Tomcat&#xff1a; 四、配置session Session服务器之Redis Redis与Memcached的区别 安装部署redis 一、服务器配置 IP地址 主机名 软件包列表 192.168.100.131 huyang1 nginx 192.168.100.133 huyang3 JDK Tomca…
阅读更多...
微信小程序上，实现图片右上角数字显示

微信小程序上，实现图片右上角数字显示

微信小程序上&#xff0c;实现图片右上角数字显示 直接上代码&#xff1a; 样式代码index.wxss如下&#xff1a; .circle_rednum {position: absolute;color: white;font-size: 13px;background-color: #EC2F43;width: 23px;height: 23px;line-height: 23px;left: 80%;top: …
阅读更多...
【docker】docker部署tomcat

【docker】docker部署tomcat

目录 1.1 搜索tomcat镜像1.2 拉取tomcat镜像1.3 创建容器&#xff0c;设置端口映射、目录映射1.4 测试 1.1 搜索tomcat镜像 docker search tomcat1.2 拉取tomcat镜像 docker pull tomcat1.3 创建容器&#xff0c;设置端口映射、目录映射 # 在/root目录下创建tomcat目录用于存…
阅读更多...
数据库备份还原-mysqldump、mydumper、xtrabackup、压缩

数据库备份还原-mysqldump、mydumper、xtrabackup、压缩

数据库备份&#xff0c;数据库为school&#xff0c;素材如下 一、创建student和score表 CREATE TABLE student ( id INT(10) NOT NULL UNIQUE PRIMARY KEY , name VARCHAR(20) NOT NULL , sex VARCHAR(4) , birth YEAR, department VARCHAR(20) , address VARC…
阅读更多...
Linux中常用的指令

Linux中常用的指令

ls ls [选项] [目录或文件] 功能&#xff1a;对于目录&#xff0c;列出该目录下所有的子目录和文件&#xff1b;对于文件&#xff0c;列出该文件的文件名和其他属性 常用选项&#xff1a; -a:列出目录下的所有文件&#xff0c;包括以.开头的隐藏文件 -l:列出文件的详细信息。…
阅读更多...
单片机第一季：零基础11——实时时钟DS1302

单片机第一季：零基础11——实时时钟DS1302

目录 1&#xff0c;DS1302 时钟芯片介绍 2&#xff0c;BCD码介绍 3&#xff0c;涉及到的寄存器 3.1&#xff0c;控制寄存器 3.2&#xff0c;日历/时钟寄存器 3.3&#xff0c;DS1302 的读写时序 4&#xff0c;相关代码 这一章我们来学习DS1302 时钟芯片&#xff0c…
阅读更多...
测牛学堂：软件测试之andorid app性能测试面试知识点总结（二）

测牛学堂：软件测试之andorid app性能测试面试知识点总结（二）

APP性能测试指标之FPS 如果经常玩游戏的同学应该听过FPS。 FPS本来是图像领域中的概念&#xff0c;是指画面每秒传输的帧数。每秒钟帧数越多&#xff0c;所显示的动作就会越流畅。 但是因为功耗的限制&#xff0c;一般60fps就是跑满的效果了。 我们测试的话&#xff0c;一般…
阅读更多...
如何在Windows上恢复已删除的文件？

如何在Windows上恢复已删除的文件？

大多数人在无意中删除了一些重要文件后无法恢复。这些文件被暂时删除&#xff0c;直到我们清空回收站才会消失。你可以通过右键单击回收站中的文件并选择还原选项来轻松恢复这些文件。但是&#xff0c;如果你清理回收站删除了文件怎么办&#xff1f;或者不小心使用Shift Delet…
阅读更多...
Pytorch nn.Linear的基本用法与原理详解

Pytorch nn.Linear的基本用法与原理详解

1. 参考 Pytorch nn.Linear的基本用法与原理详解_iioSnail的博客-CSDN博客 [机器学习]深度学习初学者大疑问之nn.Linear(a,b)到底代表什么?_五阿哥爱跳舞的博客-CSDN博客
阅读更多...
最新文章

Copyright @ 2022~2023