87 lines
3.2 KiB
C++
87 lines
3.2 KiB
C++
// Licensed to the Apache Software Foundation (ASF) under one
|
|
// or more contributor license agreements. See the NOTICE file
|
|
// distributed with this work for additional information
|
|
// regarding copyright ownership. The ASF licenses this file
|
|
// to you under the Apache License, Version 2.0 (the
|
|
// "License"); you may not use this file except in compliance
|
|
// with the License. You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing,
|
|
// software distributed under the License is distributed on an
|
|
// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
|
// KIND, either express or implied. See the License for the
|
|
// specific language governing permissions and limitations
|
|
// under the License.
|
|
|
|
// - Access pb services via HTTP
|
|
// ./http_client http://www.foo.com:8765/EchoService/Echo -d '{"message":"hello"}'
|
|
// - Access builtin services
|
|
// ./http_client http://www.foo.com:8765/vars/rpc_server*
|
|
// - Access www.foo.com
|
|
// ./http_client www.foo.com
|
|
|
|
#include <gflags/gflags.h>
|
|
#include <butil/logging.h>
|
|
#include <brpc/channel.h>
|
|
|
|
DEFINE_string(d, "", "POST this data to the http server");
|
|
DEFINE_string(load_balancer, "", "The algorithm for load balancing");
|
|
DEFINE_int32(timeout_ms, 2000, "RPC timeout in milliseconds");
|
|
DEFINE_int32(max_retry, 3, "Max retries(not including the first RPC)");
|
|
DEFINE_string(protocol, "http", "Client-side protocol");
|
|
|
|
namespace brpc {
|
|
DECLARE_bool(http_verbose);
|
|
}
|
|
|
|
int main(int argc, char* argv[]) {
|
|
// Parse gflags. We recommend you to use gflags as well.
|
|
GFLAGS_NS::ParseCommandLineFlags(&argc, &argv, true);
|
|
|
|
if (argc != 2) {
|
|
LOG(ERROR) << "Usage: ./http_client \"http(s)://www.foo.com\"";
|
|
return -1;
|
|
}
|
|
char* url = argv[1];
|
|
|
|
// A Channel represents a communication line to a Server. Notice that
|
|
// Channel is thread-safe and can be shared by all threads in your program.
|
|
brpc::Channel channel;
|
|
brpc::ChannelOptions options;
|
|
options.protocol = FLAGS_protocol;
|
|
options.timeout_ms = FLAGS_timeout_ms/*milliseconds*/;
|
|
options.max_retry = FLAGS_max_retry;
|
|
|
|
// Initialize the channel, NULL means using default options.
|
|
// options, see `brpc/channel.h'.
|
|
if (channel.Init(url, FLAGS_load_balancer.c_str(), &options) != 0) {
|
|
LOG(ERROR) << "Fail to initialize channel";
|
|
return -1;
|
|
}
|
|
|
|
// We will receive response synchronously, safe to put variables
|
|
// on stack.
|
|
brpc::Controller cntl;
|
|
|
|
cntl.http_request().uri() = url;
|
|
if (!FLAGS_d.empty()) {
|
|
cntl.http_request().set_method(brpc::HTTP_METHOD_POST);
|
|
cntl.request_attachment().append(FLAGS_d);
|
|
}
|
|
|
|
// Because `done'(last parameter) is NULL, this function waits until
|
|
// the response comes back or error occurs(including timedout).
|
|
channel.CallMethod(NULL, &cntl, NULL, NULL, NULL);
|
|
if (cntl.Failed()) {
|
|
std::cerr << cntl.ErrorText() << std::endl;
|
|
return -1;
|
|
}
|
|
// If -http_verbose is on, brpc already prints the response to stderr.
|
|
if (!brpc::FLAGS_http_verbose) {
|
|
std::cout << cntl.response_attachment() << std::endl;
|
|
}
|
|
return 0;
|
|
}
|