免责申明：文章中的工具等仅供个人测试研究，请在下载后24小时内删除，不得用于商业或非法用途，否则后果自负0x00 漏洞介绍S2-046漏洞和S2-045漏洞非常相似，都是由报错信息带入了buildErrorMessage这个方法造成的。 但是这次存在两个触发点。Content-Length 的长度值超长Content-Disposition的filename存在空字节0x01 漏洞分析Content-Length 的长度值超长这个漏洞需要在strust.xml中加入才能触发。触发漏洞的代码在 JakartaStreamMultiPartRequest类中，processUpload函数处理了content-length长度超长的异常，导致问题触发。private void processUpload(HttpServletRequest request, String saveDir) throws Exception { // Sanity check that the request is a multi-part/form-data request. if (ServletFileUpload.isMultipartContent(request)) { // Sanity check on request size. ...继续阅读 (44)

免责申明：文章中的工具等仅供个人测试研究，请在下载后24小时内删除，不得用于商业或非法用途，否则后果自负0x00 漏洞介绍S2-046漏洞和S2-045漏洞非常相似，都是由报错信息带入了buildErrorMessage这个方法造成的。 但是这次存在两个触发点。Content-Length 的长度值超长Content-Disposition的filename存在空字节0x01 漏洞分析Content-Length 的长度值超长这个漏洞需要在strust.xml中加入才能触发。触发漏洞的代码在 JakartaStreamMultiPartRequest类中，processUpload函数处理了content-length长度超长的异常，导致问题触发。private void processUpload(HttpServletRequest request, String saveDir) throws Exception { // Sanity check that the request is a multi-part/form-data request. if (ServletFileUpload.isMultipartContent(request)) { // Sanity check on request size. ...继续阅读 (33)

欢迎来我的博客阅读：《Gulp 基础与原理》Gulp 概述Gulp 是基于 NodeJS 的项目，一个用作自动化构建的工具，业界一般用来建造前端的工作流。它的核心原理其实很简单，最主要是通过各种 Transform Stream 来实现文件的处理，然后再进行输出。Transform Streams 是 NodeJS Stream 的一种，是可读又可写的，它会对传给它的对象做一些转换的操作。文件输入 → Gulp 插件处理 → 文件输出原则上，gulp 可以针对文件做任何有趣、有创造力事情。而自动化构建，只是大家主要比较喜欢使用的方向。Gulp 的特点：自动化- Gulp 为你的工作流而服务，自动运行那些费事费力任务。平台透明- Gulp 被集成到各种 IDE 中，并且除了 NodeJS 之外，其他如 PHP、.NET、Java 平台都可以使用 Gulp。强大生态系统- 你可以使用 npm 上 2000+ 的插件来构造你的工作流。简单- Gulp 只提供几个 API，这可以很快地学习和上手。使用 Gulp安装$ npm install gulp-cli -g // 全局安装 Gulp 命令行工具 $ npm install gulp -D // 在项目中，作为 devDependencies 依赖安装 gulpGulpfile.js在使用 CLI 工具的时候，会执行该文件，它是一个 ...继续阅读 (11)

_http_outgoing.js:541 if (this.finished) { ^TypeError: Cannot read property ‘finished’ of undefined at OutgoingMessage.end (_http_outgoing.js:541:11) at ServerResponse.res.end (E:/code/first/sense/server/lib/apply-express-middleware.js:7:19) at ReadStream.onend (_stream_readable.js:490:10) at ReadStream.g (events.js:260:16) at emitNone (events.js:72:20) at ReadStream.emit (events.js:166:7) at endReadableNT (_stream_readable.js:905:12) at doNTCallback2 (node.js:450:9) at process._tickDomainCallback (node.js:405:17) [nodemon] app crashed - waiting for file changes before starting… ...继续阅读 (11)

第一部分我们已经完成了表情包链接的获取，接下来我们开始批量下载表情包到本地。下载表情包到本地观察表情包地址我们发现表情包后面22位就是它完整且唯一的文件名。我们首先判断本地是否存在这个文件，如果存在则跳过下载，如果不存在， 我们就创建一个可写的文件stream,然后请求表情包地址，并pipe到stream, 监听close事件，触发时完成Promise。function downloadMeMe (url) { console.log(`下载: ${url}`); let filePath = `./memes/${url.substr(-22)}`; // 取到后22位作为文件名 let stream = fs.createWriteStream(filePath); // 创建一个可写 stream 对象 // 请求表情包地址，并 pipe 到刚才创建的 stream 对象 request.get(url).pipe(stream); }限流器假设我们打开表情包页面，他会同时请求一整页的表情包，所以我们只需要限制批量请求之间的间隔就好。 写个限流器，控制单次请求数，访问频率过快 ...继续阅读 (1)

本书第六章的读书笔记，也是我这个系列的最后一篇读书笔记。后面7、8、9章分别讲的“测试、调试与重构”、“设计和架构的原则”以及“使用Lambda表达式编写并发程序”，因为笔记不好整理，就不写了，感兴趣的同学自己买书来看吧。并行化流操作关于并行与并发的区别和并行的重要性的讨论这里不做笔记了，直接看Stream类库提供了哪些关于并行的操作把。如果已经有了一个Stream对象，可以调用parallel方法使其拥有并行操作的能力；如果想从一个集合类创建一个Stream对象，可以调用parallelStream方法获得一个拥有并行能力的流。BaseStream提供的sequential方法将会按顺序遍历Stream中的元素对于同一个Stream对象，如果parallel方法和sequential方法都被调用，最后调用的那个方法将起效，不能同时处于两种模式。使用并行流，不需要写代码用于处理调度和等待线程池中的某项任务完成，这些工作都交由类库完成。限制编写并行流，存在一些与非并行流不一样的约定。reduce方法的限制初值必须为组合函数的恒等值使用恒等值与其他值做reduce运算时，其他值保持不变。比如，使用reduce进行求和运算时，初值必须为0，而进行求积运算时，初值必须为1reduce操作必须符合结合律因为并行计算时，元素的遍历顺序是不确定的，所以只有符合结合律才能保证结果是确定的。避免持有 ...继续阅读 (15)

摘自：villainhrWebRTC 全称为：Web Real-Time Communication。它是为了解决 Web 端无法捕获音视频的能力，并且提供了 peer-to-peer（就是浏览器间）的视频交互。实际上，细分看来，它包含三个部分：MediaStream:捕获音视频流RTCPeerConnection:传输音视频流（一般用在 peer-to-peer 的场景）RTCDataChannel: 用来上传音视频二进制数据（一般用到流的上传）但通常，peer-to-peer 的场景实际上应用不大。对比与去年火起来的直播业务，这应该才是 WebRTC 常常应用到的地方。那么对应于 Web 直播来说，我们通常需要两个端：主播端：录制并上传视频观众端：下载并观看视频这里，我就不谈观众端了，后面另写一篇文章介绍（因为，这是在是太多了）。这里，主要谈一下会用到 WebRTC 的主播端。简化一下，主播端应用技术简单可以分为：录制视频，上传视频。大家先记住这两个目标，后面我们会通过 WebRTC 来实现这两个目标。WebRTC 基本了解WebRTC 主要由两个组织来制定。Web Real-Time Communications (WEBRTC) W3C 组织：定义浏览器 APIReal-Time Communication in Web-browsers (RTCWEB) IETF 标准 ...继续阅读 (14)

最近被这个内存泄漏的问题折腾死了，根据GIT上面event-stream的文档稍微改动了一下代码。主要原因是存放cities的源文件信息量比较大，可读流中存放了大量的数据而用来写入数据的commit速度跟不上，导致内存爆满，希望能通过pause来解决，但是调试了很久发现貌似流一开始就是按时序执行的，pause并没有起作用，运行时占用内存还是持续飙升最后溢出然后程序终止。。不知道pause究竟要怎么用，还是node新手，求大神们指点一下！！谢谢var _ = require('underscore') var es = require('event-stream') var fs = require('fs') var events = require('events') var fibrous = require('fibrous') var config = require('../config.js') var db = require('../common/db.js') // var mysql = require('./common/mysql.js&# ...继续阅读 (14)

Stream是我在 2016 年中旬完成的一个业余项目，它希望提供一个基于发布、订阅模型的消息服务，提供 HTTP API 并传输结构化的数据（JSON）。适用的场景就是自动化工具间的通讯（例如两个运行在 NAT 内的脚本需要交换数据）、自动化脚本需要推送数据给人阅读（人可以在 Web UI 上阅读消息）。还更进一步希望能够提供移动平台的客户端，对于已经订阅的消息实现实时的推送，不过这个部分并没有完成。其实也是因为这个项目被搁置了很久，在最近我也发现了一些和 Stream 非常相似的服务（getstream.io），所以才将这个半成品发布了出来。目前 Stream 的 Web UI 可以发布、以时间轴查看消息、按照标签检索消息；HTTP API（文档位于Stream API Reference）还提供了注册和登录帐号的功能，登录帐号后发出的消息会包含你的用户名作为特殊的标签。当然，就像我其他的业余项目一样，Stream 其实更多地是在实践一些新的技术，比如基于 React 的双端渲染、React Native、RAML、Docker Swarm 等等。 ...继续阅读 (3)

Stream是我在 2016 年中旬完成的一个业余项目，它希望提供一个基于发布、订阅模型的消息服务，提供 HTTP API 并传输结构化的数据（JSON）。适用的场景就是自动化工具间的通讯（例如两个运行在 NAT 内的脚本需要交换数据）、自动化脚本需要推送数据给人阅读（人可以在 Web UI 上阅读消息）。还更进一步希望能够提供移动平台的客户端，对于已经订阅的消息实现实时的推送，不过这个部分并没有完成。其实也是因为这个项目被搁置了很久，在最近我也发现了一些和 Stream 非常相似的服务（getstream.io），所以才将这个半成品发布了出来。目前 Stream 的 Web UI 可以发布、以时间轴查看消息、按照标签检索消息；HTTP API（文档位于Stream API Reference）还提供了注册和登录帐号的功能，登录帐号后发出的消息会包含你的用户名作为特殊的标签。当然，就像我的其他的业余项目一样，其实更多地是在实践一些新的技术，比如基于 React 的双端渲染、React Native、RAML、Docker Swarm 等等。 ...继续阅读 (6)

有时会碰到向db查询大量记录，需要边接收边处理的场景。mysql模块提供了一个流式查询的方法streaming query rows。 如果需要每收到一条记录就写入到http response中，如何处理接收过程中可能产生的错误呢？此时response head已经发出200，且已经正常发送了部分数据，当query发生错误时，如何通知客户端发生了错误？ 代码如下：const pool = require('mysql').createPool(...); const http = require('http'); http.createServer((req, res)=> { response.statusCode = 200; let sql = 'SELECT * FROM tb1'; let query = pool.query(sql); query .on('result', (row)=> { res.write(JSON.stringify(row)); }) .on('error', (err)=> { res.end(); // 如何handle中途可能产生的error？ }) .on ...继续阅读 (14)

Shadow Stream Pro 是 macOS 平台上的一款实时文件备份工具，同时还能支持版本控制，当你的文件或者文档被修改或保存的时候，它就会将新版本的文件自动备份到指定的位置或者云空间上，而且你还可以选择进行加密保存。 软件可以监控文件或文件夹的变化，可以随意设置需要备份的文件夹，支持 iCloud D……[马上前往围观....]异次元正版数字商城  |  异次元首页  |  iPc.me  |  新浪微博  |  软件精选 ...继续阅读 (28)

Shadow Stream Pro是一款文件实时备份工具，同时还支持版本控制，当你的文件或者文档被更改保存时，它会自动将新版本备份到指定的位置或者云空间上，还可以进行加密保存。下载地址： 来自反斗限免您可能也喜欢：Shadow Stream Pro - 文件实时备份工具[OS X][￥18→0]Shadow Stream Pro - 文件实时备份工具[OS X][￥128→0]AOMEI Backupper Pro – 系统备份还原软件[Windows][$39.95→0]Poster Maker Pro - 海报制作工具[macOS][￥30→0]Cyberlink PowerBackup - 连讯文件备份软件[Windows][$39.95→0]无觅 ...继续阅读 (11)

背景平时在编写前端代码时，习惯使用lodash来编写‘野生’的JavaScript;lodash提供来一套完整的API对JS对象（Array,Object,Collection等）进行操作，这其中就包括_.groupBy 和 _.reduce，即分组和'聚合'（reduce不知道该怎么翻译合适）。使用这些‘野生’的API能够极大的提高我本人编写JS代码的效率。而JAVA8开始支持stream和lambda表达式，这些和lodash的API有很多类似的功能。因此我在熟悉lodash的前提下尝试使用JAVA8的新特性减少冗余代码的编写。需求在开发后端某功能接口的过程中，需要对一个从数据库中取出的数据List<T>进行按照ID进行聚合统计JAVA8 reduce APIAPI个人理解<U> U reduce(U u,BiFunction<U,? super T,U> accumulator,BinaryOperator<U> combiner) #第一个参数返回实例u，传递你要返回的U类型对象的初始化实例u #第二个参数累加器accumulator，可以使用二元ℷ表达式（即二元lambda表达式），声明你在u上累加你的数据来源t的逻辑 #例如(u,t)->u.sum(t),此时lambda表达式的行参列表是返回实例u和遍 ...继续阅读 (19)

转载请注明出处：https://zhuanlan.zhihu.com/p/20540202Stream作为Java8的新特性之一，他与Java IO包中的InputStream和OutputStream完全不是一个概念。Java8中的Stream是对集合功能的一种增强，主要用于对集合对象进行各种非常便利高效的聚合和大批量数据的操作。结合Lambda表达式可以极大的提高开发效率和代码可读性。假设我们需要把一个集合中的所有形状设置成红色，那么我们可以这样写for (Shape shape : shapes){ shape.setColor(RED) }如果使用Java8扩展后的集合框架则可以这样写：shapes.foreach(s -> s.setColor(RED));__第一种__写法我们叫外部迭代，for-each调用shapes的iterator()依次遍历集合中的元素。这种外部迭代有一些问题：for循环是串行的，而且必须按照集合中元素的顺序依次进行；集合框架无法对控制流进行优化，例如通过排序、并行、短路求值以及惰性求值改善性能。上面这两个问题我们会在后面的文章中逐步解答。__第二种__写法我们叫内部迭代，两段代码虽然看起来只是语法上的区别，但实际上他们内部的区别其实非常大。用户把对操作的控制权交还给类库，从而允许类库进行各种各样的优化（例如乱序执行、惰性求值和并 ...继续阅读 (17)

前言本文受启发于Trisha Gee在JavaOne 2016的主题演讲Refactoring to Java 8。Java 8已经发行两年多，但很多人仍然在使用JDK7。对企业来说，技术上谨慎未必是坏事，但对个人学习而言，不去学习新技术就很可能被技术抛弃。Java 8一个重要的变更是引入Lambda表达式(lambda expression)，这听起来似乎很牛，有种我虽然不知道Lambda表达式是什么，但我仍然觉得很厉害的感觉。不要怕，具体到语言层面上Lambda表达式不过是一种新的语法而已，有了它，Java将开启函数式编程的大门。为什么需要Lambda表达式不要纠结什么是Lambda表达式、什么是函数式编程。先来看一下Java 8新的语法特性带来的便利之处，相信你会过目不忘的。在有Lambda表达式之前，要新建一个线程，需要这样写：new Thread(new Runnable(){ @Override public void run(){ System.out.println("Thread run()"); } }).start();有Lambda表达式之后，则可以这样写：new Thread( () -> System.out.println("Thread run()") ).start();正如你所见，之前 ...继续阅读 (11)

var http = require('http'); var fs = require('fs'); var server = http.createServer(function (req, res) { var stream = fs.createReadStream(__dirname + '/data.txt'); stream.pipe(res); }); server.listen(8000);这段代码是在stream-handbook中摘取的，带有下面这句解释：now the data.txt file will be written to clients one chunk at a time immediately as they are received from the disk.我的疑问是：response在接收到每一个小chunk之后，会立即发往客户端吗？不是在response.end时候才一起发往客户端的吗？ 如果是前者，那浏览器会怎么处理这些小chunk，会跟bigpipe的处理方式一样吗？ ...继续阅读 (8)

现在浏览器里面很大一部分网页还在使用HTTP1.1作为主要的网络通信协议。 但,这傻逼协议是1999年弄出来的. 距今已经有xx年了, 这些年里,美国的IETF 觉得这样不行.我得出来拯救世界了, 在Chrome的倡导下, 借用Chrome的SPDY 来做为HTTP2的前身,即, HTTP2 是SPDY/3 draft的优优化版.那,HTTP2 为什么要出现,又解决了HTTP1.1不能解决的什么事情呢？简而言之就是H2是一个二进制协议而,H1是超文本协议.传输的内容都不是一样的H2遵循多路复用即,代替同一host下的内容,只建立一次连接. H1不是(傻逼)H2可以使用HPACK进行头部的压缩,H1则不论什么请求都会发送H2允许服务器,预先将网页所需要的资源PUSH到浏览器的内存当中.接下来,我们来看看,H2到底有哪些具体的featureHTTP2的features首先介绍一下,HTTP2为什么是一种二进制的协议.HTTP2 binary说道H2的二进制,首先得介绍一下H1的超文本协议.HTTP1.1每次在发送请求时,都需要找出 开头和结尾的每一帧的位置, 并且,在写入的时候,还需要删除多余的空格,以及选择最优的方式写入, 并且如果是HTTP+TLS的话,那性能损耗就比较呵呵了,因为TLS本身的握手协议,以及加密的方式,在一定程度上会对文本信息的内容进行处理等等. 这些无疑都给HTT ...继续阅读 (39)

最近在spark-stream上写了一些流计算处理程序，程序架构如下程序运行在Spark-stream上，我的目标是kafka、Redis的参数都支持在启动时指定。在写代码时参考了这篇文章https://www.iteblog.com/archi...，该文讲的比较清楚，但是有两个问题：用scala实现的Redis服务器的地址是写死的，我的程序要挪个位置，要重新改代码编译。当时倒腾了一些时间，现在写出来和大家分享，提高后来者的效率。如上图Spark是分布式引擎，Driver中创建的Redis Pool，在Worker上又得重新创建，参考文章中是定义一个Redis连接池管理类，Redis Pool是类的静态变量，类加载时由JVM自动创建。这个和我的预期有差距。在Driver中创建Redis管理对象，然后将该对象广播，然后在Worker上获取该广播对象，从而实现参数可变，但是Redis管理对象在每个Worker上又只实例化了一次。DriverDriver 指定序列化方式，Spark支持两种序列化方式，Java 和 Kryo，Kryo更高效。资料上说Kryo方式需要注册类，但是我没有注册也能成功运行。public static void main(String[] args) { if (args.length < 3) { System.e ...继续阅读 (67)

Manager处理session请求是通过_Dispatcher_Session_Handler这个函数（./api/dispatcher.pb.go）：func _Dispatcher_Session_Handler(srv interface{}, stream grpc.ServerStream) error { m := new(SessionRequest) if err := stream.RecvMsg(m); err != nil { return err } return srv.(DispatcherServer).Session(m, &dispatcherSessionServer{stream}) }实际函数调用栈如下：0 0x0000000000b65cbf in github.com/docker/swarmkit/manager/dispatcher.(*Dispatcher).Session at /go/src/github.com/docker/swarmkit/manager/dispatcher/dispatcher.go:768 1 0x0000000000782aa5 in github.com/docker/swarmkit/api.(*authenticatedWra ...继续阅读 (74)

使用Collectors.toMap方法时的两个问题：1、当key重复时，会抛出异常：java.lang.IllegalStateException: Duplicate key **2、当value为null时，会抛出异常：java.lang.NullPointerException首先这个不是JDK的bug，只是不符合我们的预期。大家通常希望这个方法是可以容错的，遇到重复的key就使用后者替换，而且HashMap的value可以是null。下面举个小例子。首先是元素类Emp：public class Emp { private Integer id; private String name; public Emp(Integer id, String name) { super(); this.id = id; this.name = name; System.out.println(this); } public Integer getId() { return id; } public String getName() { return name; } @Override public String toString() { return "id: " + id + ", name: " + name; } } ...继续阅读 (37)

Stream for YouTube是一款第三方 YouTube 视频播放器，能够屏蔽页面上的广告，拥有三种播放模式，支持窗口置顶，基本上都实现了所有网页版能够实现的功能（毕竟是壳）。软件是由收费模式变成免费 + 内购了。下载地址： 来自反斗限免您可能也喜欢：Tuba for YouTube - YouTube 桌面播放器Miniplayer for Youtube – 迷你 Youtube 播放器[OS X]Miniplayer for Youtube – 迷你 Youtube 播放器Miniplayer for Youtube - 迷你 Youtube 播放器Airy YouTube Downloader – 网络视频下载软件[Windows][$0.99→0]无觅 ...继续阅读 (39)

原文链接：http://morning.work/page/2016-07/readable-stream-and-log-files-processing-in-nodejs.html在上一篇文章《如何实时监听文件的新增内容：一个简单 tailf 命令的实现》里面，我们已经实现了一个tailf函数用来监听文件的新增内容，看起来它也工作良好。然而当我想把它应用到手头正要做的日志文件处理时，却发现这样一个非标准的接口很难与之前编写的模块愉快地合作。我在去年的文章《在 Node.js 中读写大文件》中实现了一个readLine(stream)函数，其接收的参数是一个Readable Stream对象，能按照给定的规则（比如使用\n换行）来emit出每一行的内容，再结合tailf来监听文件的新增内容，我们就可以很轻易地对新增的内容进行按行切分。所以，我们要实现一个实现了Readable Stream接口的tailf，在本文中我给它起了个名字叫TailStream。关于 Readable StreamNode.js 的stream模块提供了四种形式的流，分别适用于不同的场景：适用场景Class需要实现的方法只读Readable_read只写Writable_write,_writev读写Duplex_read,_write,_writev处理写入的数据供读取Transform_transf ...继续阅读 (25)

接上文《深度学习主机环境配置: Ubuntu16.04+Nvidia GTX 1080+CUDA8.0》，我们继续来安装TensorFlow，使其支持GeForce GTX 1080显卡。1 下载和安装cuDNNcuDNN全称 CUDA Deep Neural Network library，是NVIDIA专门针对深度神经网络设计的一套GPU计算加速库，被广泛用于各种深度学习框架，例如Caffe, TensorFlow, Theano, Torch, CNTK等。The NVIDIA CUDA® Deep Neural Network library (cuDNN) is a GPU-accelerated library of primitives for deep neural networks. cuDNN provides highly tuned implementations for standard routines such as forward and backward convolution, pooling, normalization, and activation layers. cuDNN is part of the NVIDIA Deep Learning SDK.Deep learning researchers and framework dev ...继续阅读 (267)

接上文《深度学习主机环境配置: Ubuntu16.04+Nvidia GTX 1080+CUDA8.0》，我们继续来安装TensorFlow，使其支持GeForce GTX 1080显卡。1 下载和安装cuDNNcuDNN全称 CUDA Deep Neural Network library，是NVIDIA专门针对深度神经网络设计的一套GPU计算加速库，被广泛用于各种深度学习框架，例如Caffe, TensorFlow, Theano, Torch, CNTK等。The NVIDIA CUDA® Deep Neural Network library (cuDNN) is a GPU-accelerated library of primitives for deep neural networks. cuDNN provides highly tuned implementations for standard routines such as forward and backward convolution, pooling, normalization, and activation layers. cuDNN is part of the NVIDIA Deep Learning SDK.Deep learning researchers and framework dev ...继续阅读 (157)

¶用 Node 实现异步 I/ONode 是基于 C++ 的调整 JavaScript 解释器，绑定了用于进程、文件和网络套接字等底层 Unix API，还绑定了 HTTP 客户端和服务器 API。除了一些专门命名的同步方法外，Node 的绑定是异步的，且 Node 程序默认绝不阻塞，这意味着它们通过具备强大的可伸缩能力并能有效地处理高负荷。由于 API 是异步的，因此 Node 依赖事件处理程序，其通常使用嵌套函数和闭包来实现moreNode 在其全局对象中实现了所有标准的 ECMAScript 5 构造函数、属性和函数。除此之外，它也支持客户端講器函数集 setTimeout(), setInterval()Node 在 process 名字空间中定义了其它重要的全局属性：process.version// Node 的版本字符串信息process.argv// 'node' 命令行数组参数，argv[0] 是 "node"process.pid// 进程 idprocess.getuid()// 返回用户 idprocess.cwd()// 返回当前的工作目录process.chdir()// 改变当目录process.exit()// 退出在有的情况下，可以使用 Node 的事件机制。Node 对象产生事件（称为事件触发器(event emitter)），定义 on() 方 ...继续阅读 (8)

ffmpeg学习4--ffmpeg类的简单封装，包含解码和定时录像功能       参考网上的资料，简单封装了一下ffmpeg，这里记录一下，其它传感器编码及项目中用到的已经抽离，这里只包含解码和录像部分。这只是个玩具级别的测试。完整测试代码下载：代码下载   ffmpegDeCode.h   #pragma once#include "stdafx.h"#include<iostream>using namespace std;extern char *VideoPath;extern int CameraIndex;extern int fps;extern "C"{#include "libavcodec/avcodec.h"#include "libavformat/avformat.h"#include "libswscale/swscale.h"#include <libavdevice/avdevice.h>};class ffmpegDeCode{public:ffmpegDeCode();~ffmpegDeCode();bool DecoderInit(const ...继续阅读 (39)

本文翻译自《JAVA开发指南》第三章本章中，你将学习到怎样使用Stream API进行开发。首先，你将会了解Stream API背后的机制，什么是流以及流的用处。其次，你将学习到一系列的流式操作、流式数据处理模型以及能让你写出更复杂数据查询的流式集合操作。接下来是如何应用流式操作的例子。最后，你将学习到并行流。为什么需要流式操作集合API是Java API中最重要的部分。基本上每一个java程序都离不开集合。尽管很重要，但是现有的集合处理在很多方面都无法满足需要。一个原因是，许多其他的语言或者类库以声明的方式来处理特定的数据模型，比如SQL语言，你可以从表中查询，按条件过滤数据，并且以某种形式将数据分组，而不必需要了解查询是如何实现的——数据库帮你做所有的脏活。这样做的好处是你的代码很简洁。很遗憾，Java没有这种好东西，你需要用控制流程自己实现所有数据查询的底层的细节。其次是你如何有效地处理包含大量数据的集合。理想情况下，为了加快处理过程，你会利用多核架构。但是并发程序不太好写，而且很容易出错。Stream API很好的解决了这两个问题。它抽象出一种叫做流的东西让你以声明的方式处理数据，更重要的是，它还实现了多线程：帮你处理底层诸如线程、锁、条件变量、易变变量等等。例如，假定你需要过滤出一沓发票找出哪些跟特定消费者相关的，以金额大小排列，再取出这些发票的ID。如果用Stream ...继续阅读 (33)

文章目录C-style file input/outputC-style file input/output - cppreference.comhttp://en.cppreference.com/w/cpp/io/cC-style file input/outputC-style I/OThe C I/O subsetof the C++ standard library implementsC-style stream input/outputoperations. The<cstdio>header providesgeneric file operation supportand supplies functions withnarrow and multibyte character（窄字符或多字节字符）input/output capabilities, and the<cwchar>header provides functions withwide character input/output capabilities.C streamsare objects of typestd::FILEthatcan only beaccessed and manipulated through pointers of type std::FILE* ...继续阅读 (31)

Full support for TypeScript and multiple stream librariesToday we are releasing Cycle Diversity, the next big version of Cycle.js, after months of continuous development. The highlights of this release are:Support formultiple stream libraries:RxJS v4,RxJS v5,most.js,xstreamxstreamis a stream library custom built for Cycle.jsRewritten entirely inTypeScript, so all type definitions are accurate and up-to-dateCycle DOM rewritten inSnabbdom: faster performance, better lifecycle hooks API, smaller kB footprintCycle DOM isolation rewritten, does not depend anymore on classNamesCycle HTTP has a bette ...继续阅读 (18)