0

エコーサーバーの例を使用してboost.asioを使用してtcpサーバーをプログラミングする場合、受信データを処理して結果を送り返したいという要件を満たすために、そのコードの一部を変更しました。ソケット処理用のクラスを使用しました。 socket.h"とファイル"handler.h"のデータ用に別のハンドラーを作成したいのですが、私の問題は、handler.hの関数にデータを渡し、この関数からソケットを通過してデータを送り返す方法です。 .h ??

socket.h

#include <cstdlib>
#include <iostream>
#include <boost/bind.hpp>
#include <boost/asio.hpp>
#include <json/json.h>
#include "handler.h"

using namespace std;
using boost::asio::ip::tcp;

class session {
public:
    session(boost::asio::io_service& io_service) : socket_(io_service) {}
    tcp::socket& socket() { return socket_; }

    /* listen for first input data after connection established */
    void start() {
        socket_.async_read_some(boost::asio::buffer(data_, max_length),
        boost::bind(&session::handleIncome,this,
        boost::asio::placeholders::error,
        boost::asio::placeholders::bytes_transferred)); }

    /* handle incoming data */
    void handleIncome(const boost::system::error_code& error, size_t bytes_transferred) {
        /* data is recieved in var data_ */
            if (!error) {   
            /********************* Data Handler ****************************/

                     callHandler(data_); //this is in handler.cpp

            /**************************************************************/
        } else { delete this; } }

    /* get more input */
    void getIncome(const boost::system::error_code& error) {
        if (!error) {
            socket_.async_read_some(boost::asio::buffer(data_, max_length),
            boost::bind(&session::handleIncome, this,
            boost::asio::placeholders::error,
            boost::asio::placeholders::bytes_transferred)); }
    else { delete this; } }

    /* send outcome back to client */
    void sendOutcome(const std::string dout, size_t bytes_out) {
        boost::asio::async_write(socket_,boost::asio::buffer(dout, bytes_out),
        boost::bind(&session::getIncome, this,boost::asio::placeholders::error)); }

private:
    tcp::socket socket_;
    enum { max_length = 1024 };
    char data_[max_length];
};

class DServer {
public:
    DServer(boost::asio::io_service& io_service, short port)
    :io_service_(io_service),
    acceptor_(io_service, tcp::endpoint(tcp::v4(), port))

    {
        session* new_session = new session(io_service_);
        acceptor_.async_accept(new_session->socket(),
        boost::bind(&DServer::handle_accept,this,new_session,boost::asio::placeholders::error));
    }

    void handle_accept(session* new_session,const boost::system::error_code& error) {
    if (!error) {
        new_session->start();
        new_session = new session(io_service_);
        acceptor_.async_accept(new_session->socket(),boost::bind(&DServer::handle_accept, this, new_session,boost::asio::placeholders::error));}
    else { delete new_session; } }

private:
    boost::asio::io_service& io_service_;
    tcp::acceptor acceptor_;
};

handler.cpp

void callHandler(string data) {
    /* here i want to process data and after that i want to send back the result to the same client ofcourse using the function sendOutcome() in the socket.h file */
}
4

2 に答える 2

2

関数からデータを返す最も一般的な方法は、それを返すことです。

string callHandler(string data);

sendOutcome(callHandler(data_));

より柔軟性が必要な場合 (たとえば、複数の応答を送信する、またはソケットで何か他のことを行う場合)、ソケットへの参照を渡すか、sessionオブジェクトへの参照を渡します (おそらく抽象インターフェイスを使用して、クラスから切り離します)実装）。

于 2012-08-16T11:58:15.297 に答える
0

まず、必要なすべてのデータを受け取ったことを確認する必要があります。ハンドラーは、リクエスト全体がはるかに大きい場合でも、bytes_transferred が 1 で handleIncome() コールバックが呼び出されるシナリオに対処する必要があります。

当然のことながら、読み取りコールバックを async_write() 関数のパラメーターとして使用しないでください。

于 2012-08-17T10:54:58.900 に答える