Добрый вечер
Написал простой прокси.
Идея такова:
0. Запускаем Оперу и в настройках указываем наш прокси-сервер
1. Получаем запрос от клиента
2. Разбираем его по строчкам
3. "Склеиваем" новый запрос
2. Передаём этот запрос хосту
3. Принимаем ответ хоста
4. Передаём ответ клиенту
Когда пробовал на Денвере - то всё прекрасно работает.
Но вот когда пытаешься открыть www.ya.ru или www.rambler.ru, например, то ничего не выходит, браузер показывает просто белую страницу :(
И вторая проблема: если после того, как отработает функция ParserRequest, вывести на экран массив totalbuf, то в нём содержится только первая строка запроса + User-Agent. Всё остальное как будто затирается. В чём может быть причина?
Пример запроса от браузера:
| Код |
GET http://www.ya.ru/ HTTP/1.1
User-Agent: Opera/9.80 (Windows NT 6.1; U; ru) Presto/2.10.229 Version/11.60
Host: www.ya.ru
Accept: text/html, application/xml;q=0.9, application/xhtml+xml, image/png, image/webp, image/jpeg, image/gif, image/x-xbitmap, */*;q=0.1
Accept-Language: ru-RU,ru;q=0.9,en;q=0.8
Accept-Encoding: gzip, deflate
Cookie: yandexuid=5594903511330216492
Pragma: no-cache
Cache-Control: no-cache
Connection: Keep-Alive
|
Вот ответ www.ya.ru на этот запрос:
| Код |
HTTP/1.1 200 Ok
Server: nginx
Date: Mon, 05 Mar 2012 18:20:46 GMT
Content-Type: text/html; charset=UTF-8
Transfer-Encoding: chunked
Connection: close
Cache-Control: no-cache,no-store,max-age=0,must-revalidate
Expires: Mon, 05 Mar 2012 18:20:46 GMT
Last-Modified: Mon, 05 Mar 2012 18:20:46 GMT
P3P: policyref="/w3c/p3p.xml", CP="NON DSP ADM DEV PSD IVDo OUR IND STP PHY PRE NAV UNI"
X-XRDS-Location: http://openid.yandex.ru/server_xrds/
Content-Encoding: gzip
|
Далее идёт следующий запрос от браузера:
| Код |
GET http://www.ya.ru/favicon.ico HTTP/1.1
User-Agent: Opera/9.80 (Windows NT 6.1; U; ru) Presto/2.10.229 Version/11.60
Host: www.ya.ru
Accept: text/html, application/xml;q=0.9, application/xhtml+xml, image/png, image/webp, image/jpeg, image/gif, image/x-xbitmap, */*;q=0.1
Accept-Language: ru-RU,ru;q=0.9,en;q=0.8
Accept-Encoding: gzip, deflate
Pragma: no-cache
Cache-Control: no-cache
Connection: Keep-Alive
|
И соответственно ответ на него:
| Код |
HTTP/1.1 200 OK
Server: nginx
Date: Mon, 05 Mar 2012 18:20:46 GMT
Content-Type: image/x-icon
Content-Length: 1150
Last-Modified: Fri, 02 Mar 2012 18:45:48 GMT
Connection: close
Accept-Ranges: bytes
|
Вот код прокси:
| Код |
// Подключаем необходимые библиотеки
#include "stdafx.h"
#include <winsock2.h>
#include <windows.h>
#include <process.h>
#include <stdio.h>
#include <string.h>
#include <iostream>
#pragma comment (lib, "ws2_32.lib")
// Определяем параметры прокси: порт и ip-адрес
#define PROXY_PORT 7777 // порт прокси
#define PROXY_IP "192.168.126.10" // ip-адрес прокси-сервера
// Определяем ключевые слова для разбора запроса клиента
#define HTTP "http://"
#define USER_AGENT "User-Agent:"
#define HOST "Host:"
#define ACCEPT "Accept:"
#define ACCEPT_LANGUAGE "Accept-Language:"
#define ACCEPT_ENCODING "Accept-Encoding:"
#define PRAGMA "Pragma:"
#define CACHE_CONTROL "Cache-Control:"
#define CONNECTION "Connection:"
#define COOKIE "Cookie:"
#define REFERER "Referer:"
#define ACCEPT_CHARSET "Accept-Charset:"
#define EMPTY_STRING "\r\n"
// Структура с параметрами прокси, когда он будет подключаться к хосту
struct ProxyParam
{
char HostAddress[128]; // IP-Адрес хоста
char HostName[256];// Имя хоста
int HostPort; // ПОрт, по которому будет соединение с хостом
};
// Структура для разбора запроса клиента
struct ProxyRequest
{
char Command [10];
char URL [512];
char Protocol [10];
char User_Agent[1024];
char Host[256];
char Accept[1024];
char Referer [256];
char Accept_Language[50];
char Accept_Encoding[50];
char Accept_Charset [50];
char Cookie [2048];
char Pragma[10];
char Cache_Control[15];
char Сonnection[15];
};
// Вспомогательная функция для разбора запроса клинта.
void func ( char *a, char *b, char *c)//char *buf)
{
if(a) // если в p не ноль, т.е. в нашем массиве buf всё таки было вхождение 'User-Agent:'
{
int i;
a+=strlen(b); //прибавляем к указателю р длину 'User-Agent:'
for(i=0;i<strlen(a);i++) //
if( *(a+i)=='\r') break; //получаем значение, которое следует за 'User-Agent:'
*(a+i)=0;
strcpy(c,a);
}
}
// Функция разбора запроса клиента
int ParserRequest (char *str, struct ProxyRequest *pRequest)
{
char *url, *u, *h, *a, *r, *al, *ae, *ac, *pr, *cc, *con, *cok; // Указатели для поиска в запросе ключевых слов
sscanf(str,"%s%s%s",pRequest->Command, pRequest->URL, pRequest->Protocol);
u = strstr(str, USER_AGENT); //
h = strstr(str, HOST);
a = strstr(str, ACCEPT);
r = strstr (str, REFERER);
al = strstr(str, ACCEPT_LANGUAGE);
ae = strstr(str, ACCEPT_ENCODING);
ac = strstr (str, ACCEPT_CHARSET);
cok = strstr(str, COOKIE);
pr = strstr(str, PRAGMA);
cc = strstr(str, CACHE_CONTROL);
con = strstr(str, CONNECTION);
func (u, USER_AGENT, pRequest->User_Agent);
func (h, HOST, pRequest->Host);
func (a, ACCEPT, pRequest->Accept);
func (r, REFERER, pRequest->Referer);
func (al, ACCEPT_LANGUAGE, pRequest->Accept_Language);
func (ae, ACCEPT_ENCODING, pRequest->Accept_Encoding);
func (ac, ACCEPT_CHARSET, pRequest->Accept_Charset);
func (cok, COOKIE, pRequest->Cookie);
func (pr, PRAGMA, pRequest->Pragma);
func (cc, CACHE_CONTROL, pRequest->Cache_Control);
func (con, CONNECTION, pRequest->Сonnection);
return 1;
}
int GetAddressAndPort (char *str, char *address, int *port)
{
char buf[256], command[5], proto[10], *p;
int i, j;
sscanf (str, "%s%s%s", command, buf, proto);
p=strstr(buf,HTTP); //ищем вхождение http:// в нашем массиве buf. если вхождение нашлось, то в p будет указатель на это вхождение.
//HTTP
if(p) // если в p не ноль, т.е. в нашем массиве buf всё таки было вхождение http://
{
p+=strlen(HTTP); //прибавляем к указателю р длину 'http://'
for(i=0;i<strlen(p);i++) //
if( *(p+i)=='/') break; //получаем адрес хоста, к которому обращается клиент
*(p+i)=0;
strcpy(address,p); //копируем в переменную address наш указатель p, т.е. как раз адрес сервера
*port=80; //default http port
}
return 1;
}
// Функция для сцепления строк изменённого запроса
char *UnionModifiedRequest(char *s1, ...)
{ char **cp = &s1; //--адрес первого указателя
int len = 0;
// цикл для определения общей длины сцепляемых строк
while (*cp) { len += strlen(*cp); cp++; }
char *s = new char[len+1]; //--память для строки
s[0]=0; //-- "очищаем" строку
// цикл для сцепления строк
cp=&s1; //-- опять установка на 1-й параметр
while (*cp)
{ strcat(s, *cp); //-- прицепляем первую (и следующие)
cp++; //-- перемещаемся на следующую
}
return s;
}
int Proxy (LPVOID clientsocket) // Основная функция
{
char totalbuf[10240];
struct in_addr host2_addr; //
int retval, len;
SOCKET hostsocket;
struct hostent *ht;
char *host_name;
int i;
ProxyParam pProxy; // Структура с параметрами прокси - Имя и Адрес хоста, а так же номер порта куда подключаться после запроса клиента
struct ProxyRequest proxyRequest; // Структура с разобранным запросом клиента
struct ProxyRequest modifiedRequest; // Структура с изменённым запросом клиента
struct sockaddr_in host_addr;
hostsocket = socket(AF_INET, SOCK_STREAM, 0); // Определяем сокет хоста, по которому будет происходить подключение от прокси к хосту
ZeroMemory(totalbuf, sizeof(totalbuf)); // Обнуляем массив для приёма запроса от клиента
retval = recv((SOCKET)clientsocket, totalbuf, sizeof(totalbuf), 0); // Приняли запрос от клиента
printf("\n Received %d bytes,data\n[%s]\nfrom client\n",retval,totalbuf);
len = retval; // Размер принятых данных, т.е. размер запроса
ZeroMemory (pProxy.HostName, sizeof(pProxy.HostName));
GetAddressAndPort (totalbuf, pProxy.HostName, &pProxy.HostPort); // Получаем из массива Имя хоста
host_name = pProxy.HostName;
ht = gethostbyname (host_name); // Получаем IP-адрес хоста, к которому хочет подключиться клиент
i=0;
while (ht->h_addr_list[i] != 0)
{
host2_addr.s_addr = *(u_long *)ht->h_addr_list[i++];
}
ZeroMemory(&host_addr, sizeof(host_addr));
// Заполняем адресную информацию для подключения к хосту
host_addr.sin_family = AF_INET;
host_addr.sin_addr.s_addr = host2_addr.s_addr;
host_addr.sin_port = htons(pProxy.HostPort); // Номер порта получили в функции GetAddressAndPort
if (connect(hostsocket, (struct sockaddr *)&host_addr, sizeof(host_addr)) == SOCKET_ERROR) // Устанавливаем соединение с хостом
{
printf ("Connect () Error: %d\n", WSAGetLastError());
return -1;
}
ZeroMemory (&proxyRequest, sizeof(proxyRequest));
ParserRequest (totalbuf, &proxyRequest); // Разбираем запрос клиента и сохраняем результаты в структуру pRequest.
char *ss = UnionModifiedRequest(proxyRequest.Command, " ", proxyRequest.URL, " ", proxyRequest.Protocol, EMPTY_STRING,
USER_AGENT, proxyRequest.User_Agent, EMPTY_STRING,
HOST, proxyRequest.Host, EMPTY_STRING,
ACCEPT, proxyRequest.Accept, EMPTY_STRING,
ACCEPT_LANGUAGE, proxyRequest.Accept_Language, EMPTY_STRING,
ACCEPT_ENCODING, proxyRequest.Accept_Encoding, EMPTY_STRING,
COOKIE, proxyRequest.Cookie, EMPTY_STRING,
PRAGMA, " no-cache", EMPTY_STRING,
CACHE_CONTROL, proxyRequest.Cache_Control, EMPTY_STRING,
CONNECTION, proxyRequest.Сonnection, EMPTY_STRING, EMPTY_STRING, 0);
retval = send(hostsocket, ss, strlen(ss), 0); // Посылаем принятые данные от клиента хосту
if(retval == SOCKET_ERROR)
{
printf ("send () Error: %d\n", WSAGetLastError());
closesocket (hostsocket);
}
ZeroMemory(totalbuf, sizeof(totalbuf));
len = 0;
retval = recv((SOCKET)hostsocket, totalbuf, sizeof(totalbuf), 0); // Принимаем ответ хоста на посланный запрос
if (retval == INVALID_SOCKET)
{
printf ("\nError Recv.");
closesocket ((SOCKET)hostsocket);
}
printf("\n Received %d bytes,data\n[%s]\nfrom server\n",len,totalbuf);
len = retval;
closesocket (hostsocket); // Закрыли соединение с хостом
retval = send ((SOCKET)clientsocket, totalbuf, len, 0); // Пересылаем ответ хоста клиенту
if (retval == SOCKET_ERROR)
{
printf ("send () Error: %d\n", WSAGetLastError());
closesocket ((SOCKET)clientsocket);
}
closesocket((SOCKET)clientsocket); // Закрыли соединение с клиентом
return 0;
}
int main(void)
{
setlocale(LC_ALL, "Russian"); // Для отображения кириллицы в консоли
WSADATA wsd; // Для инициализации библиотеки сокетов
SOCKET listensocket, clientsocket; // дескрипторы сокетов
struct sockaddr_in server_addr, client_addr; // Адресная информация самого прокси и клиента
struct hostent *client; //
if(WSAStartup (0x201, &wsd) != 0) //Инициализируем библиотеку сокетов
{
printf ("\n Error in Startup session.\n");
WSACleanup();
return -1;
}
// Заполняем адресную информацию для соединения с клиентом
server_addr.sin_family = AF_INET; // Адресное семество
server_addr.sin_addr.s_addr = INADDR_ANY; //
server_addr.sin_port = htons(PROXY_PORT); // Порт, на котором "висит" прокси (7777)
listensocket = socket(AF_INET, SOCK_STREAM, 0); // Определяем сокет прокси, на котором будет происходить прослушивание сети
if (listensocket == INVALID_SOCKET)
{
printf ("\n Error in New a Socket.");
WSACleanup();
return -2;
}
if (bind(listensocket, (struct sockaddr *)&server_addr, sizeof(server_addr)) != 0)
{
printf ("\n Error in Binding socket.");
WSACleanup();
return -3;
}
if (listen (listensocket, 5) != 0) // Создаём очередь на прослушивание сети, максимум 5 подключений
{
printf ("\n Error in Listen.");
WSACleanup ();
return -4;
}
int size_of_cli = sizeof(client_addr); // Размер структуры sockaddr_in client_addr с адресной информацией клиента
while (1)
{
// Принимаем соединение от клиента к прокси на сокет клиента
clientsocket = accept(listensocket, (struct sockaddr *)&client_addr, &size_of_cli);
if (clientsocket == INVALID_SOCKET)
{
printf ("\n Error in Accept.");
WSACleanup();
return -5;
}
else
{
client = gethostbyaddr ((char *)&client_addr.sin_addr.s_addr, 4, AF_INET); // Получаем информацию о клиенте, который к нам подключается
Proxy ((LPVOID) clientsocket);
}
}
return 1;
}
|
Сразу пояснения:
1. Необходимо разбирать запрос
2. Если отсылать оригинальный запрос, то www.ya.ru отвечает "Bad Request, видимо - на отсутствие параметра Pragma. Поэтому когда "склеиваем" новый запрос, вставляем этот параметр вручную
Буду признателен за помощь 
Спасибо. |
