21ic电子技术开发论坛 › 个人版区 › 贝贝的实验室 › 关于fdbus：一个更完整的实例
返回列表 发新帖我要提问

关于fdbus：一个更完整的实例

[复制链接]
 楼主| keer_zu 发表于 2022-9-16 18:18 | 显示全部楼层 |阅读模式
US, se, ST, Group, server, TE
fdbus普通client-server示例及接口说明

一、server
1.FDServer.h

复制
  1. #pragma once
    

  2. #include<fdbus/fdbus.h>
    

  3. #include<fdbus/CBaseServer.h>
    

  4. using namespace ipc::fdbus;
    

  5.  
    

  6. class FDServer : public CBaseServer
    

  7. {
    

  8. public:
    

  9.         enum EGroupId
    

  10.         {
    

  11.                 GROUP_MASTER,
    

  12.                 GROUP_1
    

  13.         };
    

  14.         enum EMessageId
    

  15.         {
    

  16.                 NTF_CJSON_TEST = 128,
    

  17.                 NTF_GROUP_TEST1 = fdbMakeEventCode(GROUP_1, 0),
    

  18.                 NTF_GROUP_TEST2 = fdbMakeEventCode(GROUP_1, 1),
    

  19.                 NTF_GROUP_TEST3 = fdbMakeEventCode(GROUP_1, 2)
    

  20.         };
    

  21.         static CBaseWorker main_worker;
    

  22.         FDServer(const char* name, CBaseWorker *worker = 0);
    

  23.         ~FDServer();
    

  24.  
    

  25.         void broadcastElapseTime(CMethodLoopTimer<FDServer> *timer);
    

  26.  
    

  27. protected:
    

  28.         virtual void onOnline(const CFdbOnlineInfo &info);
    

  29.         virtual void onOffline(const CFdbOnlineInfo &info);
    

  30.         virtual void onInvoke(CBaseJob::Ptr &msg_ref);
    

  31.         virtual void onSubscribe(CBaseJob::Ptr &msg_ref);
    

  32.  
    

  33. private:
    

  34.         CMethodLoopTimer<FDServer>* mTimer;
    

  35. };
    

  36.  
    

  37. class CBroadcastTimer : public CMethodLoopTimer<FDServer>
    

  38. {
    

  39. public:
    

  40.         CBroadcastTimer(FDServer *server);
    

  41. };
回复 赏

举报

相关帖子
 楼主| keer_zu 发表于 2022-9-16 18:22 | 显示全部楼层
2.FDServer.cpp
复制
  1. #include "FDServer.h"
    

  2. #include<fdbus/CFdbProtoMsgBuilder.h>
    

  3. #include<fdbus/CFdbCJsonMsgBuilder.h>
    

  4. #include<iostream>
    

  5. #include<fdbus/cJSON/cJSON.h>
    

  6. #include"TempleMsg.pb.h"
    

  7. #include"CFdbIfPerson.h"
    

  8. CBaseWorker FDServer::main_worker;
    

  9. FDServer::FDServer(const char * name, CBaseWorker * worker)
    

  10.         : CBaseServer(name, worker)
    

  11. {
    

  12.         mTimer = new CBroadcastTimer(this);
    

  13.         mTimer->attach(&main_worker, false);
    

  14. }
    

  15.  
    

  16. FDServer::~FDServer()
    

  17. {
    

  18. }
    

  19.  
    

  20. /**server主动推送消息给订阅过该消息的客户端**/
    

  21. void FDServer::broadcastElapseTime(CMethodLoopTimer<FDServer>* timer)
    

  22. {
    

  23.         std::cout << __FUNCTION__ << std::endl;
    

  24.         NFdbTemple::ElapseTime eTime;
    

  25.         eTime.set_hour(1);
    

  26.         eTime.set_minute(20);
    

  27.         eTime.set_second(45);
    

  28.  
    

  29.         CFdbProtoMsgBuilder builder(eTime);
    

  30.         /*当消息ID和字符串都匹配时，客户端才对其做出响应，客户端接收消息无先后顺序*/
    

  31.         broadcast(NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME, builder, "my_filter");
    

  32.  
    

  33.         char raw_data[256];
    

  34.         memset(raw_data, '=', sizeof(raw_data));
    

  35.         /*向客户端主动推送广播消息*/
    

  36.         broadcast(NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME, raw_data, 256, "raw_buffer");
    

  37.  
    

  38.         cJSON *f = cJSON_CreateObject();
    

  39.         cJSON_AddNumberToObject(f, "birthday", 199900101);
    

  40.         cJSON_AddNumberToObject(f, "id", 1);
    

  41.         cJSON_AddStringToObject(f, "name", "sofia");
    

  42.         CFdbCJsonMsgBuilder builder1(f);
    

  43.         broadcast(NTF_CJSON_TEST, builder1);
    

  44.         cJSON_Delete(f);
    

  45.  
    

  46.         broadcast(NTF_GROUP_TEST1);
    

  47.         broadcast(NTF_GROUP_TEST2);
    

  48.         broadcast(NTF_GROUP_TEST3);
    

  49. }
    

  50.  
    

  51. /*客户端连接服务器时，响应该函数*/
    

  52. void FDServer::onOnline(const CFdbOnlineInfo & info)
    

  53. {
    

  54.         FDB_LOG_I("server session: %d, secure: %d\n", info.mSid, info.mQOS);
    

  55.         if (info.mFirstOrLast)
    

  56.         {
    

  57.                 FDB_LOG_I("time enabled\n");
    

  58.                 mTimer->enable();
    

  59.         }
    

  60.         std::cout << __FUNCTION__ << std::endl;
    

  61. }
    

  62.  
    

  63. /*客户端关闭时，响应该函数*/
    

  64. void FDServer::onOffline(const CFdbOnlineInfo & info)
    

  65. {
    

  66.         FDB_LOG_I("server session off: %d, secure: %d\n", info.mSid, info.mQOS);
    

  67.         if (info.mFirstOrLast)
    

  68.         {
    

  69.                 mTimer->disable();
    

  70.         }
    

  71.         std::cout << "server session off: " << info.mSid << ",secure: " << info.mQOS << std::endl;
    

  72.         std::cout << __FUNCTION__ << std::endl;
    

  73. }
    

  74.  
    

  75. /*接收并处理客户端invoke请求*/
    

  76. void FDServer::onInvoke(CBaseJob::Ptr & msg_ref)
    

  77. {
    

  78.         auto msg = castToMessage<CBaseMessage *>(msg_ref);
    

  79.  
    

  80.         static int32_t elapse_time = 0;
    

  81.         std::cout << "msg->code():" << msg->code() << std::endl;
    

  82.  
    

  83.         switch (msg->code())
    

  84.         {
    

  85.         case NFdbTemple::FdbMediaSvcMsgId::REQ_METADATA:
    

  86.         {
    

  87.                 NFdbTemple::SongId song_id;
    

  88.                 CFdbProtoMsgParser parser(song_id);
    

  89.                 if (!msg->deserialize(parser))
    

  90.                 {
    

  91.                         msg->status(msg_ref, FDB_ST_MSG_DECODE_FAIL, "fail to decode");
    

  92.                         std::cout << "REQ_METADATA song_id fail to decode\n" << std::endl;
    

  93.                         return;
    

  94.                 }
    

  95.  
    

  96.                 std::cout << "request song id:" << song_id.id() << ",sender: " << msg->senderName().c_str() << std::endl;
    

  97.                 
    

  98.                 NFdbTemple::NowPlayingDetails req_msg;
    

  99.                 req_msg.set_artist("Liu Dehua");
    

  100.                 req_msg.set_album("Ten Year's Golden Song");
    

  101.                 req_msg.set_genre("County");
    

  102.                 req_msg.set_title("Wang Qing Shui");
    

  103.                 req_msg.set_file_name("Lau Dewa");
    

  104.                 req_msg.set_elapse_time(elapse_time++);
    

  105.                 CFdbProtoMsgBuilder builder(req_msg);
    

  106.                 msg->reply(msg_ref, builder);
    

  107.         }
    

  108.         break;
    

  109.         case NFdbTemple::FdbMediaSvcMsgId::REQ_RAWDATA:
    

  110.         {
    

  111.                 int32_t size = msg->getPayloadSize();
    

  112.                 std::cout << "size:" << size << " sender:" << msg->senderName().c_str();
    

  113.                 CFdbParcelableArray<CPerson> persions;
    

  114.                 CPerson *p = persions.Add();
    

  115.                 p->mAddress = "Shanghai";
    

  116.                 p->mAge = 22;
    

  117.                 p->mName = "Zhang San";
    

  118.                 CCar *c = p->mCars.Add();
    

  119.                 c->mBrand = "Hongqi";
    

  120.                 c->mModel = "H5";
    

  121.                 c->mPrice = 400000;
    

  122.  
    

  123.                 c = p->mCars.Add();
    

  124.                 c->mBrand = "POWER";
    

  125.                 c->mModel = "X5";
    

  126.                 c->mPrice = 200000;
    

  127.  
    

  128.                 for (int32_t i = 0; i < 5; ++i)
    

  129.                 {
    

  130.                         CFdbByteArray<20> *arr = p->mPrivateInfo.Add();
    

  131.                         for (int32_t j = 0; i < arr->size(); ++j)
    

  132.                         {
    

  133.                                 arr->vbuffer()[j] = j;
    

  134.                         }
    

  135.                 }
    

  136.  
    

  137.                 p = persions.Add();
    

  138.                 p->mAddress = "Guangzhou";
    

  139.                 p->mAge = 32;
    

  140.                 p->mName = "Li si";
    

  141.                 c = p->mCars.Add();
    

  142.                 c->mBrand = "Chuanqi";
    

  143.                 c->mModel = "H5";
    

  144.                 c->mPrice = 400000;
    

  145.  
    

  146.                 c = p->mCars.Add();
    

  147.                 c->mBrand = "Toyoto";
    

  148.                 c->mModel = "X5";
    

  149.                 c->mPrice = 200000;
    

  150.  
    

  151.                 for (int32_t i = 0; i < 8; ++i)
    

  152.                 {
    

  153.                         CFdbByteArray<20> *arr = p->mPrivateInfo.Add();
    

  154.                         for (int32_t j = 0; j < arr->size(); ++j)
    

  155.                         {
    

  156.                                 arr->vbuffer()[j] = j + 10;
    

  157.                         }
    

  158.                 }
    

  159.  
    

  160.                 CFdbParcelableBuilder builder(persions);
    

  161.                 msg->reply(msg_ref, builder);
    

  162.         }
    

  163.         break;
    

  164.         default:
    

  165.                 break;
    

  166.         }
    

  167. }
    

  168.  
    

  169. /*当client注册消息时，server通过该回调函数获知，将初始值返回给客户端*/
    

  170. void FDServer::onSubscribe(CBaseJob::Ptr & msg_ref)
    

  171. {
    

  172.         auto msg = castToMessage<CBaseMessage *>(msg_ref);
    

  173.         const CFdbMsgSubscribeItem *sub_item;
    

  174.         FDB_BEGIN_FOREACH_SIGNAL(msg, sub_item)
    

  175.         {
    

  176.                 FdbMsgCode_t msg_code = sub_item->msg_code();
    

  177.                 const char* filter = "";
    

  178.                 if (sub_item->has_filter())
    

  179.                 {
    

  180.                         filter = sub_item->filter().c_str();
    

  181.                         std::cout << filter << std::endl;
    

  182.                 }
    

  183.  
    

  184.                 FdbSessionId_t sid = msg->session();
    

  185.  
    

  186.                 if (fdbIsGroup(msg_code))
    

  187.                 {
    

  188.                         FDB_LOG_I("group message: %d, filter: %s of session %d is registered! sender: %s\n\n",
    

  189.                                 msg_code, filter, sid, msg->senderName().c_str());
    

  190.                         /*广播消息给客户端*/
    

  191.                         msg->broadcast(NTF_GROUP_TEST1);
    

  192.                         msg->broadcast(NTF_GROUP_TEST2);
    

  193.                         msg->broadcast(NTF_GROUP_TEST3);
    

  194.                         return;
    

  195.                 }
    

  196.  
    

  197.                 FDB_LOG_I("single message:%d, filter %s of session %d is registered! sender: %s\n\n",
    

  198.                         msg_code, filter, sid, msg->senderName().c_str());
    

  199.  
    

  200.                 switch (msg_code)
    

  201.                 {
    

  202.                 case NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME:
    

  203.                 {
    

  204.                         std::string str_filter(filter);
    

  205.                         if (!str_filter.compare("my_filter"))
    

  206.                         {
    

  207.                                 NFdbTemple::ElapseTime eTime;
    

  208.                                 eTime.set_hour(1);
    

  209.                                 eTime.set_hour(20);
    

  210.                                 eTime.set_hour(30);
    

  211.                                 CFdbProtoMsgBuilder builder(eTime);
    

  212.                                 /*广播消息给客户端*/
    

  213.                                 msg->broadcast(msg_code, builder, filter);
    

  214.                         }
    

  215.                         else
    

  216.                         {
    

  217.                                 std::cout << "it's not the elapse time!" << std::endl;
    

  218.                         }
    

  219.                 }
    

  220.                 default:
    

  221.                         break;
    

  222.                 }
    

  223.         }
    

  224.         FDB_END_FOREACH_SIGNAL()
    

  225. }
    

  226.  
    

  227. /*周期性地广播消息给客户端，周期为1500ms*/
    

  228. CBroadcastTimer::CBroadcastTimer(FDServer *server)
    

  229.         :CMethodLoopTimer<FDServer>(1500, true, server, &FDServer::broadcastElapseTime)
    

  230. {}
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-16 18:22 | 显示全部楼层
3.main.cpp
复制
  1. #include"FDServer.h"
    

  2. #include<iostream>
    

  3. int main(int argc, char** argv)
    

  4. {
    

  5.         FDB_CONTEXT->start();
    

  6.         FDServer::main_worker.start();
    

  7.         //for (int i = 1; i < argc; ++i)
    

  8.         //{
    

  9.         /*在Name Server中存在一个名为server_name的服务器，客户端通过server_name连接服务器*/
    

  10.                 std::string server_name = "myService";
    

  11.                 std::string url(FDB_URL_SVC);
    

  12.                 url += server_name;
    

  13.                 server_name += "_server";
    

  14.                 auto server = new FDServer(server_name.c_str(), &FDServer::main_worker);
    

  15.                 server->enableWatchdog(true);
    

  16.                 server->enableUDP(true);
    

  17.                 server->setExportableLevel(FDB_EXPORTABLE_SITE);
    

  18.                 server->bind(url.c_str());
    

  19.         //}
    

  20.                 std::cout << url << std::endl;
    

  21.                 std::cout << server_name << std::endl;
    

  22.         CBaseWorker background_worker;
    

  23.         background_worker.start(FDB_WORKER_EXE_IN_PLACE);
    

  24.         return 0;
    

  25. }
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-16 18:23 | 显示全部楼层
二、客户端
1.FDClient.h
复制
  1. #pragma once
    

  2. #include<fdbus/fdbus.h>
    

  3. #include<fdbus/CFdbProtoMsgBuilder.h>
    

  4. #include<fdbus/cJSON/cJSON.h>
    

  5. #include<fdbus/CFdbCJsonMsgBuilder.h>
    

  6.  
    

  7. using namespace ipc::fdbus;
    

  8. class FDClient;
    

  9. class CInvokeTimer : public CMethodLoopTimer<FDClient>
    

  10. {
    

  11. public:
    

  12.         CInvokeTimer(FDClient *client);
    

  13. };
    

  14.  
    

  15. class FDClient : public CBaseClient
    

  16. {
    

  17. public:
    

  18.         enum EGroupId
    

  19.         {
    

  20.                 GROUP_MASTER,
    

  21.                 GROUP_1
    

  22.         };
    

  23.         enum EMessageId
    

  24.         {
    

  25.                 NTF_CJSON_TEST = 128,
    

  26.                 NTF_GROUP_TEST1 = fdbMakeEventCode(GROUP_1, 0),
    

  27.                 NTF_GROUP_TEST2 = fdbMakeEventCode(GROUP_1, 1),
    

  28.                 NTF_GROUP_TEST3 = fdbMakeEventCode(GROUP_1, 2)
    

  29.         };
    

  30.         static CBaseWorker main_worker;
    

  31.         FDClient(const char *name, CBaseWorker *worker = 0);
    

  32.         void callServer(CMethodLoopTimer<FDClient> *timer);
    

  33.         ~FDClient();
    

  34.  
    

  35. protected:
    

  36.         void onOnline(const CFdbOnlineInfo &info);
    

  37.         void onOffline(const CFdbOnlineInfo &info);
    

  38.         void onBroadcast(CBaseJob::Ptr &msg_ref);
    

  39.         void onKickDog(CBaseJob::Ptr &msg_ref);
    

  40.         void onReply(CBaseJob::Ptr &msg_ref);
    

  41.         void onStatus(CBaseJob::Ptr &msg_ref, int32_t error_code, const char *description);
    

  42.         void printMetadata(FdbObjectId_t obj_id, const CFdbMsgMetadata *metadata);
    

  43.  
    

  44. private:
    

  45.         CInvokeTimer *mTimer;
    

  46. };
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-16 18:23 | 显示全部楼层
2.FDClient.cpp
复制
  1. #include "FDClient.h"
    

  2. #include"TempleMsg.pb.h"
    

  3. #include"CFdbIfPerson.h"
    

  4.  
    

  5. CBaseWorker FDClient::main_worker;
    

  6. FDClient::FDClient(const char * name, CBaseWorker * worker)
    

  7.         : CBaseClient(name, worker)
    

  8. {
    

  9.         mTimer = new CInvokeTimer(this);
    

  10.         mTimer->attach(&main_worker, false);
    

  11. }
    

  12.  
    

  13. /*向服务器发送请求*/
    

  14. void FDClient::callServer(CMethodLoopTimer<FDClient>* timer)
    

  15. {
    

  16.         FDB_LOG_I("****this is client : %s\n", __FUNCTION__);
    

  17.         NFdbTemple::SongId song_id;
    

  18.         song_id.set_id(1234);
    

  19.         CFdbProtoMsgBuilder builder(song_id);
    

  20.  
    

  21.         CBaseJob::Ptr ref(new CBaseMessage(NFdbTemple::FdbMediaSvcMsgId::REQ_METADATA));
    

  22.         invoke(ref, builder);/*发送至服务器*/
    

  23.  
    

  24.         auto msg = castToMessage<CBaseMessage*>(ref);
    

  25.         printMetadata(objId(), msg->metadata());
    

  26.  
    

  27.         if (msg->isStatus())
    

  28.         {
    

  29.                 int32_t id;
    

  30.                 std::string reason;
    

  31.                 if (!msg->decodeStatus(id, reason))
    

  32.                 {
    

  33.                         FDB_LOG_E("onReply:fail to decode status\n");
    

  34.                         return;
    

  35.                 }
    

  36.                 FDB_LOG_I("sync reply: status is received: msg code: %d, id: %d, reason: %s\n",
    

  37.                         msg->code(), id, reason.c_str());
    

  38.                 return;
    

  39.         }
    

  40.  
    

  41.         NFdbTemple::NowPlayingDetails now_playing;
    

  42.         CFdbProtoMsgParser parser(now_playing);
    

  43.         if (msg->deserialize(parser))
    

  44.         {
    

  45.                 auto artist = now_playing.artist().c_str();
    

  46.                 auto album = now_playing.album().c_str();
    

  47.                 auto genre = now_playing.genre().c_str();
    

  48.                 auto title = now_playing.title().c_str();
    

  49.                 auto file_name = "";
    

  50.                 if (now_playing.has_file_name())
    

  51.                 {
    

  52.                         file_name = now_playing.file_name().c_str();
    

  53.                 }
    

  54.                 auto folder_name = "";
    

  55.                 if (now_playing.has_folder_name())
    

  56.                 {
    

  57.                         folder_name = now_playing.folder_name().c_str();
    

  58.                 }
    

  59.                 int32_t elapse_time = now_playing.elapse_time();
    

  60.                 std::cout << artist << album << genre << title << file_name << folder_name << elapse_time << std::endl;
    

  61.         }
    

  62.         else
    

  63.         {
    

  64.                 FDB_LOG_I("Error! Unable to decode message!!!\n");
    

  65.         }
    

  66.         invoke(NFdbTemple::FdbMediaSvcMsgId::REQ_METADATA);
    

  67. }
    

  68.  
    

  69. FDClient::~FDClient()
    

  70. {
    

  71. }
    

  72.  
    

  73. /*客户端连接服务器时响应*/
    

  74. void FDClient::onOnline(const CFdbOnlineInfo & info)
    

  75. {
    

  76.         FDB_LOG_I("client session online: %d, secure: %d\n", info.mSid, info.mQOS);
    

  77.         mTimer->enable();
    

  78.  
    

  79.         CFdbMsgSubscribeList subscribe_list;
    

  80.         /*订阅服务器主动推送的广播消息，消息ID与字符串要求和服务器的广播消息保持一致*/
    

  81.         subscribe_list.addNotifyItem(NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME, "my_filter");
    

  82.         subscribe_list.addNotifyItem(NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME, "raw_buffer");
    

  83.         subscribe_list.addNotifyItem(NTF_CJSON_TEST);
    

  84.         subscribe_list.addNotifyGroup(GROUP_1);
    

  85.         subscribe(subscribe_list, 0, info.mQOS);/*注册广播消息，注册完成系统自动回复*/
    

  86. }
    

  87.  
    

  88. /*客户端断开时响应*/
    

  89. void FDClient::onOffline(const CFdbOnlineInfo & info)
    

  90. {
    

  91.         FDB_LOG_I("client session off:%d, secure:%d\n", info.mSid, info.mQOS);
    

  92.         if (info.mFirstOrLast)
    

  93.         {
    

  94.                 mTimer->disable();
    

  95.         }
    

  96. }
    

  97. /*收到服务器主动推送的广播消息*/
    

  98. void FDClient::onBroadcast(CBaseJob::Ptr & msg_ref)
    

  99. {
    

  100.         auto msg = castToMessage<CBaseMessage*>(msg_ref);
    

  101.         FDB_LOG_I("Broadcast is received:%d, filter: %s, qos:%d\n", msg->code(), msg->topic().c_str(), msg->qos());
    

  102.  
    

  103.         switch (msg->code())
    

  104.         {
    

  105. /*广播消息有消息ID和消息字符串作为标识*/
    

  106.         case NFdbTemple::FdbMediaSvcMsgId::NTF_ELAPSE_TIME:
    

  107.         {
    

  108.                 std::string filter(msg->topic());
    

  109.                 if (!filter.compare("my_filter"))
    

  110.                 {
    

  111.                         NFdbTemple::ElapseTime eTime;
    

  112.                         CFdbProtoMsgParser parser(eTime);
    

  113.                         if (msg->deserialize(parser))
    

  114.                         {
    

  115.                                 FDB_LOG_I("elapse time is received: hour: %d, minute: %d, second: %d", eTime.hour(), eTime.minute(), eTime.second());
    

  116.                                 std::cout << "Broadcast hour: " << eTime.hour() << ", minute: " << eTime.minute() << ", second: " << eTime.second() << std::endl;
    

  117.                         }
    

  118.                         else
    

  119.                         {
    

  120.                                 FDB_LOG_E("Unable to decode Elapsetime\n");
    

  121.                         }
    

  122.                 }
    

  123.                 else if (!filter.compare("raw_buffer"))
    

  124.                 {
    

  125.                         int32_t size = msg->getPayloadSize();
    

  126.                         std::cout << "Broadcast size: " << size << std::endl;
    

  127.                         FDB_LOG_I("Broadcast of raw buffer is received: size: %d\n", size);
    

  128.                 }
    

  129.         }
    

  130.         break;
    

  131.         case NTF_CJSON_TEST:
    

  132.         {
    

  133.                 CFdbCJsonMsgParser parser;
    

  134.                 if (msg->deserialize(parser))
    

  135.                 {
    

  136.                         cJSON *f = parser.retrieve();
    

  137.                         int birthday = 0;
    

  138.                         int id = 0;
    

  139.                         const char* name = 0;
    

  140.                         if (cJSON_IsObject(f))
    

  141.                         {
    

  142.                                 cJSON *item = cJSON_GetObjectItem(f, "birthday");
    

  143.                                 if (item && cJSON_IsNumber(item))
    

  144.                                 {
    

  145.                                         birthday = item->valueint;
    

  146.                                 }
    

  147.                                 item = cJSON_GetObjectItem(f, "id");
    

  148.                                 if (item && cJSON_IsNumber(item))
    

  149.                                 {
    

  150.                                         id = item->valueint;
    

  151.                                 }
    

  152.  
    

  153.                                 item = cJSON_GetObjectItem(f, "name");
    

  154.                                 if (item && cJSON_IsString(item))
    

  155.                                 {
    

  156.                                         name = item->valuestring;
    

  157.                                 }
    

  158.                                 std::cout << "Broadcast json: birthday: " << birthday << ", id: " << id << ", name: " << name << std::endl;
    

  159.                                 FDB_LOG_I("Broadcast of JSON is: birthday: %d, id: %d, name: %s\n", birthday, id, name);
    

  160.                         }
    

  161.                 }
    

  162.                 else
    

  163.                 {
    

  164.                         FDB_LOG_E("Broadcast of JSON is: with error!\n");
    

  165.                 }
    

  166.                 break;
    

  167.         }
    

  168.         case NTF_GROUP_TEST1:
    

  169.         case NTF_GROUP_TEST2:
    

  170.         case NTF_GROUP_TEST3:
    

  171.                 FDB_LOG_I("Broadcast of group message %d is received, Init:%d\n", fdbMakeEventCode(msg->code()), msg->isInitialResponse());
    

  172.                 std::cout << "Broadcast of group message: " << msg->code() << ", init: " << msg->isInitialResponse() << std::endl;
    

  173.                 break;
    

  174.         default:
    

  175.                 break;
    

  176.         }
    

  177. }
    

  178.  
    

  179. void FDClient::onKickDog(CBaseJob::Ptr & msg_ref)
    

  180. {
    

  181.         CFdbMessage::kickDog(msg_ref, worker(), [](CBaseJob::Ptr &msg_ref) {
    

  182.                 CFdbMessage::feedDog(msg_ref);
    

  183.         });
    

  184. }
    

  185. /*异步请求时，通过该回调函数获得server回复*/
    

  186. void FDClient::onReply(CBaseJob::Ptr & msg_ref)
    

  187. {
    

  188.         auto msg = castToMessage<CBaseMessage*>(msg_ref);
    

  189.         FDB_LOG_I("response is received. sn: %d\n", msg->sn());
    

  190.  
    

  191.         printMetadata(objId(), msg->metadata());
    

  192.  
    

  193.         switch (msg->code())
    

  194.         {
    

  195.         case NFdbTemple::FdbMediaSvcMsgId::REQ_METADATA:
    

  196.         {
    

  197.                 if (msg->isStatus())
    

  198.                 {
    

  199.                         if (msg->isError())
    

  200.                         {
    

  201.                                 int32_t error_code;
    

  202.                                 std::string reason;
    

  203.                                 if (!msg->decodeStatus(error_code, reason))
    

  204.                                 {
    

  205.                                         FDB_LOG_E("onReply:fail to decode status\n");
    

  206.                                         return;
    

  207.                                 }
    

  208.                                 FDB_LOG_I("onReply: status is received. msg code: %d, error code: %d, reason: %s\n",
    

  209.                                         msg->code(), error_code, reason.c_str());
    

  210.                         }
    

  211.                         return;
    

  212.                 }
    

  213.                 NFdbTemple::NowPlayingDetails now_playing;
    

  214.                 CFdbProtoMsgParser parser(now_playing);
    

  215.                 if (msg->deserialize(parser))
    

  216.                 {
    

  217.                         auto artist = now_playing.artist().c_str();
    

  218.                         auto album = now_playing.album().c_str();
    

  219.                         auto genre = now_playing.genre().c_str();
    

  220.                         auto title = now_playing.title().c_str();
    

  221.                         auto file_name = "";
    

  222.                         if (now_playing.has_file_name())
    

  223.                         {
    

  224.                                 file_name = now_playing.file_name().c_str();
    

  225.                         }
    

  226.                         auto folder_name = "";
    

  227.                         if (now_playing.has_folder_name())
    

  228.                         {
    

  229.                                 folder_name = now_playing.folder_name().c_str();
    

  230.                         }
    

  231.                         int32_t elapse_time = now_playing.elapse_time();
    

  232.                         FDB_LOG_I("async reply: artist: %s, album: %s, genre: %s, title: %s, file name: %s, folder name: %s",
    

  233.                                 artist, album, genre, title, file_name, folder_name);
    

  234.                         std::cout << "async from server: artist: " << artist << ", album: " << album << ", genre: " << genre << ", title:" << title << ", file name: " << file_name
    

  235.                                 << ", folder name: " << folder_name << std::endl;
    

  236.                  }
    

  237.                 else
    

  238.                 {
    

  239.                         FDB_LOG_I("Error, unable to decode message\n");
    

  240.                 }
    

  241.         }
    

  242.         break;
    

  243.         case NFdbTemple::FdbMediaSvcMsgId::REQ_RAWDATA:
    

  244.         {
    

  245.                 if (msg->isStatus())
    

  246.                 {
    

  247.                         int32_t error_code;
    

  248.                         std::string reason;
    

  249.                         if (!msg->decodeStatus(error_code, reason))
    

  250.                         {
    

  251.                                 FDB_LOG_E("onReply: fail to decode status\n");
    

  252.                                 return;
    

  253.                         }
    

  254.                         FDB_LOG_I("onReply: msg code: %d, error code: %d, reason: %s\n", msg->code(), error_code, reason);
    

  255.                         return;
    

  256.                 }
    

  257.  
    

  258.                 CFdbParcelableArray<CPerson> persions;
    

  259.                 CFdbParcelableParser parser(persions);
    

  260.                 if (!msg->deserialize(parser))
    

  261.                 {
    

  262.                         FDB_LOG_E("onReply: fail to decode from simple parser\n");
    

  263.                         return;
    

  264.                 }
    

  265.                 std::ostringstream stream;
    

  266.                 (void)persions.format(stream);
    

  267.                 FDB_LOG_I("onReply:%s\n", stream.str().c_str());
    

  268.                 std::cout << "reply from server:" << stream.str().c_str() << std::endl;
    

  269.         }
    

  270.         break;
    

  271.         default:
    

  272.                 break;
    

  273.         }
    

  274. }
    

  275. /*注册服务器广播消息后的回复*/
    

  276. void FDClient::onStatus(CBaseJob::Ptr & msg_ref, int32_t error_code, const char * description)
    

  277. {
    

  278.         auto msg = castToMessage<CBaseMessage*>(msg_ref);
    

  279.         if (msg->isSubscribe())
    

  280.         {
    

  281.                 if (!msg->isError())
    

  282.                 {
    

  283.                         FDB_LOG_I("subscribe is ok, sn:%d\n", msg->sn());
    

  284.                 }
    

  285.         }
    

  286.         FDB_LOG_I("reason: %s\n", description);
    

  287. }
    

  288.  
    

  289. void FDClient::printMetadata(FdbObjectId_t obj_id, const CFdbMsgMetadata * metadata)
    

  290. {
    

  291.         uint64_t time_c2s;
    

  292.         uint64_t time_s2r;
    

  293.         uint64_t time_r2c;
    

  294.         uint64_t time_total;
    

  295.         CFdbMessage::parseTimestamp(metadata, time_c2s, time_s2r, time_r2c, time_total);
    

  296.         FDB_LOG_I("obj:%d, server:%llu, reply:%llu, receive:%llu, total:%llu\n",
    

  297.                 obj_id, time_c2s, time_s2r, time_r2c, time_total);
    

  298. }
    

  299.  
    

  300. /*周期性地向服务器发送请求*/
    

  301. CInvokeTimer::CInvokeTimer(FDClient *client)
    

  302.         :CMethodLoopTimer<FDClient>(1000, true, client, &FDClient::callServer)
    

  303. {}
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-16 18:24 | 显示全部楼层
3.main.cpp  （客户端）
复制
  1. #include "FDClient.h"
    

  2.  
    

  3. int main(int argc, char **argv)
    

  4. {
    

  5.         FDB_CONTEXT->start();
    

  6.         fdbLogAppendLineEnd(true);
    

  7.         FDB_CONTEXT->registerNsWatchdogListener([](const tNsWatchdogList &dropped_list)
    

  8.         {
    

  9.                 for (auto it = dropped_list.begin(); it != dropped_list.end(); ++it)
    

  10.                 {
    

  11.                         FDB_LOG_F("Error!!! name: %s, pid: %d\n", it->mClientName.c_str(), it->mPid);
    

  12.                 }
    

  13.         });
    

  14.         FDClient::main_worker.start();
    

  15.  
    

  16.         //for (int i = 1; i < argc; ++i)
    

  17.         //{
    

  18.         /*客户端向server_name服务器发起连接请求*/
    

  19.                 std::string server_name = "myService";
    

  20.                 std::string url(FDB_URL_SVC);
    

  21.                 url += server_name;
    

  22.                 server_name += "_client";
    

  23.                 auto client = new FDClient(server_name.c_str(), &FDClient::main_worker);
    

  24.  
    

  25.                 client->enableReconnect(true);
    

  26.                 client->enableUDP(true);
    

  27.                 client->enableTimeStamp(true);
    

  28.                 client->connect(url.c_str());
    

  29.         //}
    

  30.                 std::cout << url.c_str() << std::endl;
    

  31.                 std::cout << server_name << std::endl;
    

  32.         CBaseWorker background_worker;
    

  33.         background_worker.start(FDB_WORKER_EXE_IN_PLACE);
    

  34.         return 0;
    

  35. }
回复 赏

举报

 楼主| keer_zu 发表于 2022-9-16 18:24 | 显示全部楼层
三、接口说明
1. CBaseLoopTimer(int32_t interval, bool repeat = false)

注： Interval代表Timer的时间间隔；

repeat表示创建的是cyclic Timer还是one-shot Timer；一旦使能后，cyclic Timer会以interval毫秒为周期反复执行；one-shot Timer在interval毫秒超时后不再执行。

2. attach(CBaseWorker *worker, bool enb = true)

注： 指定运行Timer的Worker。只有指定了Worker后Timer才能开始工作。超时后，Timer的run()函数将在该Worker上执行。 如果enb为true，Timer立刻开始在指定的Worker上执行；否则可以将来用enable()启动。

3.enable(int32_t interval = -1)

注：使能Timer。使能后的Timer将在指定的Worker上工作。如果调用该函数时Timer正在运行，那么超时时间将被重置为interval毫秒之后。

备注：代码中关于protobuf部分是与通信相关的，可以不用过多关注，当用于实际项目时，根据实际情况定义响应的protobuf数据就可以。
回复 赏

举报

返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则

keer_zu

1477

主题

12909

帖子

55

粉丝
快速回复 在线客服 返回列表 返回顶部