Linuxプラットフォームsocks 5エージェント
ガイド:先日MSNはなかなか行かなかったので、会社がファイアウォールの制限をしたと思っていました.そこで去年の今頃、エージェントプログラムを変更して、出して使いました.結局MSNはマイクロソフトの問題で、軽蔑しているのでしょうか・・・急いで書いたので、これはTCPエージェントしかサポートしていませんが、UDPの私は書いていません.MSNが使えないからです.このコードは勝手に修正して配布することができますが、私に1部くれたほうがいいです.これはヘッダファイルです.
-
- ///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- // Socks5 ，
- // 0.1，
- // 2007 1 9 1 15 ，GF 11 。
- // 2008 1 25 ， GF ，
- //
- // ：
- // http://www.rfc-editor.org/rfc/rfc1928.txt
- // http://www.rfc-editor.org/rfc/rfc1929.txt
- ///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- #ifndef SOCKS5_H
- #define SOCKS5_H
- #define VERSION 0x05
- #define CONNECT 0x01
- #define IPV4 0x01
- #define DOMAIN 0x03
- #define IPV6 0x04
- typedef struct _method_select_response //
- {
- char version; // Socks ，0x04 0x05
- char select_method;// ，0x00 ，0x02
- } METHOD_SELECT_RESPONSE;
- typedef struct _method_select_request //
- {
- char version; // ，0x04 0x05
- char number_methods; //
- char methods[255]; // ， 255 ，0x00 ，0x02
- } METHOD_SELECT_REQUEST;
- typedef struct _AUTH_RESPONSE //
- {
- char version;// ， 0x01
- char result;// ，0x00 ，
- } AUTH_RESPONSE;
- typedef struct _AUTH_REQUEST //
- {
- char version; // ， 0x01
- char name_len; // ， ， 0xff
- char name[255]; //
- char pwd_len;// ， ， 0xff
- char pwd[255]; //
- } AUTH_REQUEST;
- typedef struct _SOCKS5_RESPONSE // ，Socks
- {
- char version; // Socks ，0x04 0x05
- char reply; // ，0x00
- char reserved; // ， 0x00
- char address_type; // Socks ，IP V4 0x01,IP V6 0x04， 0x03
- char address_port[1]; // address_type ， ， ， 0 , Socks
- }SOCKS5_RESPONSE;
- typedef struct _SOCKS5_REQUEST //
- {
- char version; // Socks ，0x04 0x05
- char cmd; // ，CONNECT 0x01，BIND 0x02，UDP 0x03， 0x01
- char reserved; // ， 0x00
- char address_type; // ，IP V4 0x00,IP V6 0x04， 0x03 char address_port[1]; // address_type ， ， ， 0 ,
- }SOCKS5_REQUEST;
- #endif
- ：
- ///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- // Socks5 ， TCP
- // 0.1，
- // 2007 1 9 1 15 ，GF 11 。
- // 2008 1 25 ， GF ，
- //
- // ：
- // http://www.rfc-editor.org/rfc/rfc1928.txt
- // http://www.rfc-editor.org/rfc/rfc1929.txt
- // ：
- // gcc -o socks5 -O2 Socks5.c -lpthread( RedHat AS5 ）
- ///////////////////////////////////////////////////////////////////////////////////////////////////////////////
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include
- #include "Socks5.h"
- #define MAX_USER 10
- #define BUFF_SIZE 1024
- #define AUTH_CODE 0x02
- #define TIME_OUT 6000000
- #define USER_NAME "yunshu"
- #define PASS_WORD "ph4nt0m"
- // Select auth method, return 0 if success, -1 if failed
- int SelectMethod( int sock )
- {
- char recv_buffer[BUFF_SIZE] = { 0 };
- char reply_buffer[2] = { 0 };
- METHOD_SELECT_REQUEST *method_request;
- METHOD_SELECT_RESPONSE *method_response;
-
- // recv METHOD_SELECT_REQUEST
- int ret = recv( sock, recv_buffer, BUFF_SIZE, 0 );
- if( ret <= 0 )
- {
- perror( "recv error" );
- close( sock );
- return -1;
- }
- //printf( "SelectMethod: recv %d bytes
", ret );
- // if client request a wrong version or a wrong number_method
- method_request = (METHOD_SELECT_REQUEST *)recv_buffer;
- method_response = (METHOD_SELECT_RESPONSE *)reply_buffer;
- method_response->version = VERSION;
-
- // if not socks5
- if( (int)method_request->version != VERSION )
- {
- method_response->select_method = 0xff;
- send( sock, method_response, sizeof(METHOD_SELECT_RESPONSE), 0 );
- close( sock );
-
- return -1;
- }
- method_response->select_method = AUTH_CODE;
- if( -1 == send( sock, method_response, sizeof(METHOD_SELECT_RESPONSE), 0 ) )
- {
- close( sock );
- return -1;
- }
-
- return 0;
- }
- // test password, return 0 for success.
- int AuthPassword( int sock )
- {
- char recv_buffer[BUFF_SIZE] = { 0 };
- char reply_buffer[BUFF_SIZE] = { 0 };
- AUTH_REQUEST *auth_request;
- AUTH_RESPONSE *auth_response;
-
- // auth username and password
- int ret = recv( sock, recv_buffer, BUFF_SIZE, 0 );
- if( ret <= 0 )
- {
- perror( "recv username and password error" );
- close( sock );
- return -1;
- }
- //printf( "AuthPass: recv %d bytes
", ret );
- auth_request = (AUTH_REQUEST *)recv_buffer;
- memset( reply_buffer, 0, BUFF_SIZE );
- auth_response = (AUTH_RESPONSE *)reply_buffer;
- auth_response->version = 0x01;
- char recv_name[256] = { 0 };
- char recv_pass[256] = { 0 };
- // auth_request->name_len is a char, max number is 0xff
- char pwd_str[2] = { 0 };
- strncpy( pwd_str, auth_request->name + auth_request->name_len, 1 );
- int pwd_len = (int)pwd_str[0];
- strncpy( recv_name, auth_request->name, auth_request->name_len );
- strncpy( recv_pass, auth_request->name + auth_request->name_len + sizeof(auth_request->pwd_len), pwd_len );
- //printf( "username: %s
password: %s
", recv_name, recv_pass );
- // check username and password
- if( (strncmp( recv_name, USER_NAME, strlen(USER_NAME) ) == 0) &&
- (strncmp( recv_pass, PASS_WORD, strlen(PASS_WORD) ) == 0)
- )
- {
- auth_response->result = 0x00;
- if( -1 == send( sock, auth_response, sizeof(AUTH_RESPONSE), 0 ) )
- {
- close( sock );
- return -1;
- }
- else
- {
- return 0;
- }
- }
- else
- {
- auth_response->result = 0x01;
- send( sock, auth_response, sizeof(AUTH_RESPONSE), 0 );
- close( sock );
- return -1;
- }
- }
- // parse command, and try to connect real server.
- // return socket for success, -1 for failed.
- int ParseCommand( int sock )
- {
- char recv_buffer[BUFF_SIZE] = { 0 };
- char reply_buffer[BUFF_SIZE] = { 0 };
-
- SOCKS5_REQUEST *socks5_request;
- SOCKS5_RESPONSE *socks5_response;
- // recv command
- int ret = recv( sock, recv_buffer, BUFF_SIZE, 0 );
- if( ret <= 0 )
- {
- perror( "recv connect command error" );
- close( sock );
- return -1;
- }
-
- socks5_request = (SOCKS5_REQUEST *)recv_buffer;
- if( (socks5_request->version != VERSION) || (socks5_request->cmd != CONNECT) ||
- (socks5_request->address_type == IPV6) )
- {
- //printf( "connect command error.
" );
- close( sock );
- return -1;
- }
- // begain process connect request
- struct sockaddr_in sin;
- memset( (void *)&sin, 0, sizeof(struct sockaddr_in) );
- sin.sin_family = AF_INET;
- // get real server's ip address
- if( socks5_request->address_type == IPV4 )
- {
- memcpy( &sin.sin_addr.s_addr, &socks5_request->address_type + sizeof(socks5_request->address_type) , 4 );
- memcpy( &sin.sin_port, &socks5_request->address_type + sizeof(socks5_request->address_type) + 4, 2 );
- //printf( "Real Server: %s %d
", inet_ntoa( sin.sin_addr ), ntohs( sin.sin_port ) );
- }
- else if( socks5_request->address_type == DOMAIN )
- {
- char domain_length = *(&socks5_request->address_type + sizeof(socks5_request->address_type));
- char target_domain[ 256] = { 0 };
- strncpy( target_domain, &socks5_request->address_type + 2, (unsigned int)domain_length );
- //printf( "target: %s
", target_domain );
- struct hostent *phost = gethostbyname( target_domain );
- if( phost == NULL )
- {
- //printf( "Resolve %s error!
" , target_domain );
- close( sock );
- return -1;
- }
- memcpy( &sin.sin_addr , phost->h_addr_list[0] , phost->h_length );
- memcpy( &sin.sin_port, &socks5_request->address_type + sizeof(socks5_request->address_type) +
- sizeof(domain_length) + domain_length, 2 );
- }
- // try to connect to real server
- int real_server_sock = socket( AF_INET, SOCK_STREAM, 0 );
- if( real_server_sock <0 )
- {
- perror( "Socket creation failed
");
-
- close( sock );
- return -1;
- }
- memset( reply_buffer, 0, sizeof(BUFF_SIZE) );
- socks5_response = (SOCKS5_RESPONSE *)reply_buffer;
- socks5_response->version = VERSION;
- socks5_response->reserved = 0x00;
- socks5_response->address_type = 0x01;
- memset( socks5_response + 4, 0 , 6 );
- ret = connect( real_server_sock, (struct sockaddr *)&sin, sizeof(struct sockaddr_in) );
- if( ret == 0 )
- {
- socks5_response->reply = 0x00;
- if( -1 == send( sock, socks5_response, 10, 0 ) )
- {
- close( sock );
-
- return -1;
- }
- }
- else
- {
- perror( "Connect to real server error" );
- socks5_response->reply = 0x01;
- send( sock, socks5_response, 10, 0 );
-
- close( sock );
- return -1;
- }
-
- return real_server_sock;
- }
- int ForwardData( int sock, int real_server_sock )
- {
- char recv_buffer[BUFF_SIZE] = { 0 };
-
- fd_set fd_read;
- struct timeval time_out;
- time_out.tv_sec = 0;
- time_out.tv_usec = TIME_OUT;
-
- int ret = 0;
-
- while( 1 )
- {
- FD_ZERO( &fd_read );
- FD_SET( sock, &fd_read );
- FD_SET( real_server_sock, &fd_read );
- ret = select( (sock >real_server_sock ? sock : real_server_sock) + 1, &fd_read, NULL, NULL, &time_out );
- if( -1 == ret )
- {
- perror( "select socket error" );
- break;
- }
- else if( 0 == ret )
- {
- //perror( "select time out" );
- continue;
- }
-
- //printf( "[DEBUG] testing readable!
" );
- if( FD_ISSET(sock, &fd_read) )
- {
- //printf( "client can read!
" );
- memset( recv_buffer, 0, BUFF_SIZE );
- ret = recv( sock, recv_buffer, BUFF_SIZE, 0 );
- if( ret >0 )
- {
- //printf( "%s", recv_buffer );
- //printf( "recv %d bytes from client.
", ret );
- ret = send( real_server_sock, recv_buffer, ret, 0 );
- if( ret == -1 )
- {
- perror( "send data to real server error" );
- break;
- }
- //printf( "send %d bytes to client!
", ret );
- }
- else if( ret == 0 )
- {
- //printf( "client close socket.
" );
- break;
- }
- else
- {
- //perror( "recv from client error" );
- break;
- }
- }
-
- else if( FD_ISSET(real_server_sock, &fd_read) )
- {
- //printf( "real server can read!
" );
- memset( recv_buffer, 0, BUFF_SIZE );
- ret = recv( real_server_sock, recv_buffer, BUFF_SIZE, 0 );
- if( ret >0 )
- {
- //printf( "%s", recv_buffer );
- //printf( "recv %d bytes from real server.
", ret );
- ret = send( sock, recv_buffer, ret, 0 );
- if( ret == -1 )
- {
- perror( "send data to client error" );
- break;
- }
- }
- else if( ret == 0 )
- {
- //printf( "real server close socket.
" );
- break;
- }
- else
- {
- perror( "recv from real server error" );
- break;
- }
- }
- }
-
- return 0;
- }
- int Socks5( void *client_sock )
- {
- int sock = *(int *)client_sock;
- if( SelectMethod( sock ) == -1 )
- {
- //printf( "socks version error
" );
- return -1;
- }
-
- if( AuthPassword( sock ) == -1 )
- {
- //printf( "auth password error
" );
- return -1;
- }
-
- int real_server_sock = ParseCommand( sock );
- if( real_server_sock == -1 )
- {
- //printf( "parse command error.
" );
- return -1;
- }
-
- ForwardData( sock, real_server_sock );
- close( sock );
- close( real_server_sock );
-
- return 0;
- }
- int main( int argc, char *argv[] )
- {
- if( argc != 2 )
- {
- printf( "Socks5 proxy for test,code by YunShu
" );
- printf( "Usage: %s
", argv[0] );
- printf( "Options:
" );
- printf( " ---which port of this proxy server will listen.
" );
-
- return 1;
- }
- struct sockaddr_in sin;
- memset( (void *)&sin, 0, sizeof( struct sockaddr_in) );
- sin.sin_family = AF_INET;
- sin.sin_port = htons( atoi(argv[1]) );
- sin.sin_addr.s_addr = htonl(INADDR_ANY);
- int listen_sock = socket( AF_INET, SOCK_STREAM, 0 );
- if( listen_sock <0 )
- {
- perror( "Socket creation failed
");
- return -1;
- }
- int opt = SO_REUSEADDR;
- setsockopt( listen_sock, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt) );
- if( bind( listen_sock, (struct sockaddr*)&sin, sizeof(struct sockaddr_in) ) <0 )
- {
- perror( "Bind error" );
- return -1;
- }
- if( listen( listen_sock, MAX_USER ) <0 )
- {
- perror( "Listen error" );
- return -1;
- }
- struct sockaddr_in cin;
- int client_sock;
- int client_len = sizeof( struct sockaddr_in );
- while( client_sock = accept( listen_sock, (struct sockaddr *)&cin, (socklen_t *)&client_len ) )
- {
- printf( "Connected from %s, processing......
", inet_ntoa( cin.sin_addr ) );
- pthread_t work_thread;
- if( pthread_create( &work_thread, NULL, (void *)Socks5, (void *)&client_sock ) )
- {
- perror( "Create thread error..." );
- close( client_sock );
- }
- else
- {
- pthread_detach( work_thread );
- }
- }
- }