server.cpp 2.78 KB
Newer Older
gejun's avatar
gejun committed
1
// Copyright (c) 2018 brpc authors.
zyearn's avatar
zyearn committed
2 3 4 5 6 7 8 9 10 11 12 13 14
//
// Licensed 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.

15 16 17
// A server to receive HelloRequest and send back HelloReply
//
// Authors: Jiashun Zhu(zhujiashun@bilibili.com)
zyearn's avatar
zyearn committed
18 19 20 21 22 23 24

#include <gflags/gflags.h>
#include <butil/logging.h>
#include <brpc/server.h>
#include <brpc/restful.h>
#include "helloworld.pb.h"

25
DEFINE_int32(port, 50051, "TCP Port of this server");
zyearn's avatar
zyearn committed
26 27 28 29
DEFINE_int32(idle_timeout_s, -1, "Connection will be closed if there is no "
             "read/write operations during the last `idle_timeout_s'");
DEFINE_int32(logoff_ms, 2000, "Maximum duration of server's LOGOFF state "
             "(waiting for client to close connection before server stops)");
30
DEFINE_bool(gzip, false, "compress body using gzip");
zyearn's avatar
zyearn committed
31

32
class GreeterImpl : public helloworld::Greeter {
zyearn's avatar
zyearn committed
33
public:
34 35
    GreeterImpl() {};
    virtual ~GreeterImpl() {};
zyearn's avatar
zyearn committed
36
    void SayHello(google::protobuf::RpcController* cntl_base,
37 38
                 const helloworld::HelloRequest* req,
                 helloworld::HelloReply* res,
zyearn's avatar
zyearn committed
39 40 41
                 google::protobuf::Closure* done) {
        brpc::ClosureGuard done_guard(done);
        brpc::Controller* cntl = static_cast<brpc::Controller*>(cntl_base);
42 43 44
        if (FLAGS_gzip) {
            cntl->set_response_compress_type(brpc::COMPRESS_TYPE_GZIP);
        }
45
        res->set_message("Hello " + req->name());
zyearn's avatar
zyearn committed
46 47 48 49 50 51 52 53 54 55
    }
};

int main(int argc, char* argv[]) {
    // Parse gflags. We recommend you to use gflags as well.
    GFLAGS_NS::ParseCommandLineFlags(&argc, &argv, true);

    // Generally you only need one Server.
    brpc::Server server;

56
    GreeterImpl http_svc;
zyearn's avatar
zyearn committed
57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78

    // Add services into server. Notice the second parameter, because the
    // service is put on stack, we don't want server to delete it, otherwise
    // use brpc::SERVER_OWNS_SERVICE.
    if (server.AddService(&http_svc,
                          brpc::SERVER_DOESNT_OWN_SERVICE) != 0) {
        LOG(ERROR) << "Fail to add http_svc";
        return -1;
    }

    // Start the server.
    brpc::ServerOptions options;
    options.idle_timeout_sec = FLAGS_idle_timeout_s;
    if (server.Start(FLAGS_port, &options) != 0) {
        LOG(ERROR) << "Fail to start HttpServer";
        return -1;
    }

    // Wait until Ctrl-C is pressed, then Stop() and Join() the server.
    server.RunUntilAskedToQuit();
    return 0;
}