功能:

1.发布订阅模型
2.路由模型
3.主题模型

1 github:源码地址

2 rabbitmq02 子工程

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>com.yzm</groupId><artifactId>rabbitmq</artifactId><version>0.0.1-SNAPSHOT</version><relativePath>../pom.xml</relativePath> <!-- lookup parent from repository --></parent><artifactId>rabbitmq02</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>rabbitmq02</name><description>Demo project for Spring Boot</description><dependencies></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>

项目结构
在这里插入图片描述

application.yml

spring:rabbitmq:port: 5672host: 127.0.0.1username: guestpassword: guestlistener:simple:acknowledge-mode: autoprefetch: 1

3 发布订阅

在这里插入图片描述

  • 上一篇中,生产者生产消息是直接发送给队列存储的;
    现在是发送给交换机,由交换机转发消息给队列,交换机可以转发给所有绑定它的队列,也可以转发给符合路由规则的队列,交换机本身不会存储消息,如果没有绑定任何队列,消息就会丢失
  • 发布订阅使用的交换机是Fanout交换机,也叫广播式交换机
    广播式交换机:fanout交换器中没有路由键的概念,他会把消息发送到所有绑定在此交换器上面的队列中

创建交换机、队列

package com.yzm.rabbitmq02.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;@Configuration
@EnableScheduling
public class FanoutRabbitConfig {//队列public static final String QUEUE_A = "queue-a";public static final String QUEUE_B = "queue-b";public static final String FANOUT_EXCHANGE = "fanout.exchange";@Beanpublic Queue queueA() {return new Queue(QUEUE_A);}@Beanpublic Queue queueB() {return new Queue(QUEUE_B);}/*** 消息交换机配置* 定义交换机direct exchange,绑定消息队列queue* name:交换机名称* durable:设置是否持久,设置为true则将Exchange存盘,即使服务器重启数据也不会丢失* autoDelete:设置是否自动删除,当最后一个绑定到Exchange上的队列删除后,自动删除该Exchange,简单来说也就是如果该Exchange没有和任何队列Queue绑定则删除* internal:设置是否是RabbitMQ内部使用,默认false。如果设置为 true ,则表示是内置的交换器,客户端程序无法直接发送消息到这个交换器中,只能通过交换器路由到交换器这种方式。* <p>* 广播式交换机:fanout交换器中没有路由键的概念,他会把消息发送到所有绑定在此交换器上面的队列中。* 路由式交换机:direct交换器相对来说比较简单,匹配规则为:路由键匹配,消息就被投送到相关的队列* 主题式交换机:topic交换器你采用模糊匹配路由键的原则进行转发消息到队列中*/@Beanpublic FanoutExchange fanoutExchange() {return ExchangeBuilder.fanoutExchange(FANOUT_EXCHANGE).build();}/*** 将消息队列和交换机进行绑定* 交换机相当于Map容器,路由对应key,Queue对应value* 发送消息时,指定交换机中的key就能将消息加入到对应的队列中*/@Beanpublic Binding bindingA() {return BindingBuilder.bind(queueA()).to(fanoutExchange());}@Beanpublic Binding bindingB() {return BindingBuilder.bind(queueB()).to(fanoutExchange());}
}

生产者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.FanoutRabbitConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class FanoutSenderService {private final RabbitTemplate rabbitTemplate;private int count = 1;public FanoutSenderService(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}@Scheduled(fixedDelay = 500, initialDelay = 10000)public void send() {if (count <= 10) {String message = "Hello.........." + count++;rabbitTemplate.convertAndSend(FanoutRabbitConfig.FANOUT_EXCHANGE, "", message);System.out.println(" [ 生产者 ] Sent ==> '" + message + "'");}}
}

消费者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.FanoutRabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class FanoutReceiverService {private int countA = 1;private int countB = 1;private int countB_2 = 1;@RabbitListener(queues = FanoutRabbitConfig.QUEUE_A)public void receiveA(String message) {try {System.out.println(" [ 消费者@A号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@A号 ] Dealt with:" + countA++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = FanoutRabbitConfig.QUEUE_B)public void receiveB(String message) {try {System.out.println(" [ 消费者@B号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@B号 ] Dealt with:" + countB++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = FanoutRabbitConfig.QUEUE_B)public void receiveB_2(String message) {try {System.out.println(" [ 消费者@B_2号 ] Received ==> '" + message + "'");Thread.sleep(2000);System.out.println(" [ 消费者@B_2号 ] Dealt with:" + countB_2++);} catch (Exception e) {e.printStackTrace();}}
}

启动项目
在这里插入图片描述
运行结果如下
在这里插入图片描述
生产者生产了10条消息发送给交换机,交换机将消息分别转发给绑定它的队列A、B;
队列A、B拿到内容一样的10条消息,队列A只有一个消费者A,所以由消费者A处理所有消息
队列B有两个消费者B、B_2,分配模式是按能力分配,所以消费者B处理的多

4 路由模型

在这里插入图片描述

路由式交换机:direct交换器相对来说比较简单,匹配规则为:路由键完全匹配,消息就被投送到相关的队列

创建交换机、队列

package com.yzm.rabbitmq02.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;@Configuration
@EnableScheduling
public class DirectRabbitConfig {//队列public static final String QUEUE_C = "queue-c";public static final String QUEUE_D = "queue-d";//路由键public static final String DIRECT_C = "direct.c";public static final String DIRECT_D = "direct.d";public static final String DIRECT_D2 = "direct.dcd";public static final String DIRECT_EXCHANGE = "direct.exchange";@Beanpublic Queue queueC() {return new Queue(QUEUE_C);}@Beanpublic Queue queueD() {return new Queue(QUEUE_D);}/*** 消息交换机配置* 定义交换机direct exchange,绑定消息队列queue* name:交换机名称* durable:设置是否持久,设置为true则将Exchange存盘,即使服务器重启数据也不会丢失* autoDelete:设置是否自动删除,当最后一个绑定到Exchange上的队列删除后,自动删除该Exchange,简单来说也就是如果该Exchange没有和任何队列Queue绑定则删除* internal:设置是否是RabbitMQ内部使用,默认false。如果设置为 true ,则表示是内置的交换器,客户端程序无法直接发送消息到这个交换器中,只能通过交换器路由到交换器这种方式。* <p>* 广播式交换机:fanout交换器中没有路由键的概念,他会把消息发送到所有绑定在此交换器上面的队列中。* 路由式交换机:direct交换器相对来说比较简单,匹配规则为:路由键完全匹配,消息就被投送到相关的队列* 主题式交换机:topic交换器你采用模糊匹配路由键的原则进行转发消息到队列中*/@Beanpublic DirectExchange directExchange() {return ExchangeBuilder.directExchange(DIRECT_EXCHANGE).build();}/*** 将消息队列和交换机进行绑定* 交换机相当于Map容器,路由对应key,Queue对应value* 发送消息时,指定交换机中的key就能将消息加入到对应的队列中*/@Beanpublic Binding bindingC() {return BindingBuilder.bind(queueC()).to(directExchange()).with(DIRECT_C);}@Beanpublic Binding bindingD() {return BindingBuilder.bind(queueD()).to(directExchange()).with(DIRECT_D);}@Beanpublic Binding bindingD2() {return BindingBuilder.bind(queueD()).to(directExchange()).with(DIRECT_D2);}}

生产者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.DirectRabbitConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class DirectSenderService {private final RabbitTemplate rabbitTemplate;private int count = 0;public DirectSenderService(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}@Scheduled(fixedDelay = 500, initialDelay = 10000)public void send_1() {count++;if (count <= 30) {String message = "Hello.........." + count;System.out.println(" [ 生产者 ] Sent ==> '" + message + "'");if (count % 3 == 0) {rabbitTemplate.convertAndSend(DirectRabbitConfig.DIRECT_EXCHANGE, DirectRabbitConfig.DIRECT_C, message);} else if (count % 3 == 1) {rabbitTemplate.convertAndSend(DirectRabbitConfig.DIRECT_EXCHANGE, DirectRabbitConfig.DIRECT_D, message);} else {rabbitTemplate.convertAndSend(DirectRabbitConfig.DIRECT_EXCHANGE, DirectRabbitConfig.DIRECT_D2, message);}}}}

消费者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.DirectRabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class DirectReceiverService {private int countC = 1;private int countD = 1;private int countD_2 = 1;@RabbitListener(queues = DirectRabbitConfig.QUEUE_C)public void receiveC(String message) {try {System.out.println(" [ 消费者@C号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@C号 ] Dealt with:" + countC++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = DirectRabbitConfig.QUEUE_D)public void receiveD(String message) {try {System.out.println(" [ 消费者@D号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@D号 ] Dealt with:" + countD++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = DirectRabbitConfig.QUEUE_D)public void receiveD_2(String message) {try {System.out.println(" [ 消费者@D_2号 ] Received ==> '" + message + "'");Thread.sleep(2000);System.out.println(" [ 消费者@D_2号 ] Dealt with:" + countD_2++);} catch (Exception e) {e.printStackTrace();}}
}

为了不影响路由模式的测试,关闭发布订阅模式的定时器
在这里插入图片描述
启动项目
在这里插入图片描述
运行结果如下:
在这里插入图片描述
我们创建了两个队列C、D,C有一个路由键,而D有两个路由键;
生产者生产30条消息,是通过路由键平均发送给交换机的,交换机根据路由键,给C队列分配10条消息,D队列分配20条消息;
从运行的结果看,确实达到预期结果

5 主题模式(通配符模式)

在这里插入图片描述

主题式交换机:topic交换器采用模糊匹配路由键的原则进行转发消息到队列中

创建交换机、队列

package com.yzm.rabbitmq02.config;import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;@Configuration
@EnableScheduling
public class TopicRabbitConfig {//队列public static final String QUEUE_E = "queue-e";public static final String QUEUE_F = "queue-f";public static final String QUEUE_G = "queue-g";public static final String TOPIC_EXCHANGE = "topic.exchange";//两种特殊字符*与#,用于做模糊匹配,其中*用于匹配一个单词,#用于匹配多个单词(可以是零个)public static final String TOPIC_E = "topic.*";public static final String TOPIC_F = "topic.#";public static final String TOPIC_G = "topic.*.key";@Beanpublic Queue queueE() {return new Queue(QUEUE_E);}@Beanpublic Queue queueF() {return new Queue(QUEUE_F);}@Beanpublic Queue queueG() {return new Queue(QUEUE_G);}/*** 消息交换机配置* 定义交换机direct exchange,绑定消息队列queue* name:交换机名称* durable:设置是否持久,设置为true则将Exchange存盘,即使服务器重启数据也不会丢失* autoDelete:设置是否自动删除,当最后一个绑定到Exchange上的队列删除后,自动删除该Exchange,简单来说也就是如果该Exchange没有和任何队列Queue绑定则删除* internal:设置是否是RabbitMQ内部使用,默认false。如果设置为 true ,则表示是内置的交换器,客户端程序无法直接发送消息到这个交换器中,只能通过交换器路由到交换器这种方式。* <p>* 广播式交换机:fanout交换器中没有路由键的概念,他会把消息发送到所有绑定在此交换器上面的队列中。* 路由式交换机:direct交换器相对来说比较简单,匹配规则为:路由键匹配,消息就被投送到相关的队列* 主题式交换机:topic交换器采用模糊匹配路由键的原则进行转发消息到队列中*/@Beanpublic TopicExchange topicExchange() {return ExchangeBuilder.topicExchange(TOPIC_EXCHANGE).build();}/*** 将消息队列和交换机进行绑定* 交换机相当于Map容器,路由对应key,Queue对应value* 发送消息时,指定交换机中的key就能将消息加入到对应的队列中*/@Beanpublic Binding bindingE() {return BindingBuilder.bind(queueE()).to(topicExchange()).with(TOPIC_E);}@Beanpublic Binding bindingF() {return BindingBuilder.bind(queueF()).to(topicExchange()).with(TOPIC_F);}@Beanpublic Binding bindingG() {return BindingBuilder.bind(queueG()).to(topicExchange()).with(TOPIC_G);}
}

生产者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.TopicRabbitConfig;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class TopicSenderService {private final RabbitTemplate rabbitTemplate;private int count = 0;public TopicSenderService(RabbitTemplate rabbitTemplate) {this.rabbitTemplate = rabbitTemplate;}@Scheduled(fixedDelay = 500, initialDelay = 10000)public void send_1() {count++;if (count <= 30) {String message = "Hello.........." + count;System.out.println(" [ 生产者 ] Sent ==> '" + message + "'");if (count % 3 == 0) {rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPIC_EXCHANGE, "topic.yzm", message);} else if (count % 3 == 1) {rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPIC_EXCHANGE, "topic.yzm.yzm", message);} else {rabbitTemplate.convertAndSend(TopicRabbitConfig.TOPIC_EXCHANGE, "topic.yzm.key", message);}}}}

消费者

package com.yzm.rabbitmq02.service;import com.yzm.rabbitmq02.config.TopicRabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;@Component
public class TopicReceiverService {private int countE = 1;private int countF = 1;private int countG = 1;@RabbitListener(queues = TopicRabbitConfig.QUEUE_E)public void receiveE(String message) {try {System.out.println(" [ 消费者@E号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@E号 ] Dealt with:" + countE++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = TopicRabbitConfig.QUEUE_F)public void receiveF(String message) {try {System.out.println(" [ 消费者@F号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@F号 ] Dealt with:" + countF++);} catch (Exception e) {e.printStackTrace();}}@RabbitListener(queues = TopicRabbitConfig.QUEUE_G)public void receiveG(String message) {try {System.out.println(" [ 消费者@G号 ] Received ==> '" + message + "'");Thread.sleep(1000);System.out.println(" [ 消费者@G号 ] Dealt with:" + countG++);} catch (Exception e) {e.printStackTrace();}}
}

关闭前面的定时器
在这里插入图片描述
启动项目
在这里插入图片描述
运行结果如下:
在这里插入图片描述
分析E、F、G队列会受到的消息数量在这里插入图片描述
运行结果跟预期结果一致

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

相关文章

  1. 18.深度理解rnn--回归中的维度变化

    Author: 365JHWZGo Description: rnn--回归 Date: 2021/11/4 14:29 FilePath: day1104-1.py # 导包 import torch import torchvision import torch.autograd as Variable import matplotlib.pyplot as plt import numpy as nptorch.manual_seed(1)# 超参数设置 BATCH_SIZE 1 …...

    2024/3/6 10:23:39
  2. 新版azkaban4.0编译安装教程

    新版azkaban4.0编译安装教程 由于官方没有提供安装包所以需要下载源码&#xff0c;按照本文安装可以完美运行 解压 wget https://github.com/azkaban/azkaban/archive/refs/tags/4.0.0.tar.gztar -zxvf 4.0.0.tar.gz -C /opt/software/ cd azkaban-4.0.0 没有安装git的话需要…...

    2024/3/4 15:05:23
  3. Java 中 this 和 super 的用法总结

    转存&#xff0c;侵删 https://www.runoob.com/w3cnote/the-different-this-super.html...

    2024/3/4 15:05:21
  4. Spring缓存注解@Cacheable、@CacheEvict、@CachePut使用

    Spring缓存注解Cacheable、CacheEvict、CachePut使用 从3.1开始&#xff0c;Spring引入了对Cache的支持。其使用方法和原理都类似于Spring对事务管理的支持。Spring Cache是作用在方法上的&#xff0c;其核心思想是这样的&#xff1a;当我们在调用一个缓存方法时会把该方法参数…...

    2024/3/4 15:05:20
  5. Java 修饰符——记得认真看完哦

    Java 修饰符 Java语言提供了很多修饰符&#xff0c;主要分为以下两类&#xff1a; 访问修饰符非访问修饰符 修饰符用来定义类、方法或者变量&#xff0c;通常放在语句的最前端。我们通过下面的例子来说明&#xff1a; public class ClassName { // ... } private boolean my…...

    2024/3/28 21:47:14
  6. Python项目打包可执行文件(有调用Matlab程序)

    一、简介 创建本帖的目的是保存相关方法&#xff0c;并做简要记录。首先感谢两位博主&#xff0c;他们的文章非常详细&#xff0c;极大的支持我完成相应的工作。 pythonGUI调用matlab并打包成可执行文件的解决方法_白金之星1717的博客-CSDN博客 Python PyInstaller安装和使用…...

    2024/3/29 1:22:09
  7. Spring Boot 统一返回前端封装VO类型结果集定义

    现在大部分项目都是前后端分离的项目,为了统一管理,后端需要对数据进行封装对应的VO数据,什么是Vo我就不叙述了,这里贴出我自己的VO封装类,项目的故障码并没有定义太多,所以也没有定义枚举类型,供大家参考: import io.swagger.annotations.ApiModel; import io.swagger.annota…...

    2024/3/6 10:23:37
  8. pig、hive、hbase的关系与区别

    内容源自博客:https://blog.csdn.net/qq_33161208/article/details/79441129 Pig: 一种操作hadoop的轻量级脚本语言,是一种数据流语言,最初由雅虎公司推出,用来快速轻松的处理巨大的数据。 Pig包含两个部分:Pig Interface,Pig Latin。 Pig可以非常方便的处理HDFS和HBase的…...

    2024/3/6 10:23:36
  9. 用c#实现年厉/月历/日历

    终端的输出结果如下&#xff1a;&#xff08;这里用的是visual studio for Mac&#xff09; 设计思路&#xff1a; 1.实现年历&#xff1a;调用12遍实现月历 2.实现月历&#xff1a; --格式&#xff1a; xx年xx月 日 一 二 三 四 五 六 --计算当月第一天的星期…...

    2024/3/6 10:23:35
  10. IO流基础(一)

    一、IO 1.1 IO概述 回想之前写过的程序&#xff0c;数据都是在内存中&#xff0c;一旦程序运行结束&#xff0c;这些数据都没有了&#xff0c;等下次再想使用这些数据&#xff0c;可是已经没有了。那怎么办呢&#xff1f;能不能把运算完的数据都保存下来&#xff0c;下次程序…...

    2024/3/6 10:23:34
  11. ITK入门教程(15)向量作为像素类型

    目录1.概述2.过程详解3.代码4.结果展示1.概述 这个例子阐述了如何参数化一个点集来管理一个特定的像素类型。将向量值和点相关联以创建一个几何表示是很普遍的。 下面的代码展示了如何使用向量值作为点集PointSet类的像素类型。在这里使用itk::Vector 类作为像素类型。这个类…...

    2024/3/28 15:10:03
  12. 2020icpc上海 Walker (三分)

    题目链接&#xff1a;D-Walker_第 45 届国际大学生程序设计竞赛&#xff08;ICPC&#xff09;亚洲区域赛&#xff08;上海&#xff09; (nowcoder.com)s​​​​​​​a 题意&#xff0c;给你一个线段&#xff0c;端点是0&#xff0c;&#xff4e;&#xff0c;现在给你两个点的…...

    2024/3/29 10:58:00
  13. 中国制冰机行业运行潜力及十四五未来战略咨询报告2021年版

    【报告目录】: 第1章&#xff1a;中国制冰机行业发展综述1.1 中国制冰机行业定义及分类 1.1.1 行业定义 1.1.2 行业主要产品大类 1.1.3 行业在国民经济中的地位 1.2 中国制冰机行业统计标准 1.2.1 制冰机行业统计部门和统计口径 1.2.2 制冰机行业统计方法 1.2.3 制冰机行…...

    2024/3/6 10:23:31
  14. Opencl开发过程记录

    下载Eclipse 给Eclips安装插件ADT 配置SDK 手动下载NDK并添加到Eclipse设置中 新建Eclipse项目 解决依赖问题&#xff08;未作具体记录&#xff09; 无法解决问题 更改使用Android Studio 配置SDK 配置NKD过程中发生问题 SDK Manager中忆境添加NDK和CMAKE工具 在Proje…...

    2024/3/27 15:57:46
  15. 2021年电工(初级)考试总结及电工(初级)模拟考试

    题库来源&#xff1a;安全生产模拟考试一点通公众号小程序 安全生产模拟考试一点通&#xff1a;电工&#xff08;初级&#xff09;考试总结是安全生产模拟考试一点通生成的&#xff0c;电工&#xff08;初级&#xff09;证模拟考试题库是根据电工&#xff08;初级&#xff09;…...

    2024/3/29 2:03:31
  16. 数据治理方案落地的5步必经之路

    接触过数据分析的小伙伴都应该听说过数据治理的名字。数据治理听起来似乎很抽象&#xff0c;很难理解。百科全书上的数据治理解释是组织中涉及数据使用的一整套管理行为。 似乎还是有点抽象。简单来说&#xff0c;数据治理是由企业数据治理部门发起实施的一系列政策和流程&…...

    2024/3/6 10:23:28
  17. Docker网络-(六)

    Docker网络(六) 理解Docker0 先测试一手网络地址 会发现一个Docker0网络地址 这个Docker0就相当于一个路由器&#xff0c;每新建一个容器&#xff0c;就会为其分配一个ip&#xff0c;这个路由器会以桥接的模式连接我们的本机。 容器和容器之间通信 容器和容器之间能不能直接…...

    2024/3/6 10:23:27
  18. 2021-11docker安装并使用阿里巴巴Canal连接Mysql

    一. 开启MySQL binlog日志并注册账户 1、查看是否已经开启binlog show variables like log_bin;log_bin俩种状态&#xff08;ON&#xff0c;OFF&#xff09;,如果为OFF,请先开启。 2、开启binlog日志 在mysql 下 etc/mysql/my.cnf 进行配置 因为我这里是docker 里面需要安装…...

    2024/3/18 4:08:37
  19. 6.python------内置函数和序列操作

    1. 数学运算函数 abs()取绝对值函数round&#xff08;x,[,n]&#xff09;返回浮点数x的近似值&#xff0c;四舍五入&#xff0c;n为小数点后n位pow(x,y,[,z])x的y次方divmod(a,b)求商和余数&#xff0c;输出元组&#xff08;a//b,a%b&#xff09;max(序列)返回给定参数的最大值…...

    2024/3/29 14:07:17
  20. Java 变量类型——文末福利相赠

    Java 变量类型 在Java语言中&#xff0c;所有的变量在使用前必须声明。声明变量的基本格式如下&#xff1a; type identifier [ value][, identifier [ value] ...] ; 格式说明&#xff1a;type为Java数据类型。identifier是变量名。可以使用逗号隔开来声明多个同类型变量。…...

    2024/3/17 0:13:15

最新文章

  1. 使用Kaggle API快速下载Kaggle数据集

    前言 在使用Kaggle网站下载数据集时&#xff0c;直接在网页上点击下载可能会很慢&#xff0c;甚至会出现下载失败的情况。本文将介绍如何使用Kaggle API快速下载数据集。 具体步骤 安装Kaggle API包 在终端中输入以下命令来安装Kaggle API相关的包&#xff1a; pip install…...

    2024/3/29 18:16:12
  2. 梯度消失和梯度爆炸的一些处理方法

    在这里是记录一下梯度消失或梯度爆炸的一些处理技巧。全当学习总结了如有错误还请留言&#xff0c;在此感激不尽。 权重和梯度的更新公式如下&#xff1a; w w − η ⋅ ∇ w w w - \eta \cdot \nabla w ww−η⋅∇w 个人通俗的理解梯度消失就是网络模型在反向求导的时候出…...

    2024/3/20 10:50:27
  3. 银行数字人民币系统应用架构设计

    2019年10月&#xff0c;01区块链联合数字资产研究院发布了《人民币3.0&#xff1a;中国央行数字货币运行框架与技术解析》&#xff0c;从数字货币界定和人民币发展历程出发&#xff0c;区分了央行数字货币与比特币、移动支付等的区别&#xff0c;全面介绍了央行数字货币的发展历…...

    2024/3/29 11:56:15
  4. FFmpeg-- mp4文件合成1:aac和h264封装(c++实现)

    文章目录 流程api核心代码muxer.hmuxer.cppaac 和 h264 封装为视频流,封装为c++的Muxter类 流程 分配视频文件上下文 int Init(const char *url); 创建流,赋值给视频的音频流和视频流 int AddStream(AVCodecContext *codec_ctx); 写视频流的head int SendHeader(); 写视频流的…...

    2024/3/28 0:04:54
  5. 【外汇早评】美通胀数据走低,美元调整

    原标题:【外汇早评】美通胀数据走低,美元调整昨日美国方面公布了新一期的核心PCE物价指数数据,同比增长1.6%,低于前值和预期值的1.7%,距离美联储的通胀目标2%继续走低,通胀压力较低,且此前美国一季度GDP初值中的消费部分下滑明显,因此市场对美联储后续更可能降息的政策…...

    2024/3/29 18:08:39
  6. 【原油贵金属周评】原油多头拥挤,价格调整

    原标题:【原油贵金属周评】原油多头拥挤,价格调整本周国际劳动节,我们喜迎四天假期,但是整个金融市场确实流动性充沛,大事频发,各个商品波动剧烈。美国方面,在本周四凌晨公布5月份的利率决议和新闻发布会,维持联邦基金利率在2.25%-2.50%不变,符合市场预期。同时美联储…...

    2024/3/29 18:08:34
  7. 【外汇周评】靓丽非农不及疲软通胀影响

    原标题:【外汇周评】靓丽非农不及疲软通胀影响在刚结束的周五,美国方面公布了新一期的非农就业数据,大幅好于前值和预期,新增就业重新回到20万以上。具体数据: 美国4月非农就业人口变动 26.3万人,预期 19万人,前值 19.6万人。 美国4月失业率 3.6%,预期 3.8%,前值 3…...

    2024/3/29 2:45:46
  8. 【原油贵金属早评】库存继续增加,油价收跌

    原标题:【原油贵金属早评】库存继续增加,油价收跌周三清晨公布美国当周API原油库存数据,上周原油库存增加281万桶至4.692亿桶,增幅超过预期的74.4万桶。且有消息人士称,沙特阿美据悉将于6月向亚洲炼油厂额外出售更多原油,印度炼油商预计将每日获得至多20万桶的额外原油供…...

    2024/3/29 16:26:39
  9. 【外汇早评】日本央行会议纪要不改日元强势

    原标题:【外汇早评】日本央行会议纪要不改日元强势近两日日元大幅走强与近期市场风险情绪上升,避险资金回流日元有关,也与前一段时间的美日贸易谈判给日本缓冲期,日本方面对汇率问题也避免继续贬值有关。虽然今日早间日本央行公布的利率会议纪要仍然是支持宽松政策,但这符…...

    2024/3/29 5:19:52
  10. 【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响

    原标题:【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响近日伊朗局势升温,导致市场担忧影响原油供给,油价试图反弹。此时OPEC表态稳定市场。据消息人士透露,沙特6月石油出口料将低于700万桶/日,沙特已经收到石油消费国提出的6月份扩大出口的“适度要求”,沙特将满…...

    2024/3/29 18:08:00
  11. 【外汇早评】美欲与伊朗重谈协议

    原标题:【外汇早评】美欲与伊朗重谈协议美国对伊朗的制裁遭到伊朗的抗议,昨日伊朗方面提出将部分退出伊核协议。而此行为又遭到欧洲方面对伊朗的谴责和警告,伊朗外长昨日回应称,欧洲国家履行它们的义务,伊核协议就能保证存续。据传闻伊朗的导弹已经对准了以色列和美国的航…...

    2024/3/29 11:11:56
  12. 【原油贵金属早评】波动率飙升,市场情绪动荡

    原标题:【原油贵金属早评】波动率飙升,市场情绪动荡因中美贸易谈判不安情绪影响,金融市场各资产品种出现明显的波动。随着美国与中方开启第十一轮谈判之际,美国按照既定计划向中国2000亿商品征收25%的关税,市场情绪有所平复,已经开始接受这一事实。虽然波动率-恐慌指数VI…...

    2024/3/29 1:13:26
  13. 【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试

    原标题:【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试美国和伊朗的局势继续升温,市场风险情绪上升,避险黄金有向上突破阻力的迹象。原油方面稍显平稳,近期美国和OPEC加大供给及市场需求回落的影响,伊朗局势并未推升油价走强。近期中美贸易谈判摩擦再度升级,美国对中…...

    2024/3/29 8:28:16
  14. 【原油贵金属早评】市场情绪继续恶化,黄金上破

    原标题:【原油贵金属早评】市场情绪继续恶化,黄金上破周初中国针对于美国加征关税的进行的反制措施引发市场情绪的大幅波动,人民币汇率出现大幅的贬值动能,金融市场受到非常明显的冲击。尤其是波动率起来之后,对于股市的表现尤其不安。隔夜美国股市出现明显的下行走势,这…...

    2024/3/29 7:41:19
  15. 【外汇早评】美伊僵持,风险情绪继续升温

    原标题:【外汇早评】美伊僵持,风险情绪继续升温昨日沙特两艘油轮再次发生爆炸事件,导致波斯湾局势进一步恶化,市场担忧美伊可能会出现摩擦生火,避险品种获得支撑,黄金和日元大幅走强。美指受中美贸易问题影响而在低位震荡。继5月12日,四艘商船在阿联酋领海附近的阿曼湾、…...

    2024/3/29 18:07:15
  16. 【原油贵金属早评】贸易冲突导致需求低迷,油价弱势

    原标题:【原油贵金属早评】贸易冲突导致需求低迷,油价弱势近日虽然伊朗局势升温,中东地区几起油船被袭击事件影响,但油价并未走高,而是出于调整结构中。由于市场预期局势失控的可能性较低,而中美贸易问题导致的全球经济衰退风险更大,需求会持续低迷,因此油价调整压力较…...

    2024/3/29 9:57:23
  17. 氧生福地 玩美北湖(上)——为时光守候两千年

    原标题:氧生福地 玩美北湖(上)——为时光守候两千年一次说走就走的旅行,只有一张高铁票的距离~ 所以,湖南郴州,我来了~ 从广州南站出发,一个半小时就到达郴州西站了。在动车上,同时改票的南风兄和我居然被分到了一个车厢,所以一路非常愉快地聊了过来。 挺好,最起…...

    2024/3/29 0:49:46
  18. 氧生福地 玩美北湖(中)——永春梯田里的美与鲜

    原标题:氧生福地 玩美北湖(中)——永春梯田里的美与鲜一觉醒来,因为大家太爱“美”照,在柳毅山庄去寻找龙女而错过了早餐时间。近十点,向导坏坏还是带着饥肠辘辘的我们去吃郴州最富有盛名的“鱼头粉”。说这是“十二分推荐”,到郴州必吃的美食之一。 哇塞!那个味美香甜…...

    2024/3/29 18:06:57
  19. 氧生福地 玩美北湖(下)——奔跑吧骚年!

    原标题:氧生福地 玩美北湖(下)——奔跑吧骚年!让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 啊……啊……啊 两…...

    2024/3/29 17:27:19
  20. 扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!

    原标题:扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!扒开伪装医用面膜,翻六倍价格宰客!当行业里的某一品项火爆了,就会有很多商家蹭热度,装逼忽悠,最近火爆朋友圈的医用面膜,被沾上了污点,到底怎么回事呢? “比普通面膜安全、效果好!痘痘、痘印、敏感肌都能用…...

    2024/3/29 18:06:36
  21. 「发现」铁皮石斛仙草之神奇功效用于医用面膜

    原标题:「发现」铁皮石斛仙草之神奇功效用于医用面膜丽彦妆铁皮石斛医用面膜|石斛多糖无菌修护补水贴19大优势: 1、铁皮石斛:自唐宋以来,一直被列为皇室贡品,铁皮石斛生于海拔1600米的悬崖峭壁之上,繁殖力差,产量极低,所以古代仅供皇室、贵族享用 2、铁皮石斛自古民间…...

    2024/3/29 18:06:22
  22. 丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者

    原标题:丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者【公司简介】 广州华彬企业隶属香港华彬集团有限公司,专注美业21年,其旗下品牌: 「圣茵美」私密荷尔蒙抗衰,产后修复 「圣仪轩」私密荷尔蒙抗衰,产后修复 「花茵莳」私密荷尔蒙抗衰,产后修复 「丽彦妆」专注医学护…...

    2024/3/28 18:26:34
  23. 广州械字号面膜生产厂家OEM/ODM4项须知!

    原标题:广州械字号面膜生产厂家OEM/ODM4项须知!广州械字号面膜生产厂家OEM/ODM流程及注意事项解读: 械字号医用面膜,其实在我国并没有严格的定义,通常我们说的医美面膜指的应该是一种「医用敷料」,也就是说,医用面膜其实算作「医疗器械」的一种,又称「医用冷敷贴」。 …...

    2024/3/29 18:06:01
  24. 械字号医用眼膜缓解用眼过度到底有无作用?

    原标题:械字号医用眼膜缓解用眼过度到底有无作用?医用眼膜/械字号眼膜/医用冷敷眼贴 凝胶层为亲水高分子材料,含70%以上的水分。体表皮肤温度传导到本产品的凝胶层,热量被凝胶内水分子吸收,通过水分的蒸发带走大量的热量,可迅速地降低体表皮肤局部温度,减轻局部皮肤的灼…...

    2024/3/28 20:09:10
  25. 配置失败还原请勿关闭计算机,电脑开机屏幕上面显示,配置失败还原更改 请勿关闭计算机 开不了机 这个问题怎么办...

    解析如下&#xff1a;1、长按电脑电源键直至关机&#xff0c;然后再按一次电源健重启电脑&#xff0c;按F8健进入安全模式2、安全模式下进入Windows系统桌面后&#xff0c;按住“winR”打开运行窗口&#xff0c;输入“services.msc”打开服务设置3、在服务界面&#xff0c;选中…...

    2022/11/19 21:17:18
  26. 错误使用 reshape要执行 RESHAPE,请勿更改元素数目。

    %读入6幅图像&#xff08;每一幅图像的大小是564*564&#xff09; f1 imread(WashingtonDC_Band1_564.tif); subplot(3,2,1),imshow(f1); f2 imread(WashingtonDC_Band2_564.tif); subplot(3,2,2),imshow(f2); f3 imread(WashingtonDC_Band3_564.tif); subplot(3,2,3),imsho…...

    2022/11/19 21:17:16
  27. 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机...

    win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”问题的解决方法在win7系统关机时如果有升级系统的或者其他需要会直接进入一个 等待界面&#xff0c;在等待界面中我们需要等待操作结束才能关机&#xff0c;虽然这比较麻烦&#xff0c;但是对系统进行配置和升级…...

    2022/11/19 21:17:15
  28. 台式电脑显示配置100%请勿关闭计算机,“准备配置windows 请勿关闭计算机”的解决方法...

    有不少用户在重装Win7系统或更新系统后会遇到“准备配置windows&#xff0c;请勿关闭计算机”的提示&#xff0c;要过很久才能进入系统&#xff0c;有的用户甚至几个小时也无法进入&#xff0c;下面就教大家这个问题的解决方法。第一种方法&#xff1a;我们首先在左下角的“开始…...

    2022/11/19 21:17:14
  29. win7 正在配置 请勿关闭计算机,怎么办Win7开机显示正在配置Windows Update请勿关机...

    置信有很多用户都跟小编一样遇到过这样的问题&#xff0c;电脑时发现开机屏幕显现“正在配置Windows Update&#xff0c;请勿关机”(如下图所示)&#xff0c;而且还需求等大约5分钟才干进入系统。这是怎样回事呢&#xff1f;一切都是正常操作的&#xff0c;为什么开时机呈现“正…...

    2022/11/19 21:17:13
  30. 准备配置windows 请勿关闭计算机 蓝屏,Win7开机总是出现提示“配置Windows请勿关机”...

    Win7系统开机启动时总是出现“配置Windows请勿关机”的提示&#xff0c;没过几秒后电脑自动重启&#xff0c;每次开机都这样无法进入系统&#xff0c;此时碰到这种现象的用户就可以使用以下5种方法解决问题。方法一&#xff1a;开机按下F8&#xff0c;在出现的Windows高级启动选…...

    2022/11/19 21:17:12
  31. 准备windows请勿关闭计算机要多久,windows10系统提示正在准备windows请勿关闭计算机怎么办...

    有不少windows10系统用户反映说碰到这样一个情况&#xff0c;就是电脑提示正在准备windows请勿关闭计算机&#xff0c;碰到这样的问题该怎么解决呢&#xff0c;现在小编就给大家分享一下windows10系统提示正在准备windows请勿关闭计算机的具体第一种方法&#xff1a;1、2、依次…...

    2022/11/19 21:17:11
  32. 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”的解决方法...

    今天和大家分享一下win7系统重装了Win7旗舰版系统后&#xff0c;每次关机的时候桌面上都会显示一个“配置Windows Update的界面&#xff0c;提示请勿关闭计算机”&#xff0c;每次停留好几分钟才能正常关机&#xff0c;导致什么情况引起的呢&#xff1f;出现配置Windows Update…...

    2022/11/19 21:17:10
  33. 电脑桌面一直是清理请关闭计算机,windows7一直卡在清理 请勿关闭计算机-win7清理请勿关机,win7配置更新35%不动...

    只能是等着&#xff0c;别无他法。说是卡着如果你看硬盘灯应该在读写。如果从 Win 10 无法正常回滚&#xff0c;只能是考虑备份数据后重装系统了。解决来方案一&#xff1a;管理员运行cmd&#xff1a;net stop WuAuServcd %windir%ren SoftwareDistribution SDoldnet start WuA…...

    2022/11/19 21:17:09
  34. 计算机配置更新不起,电脑提示“配置Windows Update请勿关闭计算机”怎么办?

    原标题&#xff1a;电脑提示“配置Windows Update请勿关闭计算机”怎么办&#xff1f;win7系统中在开机与关闭的时候总是显示“配置windows update请勿关闭计算机”相信有不少朋友都曾遇到过一次两次还能忍但经常遇到就叫人感到心烦了遇到这种问题怎么办呢&#xff1f;一般的方…...

    2022/11/19 21:17:08
  35. 计算机正在配置无法关机,关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机...

    关机提示 windows7 正在配置windows 请勿关闭计算机 &#xff0c;然后等了一晚上也没有关掉。现在电脑无法正常关机以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容&#xff0c;让我们赶快一起来看一下吧&#xff01;关机提示 windows7 正在配…...

    2022/11/19 21:17:05
  36. 钉钉提示请勿通过开发者调试模式_钉钉请勿通过开发者调试模式是真的吗好不好用...

    钉钉请勿通过开发者调试模式是真的吗好不好用 更新时间:2020-04-20 22:24:19 浏览次数:729次 区域: 南阳 > 卧龙 列举网提醒您:为保障您的权益,请不要提前支付任何费用! 虚拟位置外设器!!轨迹模拟&虚拟位置外设神器 专业用于:钉钉,外勤365,红圈通,企业微信和…...

    2022/11/19 21:17:05
  37. 配置失败还原请勿关闭计算机怎么办,win7系统出现“配置windows update失败 还原更改 请勿关闭计算机”,长时间没反应,无法进入系统的解决方案...

    前几天班里有位学生电脑(windows 7系统)出问题了&#xff0c;具体表现是开机时一直停留在“配置windows update失败 还原更改 请勿关闭计算机”这个界面&#xff0c;长时间没反应&#xff0c;无法进入系统。这个问题原来帮其他同学也解决过&#xff0c;网上搜了不少资料&#x…...

    2022/11/19 21:17:04
  38. 一个电脑无法关闭计算机你应该怎么办,电脑显示“清理请勿关闭计算机”怎么办?...

    本文为你提供了3个有效解决电脑显示“清理请勿关闭计算机”问题的方法&#xff0c;并在最后教给你1种保护系统安全的好方法&#xff0c;一起来看看&#xff01;电脑出现“清理请勿关闭计算机”在Windows 7(SP1)和Windows Server 2008 R2 SP1中&#xff0c;添加了1个新功能在“磁…...

    2022/11/19 21:17:03
  39. 请勿关闭计算机还原更改要多久,电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机怎么办...

    许多用户在长期不使用电脑的时候&#xff0c;开启电脑发现电脑显示&#xff1a;配置windows更新失败&#xff0c;正在还原更改&#xff0c;请勿关闭计算机。。.这要怎么办呢&#xff1f;下面小编就带着大家一起看看吧&#xff01;如果能够正常进入系统&#xff0c;建议您暂时移…...

    2022/11/19 21:17:02
  40. 还原更改请勿关闭计算机 要多久,配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以...

    配置windows update失败 还原更改 请勿关闭计算机&#xff0c;电脑开机后一直显示以以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容&#xff0c;让我们赶快一起来看一下吧&#xff01;配置windows update失败 还原更改 请勿关闭计算机&#x…...

    2022/11/19 21:17:01
  41. 电脑配置中请勿关闭计算机怎么办,准备配置windows请勿关闭计算机一直显示怎么办【图解】...

    不知道大家有没有遇到过这样的一个问题&#xff0c;就是我们的win7系统在关机的时候&#xff0c;总是喜欢显示“准备配置windows&#xff0c;请勿关机”这样的一个页面&#xff0c;没有什么大碍&#xff0c;但是如果一直等着的话就要两个小时甚至更久都关不了机&#xff0c;非常…...

    2022/11/19 21:17:00
  42. 正在准备配置请勿关闭计算机,正在准备配置windows请勿关闭计算机时间长了解决教程...

    当电脑出现正在准备配置windows请勿关闭计算机时&#xff0c;一般是您正对windows进行升级&#xff0c;但是这个要是长时间没有反应&#xff0c;我们不能再傻等下去了。可能是电脑出了别的问题了&#xff0c;来看看教程的说法。正在准备配置windows请勿关闭计算机时间长了方法一…...

    2022/11/19 21:16:59
  43. 配置失败还原请勿关闭计算机,配置Windows Update失败,还原更改请勿关闭计算机...

    我们使用电脑的过程中有时会遇到这种情况&#xff0c;当我们打开电脑之后&#xff0c;发现一直停留在一个界面&#xff1a;“配置Windows Update失败&#xff0c;还原更改请勿关闭计算机”&#xff0c;等了许久还是无法进入系统。如果我们遇到此类问题应该如何解决呢&#xff0…...

    2022/11/19 21:16:58
  44. 如何在iPhone上关闭“请勿打扰”

    Apple’s “Do Not Disturb While Driving” is a potentially lifesaving iPhone feature, but it doesn’t always turn on automatically at the appropriate time. For example, you might be a passenger in a moving car, but your iPhone may think you’re the one dri…...

    2022/11/19 21:16:57