1

在你决定它是一个 tl:dr （太长，没读）帖子之前，试着至少读一些，因为它是一个被分解成很多小块的问题。其中一些您可能可以回答并帮助我。

请尽量帮助我。这些类型的问题在互联网上很常见，我想你会帮助我和我之后的更多人。

我目前正在研究 HTTP 服务和协议本身，以便发现它是否对我有用。
我有一些基本问题以及一些需要讨论的代码。

首先我想知道通信是如何开始的？我发现客户端发送了一条请求资源的消息（这是正确的吗？）。然后会发生什么？我（作为服务器）必须回复什么？
我是否需要在每次响应后附加回车和换行符？它在某处说甚至需要两个 (\r\n\r\n)。
如何建立异步写入？（我希望这个问题可以理解）我的主要目标是实现客户端和服务器之间的连接，然后实现从服务器到客户端的连续数据流。客户端是否需要回复收到的每条消息？
我希望我把我的问题说清楚了，因为我不是这些事情的专家（但是，我对此很感兴趣）。

对于我的问题的编程部分。
我已经设法用 C++（服务器端）在 Qt 中编写了一个简单的程序，并在 Objective C（iOS）中编写了一个简单的客户端。客户端连接，我可以读取请求标头。它是这样的：

Data available, incoming:  "GET / HTTP/1.1
Host: localhost:9990
Connection: close
User-Agent: CFStream%20test/1.0 CFNetwork/609 Darwin/12.2.0

我应该手动回复这个标题吗？如果是这样，是什么？

客户端代码看起来像这样（我知道它不是伪代码，但我认为它非常不言自明）：

- (void)setupStream
{
    NSURL *url = [NSURL URLWithString:@"http://localhost:9990"];

    CFHTTPMessageRef message = CFHTTPMessageCreateRequest(NULL, (CFStringRef)@"GET", (CFURLRef)url, kCFHTTPVersion1_1);

    stream = CFReadStreamCreateForHTTPRequest(NULL, message);
    CFRelease(message);

    if (!CFReadStreamSetProperty(stream, kCFStreamPropertyHTTPShouldAutoredirect, kCFBooleanTrue))
    {
        NSLog(@"Some error.");
    }

    CFDictionaryRef proxySettings = CFNetworkCopySystemProxySettings();
    CFReadStreamSetProperty(stream, kCFStreamPropertyHTTPProxy, proxySettings);
    CFRelease(proxySettings);

    if (!CFReadStreamOpen(stream))
    {

        CFRelease(stream);
        NSLog(@"Error opening stream.");
    }

    CFStreamClientContext context = {0, self, NULL, NULL, NULL};
    CFReadStreamSetClient(stream, kCFStreamEventHasBytesAvailable | kCFStreamEventErrorOccurred, readStreamCallback, &context);
    CFReadStreamScheduleWithRunLoop(stream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
    NSLog(@"Done");
}

这是设置流方法。该stream变量是类型的类变量CFReadStreamRef。

回调如下所示：

static void readStreamCallback(CFReadStreamRef aStream, CFStreamEventType event, void *client)
{
    ViewController *controller = (ViewController*)client;
    [controller handleEvent:event forStream:aStream];
}

像这样的句柄事件：

- (void)handleEvent:(CFStreamEventType)event forStream:(CFReadStreamRef)aStream
{
    if (aStream != stream)
    {
        return;
    }

    NSLog(@"Handle event callback");

    switch (event)
    {
        case kCFStreamEventHasBytesAvailable:
            NSLog(@"Work log");
            UInt8 bytes[11];
            CFIndex length;
            length = CFReadStreamRead(stream, bytes, 11); //I know 11 bytes is hard coded, its in testing stage now. Feel free to suggest me how to do it better.

            if (length == -1)
            {
                NSLog(@"Error, data length = -1");
                return;
            }

            NSLog(@"Len: %li, data: %s", length, bytes);
        break;
        default:
            NSLog(@"Other event");
        break;
    }
}

这实际上就是所有值得一提的客户端代码。Qt Server 部分（我将只发布重要部分）是这样完成的：（这是一个子类 QTcpServer 类）。首先startServer();被称为：

bool Server::startServer()
{
    if (!this->listen(QHostAddress::Any, 9990))
        return false;

    return true;
}

当有连接传入incomingConnection时，将使用套接字描述符作为参数触发：

void Server::incomingConnection(int handle)
{
    qDebug("New client connected");
    ServerClient *client = new ServerClient(handle, this); //The constructor takes in the socket descriptor needed to set up the socket and the parent (this)
    client->setVectorLocation(clients.count()); //This is a int from a Qvector in which i append the clients, its not important for understanding right now.
    connect(client, SIGNAL(clientDisconnected(int)), this, SLOT(clientDisconnected(int)), Qt::QueuedConnection); //When the client socket emits a disconnected signal the ServerClient class emits a client disconnected signal which the server uses to delete that client from the vector (thats why I use "setVectorLocation(int)") - not important right now
    clients.push_back(client); //And then I append the client to the QVector - not important right now
}

类ClientServer构造函数只是创建一个新的套接字并连接所需的方法：

ServerClient::ServerClient(int handle, QObject *parent) :
QObject(parent)
{
    socket = new QTcpSocket(this); //Socket is a class variable

    connect(socket, SIGNAL(disconnected()), this, SLOT(disconnected()));
    connect(socket, SIGNAL(readyRead()), this, SLOT(readyRead()));

    socket->setSocketDescriptor(handle);
}

就绪读取只是将传入的数据写入我（我认为以后不会有太多用户）：

void ServerClient::readyRead()
{
    qDebug() << "Data available, incoming: " << socket->readAll();
}

最后是写入数据：

void ServerClient::writeData(QByteArray *data)
{
    data->append("\r\n\r\n"); //I have read this must be appended to all outgoing data from a HTTP server
    socket->write(*data);
    socket->flush();
    qDebug() << "Written data to client: " << *data;
}

但是，此代码并不总是有效。有时，当我写“消息”之类的消息时，客户端会收到所有数据和一些不应该存在的东西（新行和奇怪的符号 - 会NSLog导致这种情况吗？）。有时，当我发送"Hellow"客户端时，只会获取"Hel"和其他一些时髦的东西。

有什么问题？我应该更注意什么？任何对我有帮助的东西都将不胜感激。并且请不要粘贴一些包含几百页书的链接，我相信只要向我解释一下就可以解决这个问题。

多谢！
简。

4

2 回答 2

0

您的问题几乎等同于“HTTP 如何工作”，完整的答案在于规范。

于 2012-12-04T17:53:44.053 回答
0

你问了很多问题......这是完全合法的事情:)

我承认-太长了，我没看:(

但 ...

1) 是的，HTTP 协议确实需要 na "CRLF" ("\r\n")。许多服务器和许多客户端是“宽容的”，但严格来说 - 是的，你需要它们。

参考：RFC 2616

2) 想要了解 HTTP“内部”也是完全合法的——我为你鼓掌。

一种好方法是阅读 RFC。

另一种是使用“telnet”客户端： http: //blog.tonycode.com/tech-stuff/http-notes/making-http-requests-via-telnet

还有一个是研究FF Firebug中的请求和响应

3) 套接字编程是另一个问题——这解释了为什么有时你可能会读到“hello world”，而有时你可能只是读到“hel”。

强烈推荐：Beej's Guide to Network Programming

4）最后，我实际上不可能用 C++ 在 Qt 中编写服务器（除了可能作为玩具“科学实验”，或者对于一些非常离谱的要求）

我肯定会用 C#（适用于 Windows 服务器）、Java（适用于其他一切）或我喜欢的脚本语言（Perl、Ruby/RoR、Python 和 Lua 都想到）来编写服务器代码。

恕我直言..希望对您有所帮助！

于 2012-12-04T17:59:26.083 回答