需求背景:简单实现远程文件的MD5校验

方案设计:①通过FTP获取远程文件流;②将文件流处理获取MD5;

已知bug:①中文路径乱码

1.FTP的工具类

关于中文路径的乱码bug没能解决

import com.alibaba.datax.common.exception.DataXException;

import com.alibaba.datax.plugin.unstructuredstorage.reader.UnstructuredStorageReaderUtil;

import com.alibaba.fastjson.JSON;

import com.alibaba.fastjson.serializer.SerializerFeature;

import com.jcraft.jsch.*;

import com.jcraft.jsch.ChannelSftp.LsEntry;

import org.apache.commons.io.IOUtils;

import org.apache.commons.lang3.StringUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import java.io.ByteArrayOutputStream;

import java.io.InputStream;

import java.io.OutputStream;

import java.lang.reflect.Field;

import java.util.*;

public class SftpHelper {

private static final Logger LOG = LoggerFactory.getLogger(SftpHelper.class);

Session session = null;

ChannelSftp channelSftp = null;

public static Long totalCount = 0L;

public void loginFtpServer(String host, String username, String password, int port, int timeout,

String connectMode) {

JSch jsch = new JSch(); // 创建JSch对象

try {

session = jsch.getSession(username, host, port);

// 根据用户名，主机ip，端口获取一个Session对象

// 如果服务器连接不上，则抛出异常

if (session == null) {

throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN,

"session is null,无法通过sftp与服务器建立链接，请检查主机名和用户名是否正确.");

}

session.setPassword(password); // 设置密码

Properties config = new Properties();

config.put("StrictHostKeyChecking", "no");

session.setConfig(config); // 为Session对象设置properties

session.setTimeout(timeout); // 设置timeout时间

session.connect(); // 通过Session建立链接

channelSftp = (ChannelSftp) session.openChannel("sftp"); // 打开SFTP通道

channelSftp.connect(); // 建立SFTP通道的连接

try {

Class cl = channelSftp.getClass();

Field field = cl.getDeclaredField("server_version");

field.setAccessible(true);

field.set(channelSftp,2);

channelSftp.setFilenameEncoding("GBK");

} catch (SftpException e) {

e.printStackTrace();

String message = String.format("-------------------------", host);

LOG.error(message);

} catch (IllegalAccessException e) {

e.printStackTrace();

} catch (NoSuchFieldException e) {

e.printStackTrace();

}

//设置命令传输编码

//String fileEncoding = System.getProperty("file.encoding");

//channelSftp.setFilenameEncoding(fileEncoding);

} catch (JSchException e) {

if(null != e.getCause()){

String cause = e.getCause().toString();

String unknownHostException = "java.net.UnknownHostException: " + host;

String illegalArgumentException = "java.lang.IllegalArgumentException: port out of range:" + port;

String wrongPort = "java.net.ConnectException: Connection refused";

if (unknownHostException.equals(cause)) {

String message = String.format("请确认ftp服务器地址是否正确，无法连接到地址为: [%s] 的ftp服务器", host);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN, message, e);

} else if (illegalArgumentException.equals(cause) || wrongPort.equals(cause) ) {

String message = String.format("请确认连接ftp服务器端口是否正确，错误的端口: [%s] ", port);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN, message, e);

}

}else {

if("Auth fail".equals(e.getMessage())){

String message = String.format("与ftp服务器建立连接失败,请检查用户名和密码是否正确: [%s]",

"message:host =" + host + ",username = " + username + ",port =" + port);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN, message);

}else{

String message = String.format("与ftp服务器建立连接失败 : [%s]",

"message:host =" + host + ",username = " + username + ",port =" + port);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FAIL_LOGIN, message, e);

}

}

}

}

public void logoutFtpServer() {

if (channelSftp != null) {

channelSftp.disconnect();

}

if (session != null) {

session.disconnect();

}

}

public void mkdir(String directoryPath) {

boolean isDirExist = false;

try {

this.printWorkingDirectory();

SftpATTRS sftpATTRS = this.channelSftp.lstat(directoryPath);

isDirExist = sftpATTRS.isDir();

} catch (SftpException e) {

if (e.getMessage().toLowerCase().equals("no such file")) {

LOG.warn(String.format(

"您的配置项path:[%s]不存在，将尝试进行目录创建, errorMessage:%s",

directoryPath, e.getMessage()), e);

isDirExist = false;

}

}

if (!isDirExist) {

try {

// warn 检查mkdir -p

this.channelSftp.mkdir(directoryPath);

} catch (SftpException e) {

String message = String

.format("创建目录:%s时发生I/O异常,请确认与ftp服务器的连接正常,拥有目录创建权限, errorMessage:%s",

directoryPath, e.getMessage());

LOG.error(message, e);

throw DataXException

.asDataXException(

FtpWriterErrorCode.COMMAND_FTP_IO_EXCEPTION,

message, e);

}

}

}

public void mkDirRecursive(String directoryPath){

boolean isDirExist = false;

try {

this.printWorkingDirectory();

SftpATTRS sftpATTRS = this.channelSftp.lstat(directoryPath);

isDirExist = sftpATTRS.isDir();

} catch (SftpException e) {

if (e.getMessage().toLowerCase().equals("no such file")) {

LOG.warn(String.format("您的配置项path:[%s]不存在，将尝试进行目录创建, errorMessage:%s",directoryPath, e.getMessage()), e);

isDirExist = false;

}

}

if (!isDirExist) {

StringBuilder dirPath = new StringBuilder();

dirPath.append(IOUtils.DIR_SEPARATOR_UNIX);

String[] dirSplit = StringUtils.split(directoryPath,IOUtils.DIR_SEPARATOR_UNIX);

try {

// ftp server不支持递归创建目录,只能一级一级创建

for(String dirName : dirSplit){

try {

dirPath.append(dirName);

channelSftp.cd(dirPath.toString());

dirPath.append(IOUtils.DIR_SEPARATOR_UNIX);

} catch (SftpException e1) {

String message = String.format("没有此目录:%s,开始创建=======================================, errorMessage:%s",dirName, e1.getMessage());

LOG.info(message, e1);

channelSftp.mkdir(dirName);

channelSftp.cd(dirPath.toString());

dirPath.append(IOUtils.DIR_SEPARATOR_UNIX);

}

/*dirPath.append(dirName);

mkDirSingleHierarchy(dirPath.toString());

dirPath.append(IOUtils.DIR_SEPARATOR_UNIX);*/

}

} catch (SftpException e) {

String message = String

.format("创建目录:%s时发生I/O异常,请确认与ftp服务器的连接正常,拥有目录创建权限, errorMessage:%s",

directoryPath, e.getMessage());

LOG.error(message, e);

throw DataXException

.asDataXException(

FtpWriterErrorCode.COMMAND_FTP_IO_EXCEPTION,

message, e);

}

}

}

public boolean mkDirSingleHierarchy(String directoryPath) throws SftpException {

boolean isDirExist = false;

try {

SftpATTRS sftpATTRS = this.channelSftp.lstat(directoryPath);

isDirExist = sftpATTRS.isDir();

} catch (SftpException e) {

if(!isDirExist){

LOG.info(String.format("正在逐级创建目录 [%s]",directoryPath));

this.channelSftp.mkdir(directoryPath);

return true;

}

}

if(!isDirExist){

LOG.info(String.format("正在逐级创建目录 [%s]",directoryPath));

this.channelSftp.mkdir(directoryPath);

}

return true;

}

public OutputStream getOutputStream(String filePath) {

try {

this.printWorkingDirectory();

String parentDir = filePath.substring(0,StringUtils.lastIndexOf(filePath, IOUtils.DIR_SEPARATOR_UNIX));

this.channelSftp.cd(parentDir);

this.printWorkingDirectory();

OutputStream writeOutputStream = this.channelSftp.put(filePath,ChannelSftp.APPEND);

if (null == writeOutputStream) {

String message = String.format(

"打开FTP文件[%s]获取写出流时出错,请确认文件%s有权限创建，有权限写出等", filePath,filePath);

throw DataXException.asDataXException(FtpWriterErrorCode.OPEN_FILE_ERROR, message);

}

return writeOutputStream;

} catch (SftpException e) {

String message = String.format(

"写出文件[%s] 时出错,请确认文件%s有权限写出, errorMessage:%s", filePath,filePath, e.getMessage());

LOG.error(message);

throw DataXException.asDataXException(FtpWriterErrorCode.OPEN_FILE_ERROR, message);

}

}

public Long getOutputStream(InputStream in, String filePath) {

try {

this.printWorkingDirectory();

//断点续传

String parentDir = filePath.substring(0,StringUtils.lastIndexOf(filePath, IOUtils.DIR_SEPARATOR_UNIX));

this.channelSftp.cd(parentDir);

this.printWorkingDirectory();

this.channelSftp.put(in, filePath, new MyProgressMonitor(), ChannelSftp.RESUME);

return totalCount;

} catch (SftpException e) {

String message = String.format("写出文件[%s] 时出错,请确认文件%s有权限写出, errorMessage:%s", filePath,filePath, e.getMessage());

LOG.error(message);

throw DataXException.asDataXException(FtpWriterErrorCode.OPEN_FILE_ERROR, message);

}

}

public String getRemoteFileContent(String filePath) {

try {

this.completePendingCommand();

this.printWorkingDirectory();

String parentDir = filePath.substring(0,

StringUtils.lastIndexOf(filePath, IOUtils.DIR_SEPARATOR_UNIX));

this.channelSftp.cd(parentDir);

this.printWorkingDirectory();

ByteArrayOutputStream outputStream = new ByteArrayOutputStream(22);

this.channelSftp.get(filePath, outputStream);

String result = outputStream.toString();

IOUtils.closeQuietly(outputStream);

return result;

} catch (SftpException e) {

String message = String.format(

"写出文件[%s] 时出错,请确认文件%s有权限写出, errorMessage:%s", filePath,

filePath, e.getMessage());

LOG.error(message);

throw DataXException.asDataXException(

FtpWriterErrorCode.OPEN_FILE_ERROR, message);

}

}

public Set getAllFilesInDir(String dir, String prefixFileName) {

Set allFilesWithPointedPrefix = new HashSet();

try {

this.printWorkingDirectory();

@SuppressWarnings("rawtypes")

Vector allFiles = this.channelSftp.ls(dir);

LOG.debug(String.format("ls: %s", JSON.toJSONString(allFiles,

SerializerFeature.UseSingleQuotes)));

for (int i = 0; i < allFiles.size(); i++) {

LsEntry le = (LsEntry) allFiles.get(i);

String strName = le.getFilename();

if (strName.startsWith(prefixFileName)) {

allFilesWithPointedPrefix.add(strName);

}

}

} catch (SftpException e) {

String message = String

.format("获取path:[%s] 下文件列表时发生I/O异常,请确认与ftp服务器的连接正常,拥有目录ls权限, errorMessage:%s",

dir, e.getMessage());

LOG.error(message);

throw DataXException.asDataXException(

FtpWriterErrorCode.COMMAND_FTP_IO_EXCEPTION, message, e);

}

return allFilesWithPointedPrefix;

}

public void deleteFiles(Set filesToDelete) {

String eachFile = null;

try {

this.printWorkingDirectory();

for (String each : filesToDelete) {

LOG.info(String.format("delete file [%s].", each));

eachFile = each;

this.channelSftp.rm(each);

}

} catch (SftpException e) {

String message = String.format(

"删除文件:[%s] 时发生异常,请确认指定文件有删除权限,以及网络交互正常, errorMessage:%s",

eachFile, e.getMessage());

LOG.error(message);

throw DataXException.asDataXException(

FtpWriterErrorCode.COMMAND_FTP_IO_EXCEPTION, message, e);

}

}

private void printWorkingDirectory() {

try {

LOG.info(String.format("current working directory:%s",this.channelSftp.pwd()));

} catch (Exception e) {

LOG.warn(String.format("printWorkingDirectory error:%s",e.getMessage()));

}

}

public void completePendingCommand() {

}

public boolean isDirExist(String directoryPath) {

try {

SftpATTRS sftpATTRS = channelSftp.lstat(directoryPath);

return sftpATTRS.isDir();

} catch (SftpException e) {

return false;

}

}

public boolean isFileExist(String filePath) {

boolean isExitFlag = false;

try {

SftpATTRS sftpATTRS = channelSftp.lstat(filePath);

if(sftpATTRS.getSize() >= 0){

isExitFlag = true;

}

} catch (SftpException e) {

if (e.getMessage().toLowerCase().equals("no such file")) {

String message = String.format("请确认您的配置项path:[%s]存在，且配置的用户有权限读取", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FILE_NOT_EXISTS, message);

} else {

String message = String.format("获取文件：[%s] 属性时发生I/O异常,请确认与ftp服务器的连接正常", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.COMMAND_FTP_IO_EXCEPTION, message, e);

}

}

return isExitFlag;

}

public boolean isSymbolicLink(String filePath) {

try {

SftpATTRS sftpATTRS = channelSftp.lstat(filePath);

return sftpATTRS.isLink();

} catch (SftpException e) {

if (e.getMessage().toLowerCase().equals("no such file")) {

String message = String.format("请确认您的配置项path:[%s]存在，且配置的用户有权限读取", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FILE_NOT_EXISTS, message);

} else {

String message = String.format("获取文件：[%s] 属性时发生I/O异常,请确认与ftp服务器的连接正常", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.COMMAND_FTP_IO_EXCEPTION, message, e);

}

}

}

HashSet sourceFiles = new HashSet();

public HashSet getListFiles(String directoryPath, int parentLevel, int maxTraversalLevel ,String fileSuffix) {

if(parentLevel < maxTraversalLevel){

String parentPath = null;// 父级目录,以'/'结尾

int pathLen = directoryPath.length();

if (directoryPath.contains("*") || directoryPath.contains("?")) {//*和？的限制

// path是正则表达式

String subPath = UnstructuredStorageReaderUtil.getRegexPathParentPath(directoryPath);

if (isDirExist(subPath)) {

parentPath = subPath;

} else {

String message = String.format("不能进入目录：[%s]," + "请确认您的配置项path:[%s]存在，且配置的用户有权限进入", subPath,

directoryPath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FILE_NOT_EXISTS, message);

}

} else if (isDirExist(directoryPath)) {

// path是目录

if (directoryPath.charAt(pathLen - 1) == IOUtils.DIR_SEPARATOR_UNIX) {

parentPath = directoryPath;

} else {

parentPath = directoryPath + IOUtils.DIR_SEPARATOR_UNIX;

}

} else if(isSymbolicLink(directoryPath)){

//path是链接文件

String message = String.format("文件:[%s]是链接文件，当前不支持链接文件的读取", directoryPath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.LINK_FILE, message);

}else if (isFileExist(directoryPath)) {

// path指向具体文件

sourceFiles.add(directoryPath);

return sourceFiles;

} else {

String message = String.format("请确认您的配置项path:[%s]存在，且配置的用户有权限读取", directoryPath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FILE_NOT_EXISTS, message);

}

try {

Vector vector = channelSftp.ls(directoryPath);

for (int i = 0; i < vector.size(); i++) {

LsEntry le = (LsEntry) vector.get(i);

String strName = le.getFilename();

String filePath = parentPath + strName;

if (isDirExist(filePath)) {

// 是子目录

if (!(strName.equals(".") || strName.equals(".."))) {

//递归处理

getListFiles(filePath, parentLevel+1, maxTraversalLevel, fileSuffix);

}

} else if(isSymbolicLink(filePath)){

//是链接文件

String message = String.format("文件:[%s]是链接文件，当前不支持链接文件的读取", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.LINK_FILE, message);

}else if (isFileExist(filePath)) {

// 是文件

//是否有要求的 后缀

if(fileSuffix != null && !fileSuffix.equals("")){

List list = Arrays.asList(fileSuffix.split(","));

list.stream().forEach(l ->{

if(filePath.contains(l)) sourceFiles.add(filePath);

});

}else {

sourceFiles.add(filePath);

}

} else {

String message = String.format("请确认path:[%s]存在，且配置的用户有权限读取", filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.FILE_NOT_EXISTS, message);

}

} // end for vector

} catch (SftpException e) {

String message = String.format("获取path：[%s] 下文件列表时发生I/O异常,请确认与ftp服务器的连接正常", directoryPath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.COMMAND_FTP_IO_EXCEPTION, message, e);

}

return sourceFiles;

}else{

//超出最大递归层数

String message = String.format("获取path：[%s] 下文件列表时超出最大层数,请确认路径[%s]下不存在软连接文件", directoryPath, directoryPath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.OUT_MAX_DIRECTORY_LEVEL, message);

}

}

public InputStream getInputStream(String filePath) {

try {

return channelSftp.get(filePath);

} catch (SftpException e) {

String message = String.format("读取文件 : [%s] 时出错,请确认文件：[%s]存在且配置的用户有权限读取", filePath, filePath);

LOG.error(message);

throw DataXException.asDataXException(FtpReaderErrorCode.OPEN_FILE_ERROR, message);

}

}

public Date lstat(String filePath) {

try {

SftpATTRS attrs = this.channelSftp.lstat(filePath);

Date lastModified = new Date(attrs.getMTime() * 1000L);

return lastModified;

}catch (Exception e){

LOG.error("获取文件"+filePath+"最新修改时间有误:"+e.toString());

}

return null;

}

}

2.MD5的工具类

其中关于字符串的MD5校验功能可以用来解决文件夹的MD5校验

/**

* @ClassName:Md5Utils

* @author:莫须有 (来自网络)

* @Description: 生成文件的MD5校验码

* @create:2020/11/5 11:31

* @Version1.0

*/

import org.apache.commons.codec.digest.DigestUtils;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.io.InputStream;

public class Md5Utils {

/**

* 生成字符串的md5校验值

*

* @param s

* @return

*/

public static String getMD5String(String s) {

return DigestUtils.md5Hex(s);

}

/**

* 判断字符串的md5校验码是否与一个已知的md5码相匹配

*

* @param md5str1 要校验的字符串

* @param md5str2 已知的md5校验码

* @return

*/

public static boolean checkMd5(String md5str1, String md5str2) {

return md5str1.equals(md5str2);

}

/**

* 生成文件的md5校验值

*

* @param file

* @return

* @throws IOException

*/

public static String getFileMD5String(File file) throws IOException {

InputStream fis;

fis = new FileInputStream(file);

String md5=DigestUtils.md5Hex(fis);

fis.close();

return md5;

}

public static String getFileInputStreamMD5String(InputStream fis) throws IOException {

String md5=DigestUtils.md5Hex(fis);

fis.close();

return md5;

}

}

java中md5校验工具,java实现MD5文件校验相关推荐

  1. 《Java并发编程的艺术》——Java中的并发工具类、线程池、Execute框架（笔记）

    文章目录 八.Java中的并发工具类 8.1 等待多线程完成的CountDownLatch 8.2 同步屏障CyclicBarrier 8.2.1 CyclicBarrier简介 8.2.2 Cycl ...

  2. 《Java并发编程的艺术》读后笔记-Java中的并发工具类（第八章）

    文章目录 <Java并发编程的艺术>读后笔记-Java中的并发工具类(第八章) 1.等待多线程完成的CountDownLatch 2.同步屏障CyclicBarrier 2.1 Cycli ...

  3. Java中使用ItextPdf工具根据PDF合同模板填充pdf

    Java中使用itextPdf工具根据PDF合同模板填充内容 设置PDF合同模板的文本域 导入itextPdf的pom依赖 编写生成填充pdf代码 1:设置PDF合同模板的文本域 ​ 设置PDF文本域 ...

  4. java ftp ftpclient_详解JAVA中使用FTPClient工具类上传下载

    详解JAVA中使用FTPClient工具类上传下载 在Java程序中,经常需要和FTP打交道,比如向FTP服务器上传文件.下载文件.本文简单介绍如何利用jakarta commons中的FTPClie ...

  5. Java 中的 XML：Java 文档模型的用法

    Java 中的 XML:Java 文档模型的用法 英文原文 内容: 代码对比 DOM JDOM dom4j Electric XML XPP 结束语 下一次... 参考资料 关于作者 对本文的评价 相 ...

  6. java中如何生成可执行的jar文件

    java中如何生成可执行的jar文件最简单的方法就是:jar -cfe Card.jar CardLayoutDemo CardLayoutDemo$1.class CardLayoutDemo$my ...

  7. 在java中使用JMH（Java Microbenchmark Harness）做性能测试

    文章目录 使用JMH做性能测试 BenchmarkMode Fork和Warmup State和Scope 在java中使用JMH(Java Microbenchmark Harness)做性能测试 ...

  8. java 泛型详解、Java中的泛型方法、 java泛型详解

    本文参考java 泛型详解.Java中的泛型方法. java泛型详解 概述 泛型在java中有很重要的地位,在面向对象编程及各种设计模式中有非常广泛的应用. 什么是泛型?为什么要使用泛型? 泛型,即& ...

  9. java中函数的调用,java中如何调用函数

    java动态调用函数,Java 中使用动态代码,java函数调用,java中如何调用函数 如何在 Java 中调用 C 函数 宗薇 [期刊名称]<网络新媒体技术> [年(卷),期]2000 ...

  10. Java中使用json时java.lang.NoClassDefFoundError: net/sf/ezmorph/Morpher问题解决

    Java中使用json时java.lang.NoClassDefFoundError: net/sf/ezmorph/Morpher问题解决 参考文章: (1)Java中使用json时java.lan ...

最新文章

  1. mongo在哪创建管理员_如何给mongodb管理员权限
  2. Sql sever 分组排序
  3. android 原理 组合控件_Android自定义控件进阶01-自定义控件开发套路与流程
  4. 腾讯产品经理告诉你微信为什么没有用户等级？
  5. 用驴子拖宝马——怎样滥用结构体
  6. hdfs中8031是什么端口号_在宿主机如何访问docker中hadoop的hdfs:ip:9000啊, 端口映射出来啊...
  7. mybatis jar包_springboot2整合mybatis-plus3踩到的坑
  8. 软件研发成本估算过程之估算软件规模概述
  9. 主机数，子网数，网络号，主机号
  10. 【Elasticsearch】 es 排查问题 explain 使用 内容解释
  11. 计算机及相关设备制造业2020,在现实生活中，接近完全垄断市场类型的行业包括（）。A.计算机及相关设备制造业B.稀有金属...
  12. Django面试题汇总
  13. 单独计算机械台班费套什么定额,2017年造价《工程计价》：预算定额中机械台班消耗量的计算...
  14. nginx-proxy-manager在线申请证书
  15. 安装 adobe 软件 photoshop 遇到 81错误 mac
  16. 安卓开机画面_【电视技术】索尼液晶电视开机横线，图像上下跳动技改方案
  17. 贫穷限制了想象：富豪200亿房产当摆设，贫民窟1440人共用一厕所
  18. 【GamePlay】UGUI的注意事项
  19. 全国软件测试培训机构名单已发布
  20. 有些朋友没看清楚，我在这里再特意强调一下

热门文章

  1. 【JavaScript知识点五】javascript 流程语句
  2. JSP-08-第三方控件的使用
  3. [Linux_Ubuntu13] 声音很小前台无法调节的处理方法
  4. 【Android】Android--Dialog
  5. docker网络、bridge、host
  6. ArrayList的动态扩容机制
  7. CSS控制显示超出部分，用省略号显示
  8. mysql 索引优化分析
  9. 散列表碰撞处理、开链法、HashTable散列
  10. 使用DirectShow.NET获取摄像头视频流