Netplus收发消息的基本流程
生活随笔
收集整理的這篇文章主要介紹了
Netplus收发消息的基本流程
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
本文為初見,Netplus快速開始之PingPong Example系列第四篇
啟動一個服務 (server端):
Code Example:
這個例子,我們暫時使用一個Netplus自帶的 channel handler。
netp::handler:echo:當收到來自對端的消息的時候,原樣回復。在這個例子中, 我們監聽tcp://0.0.0.0:22310,當收新的連接Accept成功后,為其添加一個叫echo的handler
NRP<netp::channel_listen_promise> f_listen = netp::socket::listen_on( "tcp://0.0.0.0:22310", [](NRP<netp::channel> const& ch) { //once a new channel accepted, we add a echo handler which reply what it receivesch->pipeline()->add_last(netp::make_ref<netp::handler::echo>()); }); int listenrt = std::get<0>(f_listen->get()); if(listenrt != netp::OK) {//do ... } //...連接一個服務(client端):
Code Example:
我們使用一個Netplus自帶的channel handler
netp::handler::dump_in_len:當收到來自對端的消息的時候,在屏幕打印出消息的長度在這個例子中,我們撥號至tcp://127.0.0.1:22310,如果撥號成功,我們向對端發送hello。當收到來自對端的回復時,在屏幕上打印收到的消息的長度。
std::string url = "tcp://127.0.0.1:22310"; NRP<netp::channel_dial_promise> f = netp::socket::dial(url, [url](NRP<netp::channel> const& ch) {ch->pipeline()->add_last(netp::make_ref<netp::handler::dump_in_len>()); });int dialrt = std::get<0>(f->get()); if(dialrt != netp::OK) {return dialrt; }NRP<netp::channel> ch = std::get<1>(f->get()); NRP<netp::packet> write_bytes = netp::make_ref<netp::packet>(); write_bytes->write("hello",5);NRP<netp::promise<int>> write_p = ch->ch_write(write_bytes); write_p->if_done([](int rt){if(rt == netp::OK) {//WRITE SUCCEED..} });?
注意到沒,服務器,客戶端,都是如下三步曲
So easy!
下一篇,我們將正式介紹 PingPong Example。
?
寫代碼的冰冰
總結
以上是生活随笔為你收集整理的Netplus收发消息的基本流程的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: AI-语音处理理论和应用-语音识别、语音
- 下一篇: java页面标签span_span标签跳