目录

1.回顾

2.主函数书写

3.框架设计

3.1 mprpcapplication.h

 3.2 rpcprovider.h

3.3 mprpcapplication.cc

3.4 mprpcprovider.cc

---

1.回顾

mprpc框架怎么用？

在上一节，我们完成了如何把本地服务发布成RPC服务。
我们打开example下callee下的userservice.cc

#include <iostream>
#include <string>
#include "user.pb.h"

/*
UserService原来是一个本地服务，提供了两个进程内的本地方法，Login和GetFriendLists
*/
class UserService:public fixbug::UserServiceRpc//使用在rpc服务发布端（rpc服务提供者）
{
public:
    bool Login(std::string name,std::string pwd)
    {
        std::cout<<"doing local service:Login"<<std::endl;
        std::cout<<"name:"<<name<<" pwd:"<<pwd<<std::endl;
        return true;
    }

    /*
    重写基类UserServiceRpc的虚函数  下面这些方法都是框架直接调用的
    1.caller  ===>  Login(LoginRequest) =>muduo =>  callee
    2.callee  ===>  Login(LoginRequest) =>交到下面重写的这个Login方法上了
    */
    void Login(::google::protobuf::RpcController *controller,
                               const ::fixbug::LoginRequest * request,
                               ::fixbug::LoginResponse * response,
                               ::google::protobuf::Closure *done)
    {
        //框架给业务上报了请求参数LoginRequest,应用获取相应数据做本地业务
        std::string name = request->name();
        std::string pwd = request->pwd();

        //做本地业务
        bool login_result=Login(name,pwd);

        //把响应写入  包括错误码、错误消息、返回值
        fixbug::ResultCode* code=response->mutable_result();
        code->set_errcode(0);
        code->set_errmsg("");
        response->set_success(login_result);

        //执行回调操作   执行响应对象数据的序列化和网络发送（都是由框架来完成的）
        done->Run();
    }
};

2.主函数书写

我们现在书写主函数

我们希望实现后的mprpc框架，可以这么使用：

int main(int argc,char **argv)
{
    //调用框架初始化操作
    MprpcApplication::Init(argc,argv);

    //provider是一个rpc网络服务对象。把UserService对象发布到rpc节点上
    RpcProvider provider;
    provider.NotifyService(new UserService());

    //启动一个rpc服务发布节点  Run以后，进程进入阻塞状态，等待远程的rpc调用请求
    provider.Run();
    return 0;
}

可以调用多次，生成多个远程RPC服务

如果可以这么使用的话，想把本地业务变成远程服务就很简单了：定义proto文件，继承UserServiceRpc类，然后重写方法，打4套动作(上报请求并从中取数据、做本地业务、填写响应、执行回调)。就OK了。
然后要发布服务，就初始化框架，定义一个可以发布服务的对象，在这个对象上发布服务。provider是一个rpc网络的服务对象。把UserService对象发布到rpc节点上。Run以后，进程进入阻塞状态，等待远程的rpc调用请求。

我们接下来将往这个方向去设计框架

3.框架设计

我们实现框架的代码存放在src中，我们在src下再创一个文件夹：include；用来存放头文件。

3.1 mprpcapplication.h

在include下创建头文件：mprpcapplication.h

#pragma once

//mprpc框架的基础类，负责框架的一些初始化操作
class MprpcApplication
{
public:
    static void Init(int argc,char** argv);//初始化
    //单例模式
    static MprpcApplication& GetInstance()//定义获取唯一实例的方法
    {
        static MprpcApplication app;
        return app;
    }
private:
    MprpcApplication(){}//构造函数
    MprpcApplication(const MprpcApplication&)=delete;//将与拷贝构造有关的函数delete
    MprpcApplication(MprpcApplication&&) = delete;
};

 3.2 rpcprovider.h

RpcProvider是一个网络的服务对象，要做到高并发，使用muduo库实现。 我们再定义一个头文件：rpcprovider.h

#pragma once
#include "google/protobuf/service.h"

//框架提供的专门发布rpc服务的网络对象类
class RpcProvider
{
public:
    //这里是框架提供给外部使用的，可以发布rpc方法的函数接口
    void NotifyService(google::protobuf::Service* service){}//具体的服务对象类是从Service类继承而来
    //框架是可以接收各种RPC服务的，不能依赖具体的某一个业务。 
    //基类指针指向子对象 

    //启动rpc服务节点，开始提供rpc远程网络调用服务
    void Run();
};

我们把这2个头文件写到userservice.cc

接下来我们在src下创建
mprpcprovider.cc
mprpcapplication.cc

3.3 mprpcapplication.cc

#include "mprpcapplication.h"

void MprpcApplication::Init(int argc, char **argv) // 初始化
{
    
}
// 单例模式
MprpcApplication &MprpcApplication::GetInstance() // 定义获取唯一实例的方法
{
    static MprpcApplication app;
    return app;
}

3.4 mprpcprovider.cc

#include "rpcprovider.h"

//这里是框架提供给外部使用的，可以发布rpc方法的函数接口
void RpcProvider::NotifyService(google::protobuf::Service *service) 
{

}

// 启动rpc服务节点，开始提供rpc远程网络调用服务
void RpcProvider::Run()
{

}