提问者:小点点

AFNetworking 2.0/Boost::Asio-获取JSON数据(网络连接丢失)


我已经成功地使用AFHTTPRequest estoperationManager将JSON数据发送到BOOST Asio,但未能成功检索JSON数据。我确实确保我可以通过AFNetwork中的可达性功能到达主机。我尝试了几个基于AFHTTPRequest estoperationManager的功能,例如:

AFHTTPRequestOperationManager *manager = [AFHTTPRequestOperationManager manager];
manager.securityPolicy.allowInvalidCertificates=YES;
manager.responseSerializer = [AFJSONResponseSerializer serializer];
[manager POST:@"http://xx.xx.xx.x:8888"
  parameters:nil
     success:^(AFHTTPRequestOperation *operation, id responseObject) {
         NSLog(@"JSON: %@", responseObject);
     } failure:^(AFHTTPRequestOperation *operation, NSError *error) {
         NSLog(@"Error: %@", error);
     }];

但是,我不断收到相同的错误:

错误域 = NSURLErrorDomain 代码 =-1005 “网络连接丢失。”UserInfo={NSUnderlyingError=0x12fd7c580 {Error Domain=kCFErrorDomainCFNetwork Code=-1005 “网络连接丢失。”UserInfo={NSErrorFailingURLStringKey=http:/xx.xx.xx.x:8888/, _kCFStreamErrorDomainKey=1, NSErrorPeerAddressKey={length = 16, capacity = 16, bytes = 0x100222b82d3741040000000000000000}, _kCFStreamErrorCodeKey=54, NSErrorFailingURLKey=http://xx.xx.xx.x:8888/, NSLocalizedDescription=网络连接丢失了。 NSErrorFailingURLStringKey=http://xx.xx.xx.x:8888/, NSErrorFailingURLKey=http://xx.xx.xx.x:8888/, _kCFStreamErrorDomainKey=1, _kCFStreamErrorCodeKey=54,NSLocalizedDescription=网络连接丢失。

Linux 服务器示例利用 Boost Asio async_write 功能和写入处理程序来确保 JSON POST 完成。

#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <string>
#include <boost/property_tree/json_parser.hpp>
#include <boost/property_tree/ptree.hpp>

using boost::property_tree::ptree;
using boost::property_tree::basic_ptree;

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

typedef std::string Blob;
const std::string NOOBJECT = "a";

class Server : public boost::enable_shared_from_this<Server> {
private:
    const std::string AUTHSVCS = "xx.xx.xx.x:8888";

public:
    Server();
    virtual ~Server();
    void send(tcp::socket&, boost::asio::io_service&, std::string&);
    void on_send(const boost::system::error_code &, size_t);
    void genheader(Blob& body, std::string& request);
    void genbody(const std::string& reqtype, Blob& token, Blob& body);
};

Server::Server() {
}

Server::~Server() {
}

void
Server::genheader(Blob& body, std::string& request)
{
    cout << "Server::genheader" << endl;

    request += "POST / HTTP/1.1 \r\n";
    request += "Host:";
    request += AUTHSVCS;
    request += "\r\n";
    request += "User-Agent: ProteAuth/1.0 \r\n";
    request += "Content-Type: application/json; charset=utf-8 \r\n";
    request   += "Content-Type: application/json \r\n";
    request += "Accept: */*\r\n";
    request += "Content-Length: ";
    request += std::to_string(body.length());
    request += "\r\n";
    request += "Connection: close\r\n\r\n";
    request += body;
}

void
Server::genbody(const std::string& reqtype, Blob& token, Blob& body)
{
    ptree requestTree;
    ptree requestElement;

    std::cout << "Server::genbody" << std::endl;

    // Add request token
    requestElement.put_value(token);
    requestTree.add_child(reqtype, requestElement);

    // Create (JSON) request
    std::stringstream ss;
    write_json(ss, requestTree, false);
    body = ss.str();
}

void
Server::send(tcp::socket& sock, boost::asio::io_service& io_service, std::string& request) {
    std::cout << "Server::send" << std::endl;

    try {
        async_write(sock, boost::asio::buffer(request), boost::bind(
                &Server::on_send,
                shared_from_this(),
                boost::asio::placeholders::error,
                boost::asio::placeholders::bytes_transferred));

        io_service.run();
    } catch (exception& e) {
        std::cerr << e.what() << std::endl;
    }

    return;
}
void
Server::on_send(const boost::system::error_code & error, size_t bytes_transferred) {
    std::cout << "Server::on_send" << std::endl;

    if (error) {
        std::cout << "Error: " << error.message() << std::endl;
        std::cout << "Bytes sent: " << bytes_transferred << std::endl;
    } else {
        std::cout << "Bytes sent: " << bytes_transferred << std::endl;
    }

    return;
}

int main() {
    try {
        boost::asio::io_service ioserv;
        tcp::acceptor acceptor(ioserv, tcp::endpoint(tcp::v4(), 8888));
        boost::shared_ptr<Server> sesh(new Server());

        //Blob 
        Blob token("a");

        // Generate URL body
        Blob body;
        sesh->genbody(NOOBJECT, token, body);

        // Generate Headers (append body)
        std::string request;
        sesh->genheader(body, request);

        for (;;) {
            tcp::socket newsocket(ioserv);
            acceptor.accept(newsocket);

            cout << "New Request" << endl;

            sesh->send(newsocket, ioserv, request);
        }
    } catch (exception& e) {
        cerr << e.what() << endl;
    }

    return 0;
}

我使用 REST 客户端爪子来验证是否检索到以下内容:

    POST / HTTP/1.1 
    Host:xx.xx.xx.x:8888
    User-Agent: ProteAuth/1.0 
    Content-Type: application/json; charset=utf-8 
    Content-Type: application/json 
    Accept: */*
    Content-Length: 10
    Connection: close

{"a":"a"}

有人知道为什么我经常失去与网络的连接(Boost ASIO嵌入式超文本传输协议-server)吗?


共1个答案

匿名用户

我能够确定async_write函数(BOOST::Asio)和AFHTTPRequestOperationManager(iOS)之间的JSON数据传输问题。这只是一个格式错误的头,在genheader函数中更新如下:

void Server::genheader(Blob& body, std::string& request)
{
    cout << "Server::genheader" << endl;

    request += "HTTP/1.1 200 OK \r\n";
    request += "Content-Length: ";
    request += std::to_string(body.length());
    request += "\r\n";
    request += "Content-Type: application/json \r\n";
    request += "Connection: Keep-Alive\r\n\r\n";
    request += body;
}