什么是响应式编程？
用一个字来概括就是流(Stream)。Stream 就是一个按时间排序的 Events 序列,它可以放射三种不同的 Events：(某种类型的)Value、Error 或者一个” Completed” Signal。通过分别为 Value、Error、”Completed”定义事件处理函数，我们将会异步地捕获这些 Events。基于观察者模式，事件流将从上往下，从订阅源传递到观察者。
至于使用Rx框架的优点，它可以避免回调嵌套，更优雅地切换线程实现异步处理数据。配合一些操作符，可以让处理事件流的代码更加简洁，逻辑更加清晰。
android 中的Rxjava
在Android 应用最广泛的就是RXjava了。基于RxJava Retrofit OkHttp 构成了Android 网络的 网络访问的三板斧。
RxCpp
RxCpp 是 ReactiveX 的 C++ 语言实现。C11 提供了丰富的现代语言特性，使Ｃ++ 不再是面向对象的Ｃ。
这些特性也为RxCpp 的开发提供了便利。
https://github.com/ReactiveX/RxCpp.git
{ // Creating
auto observableCreate = observable<>::create<int>(
[](subscriber<int> s) {
s.on_next(1);
s.on_next(2);
s.on_completed();
});
observableCreate.subscribe(
[](int v) { printf("OnNext: %d\n", v); },
[]() { printf("create OnCompleted\n"); });
}
{ // Converting
std::array<int, 3> a = {{1, 2, 3}};
auto values1 = observable<>::iterate(a);
values1.subscribe(
[](int v) { printf("OnNext: %d\n", v); },
[]() { printf("iterate OnCompleted\n"); });
}
结果：
OnNext: 1
OnNext: 2
create OnCompleted
OnNext: 1
OnNext: 2
OnNext: 3
iterate OnCompleted
cpprestsdk
Android 基于Retrofit OKhttp Gson 很容易实现RESTfull 风格的客户端。
微软提供了轮子
cpprestsdk
https://github.com/Microsoft/cpprestsdk
一个简单的例子，大大简化了网络访问请求。
但是 不支持Mutipart Post 请求。
int BingTest::main() {
auto fileStream = std::make_shared<ostream>();
// Open stream to output file.
pplx::task<void> requestTask = fstream::open_ostream(U("results.html"))
.then([=](ostream outFile) {
*fileStream = outFile;
// Create http_client to send the request.
http_client client(U("http://www.bing.com/"));
// Build request URI and start the request.
uri_builder builder(U("/search"));
builder.append_query(U("q"), U("cpprestsdk github"));
return client.request(methods::GET, builder.to_string());
})
.then([=](http_response response) {
printf("Received response status code:%u\n", response.status_code());
// Write response body into the file.
return response.body().read_to_end(fileStream->streambuf());
})
.then([=](size_t) {
return fileStream->close();
});
// Wait for all the outstanding I/O to complete and handle any exceptions
try {
requestTask.wait();
}
catch (const std::exception &e) {
printf("Error exception:%s\n", e.what());
}
return 0;
}
nlohmann JSON
https://github.com/nlohmann/json
nlohmann 在数据的访问上很方便，但是没有类似Java 那样的POJO 工具。写起来类也是很累的。
另外一个坑是不支持 value 为null.
RxCppRestfull 框架
定义 GithubUser
struct GithubUser {
std::string login;
int id;
std::string node_id;
std::string avatar_url;
...
}
void to_json(json& j, const GithubUser& p);
void from_json(const json& j, GithubUser& p);
创建observable
observable<T> getObject(const string_t &path_query_fragment) {
return observable<>::create<T>(
[&](subscriber<T> s){
client
.request(methods::GET, path_query_fragment)
.then([](http_response response) -> pplx::task<string_t> {
return response.extract_string();
})
.then([&](pplx::task<string_t> previousTask) {
try {
string_t const & v = previousTask.get();
std::cout << v << std::endl;
json j = json::parse(v);
T t = j;
s.on_next(t);
s.on_completed();
} catch (http_exception const & e) {
s.on_error(std::current_exception());
}
})
.wait();
});
}
subscribe
RestApi<GithubUser> apiGithub(U("https://api.github.com/"));
apiGithub.getObject(U("/users/octocat")).subscribe([](const GithubUser& v){cout << v << endl;});
