【Winsock】持続的接続ができない？

[MoNoQLoREATOR]

Winsockプログラミングのお話です。
httpに従って、

HEADリクエストでヘッダー情報取得
↓
そこから必要な容量を読み取り、バッファを確保
↓
GETリクエストでデータを取得

ということをやりたいのですが、どうやら持続的接続ができていないようなのです。
GETリクエストを送信した後に受信するデータ量が0なのです。
一旦接続し直してからGETリクエストを送ると正常にデータを受信することができます。

以下ソースコードです。(関数などをできるだけ展開してみました)

main.cpp

► スポイラーを表示

コード:

#define _CRT_SECURE_NO_DEPRECATE
#define WIN32_LEAN_AND_MEAN

/*
#include "DxLib.h"
#define FW_DX_DEF_
//*/
#define FW_MAIN_
#define FW_STD_DEF_
//*
#define FW_STD_PROGRAMABLE_DEF_
#define FW_DX_PROGRAMABLE_DEF_
//*/
#include "../safe_fireworks/fireworks.h"

#include "includes.h"



void __cdecl cleanup();

int main()
{
	std::string url("localhost/index.html");
	vuchar content;





	std::string domain;
	std::string uri;
	SOCKET socket;
	SOCKADDR_IN hostinfo;

	// Init Winsock
	{
		const char lobyte = 2;
		const char hibyte = 0;
		WSADATA wsd;
		bool wsdres = WSAStartup(MAKEWORD(lobyte,hibyte), &wsd) == 0;

		if(wsdres)
		{
			bool match = LOBYTE(wsd.wVersion)==lobyte && HIBYTE(wsd.wVersion)==hibyte;
			if(match==false)
			{
				return -1;
			}
		}
		else
		{
			return -1;
		}
		atexit(cleanup);
	}

	// Create Socket
	{
		socket = ::socket(AF_INET, SOCK_STREAM, 0);
		if(socket == INVALID_SOCKET)
		{
			return -1;
		}
	}

	// Get Domain and URI
	{
		uint slash = url.find('/');
		domain = url.substr(0, slash);
		uri = url.substr(slash);
	}

	// Get IP
	{
		hostinfo;
		hostinfo.sin_family = AF_INET;
		hostinfo.sin_port = htons(short(80) );
		ULONG & ref = hostinfo.sin_addr.S_un.S_addr;
		ref = inet_addr(domain.c_str() );
		if(ref==INADDR_NONE)
		{
			HOSTENT * hostent = gethostbyname(domain.c_str() );
			if(hostent==NULL)
			{
				return -1;
			}
			ref = *fw::pointer_cast<uint *>(hostent->h_addr_list[0]);
		}
	}

	// Connect to Server
	{
		if(::connect(socket, fw::pointer_cast<sockaddr *>(&hostinfo), sizeof(hostinfo) ) == SOCKET_ERROR)
		{
			return -1;
		}
	}

	// HEAD Request
	{
		std::string request
		=
		fw::cnct() <<
		"HEAD " << uri << " HTTP/1.1" << "\r\n" <<
		"Host: " << domain << "\r\n" <<
		"Content-Length: 0" << "\r\n" <<
		"Connection: Keep-Alive" << "\r\n" <<=
		"\r\n";

		if(::send(socket, request.c_str(), request.length(), 0) == SOCKET_ERROR)
		{
			return -1;
		}
	}

	// Receive Header
	{
		HTTPheader header;
		header.buffer.setsize(1024);
		uint HeadSize = 0;
		while(true)
		{
			int nBytesRecv = recv(socket, header.bufhead(), header.buffer.size(), 0);
			HeadSize += nBytesRecv;
			if(nBytesRecv == SOCKET_ERROR)
			{
				return -1;
			}
			else
			{
				if(nBytesRecv == 0) break;
			}
		}
		
		header.buffer.setsize(HeadSize);
		header.analyze();

		// Show Header
		header.buffer.add('\0');
		printf("header:\n%s\n\n", header.bufhead() );
		header.buffer.pop();

		// Require Buffer for Header and Body
		if(header.UsefulContentLength() )
		{
			content.setsize(HeadSize + header.ContentLength() );
			printf("Size of Header and Body:%d\n", content.size() );
		}
		else
		{
			printf("Not Found UsefulContentLength\n");
			return -1;
		}
	}

	// GET Request
	{
		std::string request
		=
		fw::cnct() <<
		"GET " << uri << " HTTP/1.1" << "\r\n" <<
		"Host: " << domain << "\r\n" <<
		"Content-Length: 0" << "\r\n" <<
		"Connection: Keep-Alive" << "\r\n" <<=
		"\r\n";

		if(::send(socket, request.c_str(), request.length(), 0) == SOCKET_ERROR)
		{
			printf("Failed to Send 'GET Request'\n");
			return -1;
		}
	}

	// Receive Header and Body
	{
		uint total = 0;
		while(true)
		{
			int nBytesRecv = recv(socket, fw::pointer_cast<char *>(content.head() ), content.size(), 0);
			total += nBytesRecv;
			if(nBytesRecv == SOCKET_ERROR)
			{
				printf("SOCKET ERROR\n");
				return -1;
			}
			else
			{
				if(nBytesRecv == 0) break;
			}
		}

		content.setsize(total);

		// Show Header and Body
		content.add('\0');
		printf("Header and Body:\n%s\n", content.head() );
		content.pop();
	}

	// Disconnect
	{
		shutdown(socket, SD_BOTH);
		closesocket(socket);
	}

	return 0;
}

void __cdecl cleanup(){ WSACleanup(); }

includes.h

► スポイラーを表示

コード:

#pragma once

#include <WinSock2.h>
#pragma comment(lib, "wsock32.lib")

#include "HTTPheader.h"

HTTPheader.h

► スポイラーを表示

コード:

#pragma once

class HTTPheader
{
public:
	vuchar buffer;

	HTTPheader()
	:
	strContentLength("Content-Length"),
	strConnection("Connection"),
	strLocation("Location")
	{}

	char * bufhead(){ return fw::pointer_cast<char *>(buffer.head() ); }
	uint bufsize() const { return buffer.size(); }
	void analyze(const char * str)
	{
		//content-valueの中に,が入る物があるとリストと区別できない。また、その場合正しく分割できていない

		fw::slice lines;
		lines(str, "\r\n");

		for(uint i=lines.size()-1;i>1;--i)
		{
			const char first = lines[i][0];
			if(first==' ' || first=='\t')
			{
				lines[i-1] += lines[i];
				lines.pop();
			}
		}

		char phrase[32];
		sscanf(lines[0].c_str(),"HTTP/%s %s %s", Version,Code,phrase);

		for(uint i=1;i<lines.size();++i)
		{
			uint colon = lines[i].find(':');
			uint beg = lines[i].find_first_not_of(" \t", colon+1);

			fw::slice param;
			param(lines[i].substr(beg), ",");

			vstring & ref = table[lines[i].substr(0, colon)];

			for(uint j=0;j<param.size();++j)
			{
				ref.add(param[j].substr(param[j].find_first_not_of(" \t") ) );
				uint spht = ref.last().find_first_of(" \t");
				ref.last() = ref.last().substr(0, spht);
			}
		}
	}
	void analyze()
	{
		buffer[buffer.size()-2] = uchar('\0');
		analyze(bufhead() );
	}

	bool ResponseIs2XX() const { return Code[0]=='2'; }
	bool ResponseIs3XX() const { return Code[0]=='3'; }

	bool UsefulContentLength() const { return table[strContentLength].size()>0; }
	uint ContentLength() const { return atoi(table[strContentLength][0].c_str() ); }

	bool UsefulConnection() const { return table[strConnection].size()>0; }
	bool ConnectionIsKeepAlive() const { return table[strConnection][0]=="Keep-Alive"; }

	bool UsefulLocation() const { return table[strLocation].size()>0; }
	const std::string & Location() const { return table[strLocation][0]; }

private:
	mutable std::map<std::string, vstring> table;
	char Version[4];
	char Code[4];

	const std::string strContentLength;
	const std::string strConnection;
	const std::string strLocation;
};

一応ソースコードをUPしておきます。
safe_fireworksのみ
safe_fireworks + ソースコードファイル(3つ全て)
※クリックした瞬間ダウンロードされます

[h2so5]

サーバーが持続的接続を許可していない可能性はないでしょうか？

[MoNoQLoREATOR]

Headerを見ると
Connection: Keep-Alive
とあるので、サーバーは持続的接続を許可しているものと思われます。
ただ、
Keep-Alive: timeout=5, max=100
とあり、データの受信にかなり時間がかかっていることから、タイムアウトしている可能性
はあるかもしれません。

[MoNoQLoREATOR]

実行ファイルをUPしましたので、よろしければ動作確認をお願いできませんか？
http://www25.atpages.jp/monoqloreator/o ... roject.lzh
※例によってクリックした瞬間にダウンロードが開始されます。
　　また、入力するURLはhttp://よりも下の部分のみとしてください。
　　さらに、おそらくアンチウイルスソフトがシャシャリ出て来るものと思われますが、
　　それについては私を信用して頂くしかございません…。

[softya（ソフト屋)]

localhostでテストしてみました。
これは、合格のなのでしょうか？

Do input URL
localhost/index.html
Now Communicating...

Begin = Init Winsock
Finish = Init Winsock

Begin = Create Socket
Finish = Create Socket

Begin = Get Domain and URI
Finish = Get Domain and URI

Begin = Get IP
Finish = Get IP

Begin = Connect to Server
Finish = Connect to Server

Begin = HEAD Request
Finish = HEAD Request

Begin = Receive Header
Finish = Receive Header

Begin = Analyze Header
header:
HTTP/1.1 200 OK
Date: Mon, 29 Apr 2013 01:49:45 GMT
Server: Apache/2.2.21 (Win32) mod_ssl/2.2.21 OpenSSL/1.0.0e PHP/5.3.8 mod_perl/2
.0.4 Perl/v5.10.1
Last-Modified: Sat, 19 Mar 2011 08:49:44 GMT
ETag: "1000000019c96-ca-49ed1f9d9da00"
Accept-Ranges: bytes
Content-Length: 202
Keep-Alive: timeout=5, max=100
Connection: Keep-Alive
Content-Type: text/html


Estimated Size of Header and Body:567
Finish = Analyze Header

Begin = GET Request
Finish = GET Request

Begin = Receive Header and Body
Header and Body:

Finish = Receive Header and Body

[MoNoQLoREATOR]

動作確認ありがとうございます。
Header情報は取得できていますが、肝心のlocalhost/index.htmlの内容が取得できていませんので、失格となります。
Begin = Receive Header
の後の部分が表示されるまでかなり時間がかかりませんでしたか？(私の場合5秒くらいかかります)
おそらくその間にタイムリミットが来て、サーバー側が接続を切ってしまっているのではないかと私は睨んでいるのですが…。

[softya（ソフト屋)]

動作確認ありがとうございます。
Header情報は取得できていますが、肝心のlocalhost/index.htmlの内容が取得できていませんので、失格となります。
Begin = Receive Header
の後の部分が表示されるまでかなり時間がかかりませんでしたか？(私の場合5秒くらいかかります)
おそらくその間にタイムリミットが来て、サーバー側が接続を切ってしまっているのではないかと私は睨んでいるのですが…。

そうですね５秒ぐらいは止まりますので、タイムリミットだと思います。

[MoNoQLoREATOR]

それにしても、どうしてこんなにも時間がかかるのでしょうか？
こんなものなのでしょうか？
それとも受信の仕方が間違っているのでしょうか？

[softya（ソフト屋)]

Keep-Aliveはやった事がないのでよくわかりませんが、WireSharkなどでパケットキャプチャして異常なパケットは出ていないのでしょうか？

[YuO]

コードを追ってデバッグしましたか。
124行目のrecvで0が返ることを期待しているようですが，ブロッキングソケットなので，recvは読む物がなくなれば単純にブロックします。
で，タイムアウトしてFINを送信された場合(shutdown(s, SD_SEND))には，recvは0を返すので，その先へ行くのだと思います。
# 面倒なのでブロックされたことを確認した時点で書いています。
当然，サーバー側は「もう送信しない」と表明しているので，GETを受信しても何も返し(返せ)ません。


ちなみに，VS 2010, IIS 8 on Windows 8の環境下で，以下のコードは問題なく動きます。
# ヘッダサイズが変わらないことを前提にした手抜きコードですが。

コード:

#include <WinSock2.h>
#include <Windows.h>
#include <iostream>
#include <string>
#include <functional>
#include <cstring>
#include <cstdlib>

#pragma comment(lib, "ws2_32.lib")

class Finally
{
private:
    std::function<void ()> func_;

    Finally (const Finally &);
    Finally& operator= (const Finally &);
public:
    Finally (const std::function<void ()> & func) : func_(func) {}
    ~Finally () { func_(); }
};

auto send_string (::SOCKET, const char *) -> bool;

auto main (void) -> int
{
    ::WSADATA wd;
    if (::WSAStartup(MAKEWORD(2,2), &wd))
    {
        std::cerr << "WSAStartup failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 1;
    }
    Finally dtorWsa_([]() { ::WSACleanup(); });

    ::SOCKET s;
    if ((s = ::socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) == INVALID_SOCKET)
    {
        std::cerr << "socket failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 2;
    }
    Finally dtorS_ ([s]() { ::closesocket(s); });

    ::sockaddr_in sai = { 0 };
    sai.sin_family = AF_INET;
    sai.sin_addr.S_un.S_addr = ::inet_addr("127.0.0.1");
    sai.sin_port = ::htons(80);

    if (::connect(s, reinterpret_cast<::sockaddr *>(&sai), sizeof(sai)) == INVALID_SOCKET)
    {
        std::cerr << "connect failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 3;
    }

    if (!send_string(s, "HEAD / HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n"))
    {
        return 4;
    }

    int recved;
    char buffer[4096];
    std::string headReceived;
    while ((recved = ::recv(s, buffer, sizeof(buffer), 0)) != 0 && recved != SOCKET_ERROR)
    {
        std::string temp(buffer + 0, buffer + recved);
        std::cout << temp;
        headReceived += temp;
        if (headReceived.size() > 4 && headReceived.substr(headReceived.size() - 4, 4) == "\r\n\r\n")
        {
            break;
        }
    }
    if (recved == SOCKET_ERROR)
    {
        std::cerr << "recv(1) failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 5;
    }

    auto pos = headReceived.find("\r\nContent-Length: ");
    if (pos == std::string::npos)
    {
        std::cerr << "Not Found Content-Length" << std::endl;
        return 6;
    }
    auto contentLength = std::strtol(headReceived.c_str() + pos + std::strlen("\r\nContent-Length: "), nullptr, 10);
    auto resultLength = headReceived.size() + contentLength;

    if (!send_string(s, "GET / HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n"))
    {
        return 7;
    }

    int readSize = 0;
    while ((recved = ::recv(s, buffer, sizeof(buffer), 0)) != 0 && recved != SOCKET_ERROR)
    {
        std::string temp(buffer + 0, buffer + recved);
        std::cout << temp;
        resultLength -= recved;
        if (resultLength <= 0)
        {
            break;
        }
    }
    if (recved == SOCKET_ERROR)
    {
        std::cerr << "recv(2) failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 8;
    }

    if (::shutdown(s, SD_SEND) == SOCKET_ERROR)
    {
        std::cerr << "shutdown with SD_SEND failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 9;
    }

    while ((recved = ::recv(s, buffer, sizeof(buffer), 0)) != 0 && recved != SOCKET_ERROR)
    {
        std::string temp(buffer + 0, buffer + recved);
        std::cout << temp;
    }
    if (recved == SOCKET_ERROR)
    {
        std::cerr << "recv(3) failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 10;
    }

    if (::shutdown(s, SD_BOTH) == SOCKET_ERROR)
    {
        std::cerr << "shutdown with SD_BOTH failed (" << ::WSAGetLastError() << ")" << std::endl;
        return 11;
    }

    return 0;
}

auto send_string (::SOCKET s, const char * str) -> bool
{
    auto length = std::strlen(str);

    while (length > 0)
    {
        auto ret = ::send(s, str, length, 0);
        if (ret == SOCKET_ERROR)
        {
            std::cerr << "send failed (" << ::WSAGetLastError() << ")" << std::endl;
            return false;
        }
        str += ret;
        length -= ret;
    }
    return true;
}

オフトピック

とりあえず，必要なファイルを残し，不要なファイルを削除して.zipにしてください。
.suoあるのに.slnがなかったり，VS 2010でプロジェクト作ってソースを追加したら，関係のない箇所でエラーになる等，コードを実行するまでに面倒なことが多すぎます。
エラー関連でいうなら，ライブラリとして作るなら，A/Wをきっちり指定すべきです。
さらに，W系を標準とすべきです (特にファイル名)。

非表示エリア

この非表示エリアを表示するには、登録し、ログインする必要があります。

[MoNoQLoREATOR]

なるほど理解しました。
1回分のデータを全て受信し終えるとrecvは0を返すのだと思い込んでいたのがいけなかったのですね。(持続的接続でなければ期待通りだったのですが…)
持続的接続については解決しました。
ありがとうございました。
以下解決コードです。(main.h以外は省略。又、デバッグのための出力は残ったままです)

► スポイラーを表示

コード:

#define _CRT_SECURE_NO_DEPRECATE
#define WIN32_LEAN_AND_MEAN

/*
#include "DxLib.h"
#define FW_DX_DEF_
//*/
#define FW_MAIN_
#define FW_STD_DEF_
//*
#define FW_STD_PROGRAMABLE_DEF_
#define FW_DX_PROGRAMABLE_DEF_
//*/
#include "../safe_fireworks/fireworks.h"

#include "includes.h"



void __cdecl cleanup();

int http()
{
	printf("Do input URL\n");
	char got[256];
	scanf("%s", got);
	std::string url(got);
	vuchar content;


	printf("Now Communicating...\n\n");


	std::string domain;
	std::string uri;
	SOCKET socket;
	SOCKADDR_IN hostinfo;
	uint BodySize = 0;

	// Init Winsock
	{
		printf("Begin = Init Winsock\n");
		const char lobyte = 2;
		const char hibyte = 0;
		WSADATA wsd;
		bool wsdres = WSAStartup(MAKEWORD(lobyte,hibyte), &wsd) == 0;

		if(wsdres)
		{
			bool match = LOBYTE(wsd.wVersion)==lobyte && HIBYTE(wsd.wVersion)==hibyte;
			if(match==false)
			{
				return -1;
			}
		}
		else
		{
			return -1;
		}
		atexit(cleanup);
		printf("Finish = Init Winsock\n\n");
	}

	// Create Socket
	{
		printf("Begin = Create Socket\n");
		socket = ::socket(AF_INET, SOCK_STREAM, 0);
		if(socket == INVALID_SOCKET)
		{
			return -1;
		}
		printf("Finish = Create Socket\n\n");
	}

	// Get Domain and URI
	{
		printf("Begin = Get Domain and URI\n");
		uint slash = url.find('/');
		domain = url.substr(0, slash);
		uri = url.substr(slash);
		printf("Finish = Get Domain and URI\n\n");
	}

	// Get IP
	{
		printf("Begin = Get IP\n");
		hostinfo;
		hostinfo.sin_family = AF_INET;
		hostinfo.sin_port = htons(short(80) );
		ULONG & ref = hostinfo.sin_addr.S_un.S_addr;
		ref = inet_addr(domain.c_str() );
		if(ref==INADDR_NONE)
		{
			HOSTENT * hostent = gethostbyname(domain.c_str() );
			if(hostent==NULL)
			{
				return -1;
			}
			ref = *fw::pointer_cast<uint *>(hostent->h_addr_list[0]);
		}
		printf("Finish = Get IP\n\n");
	}

	// Connect to Server
	{
		printf("Begin = Connect to Server\n");
		if(::connect(socket, fw::pointer_cast<sockaddr *>(&hostinfo), sizeof(hostinfo) ) == SOCKET_ERROR)
		{
			return -1;
		}
		printf("Finish = Connect to Server\n\n");
	}

	// HEAD Request
	{
		printf("Begin = HEAD Request\n");
		std::string request
		=
		fw::cnct() <<
		"HEAD " << uri << " HTTP/1.1" << "\r\n" <<
		"Host: " << domain << "\r\n" <<
		"Content-Length: 0" << "\r\n" <<
		"Connection: Keep-Alive" << "\r\n" <<=
		"\r\n";

		if(::send(socket, request.c_str(), request.length(), 0) == SOCKET_ERROR)
		{
			return -1;
		}
		printf("Finish = HEAD Request\n\n");
	}

	// Receive Header
	{
		printf("Begin = Receive Header\n");
		HTTPheader header;
		header.buffer.setsize(1024);
		uint HeadSize = 0;
		while(true)
		{
			int nBytesRecv = recv(socket, header.bufhead(), header.buffer.size(), 0);
			HeadSize += nBytesRecv;
			if(nBytesRecv == SOCKET_ERROR) return -1;
			if(nBytesRecv == 0)
			{
				printf("'recv' returned 0!\n");
				uchar * last4 = header.buffer.address(header.bufsize()-4);
				printf("\n%d\n%d\n%d\n%d\n\n", last4[0],last4[1],last4[2],last4[3]);
			//	return -1;
				break;
			}
			if(HeadSize >= 4)
			{
				uchar * last4 = header.buffer.address(HeadSize-4);
				if
				(
					last4[0]=='\r' &&
					last4[1]=='\n' &&
					last4[2]=='\r' &&
					last4[3]=='\n'
				)
				{
					printf("\n\\r\\n\\r\\n\n\n");
					break;
				}
			}
		}
		printf("Finish = Receive Header\n\n");

		printf("Begin = Analyze Header\n");
		header.buffer.setsize(HeadSize);
		header.analyze();

		// Show Header
		fw::bfile("header.txt", true).open().clear().write(header.bufhead(), header.bufsize() );
		header.buffer.add('\0');
		printf("header:\n%s\n\n", header.bufhead() );
		header.buffer.pop();

		// Require Buffer for Header and Body
		if(header.UsefulContentLength() )
		{
			BodySize = header.ContentLength();
			content.setsize(HeadSize + 256 + BodySize);
			// debug
			printf("Estimated Size of Header and Body:%d\n", content.size() );
		}
		else
		{
			printf("Not Found UsefulContentLength\n");
			return -1;
		}
		printf("Finish = Analyze Header\n\n");
	}

	// GET Request
	{
		printf("Begin = GET Request\n");
		std::string request
		=
		fw::cnct() <<
		"GET " << uri << " HTTP/1.1" << "\r\n" <<
		"Host: " << domain << "\r\n" <<
		"Content-Length: 0" << "\r\n" <<
		"Connection: Keep-Alive" << "\r\n" <<=
		"\r\n";

		if(::send(socket, request.c_str(), request.length(), 0) == SOCKET_ERROR)
		{
			printf("Failed to Send 'GET Request'\n");
			return -1;
		}
		printf("Finish = GET Request\n\n");
	}

	// Receive Header and Body
	{
		printf("Begin = Receive Header and Body\n");
		uint HeadSize = 0;
		uint total = 0;
		while(true)
		{
			int nBytesRecv = recv(socket, fw::pointer_cast<char *>(content.head() ), content.size(), 0);
			total += nBytesRecv;
			if(nBytesRecv == SOCKET_ERROR)
			{
				printf("SOCKET ERROR\n");
				return -1;
			}
			if(nBytesRecv == 0)
			{
				printf("'recv' returned 0!\n");
				printf("total:%d\n", total);
				printf("HeadSize:%d\n", HeadSize);
				printf("total-HeadSize:%d\n", total-HeadSize);
				printf("Estimated BodySize:%d\n", BodySize);
				break;
			}

			if(HeadSize==0)
			{
				content[total] = '\0';
				const char * endpoint = strstr(fw::pointer_cast<const char *>(content.head() ), "\r\n\r\n");
				if(endpoint!=NULL)
				{
					printf("endpoint was found!\n");
					endpoint += strlen("\r\n\r\n");
					HeadSize = endpoint - fw::pointer_cast<const char *>(content.head() );
					printf("New HeadSize:%d\n", HeadSize);
				}
			}

			if(HeadSize!=0)
			{
				printf("HeadSize != 0\n");
				printf("total-HeadSize:%d\n", total-HeadSize);
				printf("BodySize:%d\n", BodySize);
				if( (total-HeadSize) >= BodySize)
				{
					printf("All Body Received\n");
					break;
				}
			}
		}

		content.setsize(total);

		// Show Header and Body
		content.add('\0');
		printf("Header and Body:\n%s\n", content.head() );
		content.pop();
		printf("Finish = Receive Header and Body\n\n");
	}

	// Disconnect
	{
		shutdown(socket, SD_BOTH);
		closesocket(socket);
	}

	return 0;
}

void __cdecl cleanup(){ WSACleanup(); }

int main()
{
	if(http()==-1) printf("\n\n-ERROR-\n\n");
	char got[256];
	scanf("%s", got);
}

問題はA/Wについてです。(以下オフトピック)

オフトピック

>>エラー関連でいうなら，ライブラリとして作るなら，A/Wをきっちり指定すべきです。
とのことですが、これは例えばMessageBoxならMessageBoxAやMessageBoxWを使えということでしょうか。
それとも　#define　や　#pragma　を用いて指定する方法があるからそれを使えということでしょうか。
また、W系を標準とすべき理由は何でしょう？

[YuO]

>>エラー関連でいうなら，ライブラリとして作るなら，A/Wをきっちり指定すべきです。
とのことですが、これは例えばMessageBoxならMessageBoxAやMessageBoxWを使えということでしょうか。

そうです。

• MessageBoxを使うならば，TCHAR系で統一する
• char系を使いたいならば，MessageBoxAを使う
• wchar_t系を使いたいならば，MessageBoxWを使う

ライブラリのインターフェースとしては，

• インラインで展開される場合を除いて，インターフェースにTCHAR系をそのまま残してはならない
  →UNICODEの有無によって，関数のシグネチャが変わってしまうから
• インライン展開されない場合は，char系のみ，wchar_t系のみ，または両方のどれかのパターンから選択する
  →MessageBoxは両方を用意しているパターン。

という作りにします。

また、W系を標準とすべき理由は何でしょう？

A系を使っているプログラムから，W系のAPIを使った場合にはすべての文字を使うことができます。
しかし，W系を使っているプログラムから，A系のAPIを使った場合には一部の文字しか使えなくなります。
このため，W系を標準とする方が，制限がすくないのです。
特にファイル名と書いたのは，A系のAPIで使える文字の制限によって，ファイルやディレクトリにアクセスできなくなるという，致命的な問題があります。
# ユーザー名に使われていたら(本来の)AppDataにアクセスできないということになります。

[MoNoQLoREATOR]

丁寧なご説明をありがとうございました。
よくわかりました。
地道に書き換えてゆきます。