[![Build Status](https://travis-ci.org/windoze/fibio.svg?branch=master)](https://travis-ci.org/windoze/fibio)
Fiberized.IO
============
Fiberized.IO is a fast and simple networking framework without compromises.
* <B>Fast</B><BR/>Asynchronous I/O under the hood for maximum speed and throughtput.
* <B>Simple</B><BR/>Fiber based programming model for concise and intuitive development.
* <B>No compromises</B><BR/>Standard C++ thread and iostream compatible API, old-fashion programs just work more efficiently.
Read the [Wiki](https://github.com/windoze/fibio/wiki) for manuals and references
The echo server example
-----------------------
```
#include <fibio/fiberize.hpp>
#include <fibio/iostream.hpp>
using namespace fibio;
int fibio::main(int argc, char *argv[]) {
return tcp_listener(7)([](tcp_stream &s){
s << s.rdbuf();
}).value();
}
```
The HTTP server example
-----------------------
```
#include <fibio/fiberize.hpp>
#include <fibio/http_server.hpp>
using namespace fibio::http;
int fibio::main(int argc, char *argv[]) {
return server(23456).handler(
route(
path_("/add/:x/:y")>>[](double x, double y){return x+y;}
)
).run().value();
}
```
没有合适的资源?快使用搜索试试~ 我知道了~
温馨提示
Flink 基于事件的消息驱动流处理引擎,对于每条消息都会触发一次全流程的处理,因此在与外部存储系统交互时,对于每条消息都需要一次外部请求,对于性能的损耗较大,严重制约了flink的吞吐量。 Flink 1.2中引入了Async IO(异步IO)来加快flink与外部系统的交互性能,提升吞吐量。[FLIP-12: Asynchronous I/O Design and Implementation]。 其设计的核心是对原有的每条处理后的消息发送至下游operator的执行流程进行改进。其核心实现是引入了一个AsyncWaitOperator,在其processElement/processWatermark方法中完成对消息的处理。其执行流程是: 将每条消息封装成一个StreamRecordQueueEntry(其实现了ResultFuture),放入StreamElementQueue中 消息与外部系统交互的逻辑放入AsynInvoke方法中,将交互执行结果放入StreamRecordQueueEntry中
资源推荐
资源详情
资源评论
收起资源包目录
Fiberized.IO 是一个基于 Fiber 和 Async IO 的通用 C++ 网络库.rar (132个子文件)
.clang-format 2KB
FindMySQLConnectorCPP.cmake 2KB
FindThrift.cmake 2KB
fibio-config.cmake 677B
client.cpp 36KB
database_metadata.cpp 34KB
common.cpp 32KB
test_http_server.cpp 25KB
server.cpp 22KB
fiber_object.cpp 20KB
mutex.cpp 11KB
client.cpp 11KB
test_future.cpp 10KB
resultset.cpp 7KB
connection.cpp 7KB
prepared_statement.cpp 6KB
websocket_echo.cpp 6KB
test_cookie.cpp 5KB
echo_server.cpp 5KB
condition.cpp 5KB
test_fibers.cpp 5KB
redis_proto.cpp 5KB
scheduler_object.cpp 4KB
test_redis_client.cpp 4KB
statement.cpp 3KB
test_mysql_client.cpp 3KB
test_ssl_stream.cpp 3KB
driver.cpp 3KB
test_mutex.cpp 2KB
test_http_client.cpp 2KB
test_redis_proto.cpp 2KB
test_thrift.cpp 2KB
test_tcp_stream.cpp 2KB
test_asio.cpp 2KB
test_cv.cpp 1KB
future.cpp 1KB
test_cq.cpp 1KB
test_fss.cpp 784B
test_fstream.cpp 685B
stream.cpp 638B
.gitignore 223B
valgrind.h 340KB
http_parser_merged.h 76KB
future.hpp 41KB
json.hpp 35KB
fstream.hpp 35KB
promise.hpp 28KB
restful.hpp 22KB
shared_state.hpp 21KB
shared_mutex.hpp 20KB
client.hpp 19KB
mustache.hpp 18KB
concurrent_queue.hpp 18KB
database_metadata.hpp 16KB
routing.hpp 13KB
chunked_stream.hpp 12KB
iostream.hpp 12KB
websocket.hpp 12KB
fiber.hpp 10KB
streambuf.hpp 8KB
redis_proto.hpp 8KB
client.hpp 8KB
thrift.hpp 7KB
async.hpp 7KB
condition_variable.hpp 7KB
utility.hpp 7KB
barrier.hpp 6KB
exceptions.hpp 6KB
fiberize.hpp 6KB
use_future.hpp 5KB
mutex.hpp 5KB
fiber_object.hpp 5KB
url_codec.hpp 4KB
yield.hpp 4KB
fss.hpp 4KB
connection.hpp 4KB
resultset.hpp 4KB
common_types.hpp 4KB
packaged_task.hpp 4KB
prepared_statement.hpp 3KB
fiber_group.hpp 3KB
ssl.hpp 3KB
server.hpp 3KB
response.hpp 3KB
url_parser.hpp 3KB
task_object.hpp 2KB
request.hpp 2KB
statement.hpp 2KB
cookie.hpp 2KB
request.hpp 2KB
fiber_base.hpp 2KB
fiber_data.hpp 2KB
string_pred.hpp 2KB
mustache_template.hpp 2KB
use_future.hpp 2KB
driver.hpp 1KB
scheduler_object.hpp 1KB
response.hpp 1KB
yield.hpp 1KB
shared_state_object.hpp 1KB
共 132 条
- 1
- 2
资源评论
野生的狒狒
- 粉丝: 3393
- 资源: 2436
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功