前端技术
HTML
CSS
Javascript
前端框架和UI库
VUE
ReactJS
AngularJS
JQuery
NodeJS
JSON
Element-UI
Bootstrap
Material UI
服务端和客户端
Java
Python
PHP
Golang
Scala
Kotlin
Groovy
Ruby
Lua
.net
c#
c++
后端WEB和工程框架
SpringBoot
SpringCloud
Struts2
MyBatis
Hibernate
Tornado
Beego
Go-Spring
Go Gin
Go Iris
Dubbo
HessianRPC
Maven
Gradle
数据库
MySQL
Oracle
Mongo
中间件与web容器
Redis
MemCache
Etcd
Cassandra
Kafka
RabbitMQ
RocketMQ
ActiveMQ
Nacos
Consul
Tomcat
Nginx
Netty
大数据技术
Hive
Impala
ClickHouse
DorisDB
Greenplum
PostgreSQL
HBase
Kylin
Hadoop
Apache Pig
ZooKeeper
SeaTunnel
Sqoop
Datax
Flink
Spark
Mahout
数据搜索与日志
ElasticSearch
Apache Lucene
Apache Solr
Kibana
Logstash
数据可视化与OLAP
Apache Atlas
Superset
Saiku
Tesseract
系统与容器
Linux
Shell
Docker
Kubernetes
[数据源驱动类配置验证方法]的搜索结果
这里是文章列表。热门标签的颜色随机变换,标签颜色没有特殊含义。
点击某个标签可搜索标签相关的文章。
点击某个标签可搜索标签相关的文章。
Hadoop
... 1. 引言 在大数据处理的世界里,Apache Hadoop无疑是最热门的技术之一。不过呢,对于那些还没尝过Hadoop这道技术大餐的朋友们来说,他们脑袋里可能会蹦出一连串问号:“哎,Hadoop究竟是个啥嘞?它究竟能干些啥事儿呀?还有啊,它最主要的组成部分都有哪些呢?”今天呐,咱们就一起撸起袖子,好好挖掘探究一下这些问题吧! 2. 什么是Hadoop? 简单来说,Hadoop是一种用于存储和处理大规模数据的开源框架。它的主要目标是解决海量数据存储和处理的问题。Hadoop这家伙,处理大数据的能力贼溜,现在早就是业界公认的大数据处理“扛把子”了! 3. Hadoop的主要组件有哪些? Hadoop的主要组件包括以下几个部分: 3.1 Hadoop Distributed File System (HDFS) HDFS是Hadoop的核心组件之一,它是基于Google的GFS文件系统的分布式文件系统。HDFS这小家伙可机灵了,它知道大文件是个难啃的骨头,所以就耍了个聪明的办法,把大文件切成一块块的小份儿,然后把这些小块分散存到不同的服务器上,这样一来,不仅能储存得妥妥当当,还能同时在多台服务器上进行处理,效率杠杠滴!这种方式可以大大提高数据的读取速度和写入速度。 3.2 MapReduce MapReduce是Hadoop的另一个核心组件,它是用于处理大量数据的一种编程模型。MapReduce的运作方式就像这么回事儿:它先把一个超大的数据集给剁成一小块一小块,然后把这些小块分发给一群计算节点,大家一起手拉手并肩作战,同时处理各自的数据块。最后,将所有结果汇总起来得到最终的结果。 下面是一段使用MapReduce计算两个整数之和的Java代码: java import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.mapreduce.Job; import org.apache.hadoop.mapreduce.Mapper; import org.apache.hadoop.mapreduce.Reducer; import org.apache.hadoop.mapreduce.lib.input.FileInputFormat; import org.apache.hadoop.mapreduce.lib.output.FileOutputFormat; public class WordCount { public static class TokenizerMapper extends Mapper { private final static IntWritable one = new IntWritable(1); private Text word = new Text(); public void map(LongWritable key, Text value, Context context ) throws IOException, InterruptedException { String line = value.toString(); StringTokenizer itr = new StringTokenizer(line); while (itr.hasMoreTokens()) { word.set(itr.nextToken()); context.write(word, one); } } } public static class IntSumReducer extends Reducer { private IntWritable result = new IntWritable(); public void reduce(Text key, Iterable values, Context context ) throws IOException, InterruptedException { int sum = 0; for (IntWritable val : values) { sum += val.get(); } result.set(sum); context.write(key, result); } } public static void main(String[] args) throws Exception { Configuration conf = new Configuration(); Job job = Job.getInstance(conf, "word count"); job.setJarByClass(WordCount.class); job.setMapperClass(TokenizerMapper.class); job.setCombinerClass(IntSumReducer.class); job.setReducerClass(IntSumReducer.class); job.setOutputKeyClass(Text.class); job.setOutputValueClass(IntWritable.class); FileInputFormat.addInputPath(job, new Path(args[0])); FileOutputFormat.setOutputPath(job, new Path(args[1])); System.exit(job.waitForCompletion(true) ? 0 : 1); } } 在这个例子中,我们首先定义了一个Mapper类,它负责将文本切分成单词,并将每个单词作为一个键值对输出。然后呢,我们捣鼓出了一个Reducer类,它的职责就是把所有相同的单词出现的次数统统加起来。 以上就是Hadoop的一些基本信息以及它的主要组件介绍。如果你对此还有任何疑问或者想要深入了解,欢迎留言讨论!
2023-12-06 17:03:26
408
红尘漫步-t
转载文章
...设置可查看隐藏文件。方法:进入此电脑,点击上方查看,勾选隐藏的项目即可查看被隐藏的文件。 2、设置签名 签名主要是设置用户名和email地址,有两种级别:一种是项目级别 git config user.name 用户名, git config user.email邮箱地址;另一种是系统用户级别 git config --global user.name 用户名, git config --global user.email 邮箱地址。项目级别是优先于系统级别的,但二者至少设置一个。一般只用项目级别就行。 用 cat .git/config可以查看设置的项目签名。 3.将文件/目录从工作区追加到暂存区 命令 :git add 文件/目录 4.查看状态 命令:git status。 第一行信息告诉我们,目前正处于master分支; 第二行信息告诉我们,本地库还没有上传任何文件; 第三、四、五行信息告诉我们,可以用以下命令把暂存区的文件(绿色文件)上传到本地库。 5.把暂存区的文件移除 代码:git rm --cached 文件名。注意文件只是从暂存区中移除,并没有在目录中被删除。 未追加在暂存区的文件显示红色。 6.把文件从暂存区上传到本地库 命令:git commit -m "注释内容" 文件名。 这是查看状态可以看到暂存区已经没有文件可以上传到本地库,说明你上传成功。 7.将文件变为未暂存状态 命令:git rest HEAD 文件名。对在暂存区的文件进行操作。 8.创建远程仓库并推送 a.首先我们要有一个github或gitee账号: github官网:https://github.com/ gitee官网:https://gitee.com/ b.然后在里面创建一个远程仓库(以gihub为例): 登录进入主页面,找到并点击右上角的加号,点击 New repository,然后填写仓库信息。或者找到点击左方的 New选项。进入创建界面,填入信息。 下面三个选项可根据需要勾选。点击 Create...就创建号一个仓库了。 c.复制仓库地址 找到左上方导航Code选项,点击进入该选项 有两个地址:HTTP地址和SSH地址。我一般用HTTP地址(简单)。 如果你创建远程仓库时选择了下面的三个选项,可能你的Code界面会有所差别,点击右方的 Code即可查看仓库地址。 然后进入git命令界面:输入命令 git remote add origin(别名) 地址为你复制的地址创建别名并储存。命令 git remote -v查看你设置过的地址。 d.最后进行推送操作,将本地仓库推送到远程仓库。 命令 git push -u origin(你要推送到的远程仓库地址) master(你要推送的分支).在第一次推送是用上 -u选项,之后就可以不用。 该界面为成功推送,你再刷新你的github或gitee仓库,这是你上传的文件将出现在远程仓库表明推送成功。 注意:1.如果创建远程仓库时勾选了下面的三个选项,则可能你刷新时没发现有新文件推送到仓库,这是先找到红色划线位置,查看当前分支是否自己推送的分支,找到正确分支再看是否正确推送。 2.如果你是第n次推送,必须要在和远程仓库版本一样的条件下进行修改后推送,否则无法推送(不能跨多个版本推送)。 3.如果推送不成功,可能是你修改前的版本和远程库的版本不一致造成,先进行拉取,在修改推送。 9.删除远程仓库 首先进入要删除的远程仓库,点击上方导航条中的 Settings选项 然后找到进入左边菜单栏中的 Options选项,鼠标划到最下面找到 点击Delete this repository选项 最后按指示输入github用户名和密码进行删除即可。 10.拉取远程仓库 命令:git pull origin master。 在打算更新远程库时,先拉取远程库然后修改或添加,否则可能报错。 表明拉取成功。 注意:若你的本地仓库进行了修该导致无法拉去成功,则尝试用 git pull --rebase命令进行拉取。 三、其他命令 1.查看命令信息指令 命令:git help 2.查看版本的提交记录 命令:git log 以每条版本日志显示一行:git log --pretty=oneline 简写哈希值的方式:git log --oneline 可以看到前进后退步数:git reflog 3.进入不同版本 先用 git reflog命令查看哈希值 a.命令:git reset --hard 哈希值(索引) b.命令:git reset --hard HEAD^,该命令只能后退(查看当前版本之前的版本),后面几个 ^ 则后退几步。 c.命令:git reset --hard~,该命令只能后退(查看当前版本之前的版本),后退 (数值) 步; 4.分支操作 命令:git branch -v,查看所有分支 命令:git branch 分支名,创建分支 命令:git checkout 分支名,切换分支 5.比较文件 命令:git diff 文件名,工作区和暂存区比较 命令:git diff HEAD 文件名,当前版本比较 命令:git diff HEAD^ 文件名,历史版本比较 四、遇到的错误 git config --global http.sslVerify false 本篇文章为转载内容。原文链接:https://blog.csdn.net/qq_56180999/article/details/117634968。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-05-18 13:38:15
75
转载
Javascript
...时音频、视频通话以及数据传输。它的特点是无需依赖任何第三方软件,只需通过浏览器就能完成通信。 三、WebRTC的工作原理 WebRTC的工作原理可以简单地概括为三个步骤: 1. 媒体流获取 浏览器会调用getUserMedia API,请求用户的摄像头和麦克风权限,获取用户的实时音频和视频流。 2. 信道建立 浏览器将媒体流封装成ICE候选信息,并发送给服务器或者其他浏览器。 3. 信令交换 通过WebSocket等网络传输机制,浏览器之间进行信令交换,协商并创建出一个可用于数据传输的安全连接。 四、如何利用WebRTC实现点对点通信 下面,我们通过一个简单的例子来说明如何利用WebRTC实现点对点通信。 首先,在HTML文件中添加以下代码: html 然后,在JavaScript文件中添加以下代码: javascript // 获取本地视频 const localStream = await navigator.mediaDevices.getUserMedia({ audio: true, video: true }); // 创建RTC对讲机 const pc = new RTCPeerConnection(); // 添加媒体流 pc.addTransceiver('audio'); pc.addTransceiver('video'); // 获取远程视频容器 const remoteVideo = document.getElementById('remoteVideo'); // 将本地视频流添加到远程视频容器 pc.getSenders().forEach((sender) => { sender.track.id = 'localVideo'; remoteVideo.srcObject = sender.track; }); // 接收媒体流 pc.ontrack = (event) => { event.streams.forEach((stream) => { stream.getTracks().forEach((track) => { track.id = 'remoteVideo'; const videoElement = document.createElement('video'); videoElement.srcObject = track; document.body.appendChild(videoElement); }); }); }; // 连接到其他客户端 function connect(otherUserURL) { // 创建新的RTCPeerConnection对象 const otherPC = new RTCPeerConnection(); // 设置回调函数,处理ICE候选信息和数据通道 otherPC.onicecandidate = (event) => { if (!event.candidate) return; pc.addIceCandidate(event.candidate); }; otherPC.ondatachannel = (event) => { event.channel.binaryType = 'arraybuffer'; channel.send('hello'); }; // 发送offer const offerOptions = { offerToReceiveAudio: true, offerToReceiveVideo: true }; pc.createOffer(offerOptions).then((offer) => { offer.sdp = SDPUtils.replaceBUNDLE_ID(offer.sdp, otherUserURL); offer.sdp = SDPUtils.replaceICE_UFRAG_AND_FINGERPRINT(offer.sdp, otherUserURL); offer.sdp = SDPUtils.replaceICEServers(offer.sdp, iceServers); return otherPC.setRemoteDescription(new RTCSessionDescription(offer)); }).then(() => { return otherPC.createAnswer(); }).then((answer) => { answer.sdp = SDPUtils.replaceBUNDLE_ID(answer.sdp, otherUserURL); answer.sdp = SDPUtils.replaceICE_UFRAG_AND_FINGERPRINT(answer.sdp, otherUserURL); answer.sdp = SDPUtils.replaceICEServers(answer.sdp, iceServers); return pc.setRemoteDescription(new RTCSessionDescription(answer)); }).catch((err) => { console.error(err.stack || err); }); } 在这个例子中,我们首先通过getUserMedia API获取用户的实时音频和视频流,然后创建一个新的RTCPeerConnection对象,并将媒体流添加到这个对象中。 接着,我们设置了回调函数,处理ICE候选信息和数据通道。当你收到ICE候选信息的时候,我们就把它塞到本地的那个RTCPeerConnection对象里头;而一旦收到数据通道的消息,我们就会把它的binaryType调成'arraybuffer'模式,然后就可以在通道里畅所欲言,发送各种消息啦。 最后,我们调用connect函数,与其他客户端建立连接。在connect函数里头,我们捣鼓出了一个崭新的RTCPeerConnection对象,就像组装一台小机器一样。然后呢,我们还给这个小家伙绑定了几个“小帮手”——回调函数,用来专门处理ICE候选信息和数据通道这些重要的任务,让它们能够实时报告状况,确保连接过程顺畅无阻。然后呢,我们给对方发个offer,就像递出一份邀请函那样。等对方接收到后,他们会回传一个answer,这就好比他们给出了接受邀请的答复。我们就把这个answer,当作是我们本地RTCPeerConnection对象的远程“地图”,这样一来,连接就算顺利完成啦! 五、结论 WebRTC技术为我们提供了一种方便、快捷、安全的点对点通信方式,大大提高了应用的交互性和实时性。当然啦,这只是个入门级的小例子,实际上的运用场景可能会复杂不少。不过别担心,只要咱们把WebRTC的核心原理和使用技巧都整明白了,就能根据自身需求灵活施展拳脚,开发出更多既有趣又有用的应用程序,保证让你玩得飞起! 未来,随着5G、物联网等技术的发展,WebRTC将会发挥更大的作用,成为更多应用场景的首选方案。让我们一起期待这个充满可能的新时代吧!
2023-12-18 14:38:05
315
昨夜星辰昨夜风_t
Flink
...高效的容错机制,在大数据领域备受青睐。嘿,伙计们,这篇文咱就一起钻探钻探Flink这家伙在实际生产环境里,是如何靠着它的容错机制稳稳当当地发挥作用的。咱们会手把手通过实例代码,扒开它的“内脏”,瞅瞅这背后的运作原理究竟是啥。再结合几个实实在在的应用场景,来场接地气儿的讨论。现在,大伙儿准备好,咱们这就踏入Flink的世界,亲自体验一下它是如何帮助企业在汹涌澎湃的数据海洋中,稳稳地把舵,赢得胜利的! 二、Flink容错机制概述 1. Checkpointing与Savepoints Flink的核心容错机制基于checkpointing和savepoints。Checkpointing,这个过程就像是Flink系统的“备忘录机制”。它会时不时地把运行状态给记下来,存到一个超级稳定、不会丢数据的地方。设想一下,如果系统突然闹个小脾气,出个故障啥的,别担心,Flink能够迅速翻开最近一次顺利完成的那个“备忘录”,接着从那里继续干活儿,这样一来,处理数据的时候就能保证绝对精确无误,实现我们常说的“精确一次”语义啦。而Savepoints则是在用户自定义的时间点创建的检查点,常用于计划内的维护或作业升级等操作。 java env.enableCheckpointing(5000); // 每5秒生成一个checkpoint env.getCheckpointConfig().setCheckpointingMode(CheckpointingMode.EXACTLY_ONCE); 2. 状态后端与异步快照 Flink支持多种状态后端,如MemoryStateBackend、FileSystemStateBackend和 RocksDBStateBackend等,它们负责在checkpoint过程中持久化和恢复状态。同时,Flink采用了异步快照技术来最小化checkpoint对正常数据处理的影响,确保性能和稳定性。 三、Flink容错机制实战分析 3.1 故障恢复示例 假设我们正在使用Flink处理实时交易流,如下所示: java DataStream transactions = env.addSource(new TransactionSource()); transactions .keyBy(Transaction::getAccountId) .process(new AccountProcessor()) .addSink(new TransactionSink()); 在此场景下,若某个TaskManager节点突然宕机,由于Flink已经开启了checkpoint功能,系统会自动检测到故障并从最新的checkpoint重新启动任务,使得整个应用状态恢复到故障前的状态,从而避免数据丢失和重复处理的问题。 3.2 保存及恢复Savepoints java // 创建并触发Savepoint String savepointPath = "hdfs://path/to/savepoint"; env.executeSavepoint(savepointPath, true); // 从Savepoint恢复作业 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.restore(savepointPath); 四、Flink容错机制在生产环境中的价值体现 在真实的生产环境中,硬件故障、网络抖动等问题难以避免,Flink的容错机制就显得尤为重要。它就像是企业的“守护神”,每当遇到突发状况,都能以迅雷不及掩耳之势,把系统瞬间恢复到正常状态。这样一来,业务中断的时间就能被压缩到最小,保证数据的完整性和一致性,让整体服务更加坚韧、更值得信赖,就像一位永不疲倦的超级英雄,时刻为企业保驾护航。 五、总结与思考 当我们深度剖析并实践Flink的容错机制后,不难发现它的设计之精妙与实用。Flink这个家伙可厉害了,它不仅能确保数据处理的精准无误,就像个严谨的会计师,连一分钱都不会算错。而且在实际工作中,面对各类突发状况,它都能稳如泰山,妥妥地hold住全场,为咱们打造那个既靠谱又高效的大型数据处理系统提供了强大的后盾支持。今后,越来越多的企业会把Flink当作自家数据处理的主力工具,我敢肯定,它的容错机制将在更多实际生产场景中大显身手,效果绝对会越来越赞! 然而,每个技术都有其适用范围和优化空间,我们在享受Flink带来的便利的同时,也应持续关注其发展动态,根据业务特点灵活调整和优化容错策略,以期在瞬息万变的数据世界中立于不败之地。
2023-10-06 21:05:47
389
月下独酌
Java
... 首先,我们需要一个方法来判断一个数是否是素数。哈哈,说到这个经典算法,就不得不提“试除法”啦!简单来说呢,就是拿那个数跟比它小的所有数字玩个“能不能整除”的小游戏。你一个个去试呗,看有没有哪个数字能让这个数乖乖地被整除,一点余数都不剩!如果都没有,那它就是素数。 不过呢,为了效率,我们可以稍微优化一下。比如说啊,检查一个数是不是有因数的时候,其实没必要从头到尾都查一遍,查到这个数的平方根就够了。为啥呢?因为如果一个数能被分成两个部分,比如说是 \( n = a \times b \),那这两个部分里肯定至少有一个不会比平方根大。换句话说,你只要找到一个小于等于平方根的因数,另一个就不用再费劲去挨个找了,直接配对就行啦! 下面是Java代码实现: java public static boolean isPrime(int num) { if (num <= 1) return false; // 小于等于1的数都不是素数 for (int i = 2; i i <= num; i++) { // 只需要检查到sqrt(num) if (num % i == 0) { return false; // 如果能被i整除,则不是素数 } } return true; } 这段代码看起来简单吧?但是它的作用可不小哦!现在我们可以用它来生成一系列素数了。 --- 三、拆分数字 递归的力量 接下来,我们的目标是找到所有可能的组合方式,让这些素数组合起来等于给定的目标数字。这里我们可以用递归来解决这个问题。递归的核心思想就是把大问题分解成小问题,然后逐步解决。 假设我们要把数字10拆成素数的和,我们可以从最小的素数2开始尝试,看看能不能凑出来。如果不行,就换下一个素数继续尝试。这样一步步往下走,直到找到所有可能的组合。 下面是一段Java代码示例: java import java.util.ArrayList; public class PrimeSum { public static void main(String[] args) { int target = 10; ArrayList primes = new ArrayList<>(); for (int i = 2; i <= target; i++) { if (isPrime(i)) { primes.add(i); } } findPrimeSums(target, primes, new ArrayList<>()); } public static boolean isPrime(int num) { if (num <= 1) return false; for (int i = 2; i i <= num; i++) { if (num % i == 0) { return false; } } return true; } public static void findPrimeSums(int remaining, ArrayList primes, ArrayList currentCombination) { if (remaining == 0) { System.out.println(currentCombination); return; } for (Integer prime : primes) { if (prime > remaining) break; currentCombination.add(prime); findPrimeSums(remaining - prime, primes, currentCombination); currentCombination.remove(currentCombination.size() - 1); } } } 这段代码里,findPrimeSums方法就是一个递归函数。这玩意儿呢,要收三个东西当输入:一个是剩下的数字,一个是所有的素数小弟们列好队等着用,还有一个是咱们现在正在拼凑的那个组合。当剩余数字为0时,我们就找到了一组有效的组合。 --- 四、结果展示 数字的无限可能性 运行上面的代码后,你会看到类似如下的输出: [2, 2, 2, 2, 2] [2, 2, 2, 3, 1] [2, 2, 3, 3] [2, 3, 5] [3, 7] 哇哦!原来10可以有这么多不同的拆分方式呢!每一组都是由素数组成的,并且它们的和正好等于10。 在这个过程中,我一直在想,为什么会有这么多种可能性呢?是不是因为素数本身就具有某种特殊的规律?还是说这只是数学世界中的一种巧合? 不管怎样,我觉得这种探索的过程真的很迷人。每一次运行程序,都像是在打开一个新的宝藏箱,里面装满了未知的答案。 --- 五、总结与展望 好了朋友们,今天的旅程到这里就要结束了。我们不仅学会了如何用Java找到素数,还掌握了如何用递归的方法拆分数字。虽然过程有点复杂,但每一步都很值得回味。 未来,如果你对这个问题感兴趣,不妨尝试优化代码,或者挑战更大的数字。也许你会发现更多有趣的规律呢! 最后,希望大家都能喜欢编程带来的乐趣。记住,学习编程就像学习一门新的语言,多实践、多思考,总有一天你会说得非常流利!再见啦,下次见!
2025-03-17 15:54:40
61
林中小径
转载文章
...使用、UI布局设计、数据存储(如SQLite)、网络通信、多媒体处理等。 积分商城 , 积分商城是在线社区或平台为鼓励用户参与互动和活跃度而设立的一种虚拟交易系统。在该文中,积分商城允许用户通过在论坛发帖、回复、参与活动等方式积累积分,并将积分兑换成实物礼品或虚拟服务,比如Android开发相关的教程资源、工具包等。 Socket编程 , Socket编程是网络编程的基础技术之一,它提供进程间通信的一种机制,允许运行于不同主机上的应用建立连接并通过端口发送和接收数据。在本文提到的“基于Socket的Android手机视频实时传输”中,Socket编程技术被用于构建客户端与服务器之间的稳定、双向的数据通道,实现实时音视频流的传输,这对于Android开发者而言是构建实时通讯类应用的关键技能之一。 AChartEngine , AChartEngine是一个开源的图表绘制库,专为Android移动应用设计。在Android开发过程中,开发者可以借助AChartEngine轻松创建各种类型的图表,例如折线图、柱状图、饼图等,以便更好地展示数据统计结果或者可视化信息。文章中的“Android Chart图开源库AChartEngine教程”,即提供了如何在Android应用中集成并利用AChartEngine绘制图表的具体指导。 喷泉粒子系统 , 喷泉粒子系统是一种计算机图形学中模拟自然现象(如水流、火焰、烟雾等)的特效技术,在游戏中和动态壁纸等场景广泛应用。在Android开发领域,喷泉粒子系统源码指的是实现这一特效效果的程序代码,通过控制大量细微的粒子状态(位置、速度、颜色等),营造出类似喷泉喷射、水珠飞溅的视觉效果。
2023-04-15 17:53:42
321
转载
转载文章
...删除相应内容。 一、配置文件 几乎所有的前端工程师都知道可以用babel将es6+的语法转换为es5,转换工具要么使用babel-cli,要么使用webpack的babel-loader,不管使用哪种转换工具,通常都需要一个配置文件来建立转换规则(也可以在webpack的babel-loader的配置项,原理都一样)。 babel执行时默认从当前目录查找配置文件,支持的配置文件格式有:.babelrc,.babelrc.js,babel.config.js和package.json。它们的配置项都是相同,作用也是一样的,只需要选择其中一种,推荐使用.js结尾的文件,这样可以在配置文件中进行编程控制,如下: module.exports = function (api) {api.cache(true);const presets = [ ... ];const plugins = [ ... ];return {presets,plugins};} 也可以直接使用module.exports = {},没有必要一定是一个function。 在编写配置文件中,最主要的就是设置plugins(插件)和presets(预设),每个插件或预设都是一个npm包,插件和预设会在编译过程中把我们的ES6+代码转换成ES5。 二、插件和预设的关系 babel中的插件太多,以es2015为例: @babel/plugin-transform-arrow-functions @babel/plugin-transform-block-scoped-functions @babel/plugin-transform-block-scoping .... 如果只采用插件的话,我们需要配置非常多的插件数组,如果项目使用了es2016又得增加一堆,而且我们压根也记不住哪个es版本里该使用哪些插件。 preset就是解决这个问题的,它是一系列插件的集合,以@babel/preset-env为例,假设项目中安装的npm包版本是2020年1月发布的,那么这个预设里包含了2020年1月以前所有进入到stage4阶段的语法转换插件。 可能有小伙伴会问,假如我设置了一个语法插件,指定某个预设里又包含了插件,此时会发生什么?这就涉及到插件和预设的执行顺序了,具体的规则如下: 插件比预设先执行 插件执行顺序是插件数组从前向后执行 预设执行顺序是预设数组从后向前执行 三、插件和预设的参数 不配置参数的情况下,每个插件或预设都是数组中的一个字符串成员,例:preset:["@babel/preset-env","@babel/preset-react"],如果某个插件或预设需要配置参数,成员项就需要由字符串换成一个数组,数组的第一项是插件或预设的名称字符串,第二项为对象,该对象用来设置插件或预设的参数,格式如下: {"presets": [["@babel/preset-env",{"useBuiltIns": "entry"}]]} 四、插件和预设的简写 插件或可以在配置文件里用简写名称,如果插件的npm包名称的前缀为 babel-plugin-,可以省略前缀。例如"plugins": ["babel-plugin-transform-decorators-legacy"]可以简写为"plugins": ["transform-decorators-legacy"]。 如果npm包名称的前缀带有作用域@,例如@scope/babel-plugin-xxx,短名称可以写成@scope/xxx。 到babel7版本时,官方的插件大多采用@babel/plugin-xxx格式的,没有明确说明是否可以省略@babel/plugin-,遇到这中npm包时,最好还是采用全称写法比较稳妥。 预设的短名称规则跟插件差不多,前缀为babel-preset-或带有作用域的包@scope/babel-preset-xxx的可以省略掉babel-preset-。 babel7里@babel/preset-前缀开头的包,例如@babel/preset-env的短名称是@babel/env,官方并没有给出明确说明以@babel/preset-xxx卡头的包是否都可以采用简写,因此最好还是采用全称。 五、混乱的babel6预设 如果直接接触babel7的前端同事都知道es预设直接用@babel/preset-env就行了,但是如果要维护和迭代基于babel6的项目呢?各个项目中使用的可能都不一样,babel-preset-es20xx、babel-preset-stage-x、babel-preset-latest这些预设是啥意思? babel-preset-es20xx: TC39每年发布的、进入标准的ES语法转换器预设,最后一个预设是babel-preset-es2017,不再更新。 babel-preset-stage-x: TC39每年草案阶段的ES语法转换器预设。x的值是0到3,babel7时已废弃,不再更新。 babel-preset-latest: TC39每年发布的、进入标准的ES语法转换器预设。在babel6时等于babel-preset-es2015、babel-preset-es2016、babel-preset-es2017。该包从 v2 开始,需要@babel/core@^7.0.0,也就是需要babel7才能使用,既然要升级到babel7,不如使用更加强大的@babel/preset-env。 本篇文章为转载内容。原文链接:https://blog.csdn.net/douyinbuwen/article/details/123729828。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-01-16 22:15:54
121
转载
转载文章
...单的来实现调用学习的方法,然后在一个Test类之中输入学习的内容。但是我暂时只学java和web,但是可能我后面还要学习Spring,SpringMVC… 1.面向实现编程 public class Ggzx {public void stduyJava(){System.out.println("学习了java课程");}public void studyWeb(){System.out.println("学习了Web课程");} } public class Test {public static void main(String[] args) {Ggzx ggzx=new Ggzx();ggzx.studyJava();ggzx.studyPython();ggzx.studyGo();} } 分析: 上面使用的面向实现编程,但是Test作为我们控制的"应用层",也就是高层,而Ggzx作为低层,其实这样在比较简单的例子中,其实是没问题的,因为假如不需要扩展,仅仅是实现两个很简单的功能,并没有必要去面向接口开发,但是一般在开发中通常有很复杂的开发环境和开发需求。 现在如果想添加新的功能,学习其他的课程,怎么办??? 继续使用面向实现编程,直接在 Ggzx 类中直接添加新的方法,可以完成这个功能需求。 用上面的方法实现有没有缺点??? 学习的课程和 Ggzx 类耦合比较严重。是学习的课程只能通过Ggzx 才能得到 。并且是想要学习新的课程也要在 Ggzx 类中不断添加和修改 —>高耦合 Ggzx 作为当前 demo 的底层,经常的被改动,高层Test依赖于低层 Ggzx 的实现 ---->对应依赖倒置原则中的:高层过度依赖低层了 2.面向接口编程(简单版) 为了解决上面出现的问题,我们可以考虑把学习的课程抽出来成为一个类。到现在,类和类之间的耦合其实就已经降低很多了。然后将其当做参数传入Ggzx里面,然后调用课程里面的学习方法 //web课程类public class WebCourse {public void studyCourse() {System.out.println("学习了Web课程");} } //这里是Java课程类public class JavaCourse {public void studyCourse() {System.out.println("学习Java课程");} } 当我们写出来这两个类,想要对Ggzx里面的学习方法进行编写的时候,有没有发现其实有一些小问题呢???? Ggzx里面接收这些类的参数是什么?? 难道要这样? //以下是Ggzx类中的内容public void studyJava(JavaCourse javaCourse){}public void studyWeb(WebCourse webCourse){} nonono,如果这样做,虽然当前已经把课程类和 Ggzx 用户剥离一点点了,但是是还是形同虚设,课程类虽然分离开了,但是还是像狗皮膏药一样贴在 Ggzx 类中,但是看着还是很难受,高层 Test 调用方法还是得依赖 Ggzx 里面有什么方法 每次加入新课程,都需要修改底层功能 如何修改??? 接口是个好东西,课程类之间是不是都包含同样一个方法,被学习的方法( studyCourse ),那么我们可以将所有课程类都实现一个ICourse课程! 对应上面的问题,我们该传入什么参数能解决问题??可以传入一个接口 改编后的 UML 图解展示(Ggzx 被废弃,用新的 NewGgzx 代替):(如果没了解过UML类图,或者是纯小白,只需要知道一个大框是一个类,虚线表示实现了箭头方向的接口,小m是方法 即可) 观察上面的UML图 WebCourse 和 JavaCourse 实现自同一个接口 ICourse,每个课程都有自己的 studyXxx 方法。 这样好在什么地方? - 课程类和Ggzx类是解耦的,无论你增加多少个课程类,只要实现了ICourse接口,都能直接传入Ggzx的studyMyCourse()方法中 public interface ICourse {void studyCourse();} public class WebCourse implements ICourse{@Overridepublic void studyCourse() {System.out.println("学习了Web课程");} } public class NewGgzx {public void studyMyCourse(ICourse iCourse){iCourse.studyCourse();} } 上面就是案例的面向接口编程,我们可以看到,在 NewGgzx 类中,我们可以传入一个实现 ICourse 接口的课程类,我们在Test类中调用的时候,只需要传入一个课程类即可调用学习方法,这样当想扩展新的内容,只需要创建一个新的课程类实现 ICourse 即可 Test使用 NewGgzx newGgzx =new NewGgzx();newGgzx.studyMoocCourse(new WebCourse());newGgzx.studyMoocCourse(new com.ggzx.design.priciple.dependenceiversion.JavaCourse()); 从面向实现到面向接口,我们处理问题的方法改变了: 开始时,我们需要考虑在Test类中调用Ggzx里面的哪一种学习方法,即注重调用什么方法能够实现特定的课程 到面向接口编程,我们考虑传入什么课程即可实现学习 当业务需求拓展时,拓展方法也改变了: 面向实现:需要改变底层的代码来协调我们需要使用的功能,用上面的例子来解释就是:当你想要学习一个课程,你就需要改变你底层的实现,增加新的代码 面向接口:想学习什么课程,不会对其他课程造成影响,也不会影响到低层的Ggzx 。实际操作就是增加一门新的课程即可,实现接口之后,传入这个类到Ggzx的方法中就可以学习这一门课了 相对于细节的多变性,抽象的东西更稳定,以抽象为基础搭建的架构比以细节搭建的架构更加稳定 本篇文章为转载内容。原文链接:https://blog.csdn.net/m0_52410356/article/details/122828154。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-08-26 15:35:43
633
转载
转载文章
...种内存分配器在大规模数据处理场景下的对比评测报告,结果显示,在特定条件下,jemalloc能有效减少大对象分配时的延迟,而tcmalloc在小对象频繁分配回收的场景中表现更优。 而在操作系统内核层面,Linux内核社区正在积极改进伙伴系统算法以适应新兴硬件架构的需求,例如针对非均匀内存访问(NUMA)节点的优化,以及通过合并多个小页以减少内存碎片的技术探索。此外,Slab分配器也在不断迭代升级,新的研究指出,通过引入智能缓存替换策略,可以进一步降低slab分配器的内存浪费,提高整体系统的资源利用率。 同时,随着持久化内存、异构计算等新型硬件技术的发展,内存管理面临全新挑战。研究人员正尝试将传统内存管理模式与这些新技术相结合,如Intel Optane DC持久性内存的管理方案,以及针对GPU等加速设备的内存池设计,力求在保证高效的同时,最大限度地发挥新型硬件的潜力。 综上所述,无论是用户空间还是内核空间的内存管理,都处于一个快速演进和技术革新的阶段,对于软件开发者和系统工程师而言,紧跟最新的研究成果和最佳实践,无疑是提升系统性能和稳定性的关键所在。
2023-02-26 20:46:17
231
转载
Lua
...的工具编译库。 - 配置搜索路径:将库的 .so 或 .dll 文件添加到 Lua 的 LOADLIBS 环境变量中,或者直接在 Lua 代码中指定路径。 使用代码: lua -- 导入自定义的 mathlib 库 local mathlib = require("path_to_mathlib.mathlib") -- 调用库中的函数 local result = mathlib.square(5) print("The square of 5 is: ", result) local power_result = mathlib.power(2, 3) print("2 to the power of 3 is: ", power_result) 3. 导入和使用自定义模块 在开发过程中,你可能会编写自己的模块,用于封装特定的功能集。这不仅有助于代码的组织,还能提高可重用性和维护性。 创建自定义模块: 假设我们创建了一个名为 utility 的模块,包含了常用的辅助函数。 模块代码: lua -- utility.lua local function add(a, b) return a + b end local function subtract(a, b) return a - b end return { add = add, subtract = subtract } 使用自定义模块: lua -- main.lua local utility = require("path_to_utility.utility") local result = utility.add(3, 5) print("The sum is: ", result) local difference = utility.subtract(10, 4) print("The difference is: ", difference) 4. 总结与思考 在 Lua 中导入和使用外部模块的过程,实际上就是将外部资源集成到你的脚本中,以增强其功能和灵活性。哎呀,这个事儿啊,得说清楚点。不管是 Lua 自带的那些功能工具,还是咱们从别处找来的扩展包,或者是自己动手编的模块,关键就在于三件事。第一,得知道自己要啥,需求明明白白的。第二,环境配置得对头,别到时候出岔子。第三,代码得有条理,分门别类,这样用起来才顺手。懂我的意思吧?这事儿可不能急,得慢慢来,细心琢磨。哎呀,你听过 Lua 这个玩意儿没?这家伙可厉害了,简直就是编程界的万能工具箱!不管你是想捣鼓个小脚本,还是搞个大应用,Lua 都能搞定。它就像个魔术师,变着花样满足你的各种需求,真的是太灵活、太强大了! 结语 学习和掌握 Lua 中的模块导入与使用技巧,不仅能够显著提升开发效率,还能让你的项目拥有更广泛的适用性和扩展性。哎呀,随着你对 Lua 语言越来越熟悉,你会发现,用那些灵活多变的工具,就像在厨房里调制美食一样,能做出既省时又好看的大餐。你不仅能快速搞定复杂的任务,还能让代码看起来赏心悦目,就像是艺术品一样。这不就是咱们追求的高效优雅嘛!无论是处理日常任务,还是开发复杂系统,Lua 都能以其简洁而强大的特性,成为你编程旅程中不可或缺的一部分。
2024-08-12 16:24:19
167
夜色朦胧
转载文章
...应内容。 采集下拉词数据 闲来无事,采集一下百度下拉数据 1 进行对应的网页分析 下拉数据属于动态的数据,鼠标点击输入框出现,划出输入框消失 所以先找到对应的数据包 就要进行抓包操作 1.1 抓包操作 发现其中的关键词,并复制 打开浏览器的开发者模式(快捷键F12)并点击这个搜索按钮 打开这个搜索按钮以后,进行粘贴操作 并且按下回车! 由图可知,只搜索到一个包,在查看这个包内容之前,应该就有90%的把握就是这个包了 点开查看(没错 就是这个包了) 小细节:Preview是渲染之后的结果 Response是写代码请求的结果 接下来我们就上代码 -- coding: UTF-8 --import jsonimport requestsfrom faker import Fakerdef get_aim(file_name):"""从文件里获取想要的关键词"""with open(file_name, mode='r', encoding='utf-8') as file:keys = file.read()return keysdef aim_letter(aim):"""获取到网页的json数据并保存到txt文件"""url = f'https://m.baidu.com/sugrec?pre=1&p=3&ie=utf-8&json=1&prod=wise&from=wise_web&sugsid=128699,138809,114177,135846,141002,138945,140853,141677,138878,137978,141200,140173,131246,132552,137743,138165,107315,138883,140259,141754,140201,138585,141650,138253,140114,136196,140325,140579,133847,140793,140066,134046,131423,137703,110085,127969,140957,141581,140593,140865,139886,138426,138941,141190,140596&net=&os=&sp=null&rm_brand=0&callback=jsonp1&wd{aim}&sugmode=2&lid=12389568409845924354&sugid=1990018821100998871&preqy=java&_=1580993331416'headers = {'User-Agent': Faker().user_agent(),'Host': 'm.baidu.com','Referer': 'https://m.baidu.com/ssid=4348023d/s?word={aim}&ts=3254538&t_kt=0&ie=utf-8&rsv_iqid=2845402975&rsv_t=daabpEKSG2wGueEO%252FnXSVz2dj3oGTk5cF1suYK9xduVIBAnyA5yo&sa=ib&rsv_pq=2845402975&rsv_sug4=5130&tj=1&inputT=2405&sugid=1990018821100998871&ss=100'}res = requests.get(url, headers=headers) 由于获取到的数据不是标准的json数据要进行字符串的删减result = json.loads(res.text.replace('jsonp1', '').strip('()')) 保存到txt文件with open(f'百度下拉词.txt', mode='a', encoding='utf-8') as file:for key in result['g']:file.write(key + '\n')def main():"""进行整合,并捕捉错误"""name = input('请输入文件的名字:')start_time = time.time()try:letter = get_aim(name).split('\n') 利用线程池加快爬取速度with concurrent.futures.ThreadPoolExecutor(max_workers=100) as executor:for l in letter:executor.submit(get_data, l)except:print('请检查文件名是否存在或者文件名是否错误!!')else: 提示用户完成并打印运行时间时间print('' 30 + f'<{name}> 百度相关词 已完成' + '' 30)finally:print(time.time() - start_time)if __name__ == '__main__':main() 在此 要感谢我的晨哥!!!哈哈 本篇文章为转载内容。原文链接:https://blog.csdn.net/Result_Sea/article/details/104201970。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-06-21 12:59:26
490
转载
Spark
...ka的集成。这可是大数据领域里一个超级实用且热门的话题。不管你是刚入门的小白还是有经验的大神,学会了Spark和Kafka的结合使用,在处理实时数据流时肯定会觉得轻松很多,简直像开了外挂一样! 1.1 为什么选择Spark与Kafka? 想象一下,你正在处理海量的数据流,而且这些数据是不断更新的,怎么办?这时候,Spark与Kafka的组合就派上用场了。Spark这家伙处理海量数据那是真快,而Kafka就像是个传送带,能把这些数据飞快地倒腾来倒腾去。两者结合,简直是天作之合! 1.2 本文结构 接下来,我会从基础概念讲起,然后一步步带你了解如何将Spark与Kafka集成起来。最后,我们还会一起动手实践几个具体的例子。别担心,我不会只是给你一堆枯燥的文字,而是会尽量用口语化的方式讲解,并穿插一些我个人的理解和思考过程。让我们开始吧! 2. 基础概念 2.1 Spark简介 Spark,全名Apache Spark,是一款开源的大数据处理框架。它的亮点在于能飞快地处理数据,还能在内存里直接运算,让处理大数据变得超级顺畅,简直爽翻天!Spark提供了多种API,包括Java、Scala、Python等,非常灵活易用。 2.2 Kafka简介 Kafka,全名Apache Kafka,是一个分布式的消息系统,主要用来处理实时数据流。这个东西特别能扛,能存好多数据,还不容易丢,用来搭建实时的数据流和应用再合适不过了。 2.3 Spark与Kafka集成的优势 - 实时处理:Spark可以实时处理Kafka中的数据。 - 灵活性:Spark支持多种编程语言,Kafka则提供丰富的API接口,两者结合让开发更加灵活。 - 高吞吐量:Spark的并行处理能力和Kafka的高吞吐量相结合,能够高效处理大规模数据流。 3. 实战准备 在开始之前,你需要先准备好环境。确保你的机器上已经安装了Java、Scala以及Spark。说到Kafka,你可以直接下载安装包,或者用Docker容器搞一个本地环境,超级方便!我推荐你用Docker,因为它真的超简单方便,还能随手搞出好几个实例来测试,特别实用。 bash 安装Docker sudo apt-get update sudo apt-get install docker.io 拉取Kafka镜像 docker pull wurstmeister/kafka 启动Kafka容器 docker run -d --name kafka -p 9092:9092 -e KAFKA_ADVERTISED_HOST_NAME=localhost wurstmeister/kafka 4. 集成实战 4.1 创建Kafka主题 首先,我们需要创建一个Kafka主题,以便后续的数据流能够被正确地发送和接收。 bash 进入容器 docker exec -it kafka /bin/bash 创建主题 kafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 4.2 发送数据到Kafka 接下来,我们可以编写一个简单的脚本来向Kafka的主题中发送一些数据。这里我们使用Python的kafka-python库来实现。 python from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='localhost:9092') for _ in range(10): message = "Hello, Kafka!".encode('utf-8') producer.send('test-topic', value=message) print("Message sent:", message.decode('utf-8')) producer.flush() producer.close() 4.3 使用Spark读取Kafka数据 现在,我们来编写一个Spark程序,用于读取刚才发送到Kafka中的数据。这里我们使用Spark的Structured Streaming API。 scala import org.apache.spark.sql.SparkSession val spark = SparkSession.builder.appName("SparkKafkaIntegration").getOrCreate() val df = spark.readStream .format("kafka") .option("kafka.bootstrap.servers", "localhost:9092") .option("subscribe", "test-topic") .load() val query = df.selectExpr("CAST(value AS STRING)") .writeStream .outputMode("append") .format("console") .start() query.awaitTermination() 这段代码会启动一个Spark应用程序,从Kafka的主题中读取数据,并将其打印到控制台。 4.4 实时处理 接下来,我们可以在Spark中对数据进行实时处理。例如,我们可以统计每秒钟接收到的消息数量。 scala import org.apache.spark.sql.functions._ val countDF = df.selectExpr("CAST(value AS STRING)") .withWatermark("timestamp", "1 minute") .groupBy( window($"timestamp", "1 minute"), $"value" ).count() val query = countDF.writeStream .outputMode("complete") .format("console") .start() query.awaitTermination() 这段代码会在每分钟的时间窗口内统计消息的数量,并将其输出到控制台。 5. 总结与反思 通过这次实战,我们成功地将Spark与Kafka进行了集成,并实现了数据的实时处理。虽然过程中遇到了一些挑战,但最终还是顺利完成了任务。这个经历让我明白,书本上的知识和实际动手做真是两码事。不一次次去试,根本没法真正搞懂怎么用这门技术。希望这次分享对你有所帮助,也期待你在实践中也能有所收获! 如果你有任何问题或想法,欢迎随时交流讨论。
2025-03-08 16:21:01
76
笑傲江湖
转载文章
...是老项目的维护了。 数据可视化,可以选学,如果项目里有这块需求,可以仔细研究一下。 第六阶段,混合应用开发技术。 所谓混合开发,就是将HTML5基于浏览器的应用,嵌入到基于Android和iOS手机APP里,或者嵌入到基于Node和Chromium的桌面APP里。因为兼具了WebApp和NativeApp的双重优点,混合应用开发技术得到了广泛的应用。 学会这个部分,就拥有了多端开发能力,能够胜任跨平台跨设备的架构工作。通过Vue和React基础加持,薪资待遇能达到19K-22K。 常见的混合开发如手机端的微信公众号、微信小程序、桌面端的Electron技术和PWA技术等。 第七步,原生应用开发技术。 所谓原生应用开发,就是应用前端的技术,脱离浏览器,进行原生的手机APP的开发。 掌握这部分内容,可以达到大前端高级开发工程师水平,可以主导移动端多元产品项目实现,能够跨平台开发提出可建设性解决方案。薪资待遇能达到 23K-30K。 比如,Facebook的基于React技术的ReactNative原生APP的开发,谷歌的基于Dart技术的Flutter原生APP的开发,以及华为的基于JS技术的HarmonyOS鸿蒙原生APP的开发。 第八步,大前端架构。 这是本学习路线图最后一个步骤了,同时也到达了一个至高点。 掌握这个部分,即可拥有大前端架构师水平,主要进行前端项目架构和项目把控。能够解决网站出现的突发状况,能够改进网站性能到极致。拥有大型网站、大量高并发访问量等开发经验。这个岗位的薪资能达到30K以上的水平。 前端架构师,包含很多内容,要求有广度也要有深度,这里给出了重要的五部分内容,包括开发工具及服务器技术、前端性能、微前端架构、低代码与组件库开发以及前端安全技术。 小白起点的前端路线图,我们都走了一遍,你可能会问,这些知识我们我该如何学习呢?你可以靠查文档、看视频,也可以找个师父带你。上面给大家推荐的视频都是核心的技术点视频以及项目练手视频,更多更细节的技术点请大家关注IT千锋教育搜索你需要的课程。 本篇文章为转载内容。原文链接:https://blog.csdn.net/longz_org_cn/article/details/127673811。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-03-07 21:33:13
269
转载
Beego
...源(如服务器、存储、数据库、网络服务等)。云计算的灵活性和可扩展性使其成为现代IT基础设施的重要组成部分。 微服务架构(Microservices Architecture) , 一种软件架构风格,将单一应用程序构建为一组小而独立的服务,每个服务运行在其自己的进程中,并通过轻量级通信机制进行交互。这种架构允许独立部署服务,提高系统的可扩展性和弹性,同时降低复杂度。 分布式系统设计(Design of Distributed Systems) , 旨在构建能够在多个计算机节点上分布运行的系统。通过分散数据存储、计算任务和处理负载,分布式系统可以提高系统的可扩展性、可用性和容错性。在文中,分布式系统设计原则如服务网格和服务注入,被用来模拟和测试系统在不同故障条件下的表现,以提高系统的鲁棒性。 服务级协议(Service Level Agreement, SLA) , 双方就服务的质量、性能、响应时间、故障恢复时间等关键指标达成的书面协议。SLA为服务提供者和消费者之间提供了一种明确的责任界定,有助于在服务出现问题时迅速界定责任,加快问题解决的进程,确保服务质量符合预期。
2024-10-10 16:02:03
102
月影清风
转载文章
...好吧,咱们赶紧写一下配置文件跑起来吧~~ webpack.config.js: var path = require('path');module.exports = {entry: './src/index.js',output: {path: path.resolve(__dirname, 'dist'),filename: 'bundle.js'},module: {rules: [{test: /\.js$/,exclude: /node_modules/,loader: 'babel-loader',options: {presets: ['env']} }, {test: /\.css$/,loader: 'style-loader!css-loader?modules'}]} }; 说明: style-loader和css-loader是工具名称。 !感叹号是分割符,表示两个工具都参与处理。 ?问号,其实跟url的问号一样,就是后面要跟参数的意思。 而modules这个参数呢,就是将css打包成模块。跟js打包是一样的,你不必再担心不同模块具有相同类名时造成的问题了。 我们运行一下:(我这次特地没在局部安装webpack-cli,发现可以运行,因为我昨天在全局安装了webpack-cli,之所以要在全局安装而单独局部安装不行,可能跟package.json有关,因为这里都没有用到package.json)。 如果不报错,我们打开浏览器,看一下index.html: 我们看到,样式已然生效了,但是我们打开控制台,看到class的名称并非是我们写的样式类.content,而是生成了新名称,这就说明webpack的编译生效了。 我们打开bundle.js看一下,css其实已经被打包编译到了bundle.js文件里:(太长,截了一部分) 我们看到,css打包后,存在形态已经变成了js。这没有什么可奇怪的,只有这样才能使用包的形式做管理,css本身,是无法达到这样的目的的,所以,它还是二等公民。。。。 本篇文章为转载内容。原文链接:https://blog.csdn.net/DreamFJ/article/details/81700004。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-03-13 11:42:35
72
转载
转载文章
...e的集成体验。然而,数据可视化领域的创新和发展永无止境。近日,amCharts公司宣布即将推出的一系列新功能更新,进一步强化其产品在实时数据分析、交互式体验以及无障碍访问等方面的优势。 据官方透露,amCharts 5将在下一版本中引入更先进的动态数据流处理机制,使得大规模实时数据能够得到即时、流畅的可视化展现,尤其适用于金融交易、物联网监控等对时效性要求极高的场景。同时,针对日益增长的无障碍需求,amCharts 5也将改进图表元素的可访问性设计,确保视障用户通过辅助技术也能准确理解数据信息。 此外,amCharts团队正积极与各大开源社区合作,持续丰富地图库资源,并计划将更多开源地理空间数据项目纳入支持范围,让用户能更加便捷地创建符合特定业务需求的地图图表。通过这些升级,amCharts 5旨在巩固其作为行业领先的数据可视化工具的地位,赋能各行业用户高效、精准地洞察并传达复杂数据背后的价值。
2023-09-17 18:18:34
351
转载
Dubbo
...报错信息与具体环境和配置有关,需要根据实际情况进行排查 一、Dubbo的基本概念与作用 首先,咱们得聊聊Dubbo是什么。Dubbo嘛,就是一个特别牛的Java工具,简单讲,它能让咱们的服务像住在不同房间的小伙伴一样,虽然不在一个屋檐下,但还能互相串门、干活儿。就像你家里的电视、冰箱、空调这些家伙,插上电就能一起工作,超方便! 举个例子,假设你开发了一个电商系统,用户下单时,订单服务要调用库存服务来检查商品是否还有货。在这种情况下,Dubbo就能很好地完成这个任务。哎呀,Dubbo这东西确实挺牛的,功能强大到让人爱不释手,但也不是完美无缺啦!时不时地就会给你来个“报错警告”,而且这些错误啊,很多时候都跟你的环境配置脱不了干系,一不小心就中招了。 记得有一次我调试一个Dubbo项目的时候,就遇到了这个问题。我当时在本地测的时候,那叫一个顺风顺水,啥问题都没有,结果一到生产环境,各种错误蹦出来,看得我头都大了,心里直犯嘀咕:这是不是选错了人生路啊?后来才反应过来,哎呀妈呀,原来是生产环境的网络设置跟本地的不一样,这就搞不定啦,服务之间压根连不上话!所以说啊,在解决Dubbo问题的时候,咱们得结合实际情况来分析,不能一概而论。就像穿衣服一样,得看天气、场合啥的,对吧? --- 二、Dubbo报错信息的特点与常见原因 Dubbo的报错信息通常会包含一些关键信息,比如服务名称、接口版本、错误堆栈等。不过啊,这些东西通常不会直接告诉我们哪里出了岔子,得我们自己去刨根问底才行。 比如说,你可能会看到这样的报错: Failed to invoke remote method: sayHello, on 127.0.0.1:20880 看到这个错误,你是不是会觉得很懵?其实这可能是因为你的服务端没有正确启动,或者客户端的配置不对。又或者是网络不通畅,导致客户端无法连接到服务端。 再比如,你可能会遇到这种错误: No provider available for the service com.example.UserService on the consumer 192.168.1.100 use dubbo version 2.7.8 这表明你的消费者(也就是客户端)找不到提供者(也就是服务端)。哎呀,这问题八成是服务注册中心没整利索,要不就是服务提供方压根没成功注册上。 我的建议是,遇到这种问题时,先别急着改代码,而是要冷静下来分析一下,是不是配置文件出了问题。比如说,你是不是忘记在dubbo.properties里填对了服务地址? --- 三、排查报错的具体步骤 接下来,咱们来聊聊怎么排查这些问题。首先,你需要确认服务端是否正常运行。你可以通过以下命令查看服务端的状态: bash netstat -tuln | grep 20880 如果看不到监听的端口,那肯定是服务端没启动成功。 然后,检查服务注册中心是否正常工作。Dubbo支持多种注册中心,比如Zookeeper、Nacos等。如果你用的是Zookeeper,可以试试进入Zookeeper的客户端,看看服务是否已经注册: bash zkCli.sh -server 127.0.0.1:2181 ls /dubbo/com.example.UserService 如果这里看不到服务,那就说明服务注册中心可能有问题。 最后,别忘了检查客户端的配置。客户端的配置文件通常是dubbo-consumer.xml,里面需要填写服务提供者的地址。例如: xml 如果地址写错了,当然就会报错了。 --- 四、代码示例与实际案例分析 下面我给大家举几个具体的例子,让大家更直观地了解Dubbo的报错排查过程。 示例1:服务启动失败 假设你在本地启动服务端时,发现服务一直无法启动,报错如下: Failed to bind URL: dubbo://192.168.1.100:20880/com.example.UserService?anyhost=true&application=demo-provider&dubbo=2.7.8&interface=com.example.UserService&methods=sayHello&pid=12345&side=provider×tamp=123456789 经过检查,你会发现是因为服务端的application.name配置错了。修改后,重新启动服务端,问题就解决了。 示例2:服务找不到 假设你在客户端调用服务时,发现服务找不到,报错如下: No provider available for the service com.example.UserService on the consumer 192.168.1.100 use dubbo version 2.7.8 经过排查,你发现服务注册中心的地址配置错了。正确的配置应该是: xml 示例3:网络不通 假设你在生产环境中,发现客户端和服务端之间的网络不通,报错如下: ConnectException: Connection refused 这时候,你需要检查防火墙设置,确保服务端的端口是开放的。同时,也要检查客户端的网络配置,确保能够访问服务端。 --- 五、总结与感悟 总的来说,Dubbo的报错信息确实有时候让人摸不着头脑,但它并不是不可战胜的。只要你细心排查,结合具体的环境和配置,总能找到问题的根源。 在这个过程中,我学到的东西太多了。比如说啊,别啥都相信默认设置,每一步最好自己动手试一遍,心里才踏实。再比如说,碰到问题的时候,先别忙着去找同事求助,自己多琢磨琢磨,说不定就能找到解决办法了呢!毕竟,编程的乐趣就在于不断解决问题的过程嘛! 最后,我想说的是,Dubbo虽然复杂,但它真的很棒。希望大家都能掌握它,让它成为我们技术生涯中的一把利器!
2025-03-20 16:29:46
63
雪落无痕
转载文章
...拟DOM是一种抽象的数据结构,它将实际的DOM树映射为内存中的轻量级对象表示形式。通过比较前后两次渲染的虚拟DOM差异,框架可以在最小化DOM操作的情况下更新页面,从而提高页面渲染性能并减少不必要的重绘和回流。虽然文章没有涉及虚拟DOM,但在讨论现代Web开发技术和HTML标签的实际应用时,虚拟DOM是一个关键概念。 HTML5不支持的标签 , 随着HTML版本的迭代升级,一些旧版HTML中存在的标签因过时、有更好的替代方案或者不符合现代Web标准等原因,在HTML5及后续版本中不再被推荐或支持。例如,文章提到的<applet>标签用于嵌入Java小程序,但因为安全性和兼容性问题,在HTML5中已被废弃,开发者应采用更安全、更现代的技术实现类似功能。
2023-10-11 23:43:21
296
转载
转载文章
...界面层、系统交互层,数据管理层。达成高扩展,高可用,高性能,高安全,易运维,易部署,易接入等能力。 3、功能设计与实现:对架构设计的底层代码级别实现。如公共核心类,接口实现,应用发现规则、接口变更等。 技术经理 人生就是不断上升的过程,你已经到达经理的层次了。如今的你,需要不断提高领导力,需要定期召开团队会议讨论问题。 首先我们要更加自信,在工作中显示自己的功力,给讲话增添力量。如:“本次项目虽然有很大的困难,我们也需苦战到底。当然示先垂范,身先士卒,方能成功!” 技术经理有时候也可能叫系统分析员,一些小公司可能会整个公司或者部门有一个技术经理。技术经理承担的角色主要是系统分析、架构搭建、系统构建、代 码走查等工作,如果说项目经理是总统,那么技术经理就是总理。当然不是所有公司都是这样的,有些公司项目经理是不管技术团队的,只做需求、进度和同客户沟 通,那么这个时候的项目经理就好像工厂里的跟单人员了,这种情况在外包公司比较多。对于技术经理来说,着重于技术方面,你需要知道某种功能用哪些技术合 适,需要知道某项功能需要多长的开发时间等。同时,技术经理也应该承担提高团队整体技术水平的工作。 你需要和大家站在一起,因为人们也都有解决问题的能力,更需要有以下的能力与责任: 1、任务管理:开发工作量评估、定立开发流程、分配和追踪开发任务 2、质量管理:代码review、开发风险判断/报告/协调解决 3、效率提升:代码底层研发和培训、最佳代码实践规范总结与推广、自动化生产工具、自动化部署工具 4、技术能力提升:招聘面试、试题主拟、新人指导、项目复盘与改进 技术总监 如果一个研发团队超过20人,有多条产品线或业务量很大,这时已经有多个技术经理在负责每个业务,这时需要一位技术总监。 主要职责: 1、组建平台研发部,与架构师共建软件公共平台,方便各条产品业务线研发。 2、通过技术平台、通过高一层的职权,管理和协调公司各个部门与本部门各条线。现在每个产品线都应该有合格的技术经理和高级程序员。 结语:我们相信,每个人都能成为IT大神。现在开始,找个师兄带你入门,让你的学习之路不再迷茫。 这里推荐我们的前端学习交流圈:784783012,里面都是学习前端的从最基础的HTML+CSS+JS【炫酷特效,游戏,插件封装,设计模式】到移动端HTML5的项目实战的学习资料都有整理,送给每一位前端小伙伴。 最新技术,与企业需求同步。好友都在里面学习交流,每天都会有大牛定时讲解前端技术! 点击:前端技术分享 本篇文章为转载内容。原文链接:https://blog.csdn.net/webDk/article/details/88917912。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2024-05-10 13:13:48
755
转载
转载文章
...就可以完成系统的完全配置。 不要直接从 Lubuntu 18.04 升级到 Lubuntu 20.04 通常,你可以将 Ubuntu 从一个 LTS 版本升级到另一个 LTS 版本。但是 Lubuntu 团队建议不要从 Lubuntu 18.04 升级到 20.04。他们建议重新安装,这才是正确的。 Lubuntu 18.04 使用 LXDE 桌面,20.04 使用 LXQt。由于桌面环境的巨大变化,从 18.04 升级到 20.04 将导致系统崩溃。 更多的 KDE 和 Qt 应用程序 下面是在这个新版本中默认提供的一些应用程序,正如我们所看到的,并非所有应用程序都是轻量级的,而且大多数应用程序都是基于 Qt 的。 甚至使用的软件中心也是 KDE 的 Discover,而不是 Ubuntu 的 GNOME 软件中心。 ◈ Ark – 归档文件管理器◈ Bluedevil – 蓝牙连接管理◈ Discover 软件中心 – 包管理系统◈ FeatherPad – 文本编辑器◈ FireFox – 浏览器◈ K3b – CD/DVD 刻录器◈ Kcalc – 计算器◈ KDE 分区管理器 – 分区管理工具◈ LibreOffice – 办公套件(Qt 界面版本)◈ LXimage-Qt – 图片查看器及截图制作◈ Muon – 包管理器◈ Noblenote – 笔记工具◈ PCManFM-Qt – 文件管理器◈ Qlipper – 剪贴板管理工具◈ qPDFview – PDF 阅读器◈ PulseAudio – 音频控制器◈ Qtransmission – BT 下载工具(Qt 界面版本)◈ Quassel – IRC 客户端◈ ScreenGrab – 截屏制作工具◈ Skanlite – 扫描工具◈ 启动盘创建工具 – USB 启动盘制作工具◈ Trojita – 邮件客户端◈ VLC – 媒体播放器◈ MPV 视频播放器 测试 Lubuntu 20.04 LTS LXQt 版 Lubuntu 的启动时间不到一分钟,虽然是从 SSD 启动的。 LXQt 目前需要的内存比基于 Gtk+ 2 的 LXDE 稍微多一点,但是另一种 Gtk+ 3 工具包也需要更多的内存。 在重新启动之后,系统以非常低的内存占用情况运行,大约只有 340 MB(按照现代标准),比 LXDE 多 100 MB。 LXQt 不仅适用于硬件较旧的用户,也适用于那些希望在新机器上获得简约经典体验的用户。 桌面布局看起来类似于 KDE 的 Plasma 桌面,你觉得呢? 在左下角有一个应用程序菜单,一个用于显示固定和活动的应用程序的任务栏,右下角有一个系统托盘。 Lubuntu 的 LXQt 版本可以很容易的定制,所有的东西都在菜单的首选项下,大部分的关键项目都在 LXQt “设置”中。 值得一提的是,LXQt 在默认情况下使用流行的 Openbox 窗口管理器。 与前三个发行版一样,20.04 LTS 附带了一个默认的黑暗主题 Lubuntu Arc,但是如果不适合你的口味,可以快速更换,也很方便。 就日常使用而言,事实证明,Lubuntu 20.04 向我证明,其实每一个 Ubuntu 的分支版本都完全没有问题。 结论 Lubuntu 团队已经成功地过渡到一个现代的、依然轻量级的、极简的桌面环境。LXDE 看起来被遗弃了,迁移到一个活跃的项目也是一件好事。 我希望 Lubuntu 20.04 能够让你和我一样热爱,如果是这样,请在下面的评论中告诉我。请继续关注! via: https://itsfoss.com/lubuntu-20-04-review/ 作者:Dimitrios Savvopoulos 选题:lujun9972 译者:qfzy1233 校对:wxy 本文由 LCTT 原创编译,Linux中国 荣誉推出 本篇文章为转载内容。原文链接:https://blog.csdn.net/weixin_39539807/article/details/111619265。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-05-17 18:52:15
318
转载
转载文章
...下内容: 近期,随着数据隐私和网络安全问题日益突出,开源项目如Pi-hole的受欢迎程度正逐步提升。据《连线》杂志最近的一篇报道(2023年5月),在全球范围内,越来越多的家庭用户、小型企业和教育机构开始采用Pi-hole来保护他们的网络环境,对抗广告追踪、恶意软件和网络钓鱼等威胁。 同时,Raspberry Pi基金会发布了最新的硬件版本,为用户提供更强性能和更多功能选择,这也进一步拓宽了Pi-hole和其他安全相关项目的实施空间。例如,《 Ars Technica》在一篇深度技术分析中探讨了如何利用最新款的Raspberry Pi构建更为高效且强大的本地防火墙系统,并与Pi-hole结合,实现全方位的家庭网络安全防护。 此外,开源社区围绕Pi-hole开发了许多增强功能和插件,以适应不断变化的网络环境。TechCrunch发表的一篇文章介绍了几个重要的Pi-hole拓展工具,它们能够帮助用户更精细地管理网络流量,优化家庭网络体验,同时确保个人隐私不受侵犯。 总之,在数字化生活越发普及的今天,深入了解和运用像Pi-hole这样的开源解决方案,不仅能有效提升网络安全性,也是对个人隐私保护意识的重要体现。通过持续关注相关的技术发展和实践案例,我们可以更好地应对未来的网络挑战。
2023-08-12 20:49:59
61
转载
转载文章
...y Update)是数据同步的一种方式,在当前的Linux内核中发挥着重要的作用。RCU主要针对的数据对象是链表,目的是提高遍历读取数据的效率,为了达到目的使用RCU机制读取数据的时候不对链表进行耗时的加锁操作。这样在同一时间可以有多个线程同时读取该链表,并且允许一个线程对链表进行修改(修改的时候,需要加锁)。RCU适用于需要频繁的读取数据,而相应修改数据并不多的情景,例如在文件系统中,经常需要查找定位目录,而对目录的修改相对来说并不多,这就是RCU发挥作用的最佳场景。 Linux内核源码当中,关于RCU的文档比较齐全,你可以在 /DocumentaTIon/RCU/ 目录下找到这些文件。Paul E. McKenney 是内核中RCU源码的主要实现者,他也写了很多RCU方面的文章。今天我们就主要来说说linux内核rcu的机制详解。 在RCU的实现过程中,我们主要解决以下问题: 在读取过程中,另外一个线程删除了一个节点。删除线程可以把这个节点从链表中移除,但它不能直接销毁这个节点,必须等到所有的线程读取完成以后,才进行销毁操作。RCU中把这个过程称为宽限期(Grace period)。 在读取过程中,另外一个线程插入了一个新节点,而读线程读到了这个节点,那么需要保证读到的这个节点是完整的。这里涉及到了发布-订阅机制(Publish-Subscribe Mechanism)。 保证读取链表的完整性。新增或者删除一个节点,不至于导致遍历一个链表从中间断开。但是RCU并不保证一定能读到新增的节点或者不读到要被删除的节点。 宽限期 通过这个例子,方便理解这个内容。以下例子修改于Paul的文章。 struct foo {int a;char b;long c;};DEFINE_SPINLOCK(foo_mutex);struct foo gbl_foo;void foo_read (void){foo fp = gbl_foo;if ( fp != NULL )dosomething(fp-》a, fp-》b , fp-》c );}void foo_update( foo new_fp ){spin_lock(&foo_mutex);foo old_fp = gbl_foo;gbl_foo = new_fp;spin_unlock(&foo_mutex);kfee(old_fp);} 如上的程序,是针对于全局变量gbl_foo的操作。假设以下场景。有两个线程同时运行 foo_ read和foo_update的时候,当foo_ read执行完赋值操作后,线程发生切换;此时另一个线程开始执行foo_update并执行完成。当foo_ read运行的进程切换回来后,运行dosomething 的时候,fp已经被删除,这将对系统造成危害。为了防止此类事件的发生,RCU里增加了一个新的概念叫宽限期(Grace period)。 如下图所示: 图中每行代表一个线程,最下面的一行是删除线程,当它执行完删除操作后,线程进入了宽限期。宽限期的意义是,在一个删除动作发生后,它必须等待所有在宽限期开始前已经开始的读线程结束,才可以进行销毁操作。这样做的原因是这些线程有可能读到了要删除的元素。图中的宽限期必须等待1和2结束;而读线程5在宽限期开始前已经结束,不需要考虑;而3,4,6也不需要考虑,因为在宽限期结束后开始后的线程不可能读到已删除的元素。为此RCU机制提供了相应的API来实现这个功能。 void foo_read(void){rcu_read_lock();foo fp = gbl_foo;if ( fp != NULL )dosomething(fp-》a,fp-》b,fp-》c);rcu_read_unlock();}void foo_update( foo new_fp ){spin_lock(&foo_mutex);foo old_fp = gbl_foo;gbl_foo = new_fp;spin_unlock(&foo_mutex);synchronize_rcu();kfee(old_fp);} 其中foo_read中增加了rcu_read_lock和rcu_read_unlock,这两个函数用来标记一个RCU读过程的开始和结束。其实作用就是帮助检测宽限期是否结束。 foo_update增加了一个函数synchronize_rcu(),调用该函数意味着一个宽限期的开始,而直到宽限期结束,该函数才会返回。我们再对比着图看一看,线程1和2,在synchronize_rcu之前可能得到了旧的gbl_foo,也就是foo_update中的old_fp,如果不等它们运行结束,就调用kfee(old_fp),极有可能造成系统崩溃。而3,4,6在synchronize_rcu之后运行,此时它们已经不可能得到old_fp,此次的kfee将不对它们产生影响。 宽限期是RCU实现中最复杂的部分,原因是在提高读数据性能的同时,删除数据的性能也不能太差。 订阅——发布机制 当前使用的编译器大多会对代码做一定程度的优化,CPU也会对执行指令做一些优化调整,目的是提高代码的执行效率,但这样的优化,有时候会带来不期望的结果。如例: void foo_update( foo new_fp ){spin_lock(&foo_mutex);foo old_fp = gbl_foo;new_fp-》a = 1;new_fp-》b = ‘b’;new_fp-》c = 100;gbl_foo = new_fp;spin_unlock(&foo_mutex);synchronize_rcu();kfee(old_fp);} 这段代码中,我们期望的是6,7,8行的代码在第10行代码之前执行。但优化后的代码并不会对执行顺序做出保证。在这种情形下,一个读线程很可能读到 new_fp,但new_fp的成员赋值还没执行完成。单独线程执行dosomething(fp-》a, fp-》b , fp-》c ) 的 这个时候,就有不确定的参数传入到dosomething,极有可能造成不期望的结果,甚至程序崩溃。可以通过优化屏障来解决该问题,RCU机制对优化屏障做了包装,提供了专用的API来解决该问题。这时候,第十行不再是直接的指针赋值,而应该改为 : rcu_assign_pointer(gbl_foo,new_fp);rcu_assign_pointer的实现比较简单,如下:define rcu_assign_pointer(p, v) \__rcu_assign_pointer((p), (v), __rcu)define __rcu_assign_pointer(p, v, space) \do { \smp_wmb(); \(p) = (typeof(v) __force space )(v); \} while (0) 我们可以看到它的实现只是在赋值之前加了优化屏障 smp_wmb来确保代码的执行顺序。另外就是宏中用到的__rcu,只是作为编译过程的检测条件来使用的。 在DEC Alpha CPU机器上还有一种更强悍的优化,如下所示: void foo_read(void){rcu_read_lock();foo fp = gbl_foo;if ( fp != NULL )dosomething(fp-》a, fp-》b ,fp-》c);rcu_read_unlock();} 第六行的 fp-》a,fp-》b,fp-》c会在第3行还没执行的时候就预先判断运行,当他和foo_update同时运行的时候,可能导致传入dosomething的一部分属于旧的gbl_foo,而另外的属于新的。这样会导致运行结果的错误。为了避免该类问题,RCU还是提供了宏来解决该问题: define rcu_dereference(p) rcu_dereference_check(p, 0)define rcu_dereference_check(p, c) \__rcu_dereference_check((p), rcu_read_lock_held() || (c), __rcu)define __rcu_dereference_check(p, c, space) \({ \typeof(p) _________p1 = (typeof(p)__force )ACCESS_ONCE(p); \rcu_lockdep_assert(c, “suspicious rcu_dereference_check()” \usage”); \rcu_dereference_sparse(p, space); \smp_read_barrier_depends(); \(typeof(p) __force __kernel )(_________p1)); \})staTIc inline int rcu_read_lock_held(void){if (!debug_lockdep_rcu_enabled())return 1;if (rcu_is_cpu_idle())return 0;if (!rcu_lockdep_current_cpu_online())return 0;return lock_is_held(&rcu_lock_map);} 这段代码中加入了调试信息,去除调试信息,可以是以下的形式(其实这也是旧版本中的代码): define rcu_dereference(p) ({ \typeof(p) _________p1 = p; \smp_read_barrier_depends(); \(_________p1); \}) 在赋值后加入优化屏障smp_read_barrier_depends()。我们之前的第四行代码改为 foo fp = rcu_dereference(gbl_foo);,就可以防止上述问题。 数据读取的完整性 还是通过例子来说明这个问题: 如图我们在原list中加入一个节点new到A之前,所要做的第一步是将new的指针指向A节点,第二步才是将Head的指针指向new。这样做的目的是当插入操作完成第一步的时候,对于链表的读取并不产生影响,而执行完第二步的时候,读线程如果读到new节点,也可以继续遍历链表。如果把这个过程反过来,第一步head指向new,而这时一个线程读到new,由于new的指针指向的是Null,这样将导致读线程无法读取到A,B等后续节点。从以上过程中,可以看出RCU并不保证读线程读取到new节点。如果该节点对程序产生影响,那么就需要外部调用来做相应的调整。如在文件系统中,通过RCU定位后,如果查找不到相应节点,就会进行其它形式的查找,相关内容等分析到文件系统的时候再进行叙述。 我们再看一下删除一个节点的例子: 如图我们希望删除B,这时候要做的就是将A的指针指向C,保持B的指针,然后删除程序将进入宽限期检测。由于B的内容并没有变更,读到B的线程仍然可以继续读取B的后续节点。B不能立即销毁,它必须等待宽限期结束后,才能进行相应销毁操作。由于A的节点已经指向了C,当宽限期开始之后所有的后续读操作通过A找到的是C,而B已经隐藏了,后续的读线程都不会读到它。这样就确保宽限期过后,删除B并不对系统造成影响。 小结 RCU的原理并不复杂,应用也很简单。但代码的实现确并不是那么容易,难点都集中在了宽限期的检测上,后续分析源代码的时候,我们可以看到一些极富技巧的实现方式。 本篇文章为转载内容。原文链接:https://blog.csdn.net/m0_50662680/article/details/128449401。 该文由互联网用户投稿提供,文中观点代表作者本人意见,并不代表本站的立场。 作为信息平台,本站仅提供文章转载服务,并不拥有其所有权,也不对文章内容的真实性、准确性和合法性承担责任。 如发现本文存在侵权、违法、违规或事实不符的情况,请及时联系我们,我们将第一时间进行核实并删除相应内容。
2023-09-25 09:31:10
105
转载
站内搜索
用于搜索本网站内部文章,支持栏目切换。
知识学习
实践的时候请根据实际情况谨慎操作。
随机学习一条linux命令:
sort file.txt
- 对文件内容排序。
推荐内容
推荐本栏目内的其它文章,看看还有哪些文章让你感兴趣。
2023-04-28
2023-08-09
2023-06-18
2023-04-14
2023-02-18
2023-04-17
2024-01-11
2023-10-03
2023-09-09
2023-06-13
2023-08-07
2023-03-11
历史内容
快速导航到对应月份的历史文章列表。
随便看看
拉到页底了吧,随便看看还有哪些文章你可能感兴趣。
时光飞逝
"流光容易把人抛,红了樱桃,绿了芭蕉。"