基于Redis6.0 部署迷你版本消息队列实战
技术研究背景
由于目前的研发团队处于公司初创阶段,尚未有能成熟的运维体系,对于市面上常见的成熟MQ搭建维护能力不足,但是又希望能有一款轻量级的消息系统供研发团队的成员使用,因此开展了对该方面相关的技术调研工作。
通过相关的技术调研后,决定挑选基于Redis实现消息系统。
具体技术选型原因:
团队内部已经有搭建相关的Redis服务,并且具备一定的运维能力,可以节省技术成本
业界有较多关于Redis搭建消息系统方面的技术文章
目前的系统的整体吞吐量并不高,接入消息系统的主要目的只是为了实现系统之间的解耦
为了方便让读者们从0到1地学习这块内容,我将会从环节搭建开始介绍起。
基本环境的搭建
基于redis6.0.6版本搭建一套简单的消息队列系统。
环境部署:
docker run -p 6379:6379 --name redis_6_0_6 -d redis:6.0.6
- 参数解释:
-d 后台启动
-p 端口映射
-name 容器名称
如果本地没有相关镜像,可以尝试通过搭建下方命令进行镜像的拉取:
docker pull redis:6.0.6
当redis的基础环境配置好了之后,接下来便是基于redis内置的一些基本功能开发一款消息队列组件了。
下边我将分三种不同的技术方案来介绍如何实现一款轻量级的消息队列。
基于常规的队列结构来实现消息队列
这块的实现比较简单,主要是基于Redis内部的List结构来落地的,发送方将消息从队列的左边写入,然后消费方从队列的右边读取。
package org.idea.mq.redis.framework.mq.list;
import com.alibaba.fastjson.JSON;
import org.idea.mq.redis.framework.bean.MsgWrapper;
import org.idea.mq.redis.framework.mq.IMQTemplate;
import org.idea.mq.redis.framework.redis.IRedisService;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
/*** @Author linhao* @Date created in 3:09 下午 2022/2/7*/
@Component
public class RedisListMQTemplate implements IMQTemplate {@Resourceprivate IRedisService iRedisService;@Overridepublic boolean send(MsgWrapper msgWrapper) {try {String json = JSON.toJSONString(msgWrapper.getMsgInfo());iRedisService.lpush(msgWrapper.getTopic(),json);return true;}catch (Exception e){e.printStackTrace();}return false;}
}
问题思考
这里存在几个问题点需要思考下:
多个服务之间如何订阅同一个消息
这里我建议可以按照系统的项目名称前缀+业务标识来组织。
例如:用户系统中需要发布一条 会员已升级 的消息给到下游系统,此时可以将这条消息写入到名为:user-service:member-upgrade-list 的List集合中。如果订单系统希望访问用户系统的消息,则需要在redis的key里指定user-service:member-upgrade-list关键字。
消息的监听机制如何实现?
对于List的消息可以采用轮询的方式获取,例如下边这段案例代码:
/*** 轮询的方式获取数据** @param msgWrapper*/
private void pollingGet(MsgWrapper msgWrapper) {while (true) {String value = iRedisService.rpop(msgWrapper.getTopic());if (!StringUtils.isEmpty(value)) {System.out.println(value);}//减少访问压力,定期睡眠一段时间try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}
}
但是轮询的方式比较消耗性能,所以可以尝试使用Redis的阻塞式弹出指令,例如下边这种方式来监听消息的触发行为:
/*** 阻塞的方式获取数据*/
private void blockGet(MsgWrapper msgWrapper) {while (true) {List<String> values = iRedisService.brpop(msgWrapper.getTopic());if (!CollectionUtils.isEmpty(values)) {values.forEach(value -> {System.out.println(value);});}}
}
消息的可靠性传输如何确保?
在设计消息队列的时候,我们非常看重的就是消息的可靠性保证。当一条消息发送到消费端之后,如果出现了异常,希望消息能够实现重新发送的效果。
对于这种场景的设计我们可以尝试使用 BRPOPLPUSH 这条指令,这条指令可以帮助我们在Redis内部将数据弹出时写入到另一个备份队列中,这样即使弹出的消息消费失败了,备份队列中还有一份备用消息可以使用,而且弹出和写入备份队列操作在Redis内部做了封装,外界调用可以视作为一个原子操作。
是否可以支持广播的模式?
从List集合的实现原理来看,Redis弹出的元素只能返回给一个客户端链接,因此无法支持广播这种效果的实现。
基于发布订阅功能实现消息队列
Redis的内部提供了一个叫做发布订阅的功能,通过subscibe命令和publish指令可以帮助我们实现关于消息发布和通知的功能。
使用subscibe/publish命令实现的效果和List结构最大的不同在于它的传输方式:
list更多的是实现点对点方式的传输(P2P方式)
subscibe/publish则是可以实现广播的方式和订阅者进行通信
publish部分的案例代码:
@Override
public boolean publish(String channel, String content) {try (Jedis jedis = iRedisFactory.getConnection()) {jedis.publish(channel, content);return true;} catch (Exception e) {throw new RuntimeException(e);}
}
subscibe部分的代码:
@Override
public boolean subscribe(JedisPubSub jedisPubSub, String... channel) {try (Jedis jedis = iRedisFactory.getConnection()) {jedis.subscribe(jedisPubSub, channel);return true;} catch (Exception e) {throw new RuntimeException(e);}
}
监听的部分可以通过额外开启一个线程来实现这部分效果:
@Component
public class RedisSubscribeMQListener implements IMQListener {@Resourceprivate IRedisService iRedisService;class TestChannel extends JedisPubSub {@Overridepublic void onMessage(String channel, String message) {super.onMessage(channel, message);System.out.println("channel " + channel + " 接收到消息:" + message);}@Overridepublic void onSubscribe(String channel, int subscribedChannels) {System.out.println(String.format("subscribe redis channel success, channel %s, subscribedChannels %d",channel, subscribedChannels));}@Overridepublic void onUnsubscribe(String channel, int subscribedChannels) {System.out.println(String.format("unsubscribe redis channel, channel %s, subscribedChannels %d",channel, subscribedChannels));}}//所有频道的消息都监听@Overridepublic void onMessageReach(MsgWrapper msgWrapper) {Thread thread = new Thread(new Runnable() {@Overridepublic void run() {iRedisService.subscribe(new TestChannel(), msgWrapper.getTopic());}});thread.start();}
}
要注意,回调通知的时候需要注入一个JedisPubSub的对象,这个对象的内部定义了接收消息之后的处理操作。
问题思考
如何保证消息的可靠性传输?
通过subscibe/publish处理的消息没有持久化的特性,一旦出现网络中断,Redis宕机这类异常的时候就会导致消息丢失,而且也没有较好的机制取支持消息重复消费的问题。因此可靠性方面较差。
基于Stream实现消息队列
Redis5.0中发布的Stream类型,也用来实现典型的消息队列。提供了消息的持久化和主备复制功能,可以让任何客户端访问任何时刻的数据,并且能记住每一个客户端的访问位置,还能保证消息不丢失。该Stream类型的出现,几乎满足了消息队列具备的全部内容,包括但不限于:
- 消息ID的序列化生成
- 消息遍历
- 消息的阻塞和非阻塞读取
- 消息的分组消费
- 未完成消息的处理
- 消息队列监控
关于Stream的一些基本入门篇章这里不做过多介绍,感兴趣的朋友可以去阅读下这篇文章:
https://xie.infoq.cn/article/cdb47caddc5ff49dc09ea58cd
下边的部分我们直接来进入关于Redis XStream相关的实战环节。
封装消息监听功能
首先是定义一个MQ相关的接口:
public interface RedisStreamListener {/*** 处理正常消息*/HandlerResult handleMsg(StreamEntry streamEntry);
}
接着是基于这套接口做消息发送的实现:
package org.idea.mq.redis.framework.listener;
import com.alibaba.fastjson.JSON;
import org.idea.mq.redis.framework.bean.HandlerResult;
import org.idea.mq.redis.framework.config.StreamListener;
import org.idea.mq.redis.framework.mq.xstream.RedisStreamMQListener;
import org.idea.mq.redis.framework.redis.IRedisService;
import org.idea.mq.redis.framework.utils.PayMsg;
import redis.clients.jedis.StreamEntry;
import javax.annotation.Resource;
import java.util.Map;
import static org.idea.mq.redis.framework.config.MQConstants.SUCCESS;
/*** @Author linhao* @Date created in 10:07 下午 2022/2/9*/
@StreamListener(streamName = "order-service:order-payed-stream", groupName = "order-service-group", consumerName = "user-service-consumer")
public class OrderPayedListener implements RedisStreamMQListener {@Resourceprivate IRedisService iRedisService;@Overridepublic HandlerResult handleMsg(StreamEntry streamEntry) {Map<String, String> map = streamEntry.getFields();String json = map.get("json");PayMsg payMsg = JSON.parseObject(json, PayMsg.class);System.out.println("pending payMsg is : " + payMsg);return SUCCESS;}
}
自定义消息注解
package org.idea.mq.redis.framework.config;
import org.springframework.stereotype.Component;
import java.lang.annotation.*;
/*** @Author linhao* @Date created in 10:04 下午 2022/2/9*/
@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Component
public @interface StreamListener {String streamName() default "";String groupName() default "";String consumerName() default "";
}
代码中有一个自定义的@StreamListener的注解,该注解的内部包含了一个@Component的注解,可以将使用了该注解的对象注入到Spring容器中。
为了能将这些个初始化类进行自动装配,还需要加入一个配置的对象,代码如下:
package org.idea.mq.redis.framework.config;
import org.idea.mq.redis.framework.bean.HandlerResult;
import org.idea.mq.redis.framework.mq.xstream.RedisStreamMQListener;
import org.idea.mq.redis.framework.redis.IRedisService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.context.event.ApplicationReadyEvent;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationListener;
import org.springframework.context.annotation.Configuration;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;
import redis.clients.jedis.StreamEntry;
import redis.clients.jedis.StreamEntryID;
import redis.clients.jedis.StreamPendingEntry;
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import static org.idea.mq.redis.framework.config.MQConstants.SUCCESS;
/*** @Author linhao* @Date created in 3:25 下午 2022/2/7*/
@Configuration
public class StreamListenerConfiguration implements ApplicationListener<ApplicationReadyEvent> {@Resourceprivate ApplicationContext applicationContext;@Resourceprivate IRedisService iRedisService;private static Logger logger = LoggerFactory.getLogger(StreamListenerConfiguration.class);@Overridepublic void onApplicationEvent(ApplicationReadyEvent applicationReadyEvent) {Map<String, RedisStreamMQListener> beanMap = applicationContext.getBeansOfType(RedisStreamMQListener.class);beanMap.values().forEach(redisStreamMQListener -> {StreamListener StreamListener = redisStreamMQListener.getClass().getAnnotation(StreamListener.class);ListenerInitWrapper listenerInitWrapper = new ListenerInitWrapper(StreamListener.streamName(), StreamListener.groupName(), StreamListener.consumerName());Thread handleThread = new Thread(new CoreMsgHandlerThread(listenerInitWrapper, redisStreamMQListener, iRedisService));Thread pendingHandleThread = new Thread(new PendingMsgHandlerThread(listenerInitWrapper, redisStreamMQListener, iRedisService));handleThread.start();pendingHandleThread.start();logger.info("{} load successed ", redisStreamMQListener);});}class PendingMsgHandlerThread implements Runnable {private ListenerInitWrapper listenerInitWrapper;private RedisStreamMQListener redisStreamMQListener;private IRedisService iRedisService;public PendingMsgHandlerThread(ListenerInitWrapper listenerInitWrapper, RedisStreamMQListener redisStreamMQListener, IRedisService iRedisService) {this.redisStreamMQListener = redisStreamMQListener;this.listenerInitWrapper = listenerInitWrapper;this.iRedisService = iRedisService;}@Overridepublic void run() {String startId = "0-0";while (true) {List<StreamPendingEntry> streamConsumersInfos = iRedisService.xpending(listenerInitWrapper.getStreamName(), listenerInitWrapper.getGroupName(), new StreamEntryID(startId), 1);//如果该集合非空,则触发监听行为if (!CollectionUtils.isEmpty(streamConsumersInfos)) {for (StreamPendingEntry streamConsumersInfo : streamConsumersInfos) {StreamEntryID streamEntryID = streamConsumersInfo.getID();//比当前pending的streamId小1String streamIdStr = streamEntryID.toString();String[] items = streamIdStr.split("-");Long timestamp = Long.valueOf(items[0]) - 1;String beforeId = timestamp + "-" + "0";List<Map.Entry<String, List<StreamEntry>>> result = iRedisService.xreadGroup(listenerInitWrapper.getStreamName(), listenerInitWrapper.getGroupName(), new StreamEntryID(beforeId), 1, listenerInitWrapper.getConsumerName());for (Map.Entry<String, List<StreamEntry>> streamInfo : result) {List<StreamEntry> streamEntries = streamInfo.getValue();for (StreamEntry streamEntry : streamEntries) {try {//业务处理HandlerResult handlerResult = redisStreamMQListener.handleMsg(streamEntry);if (SUCCESS.equals(handlerResult)) {startId = streamEntryID.toString();iRedisService.xack(listenerInitWrapper.getStreamName(), listenerInitWrapper.getGroupName(), new StreamEntryID(startId));}} catch (Exception e) {logger.error("[PendingMsgHandlerThread] e is ", e);}}}}}try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}}}}class CoreMsgHandlerThread implements Runnable {private ListenerInitWrapper listenerInitWrapper;private RedisStreamMQListener redisStreamMQListener;private IRedisService iRedisService;public CoreMsgHandlerThread(ListenerInitWrapper listenerInitWrapper, RedisStreamMQListener redisStreamMQListener, IRedisService iRedisService) {this.redisStreamMQListener = redisStreamMQListener;this.listenerInitWrapper = listenerInitWrapper;this.iRedisService = iRedisService;}@Overridepublic void run() {while (true) {List<Map.Entry<String, List<StreamEntry>>> streamConsumersInfos = iRedisService.xreadGroup(listenerInitWrapper.getStreamName(), listenerInitWrapper.getGroupName(), StreamEntryID.UNRECEIVED_ENTRY, 1, listenerInitWrapper.getConsumerName());for (Map.Entry<String, List<StreamEntry>> streamInfo : streamConsumersInfos) {List<StreamEntry> streamEntries = streamInfo.getValue();for (StreamEntry streamEntry : streamEntries) {//业务处理try {HandlerResult result = redisStreamMQListener.handleMsg(streamEntry);if (SUCCESS.equals(result)) {iRedisService.xack(listenerInitWrapper.getStreamName(), listenerInitWrapper.getGroupName(), streamEntry.getID());}} catch (Exception e) {logger.error("[CoreMsgHandlerThread] e is ", e);}}}}}}
}
其原理是在Spring容器启动好了之后,监听Spring容器内部发出的ApplicationReadyEvent事件,监听该事件,并且开启两个后台线程用于处理redis内部的stream数据。
封装相关的消息发布功能
消息的发送部分比较简单,直接通过redis往stream里面写入数据即可
package org.idea.mq.redis.framework.producer;
/*** @Author linhao* @Date created in 12:23 下午 2022/2/10*/
public interface IStreamProducer {/*** 指定streamName发布消息* @param streamName* @param json*/void sendMsg(String streamName, String json);
}
消息的传输格式采用json字符串的方式写入到redis内部的stream当中。
package org.idea.mq.redis.framework.producer;import org.idea.mq.redis.framework.redis.IRedisService;import javax.annotation.Resource;
import java.util.HashMap;
import java.util.Map;/*** @Author linhao* @Date created in 12:19 下午 2022/2/10*/
public class StreamProducer implements IStreamProducer{@Resourceprivate IRedisService iRedisService;@Overridepublic void sendMsg(String streamName,String json){Map<String,String> map = new HashMap<>();map.put("json",json);iRedisService.xAdd(streamName,map);}}
注意,写入底层的时候,我使用的是Redis内部自动生成的ID序号,代码如下:
@Override
public boolean xAdd(String streamName, Map<String, String> stringMap) {try (Jedis jedis = iRedisFactory.getConnection()) {jedis.xadd(streamName, StreamEntryID.NEW_ENTRY, stringMap);return true;} catch (Exception e) {throw new RuntimeException(e);}
}
为了方便将其作为一个SpringBoot的starter组件供外界团队人员使用,我们可以将其封装为一个starter组件:
组件的测试
点对点发送测试
建立两套微服务工程,user-service 和 order-service,其中user-service部署两个服务节点,同属user-service-group。order-service也要部署两个服务节点,同属order-service-group。
最后两个微服务集群之间互相发布对方订阅的消息,查看是否能够正常接受,且同一个组内一次只有一个节点接收消息。
广播发送测试
使用之前搭建好的user-service模块,部署四个节点,订阅同一个stream队列,但是将其groupName设置为不同的属性,最后发布消息,查看四个节点都能正常接收。
具体细节在现有工程内部已经建立了测试模版,感兴趣的朋友可以去阅读下mq-redis-test模块的部分。
问题思考
为何同一个StreamName需要采用双线程消费?
一个线程用于接受Stream内部正常数据,如果业务正常处理则对其返回为ack信号,确认该消息已经消费成功。如果处理过程中出现异常,则不反回ACK信号,此时Redis内部会将该消息放入到Pending队列中,而第二个线程专门用于处理Pending队列内部的数据。如果处于Pending状态的消息第二次消费依然失败,则会进行定时轮询状况。
是否支持延迟重试
目前的设计其实一直都存在不足点,例如当消息消费异常后会进入轮询,严重情况下可能会导致消息消费出现死循环,并且一直堵塞。暂时还未实现类似于RocketMQ的那种间隔1,3,5…分钟定时投递消费失败消息都功能。感兴趣的小伙伴可以基于现有代码进行简单改造。
本文完整代码案例地址
https://gitee.com/IdeaHome_admin/mq-framework
如若内容造成侵权/违法违规/事实不符,请联系编程学习网邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!
相关文章
- 赛联区块链培训:Web3的核心要素——区块链、加密资产、智能合约和预言机
在2008年,中本聪发布了比特币白皮书,彻底颠覆了我们对数字化交易的概念,并首次提出了一种无需可信中间方的安全在线交易模式。中本聪写道:“需要基于加密证明,而非信任,来建立电子支付系统。” 智能合约被…...
2024/3/7 11:53:09 - 深入运算符重载(2)
深入运算符重载(2) 目录深入运算符重载(2)1、运算符重载时,什么时候以引用返回,什么时候以值返回?2、构造函数的三个作用3、什么是类型转换3.1 此处可以类型转换的构造函数必须是单参数的。3.2 如果不允许隐式进行构造函数:构造函…...
2024/3/25 13:30:28 - 练习10-1 使用递归函数计算1到n之和
练习10-1 使用递归函数计算1到n之和 (10 分) 本题要求实现一个用递归计算123…n的和的简单函数。 函数接口定义: int sum( int n );该函数对于传入的正整数n返回123…n的和;若n不是正整数则返回0。题目保证输入输出在长整型范围内。建议尝试写成递归函…...
2024/3/7 11:53:07 - [渝粤教育] 西南交通大学 工程流体力学 参考 资料
教育 -工程流体力学-章节资料考试资料-西南交通大学【】 第1次作业 第1次测验 1、【单选题】按连续介质的概念,液体质点是指:( ) A、液体的分子; B、液体内的固体颗粒; C、几何的点; D、几何尺寸…...
2024/3/7 11:53:06 - vulhub漏洞复现74_Wordpress
CVE-2016-10033_Wordpress 4.6 任意命令执行漏洞(PwnScriptum) 漏洞原理 参考 https://exploitbox.io/vuln/WordPress-Exploit-4-6-RCE-CODE-EXEC-CVE-2016-10033.html 测试环境 靶场:192.168.4.10_ubuntu 编译及运行测试环境 #docker-compose build…...
2024/3/7 11:53:05 - 字符串练习
例题:力扣97题 题目链接: 力扣https://leetcode-cn.com/problems/interleaving-string/ 题目描述: 给定三个字符串 s1、s2、s3,请你帮忙验证 s3 是否是由 s1 和 s2 交错 组成的。 两个字符串 s 和 t 交错 的定义与过程如下&am…...
2024/3/7 11:53:04 - 12、pandas 数据类型转换
1、 Pandas所支持的数据类型: floatintbooldatetime64[ns]datetime64[ns, tz]timedelta[ns]categoryobject 默认的数据类型是int64,float64. 2、转换数据类型的思路 使用astype()方法强制转化dtype自定义一个数据转换函数函数使用pandas内置的tonumeric()和todatetime()导入…...
2024/3/20 0:20:56 - File(Java学习第四十三天)
File是文件和目录路径的抽象表示 方法名说明File(String pathname)通过将给定的路径名字符串转换为抽象路径名来创建新的File实例File(String parent,String child)从父路径名字符串和子路径名字符串创建新的File实例File(File parent,String child)从父抽象路径名和子路径名字…...
2024/3/7 11:53:03 - medusa安装和简单使用
medusa安装和简单使用 1、手动编译安装medusa yum install openssl-devel libssh2-devel -y #安装依赖包 tar zxvf medusa-2.2.tar.gz cd medusa-2.2/ ./configure && make -j 4 && make install 2、medusa参数说明: -H [File] 包含目标主机名称…...
2024/3/7 11:53:01 - 超声波传感器闪光|乐高EV3教学
朋友喜欢用乐高 EV3 拍一些短片,教育版套装里面超声波传感器最适合做眼睛。 最近他问我有没有什么方法让超声波实现「一闪一闪」那种效果? 众所周知超声波传感器只要插上端口就常亮,不过可以通过以下方式实现该效果。 在 EV3 软件下面「传感…...
2024/3/7 11:53:00 - 撒娇看不出是不是
数组-136. 只出现一次的数字题目描述题目样例Java方法:位运算算法思路代码复杂度题目描述 给定一个非空整数数组,除了某个元素只出现一次以外,其余每个元素均出现两次。找出那个只出现了一次的元素。 题目样例 示例1: 输入: […...
2024/3/4 10:52:51 - grid布局常用属性
grid布局即网格布局(二维),flex布局(一维) <div class"wrap"> <div class"item">item 1</div> <div class"item">item 2</div> <div class"item…...
2024/3/4 10:52:49 - 2月13日学习总结
1.初步学习Java的编译。 2.学习高等数学下期。 3.背10个单词。 4.听英语听力。 以上就是2月13日学习总结。...
2024/3/21 6:25:31 - unity《愤怒的小鸟》初级案例笔记siki学院
游戏逻辑: 1.小鸟的拖拽(最大移动距离) 2.小鸟的飞出 3.小鸟与猪,木头碰撞(死亡,受伤) 4.皮筋的绘制 5.一只小鸟到多只的转换 6.镜头跟随 7.制作特效 8.游戏结束,胜利的判定…...
2024/3/4 10:52:47 - kali新手入门教学(15)--burpsuite破解版的安装&证书导入&字体调整
burpsuite是个好软件,可以截断代理…等等作用,但由于kali内部自带的是普通版,很多功能都没有所以我们需要重新安装一个burpsuite 第一步,卸载kali自身的burpsuite kali自身卸载软件有两个命令 remove - 卸载软件包 purge - 卸载并清除软件包的配置 因为我们彻底不用了,就直…...
2024/3/4 10:52:46 - Mybatis insert 时SQL报错 check for the right syntax to use near ‘‘ at line 1
在写Mybatisspringboot项目时,调用某mapper接口发生报错 ### The error occurred while setting parameters ### SQL: insert into imooc_mall_cart Caused by: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that c…...
2024/3/20 2:10:19 - SpringBoot中有关XML文件的编译问题
一、问题描述 有时候,当我们使用SpringBoot访问数据库的时候,常常会出现这样的纠结,第一,Mapper注解、MapperScan注解的关系是什么,application.properties的 mybatis.mapper-locations的属性值设置与这个两个注解之…...
2024/3/4 10:52:45 - c++学习 2.13
1、拷贝构造函数 三种时机: 1)使用一个已经创建完毕的对象来初始化一个新对象 2)值传递的方式给函数参数传值 3)以值方式返回局部对象 注意拷贝构造函数形参参数的写法 Person(const Person &p){ c…...
2024/3/4 10:52:43 - 在构造函数中使用new时应注意的事项
1、如果在构造函数中使用new来初始化指针成员,则应在析构函数中使用delete。 2、new和delete必须相兼容。new对应于delete,new[]对应于delete[]。 3、若有多个构造函数,则必须以相同的方式使用new,要么都带中括号,要…...
2024/3/28 9:13:42 - Unknown custom element: <bm-marker>
Vue Baidu Map打点,使用<bm-maker>标签报错 官网例子: <template><baidu-map class"map" :center"{lng: 116.404, lat: 39.915}" :zoom"15"><bm-marker :position"markerPoint" :draggin…...
2024/3/7 11:52:58
最新文章
- 【二十七】【算法分析与设计】归并(1),912. 排序数组,归并排序,递归函数的时间复杂度计算,LCR 170. 交易逆序对的总数
912. 排序数组 给你一个整数数组 nums,请你将该数组升序排列。 示例 1: 输入:nums [5,2,3,1] 输出:[1,2,3,5] 示例 2: 输入:nums [5,1,1,2,0,0] 输出:[0,0,1,1,2,5] 提示: 1 < …...
2024/3/29 6:06:21 - 梯度消失和梯度爆炸的一些处理方法
在这里是记录一下梯度消失或梯度爆炸的一些处理技巧。全当学习总结了如有错误还请留言,在此感激不尽。 权重和梯度的更新公式如下: w w − η ⋅ ∇ w w w - \eta \cdot \nabla w ww−η⋅∇w 个人通俗的理解梯度消失就是网络模型在反向求导的时候出…...
2024/3/20 10:50:27 - 酷炫的粒子动态表白HTML源码
源码介绍 酷炫的粒子动态表白HTML源码,自己自定义文字,动态组合文字,进行表白,喜欢的朋友可以下载使用,很不错的表白HTML代码 下载地址 酷炫的粒子动态表白HTML源码...
2024/3/28 0:56:45 - QT:QTableWidget表格中加入勾选框
1.新建QTableWidget控件:tableWidget_TestResult 2.举例:在第一行第一列添加一个勾选框 //添加选择框QTableWidgetItem* check0 new QTableWidgetItem();check0->setCheckState(Qt::Checked);ui->tableWidget_TestResult->setItem(0, 0, chec…...
2024/3/28 10:43:02 - 【外汇早评】美通胀数据走低,美元调整
原标题:【外汇早评】美通胀数据走低,美元调整昨日美国方面公布了新一期的核心PCE物价指数数据,同比增长1.6%,低于前值和预期值的1.7%,距离美联储的通胀目标2%继续走低,通胀压力较低,且此前美国一季度GDP初值中的消费部分下滑明显,因此市场对美联储后续更可能降息的政策…...
2024/3/27 10:21:24 - 【原油贵金属周评】原油多头拥挤,价格调整
原标题:【原油贵金属周评】原油多头拥挤,价格调整本周国际劳动节,我们喜迎四天假期,但是整个金融市场确实流动性充沛,大事频发,各个商品波动剧烈。美国方面,在本周四凌晨公布5月份的利率决议和新闻发布会,维持联邦基金利率在2.25%-2.50%不变,符合市场预期。同时美联储…...
2024/3/24 20:11:25 - 【外汇周评】靓丽非农不及疲软通胀影响
原标题:【外汇周评】靓丽非农不及疲软通胀影响在刚结束的周五,美国方面公布了新一期的非农就业数据,大幅好于前值和预期,新增就业重新回到20万以上。具体数据: 美国4月非农就业人口变动 26.3万人,预期 19万人,前值 19.6万人。 美国4月失业率 3.6%,预期 3.8%,前值 3…...
2024/3/29 2:45:46 - 【原油贵金属早评】库存继续增加,油价收跌
原标题:【原油贵金属早评】库存继续增加,油价收跌周三清晨公布美国当周API原油库存数据,上周原油库存增加281万桶至4.692亿桶,增幅超过预期的74.4万桶。且有消息人士称,沙特阿美据悉将于6月向亚洲炼油厂额外出售更多原油,印度炼油商预计将每日获得至多20万桶的额外原油供…...
2024/3/24 20:11:23 - 【外汇早评】日本央行会议纪要不改日元强势
原标题:【外汇早评】日本央行会议纪要不改日元强势近两日日元大幅走强与近期市场风险情绪上升,避险资金回流日元有关,也与前一段时间的美日贸易谈判给日本缓冲期,日本方面对汇率问题也避免继续贬值有关。虽然今日早间日本央行公布的利率会议纪要仍然是支持宽松政策,但这符…...
2024/3/29 5:19:52 - 【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响
原标题:【原油贵金属早评】欧佩克稳定市场,填补伊朗问题的影响近日伊朗局势升温,导致市场担忧影响原油供给,油价试图反弹。此时OPEC表态稳定市场。据消息人士透露,沙特6月石油出口料将低于700万桶/日,沙特已经收到石油消费国提出的6月份扩大出口的“适度要求”,沙特将满…...
2024/3/28 17:01:12 - 【外汇早评】美欲与伊朗重谈协议
原标题:【外汇早评】美欲与伊朗重谈协议美国对伊朗的制裁遭到伊朗的抗议,昨日伊朗方面提出将部分退出伊核协议。而此行为又遭到欧洲方面对伊朗的谴责和警告,伊朗外长昨日回应称,欧洲国家履行它们的义务,伊核协议就能保证存续。据传闻伊朗的导弹已经对准了以色列和美国的航…...
2024/3/24 5:55:47 - 【原油贵金属早评】波动率飙升,市场情绪动荡
原标题:【原油贵金属早评】波动率飙升,市场情绪动荡因中美贸易谈判不安情绪影响,金融市场各资产品种出现明显的波动。随着美国与中方开启第十一轮谈判之际,美国按照既定计划向中国2000亿商品征收25%的关税,市场情绪有所平复,已经开始接受这一事实。虽然波动率-恐慌指数VI…...
2024/3/29 1:13:26 - 【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试
原标题:【原油贵金属周评】伊朗局势升温,黄金多头跃跃欲试美国和伊朗的局势继续升温,市场风险情绪上升,避险黄金有向上突破阻力的迹象。原油方面稍显平稳,近期美国和OPEC加大供给及市场需求回落的影响,伊朗局势并未推升油价走强。近期中美贸易谈判摩擦再度升级,美国对中…...
2024/3/26 23:04:51 - 【原油贵金属早评】市场情绪继续恶化,黄金上破
原标题:【原油贵金属早评】市场情绪继续恶化,黄金上破周初中国针对于美国加征关税的进行的反制措施引发市场情绪的大幅波动,人民币汇率出现大幅的贬值动能,金融市场受到非常明显的冲击。尤其是波动率起来之后,对于股市的表现尤其不安。隔夜美国股市出现明显的下行走势,这…...
2024/3/26 11:20:25 - 【外汇早评】美伊僵持,风险情绪继续升温
原标题:【外汇早评】美伊僵持,风险情绪继续升温昨日沙特两艘油轮再次发生爆炸事件,导致波斯湾局势进一步恶化,市场担忧美伊可能会出现摩擦生火,避险品种获得支撑,黄金和日元大幅走强。美指受中美贸易问题影响而在低位震荡。继5月12日,四艘商船在阿联酋领海附近的阿曼湾、…...
2024/3/24 20:11:18 - 【原油贵金属早评】贸易冲突导致需求低迷,油价弱势
原标题:【原油贵金属早评】贸易冲突导致需求低迷,油价弱势近日虽然伊朗局势升温,中东地区几起油船被袭击事件影响,但油价并未走高,而是出于调整结构中。由于市场预期局势失控的可能性较低,而中美贸易问题导致的全球经济衰退风险更大,需求会持续低迷,因此油价调整压力较…...
2024/3/28 9:10:53 - 氧生福地 玩美北湖(上)——为时光守候两千年
原标题:氧生福地 玩美北湖(上)——为时光守候两千年一次说走就走的旅行,只有一张高铁票的距离~ 所以,湖南郴州,我来了~ 从广州南站出发,一个半小时就到达郴州西站了。在动车上,同时改票的南风兄和我居然被分到了一个车厢,所以一路非常愉快地聊了过来。 挺好,最起…...
2024/3/29 0:49:46 - 氧生福地 玩美北湖(中)——永春梯田里的美与鲜
原标题:氧生福地 玩美北湖(中)——永春梯田里的美与鲜一觉醒来,因为大家太爱“美”照,在柳毅山庄去寻找龙女而错过了早餐时间。近十点,向导坏坏还是带着饥肠辘辘的我们去吃郴州最富有盛名的“鱼头粉”。说这是“十二分推荐”,到郴州必吃的美食之一。 哇塞!那个味美香甜…...
2024/3/24 20:11:15 - 氧生福地 玩美北湖(下)——奔跑吧骚年!
原标题:氧生福地 玩美北湖(下)——奔跑吧骚年!让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 让我们红尘做伴 活得潇潇洒洒 策马奔腾共享人世繁华 对酒当歌唱出心中喜悦 轰轰烈烈把握青春年华 啊……啊……啊 两…...
2024/3/27 7:12:50 - 扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!
原标题:扒开伪装医用面膜,翻六倍价格宰客,小姐姐注意了!扒开伪装医用面膜,翻六倍价格宰客!当行业里的某一品项火爆了,就会有很多商家蹭热度,装逼忽悠,最近火爆朋友圈的医用面膜,被沾上了污点,到底怎么回事呢? “比普通面膜安全、效果好!痘痘、痘印、敏感肌都能用…...
2024/3/24 20:11:13 - 「发现」铁皮石斛仙草之神奇功效用于医用面膜
原标题:「发现」铁皮石斛仙草之神奇功效用于医用面膜丽彦妆铁皮石斛医用面膜|石斛多糖无菌修护补水贴19大优势: 1、铁皮石斛:自唐宋以来,一直被列为皇室贡品,铁皮石斛生于海拔1600米的悬崖峭壁之上,繁殖力差,产量极低,所以古代仅供皇室、贵族享用 2、铁皮石斛自古民间…...
2024/3/26 11:21:23 - 丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者
原标题:丽彦妆\医用面膜\冷敷贴轻奢医学护肤引导者【公司简介】 广州华彬企业隶属香港华彬集团有限公司,专注美业21年,其旗下品牌: 「圣茵美」私密荷尔蒙抗衰,产后修复 「圣仪轩」私密荷尔蒙抗衰,产后修复 「花茵莳」私密荷尔蒙抗衰,产后修复 「丽彦妆」专注医学护…...
2024/3/28 18:26:34 - 广州械字号面膜生产厂家OEM/ODM4项须知!
原标题:广州械字号面膜生产厂家OEM/ODM4项须知!广州械字号面膜生产厂家OEM/ODM流程及注意事项解读: 械字号医用面膜,其实在我国并没有严格的定义,通常我们说的医美面膜指的应该是一种「医用敷料」,也就是说,医用面膜其实算作「医疗器械」的一种,又称「医用冷敷贴」。 …...
2024/3/28 12:42:28 - 械字号医用眼膜缓解用眼过度到底有无作用?
原标题:械字号医用眼膜缓解用眼过度到底有无作用?医用眼膜/械字号眼膜/医用冷敷眼贴 凝胶层为亲水高分子材料,含70%以上的水分。体表皮肤温度传导到本产品的凝胶层,热量被凝胶内水分子吸收,通过水分的蒸发带走大量的热量,可迅速地降低体表皮肤局部温度,减轻局部皮肤的灼…...
2024/3/28 20:09:10 - 配置失败还原请勿关闭计算机,电脑开机屏幕上面显示,配置失败还原更改 请勿关闭计算机 开不了机 这个问题怎么办...
解析如下:1、长按电脑电源键直至关机,然后再按一次电源健重启电脑,按F8健进入安全模式2、安全模式下进入Windows系统桌面后,按住“winR”打开运行窗口,输入“services.msc”打开服务设置3、在服务界面,选中…...
2022/11/19 21:17:18 - 错误使用 reshape要执行 RESHAPE,请勿更改元素数目。
%读入6幅图像(每一幅图像的大小是564*564) 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 - 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机...
win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”问题的解决方法在win7系统关机时如果有升级系统的或者其他需要会直接进入一个 等待界面,在等待界面中我们需要等待操作结束才能关机,虽然这比较麻烦,但是对系统进行配置和升级…...
2022/11/19 21:17:15 - 台式电脑显示配置100%请勿关闭计算机,“准备配置windows 请勿关闭计算机”的解决方法...
有不少用户在重装Win7系统或更新系统后会遇到“准备配置windows,请勿关闭计算机”的提示,要过很久才能进入系统,有的用户甚至几个小时也无法进入,下面就教大家这个问题的解决方法。第一种方法:我们首先在左下角的“开始…...
2022/11/19 21:17:14 - win7 正在配置 请勿关闭计算机,怎么办Win7开机显示正在配置Windows Update请勿关机...
置信有很多用户都跟小编一样遇到过这样的问题,电脑时发现开机屏幕显现“正在配置Windows Update,请勿关机”(如下图所示),而且还需求等大约5分钟才干进入系统。这是怎样回事呢?一切都是正常操作的,为什么开时机呈现“正…...
2022/11/19 21:17:13 - 准备配置windows 请勿关闭计算机 蓝屏,Win7开机总是出现提示“配置Windows请勿关机”...
Win7系统开机启动时总是出现“配置Windows请勿关机”的提示,没过几秒后电脑自动重启,每次开机都这样无法进入系统,此时碰到这种现象的用户就可以使用以下5种方法解决问题。方法一:开机按下F8,在出现的Windows高级启动选…...
2022/11/19 21:17:12 - 准备windows请勿关闭计算机要多久,windows10系统提示正在准备windows请勿关闭计算机怎么办...
有不少windows10系统用户反映说碰到这样一个情况,就是电脑提示正在准备windows请勿关闭计算机,碰到这样的问题该怎么解决呢,现在小编就给大家分享一下windows10系统提示正在准备windows请勿关闭计算机的具体第一种方法:1、2、依次…...
2022/11/19 21:17:11 - 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”的解决方法...
今天和大家分享一下win7系统重装了Win7旗舰版系统后,每次关机的时候桌面上都会显示一个“配置Windows Update的界面,提示请勿关闭计算机”,每次停留好几分钟才能正常关机,导致什么情况引起的呢?出现配置Windows Update…...
2022/11/19 21:17:10 - 电脑桌面一直是清理请关闭计算机,windows7一直卡在清理 请勿关闭计算机-win7清理请勿关机,win7配置更新35%不动...
只能是等着,别无他法。说是卡着如果你看硬盘灯应该在读写。如果从 Win 10 无法正常回滚,只能是考虑备份数据后重装系统了。解决来方案一:管理员运行cmd:net stop WuAuServcd %windir%ren SoftwareDistribution SDoldnet start WuA…...
2022/11/19 21:17:09 - 计算机配置更新不起,电脑提示“配置Windows Update请勿关闭计算机”怎么办?
原标题:电脑提示“配置Windows Update请勿关闭计算机”怎么办?win7系统中在开机与关闭的时候总是显示“配置windows update请勿关闭计算机”相信有不少朋友都曾遇到过一次两次还能忍但经常遇到就叫人感到心烦了遇到这种问题怎么办呢?一般的方…...
2022/11/19 21:17:08 - 计算机正在配置无法关机,关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机...
关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容,让我们赶快一起来看一下吧!关机提示 windows7 正在配…...
2022/11/19 21:17:05 - 钉钉提示请勿通过开发者调试模式_钉钉请勿通过开发者调试模式是真的吗好不好用...
钉钉请勿通过开发者调试模式是真的吗好不好用 更新时间:2020-04-20 22:24:19 浏览次数:729次 区域: 南阳 > 卧龙 列举网提醒您:为保障您的权益,请不要提前支付任何费用! 虚拟位置外设器!!轨迹模拟&虚拟位置外设神器 专业用于:钉钉,外勤365,红圈通,企业微信和…...
2022/11/19 21:17:05 - 配置失败还原请勿关闭计算机怎么办,win7系统出现“配置windows update失败 还原更改 请勿关闭计算机”,长时间没反应,无法进入系统的解决方案...
前几天班里有位学生电脑(windows 7系统)出问题了,具体表现是开机时一直停留在“配置windows update失败 还原更改 请勿关闭计算机”这个界面,长时间没反应,无法进入系统。这个问题原来帮其他同学也解决过,网上搜了不少资料&#x…...
2022/11/19 21:17:04 - 一个电脑无法关闭计算机你应该怎么办,电脑显示“清理请勿关闭计算机”怎么办?...
本文为你提供了3个有效解决电脑显示“清理请勿关闭计算机”问题的方法,并在最后教给你1种保护系统安全的好方法,一起来看看!电脑出现“清理请勿关闭计算机”在Windows 7(SP1)和Windows Server 2008 R2 SP1中,添加了1个新功能在“磁…...
2022/11/19 21:17:03 - 请勿关闭计算机还原更改要多久,电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机怎么办...
许多用户在长期不使用电脑的时候,开启电脑发现电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机。。.这要怎么办呢?下面小编就带着大家一起看看吧!如果能够正常进入系统,建议您暂时移…...
2022/11/19 21:17:02 - 还原更改请勿关闭计算机 要多久,配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以...
配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容,让我们赶快一起来看一下吧!配置windows update失败 还原更改 请勿关闭计算机&#x…...
2022/11/19 21:17:01 - 电脑配置中请勿关闭计算机怎么办,准备配置windows请勿关闭计算机一直显示怎么办【图解】...
不知道大家有没有遇到过这样的一个问题,就是我们的win7系统在关机的时候,总是喜欢显示“准备配置windows,请勿关机”这样的一个页面,没有什么大碍,但是如果一直等着的话就要两个小时甚至更久都关不了机,非常…...
2022/11/19 21:17:00 - 正在准备配置请勿关闭计算机,正在准备配置windows请勿关闭计算机时间长了解决教程...
当电脑出现正在准备配置windows请勿关闭计算机时,一般是您正对windows进行升级,但是这个要是长时间没有反应,我们不能再傻等下去了。可能是电脑出了别的问题了,来看看教程的说法。正在准备配置windows请勿关闭计算机时间长了方法一…...
2022/11/19 21:16:59 - 配置失败还原请勿关闭计算机,配置Windows Update失败,还原更改请勿关闭计算机...
我们使用电脑的过程中有时会遇到这种情况,当我们打开电脑之后,发现一直停留在一个界面:“配置Windows Update失败,还原更改请勿关闭计算机”,等了许久还是无法进入系统。如果我们遇到此类问题应该如何解决呢࿰…...
2022/11/19 21:16:58 - 如何在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