• Echo RPC在接收到请求时，向下游发起一次http请求
• 对下游请求完成后，我们将http response的body信息填充到response的message里，回复给客户端
• 我们不希望阻塞/占据着Handler的线程，所以对下游的请求一定是一次异步请求
• 首先，我们通过Workflow框架的工厂创建一个异步任务http_task
• 然后，我们利用RPCContext的ctx->get_series()获取到ServerTask所在的SeriesWork
• 最后，我们使用SeriesWork的push_back接口将http_task放到SeriesWork的后面

Client

下面我们通过一个具体例子来呈现

• 我们并行发出两个请求，1个是rpc请求，1个是http请求
• 两个请求都结束后，我们再发起一次计算任务，计算两个数的平方和
• 首先，我们通过RPC Client的create_Echo_task创建一个rpc异步请求的网络任务rpc_task
• 然后，我们通过Workflow框架的工厂WFTaskFactory::create_http_task和WFTaskFactory::create_go_task分别创建异步网络任务http_task，和异步计算任务calc_task
• 最后，我们利用串并联流程图，乘号代表并行、大于号代表串行，将3个异步任务组合起来执行start

void calc(int x, int y)
{
    int z = x * x + y * y;
    printf("calc result: %d\n", z);
}
int main()
{
    Example::SRPCClient client("127.0.0.1", 1412);
        if (ctx->success())
            printf("%s\n", response->DebugString().c_str());
        else
            printf("status[%d] error[%d] errmsg:%s\n",
                    ctx->get_status_code(), ctx->get_error(), ctx->get_errmsg());
    });
    auto *http_task = WFTaskFactory::create_http_task("https://www.sogou.com", 0, 0, [](WFHttpTask *task) {
        if (task->get_state() == WFT_STATE_SUCCESS)
        {
            std::string body;
            const void *data;
            size_t len;
            body.assign((const char *)data, len);
        }
        else
            printf("Http request fail\n\n");
    });
    auto *calc_task = WFTaskFactory::create_go_task(calc, 3, 4);
    EchoRequest req;
    req.set_message("Hello, sogou rpc!");
    req.set_name("1412");
    rpc_task->serialize_input(&req);
    ((*http_task * rpc_task) > calc_task).start();
    pause();
    return 0;