HTTP通信のリクエスト送信とレスポンス確認（WinInet API使用）

解説

HTTP通信を実装する方法としては、WindowsソケットAPI を利用する方法、WinInet API を利用する方法、MFC を利用する方法、などがあります。

ここでは、WinInet API を利用した、HTTP通信のリクエスト送信とレスポンス確認、の方法をまとめます。
WinInet API を利用する方法は、WindowsソケットAPI を利用する方法に比べて、SSL通信（https://～に対する通信）の処理を楽に実装できるという利点があります。
WinInet API を利用する方法は、MFC を利用する方法に比べて、MFC を利用できない、利用したくない場合でも実装できるという利点があります。

準備

・windows.h および Wininet.h のインクルード

#include <windows.h>
#include <Wininet.h>
をファイルヘッダー部に追加します。
これにより、WinInet API が使えるようになります。

・Wininet.lib のリンク

#pragma comment( lib, "Wininet.lib" )
をファイルヘッダー部に記述することにより、Wininet.lib をリンクするファイルへ追加します。
これにより、WinInet APIがリンクされるようになります。
（リンクするファイルの追加の方法には、#pragma comment( lib, libファイル名 ) をソースに記述する方法の他にも、プロジェクトのプロパティ「構成プロパティ > リンカ > 入力 > 追加の依存ファイル」に libファイル名 を追記する方法、などもあります。）

手続き

１．URLの解析

InternetCrackUrl 関数を利用し、URLを解析し、HTTP通信かHTTPS通信か、通信先ホスト名、通信先URLパス、通信先ポート番号を求めます。

２．WinInetの初期化

InternetOpen 関数を利用し、WinInetの初期化を行います。
インターネットアクセスの方法として、直接アクセスか、プロキシアクセスがあります。インターネットアクセスの方法として、レジストリの設定に従うように、アクセスタイプ引数は、INTERNET_OPEN_TYPE_PRECONFIG を指定します。

３．HTTP接続

InternetConnect 関数を利用し、HTTP接続します。
通信先ホスト名、通信先ポート番号、を引数として指定します。
インターネットサービスタイプ引数は、HTTP通信なので、INTERNET_SERVICE_HTTP を指定します。

４．HTTP接続を開く

HttpOpenRequest 関数を利用し、HTTP接続を開きます。
通信先URLパスを指定します。GETメソッドによる通信の場合には、通信先URLパスの末尾にリクエストパラメータを「&」で連結したものを指定します。
Verb引数は、GETメソッドの場合は、"GET"を、POSTメソッドの場合は、"POST"を指定します。
Flags引数は、HTTPSの場合には、HTTPの場合のフラグに加えて、セキュア通信のためのフラグを指定します。

５．リクエストの送信

HttpSendRequest 関数を利用し、HTTPリクエストを送信します。
リクエストヘッダー、リクエストパラメータを指定します。

６．ステータスコードの取得

HttpQueryInfo 関数を利用し、ステータスコードを取得します。
ステータスコードの取得においては、InfoLevel引数として、HTTP_QUERY_STATUS_CODE | HTTP_QUERY_FLAG_NUMBER を指定します。

７．レスポンスデータ読み込み

InternetReadFile 関数を利用し、レスポンスデータを読み込みます。

サンプルコード

#include <windows.h> #include <Wininet.h> #include <assert.h> #include <string> #include <sstream> #include <locale.h> #include <conio.h> #include "NhConversion.h" #pragma comment( lib, "Wininet.lib" ) typedef std::basic_string<TCHAR> tstring; typedef std::basic_stringstream<TCHAR> tstringstream; #define URLBUFFER_SIZE (4096) #define READBUFFER_SIZE (4096) bool HttpRequest( tstring strUserAgent, tstring strUrl, bool bIsHttpVerbGet, tstring strParameter, tstring& rstrResult ) { // アウトプットの初期化 rstrResult = tstring(); // インプットのチェック if( 0 == strUrl.length() ) { assert( !"URLが不正" ); return false; } // 変数 HINTERNET hInternetOpen = NULL; HINTERNET hInternetConnect = NULL; HINTERNET hInternetRequest = NULL; char* pszOptional = NULL; URL_COMPONENTS urlcomponents; tstring strServer; tstring strObject; INTERNET_PORT nPort; tstring strVerb; tstring strHeaders; tstringstream ssRead; // URL解析 ZeroMemory( &urlcomponents, sizeof(URL_COMPONENTS) ); urlcomponents.dwStructSize = sizeof(URL_COMPONENTS); TCHAR szHostName[URLBUFFER_SIZE]; TCHAR szUrlPath[URLBUFFER_SIZE]; urlcomponents.lpszHostName = szHostName; urlcomponents.lpszUrlPath = szUrlPath; urlcomponents.dwHostNameLength = URLBUFFER_SIZE; urlcomponents.dwUrlPathLength = URLBUFFER_SIZE; if( !InternetCrackUrl( strUrl.c_str(), (DWORD)strUrl.length(), 0, &urlcomponents ) ) { // URLの解析に失敗 assert( !"URL解析に失敗" ); return false; } strServer = urlcomponents.lpszHostName; strObject = urlcomponents.lpszUrlPath; nPort = urlcomponents.nPort; // HTTPかHTTPSかそれ以外か DWORD dwFlags = 0; if( INTERNET_SCHEME_HTTP == urlcomponents.nScheme ) { // HTTP dwFlags = INTERNET_FLAG_RELOAD // 要求されたファイル、オブジェクト、またはフォルダ一覧を、キャッシュからではなく、元のサーバーから強制的にダウンロードします。 | INTERNET_FLAG_DONT_CACHE // 返されたエンティティをキャシュへ追加しません。 | INTERNET_FLAG_NO_AUTO_REDIRECT; // HTTP だけで使用され、リダイレクトが HttpSendRequest で処理されないことを指定します。 } else if( INTERNET_SCHEME_HTTPS == urlcomponents.nScheme ) { // HTTPS dwFlags = INTERNET_FLAG_RELOAD // 要求されたファイル、オブジェクト、またはフォルダ一覧を、キャッシュからではなく、元のサーバーから強制的にダウンロードします。 | INTERNET_FLAG_DONT_CACHE // 返されたエンティティをキャシュへ追加しません。 | INTERNET_FLAG_NO_AUTO_REDIRECT // HTTP だけで使用され、リダイレクトが HttpSendRequest で処理されないことを指定します。 | INTERNET_FLAG_SECURE // 安全なトランザクションを使用します。これにより、SSL/PCT を使うように変換され、HTTP 要求だけで有効です。 | INTERNET_FLAG_IGNORE_CERT_DATE_INVALID // INTERNET_FLAG_IGNORE_CERT_DATE_INVALID、INTERNET_FLAG_IGNORE_CERT_CN_INVALID | INTERNET_FLAG_IGNORE_CERT_CN_INVALID; // は、証明書に関する警告を無視するフラグ } else { assert( !"HTTPでもHTTPSでもない" ); return false; } // GETかPOSTか if( bIsHttpVerbGet ) { // GET strVerb = _T("GET"); strHeaders = _T(""); if( 0 != strParameter.length() ) { // オブジェクトとパラメータを「?」で連結 strObject += _T("?") + strParameter; } } else { // POST strVerb = _T("POST"); strHeaders = _T("Content-Type: application/x-www-form-urlencoded"); if( 0 != strParameter.length() ) { // パラメータを、送信するオプションデータに変換する pszOptional = NhT2M( strParameter.c_str() ); // char文字列に変換 } } // WinInetの初期化 hInternetOpen = InternetOpen( strUserAgent.c_str(), INTERNET_OPEN_TYPE_PRECONFIG, NULL, NULL, 0 ); if( NULL == hInternetOpen ) { assert( !"WinInetの初期化に失敗" ); goto LABEL_ERROR; } // HTTP接続 hInternetConnect = InternetConnect( hInternetOpen, strServer.c_str(), nPort, NULL, NULL, INTERNET_SERVICE_HTTP, 0, 0 ); if( NULL == hInternetConnect ) { assert( !"HTTP接続に失敗" ); goto LABEL_ERROR; } // HTTP接続を開く hInternetRequest = HttpOpenRequest( hInternetConnect, strVerb.c_str(), strObject.c_str(), NULL, NULL, NULL, dwFlags, NULL ); if( NULL == hInternetRequest ) { assert( !"HTTP接続を開くに失敗" ); goto LABEL_ERROR; } // HTTP要求送信 if( !HttpSendRequest( hInternetRequest, strHeaders.c_str(), (DWORD)strHeaders.length(), (LPVOID)((char*)pszOptional), pszOptional ? (DWORD)(strlen(pszOptional) * sizeof(char)) : 0 ) ) { assert( !"HTTP要求送信に失敗" ); goto LABEL_ERROR; } // HTTP要求に対応するステータスコードの取得 DWORD dwStatusCode; DWORD dwLength = sizeof(DWORD); if( !HttpQueryInfo( hInternetRequest, HTTP_QUERY_STATUS_CODE | HTTP_QUERY_FLAG_NUMBER, &dwStatusCode, &dwLength, 0 ) ) { assert( !"HTTP要求に対応するステータスコードの取得に失敗" ); goto LABEL_ERROR; } if( HTTP_STATUS_OK != dwStatusCode ) { assert( !"ステータスコードがOKでない" ); goto LABEL_ERROR; } // HTTPファイル読み込み char szReadBuffer[READBUFFER_SIZE + 1]; while( 1 ) { DWORD dwRead = 0; if( !InternetReadFile( hInternetRequest, szReadBuffer, READBUFFER_SIZE, &dwRead ) ) { assert( !"HTTPファイル読み込みに失敗" ); goto LABEL_ERROR; } if( 0 == dwRead ) { break; } szReadBuffer[dwRead] = '\0'; // 終端文字「\0」の付加 size_t length = dwRead + 1; LPWSTR pszWideChar = (LPWSTR)malloc( length * sizeof(WCHAR) ); MultiByteToWideChar( CP_UTF8, // CODE PAGE: UTF-8 0, szReadBuffer, -1, pszWideChar, (int)length ); // UTF-8文字列をANSI文字列に変換 TCHAR* pszTchar = NhW2T( pszWideChar ); // WideChar文字列をTCHAR文字列に変換 ssRead << pszTchar; // ストリーム文字列に流し込む free( pszTchar ); free( pszWideChar ); } // ストリーム文字列を、出力文字列に変換 rstrResult = ssRead.str().c_str(); if( pszOptional ){ free( pszOptional ); } InternetCloseHandle(hInternetRequest); InternetCloseHandle(hInternetConnect); InternetCloseHandle(hInternetOpen); return true; LABEL_ERROR: if( pszOptional ){ free( pszOptional ); } InternetCloseHandle(hInternetRequest); InternetCloseHandle(hInternetConnect); InternetCloseHandle(hInternetOpen); return false; } int _tmain(int argc, _TCHAR* argv[]) { tstring strUserAgent = _T("HttpRequestTest"); tstring strUrl = _T("http://weather.livedoor.com/forecast/webservice/json/v1"); bool bIsHttpVerbGet = true; tstring strParameter = _T("city=400040"); tstring strResult; if( !HttpRequest( strUserAgent, strUrl, bIsHttpVerbGet, strParameter, strResult ) ) { return false; } setlocale( LC_ALL, "Japanese" ); _tprintf( _T("%s"), strResult.c_str() ); _getch(); return 0; }

サンプルコードアプリケーション実行結果

ダウンロード

サンプルプロジェクト

関連ページ

HTTP通信のリクエスト送信とレスポンス確認（WinHTTP API使用）（同期通信）

HTTP通信のリクエスト送信とレスポンス確認（WinHTTP API使用）（非同期通信）