Forum PHP.pl

Jak zbudować nagłówek tcp/ip w php? Wiem jak to zrobić w C, ale chciałbym to w php.

Jakieś szczegóły? php to trochę inny poziom warstwy komunikacyjnej. W jakim celu chcesz budować nagłówek TCP/IP w php?

Buduję server proxy, potrzebuję zamaskować adres IP.

Piszesz serwer proxy w php? Jesteś pewien, że to dobry pomysł?

dlaczego, działa całkiem sprawnie.

Kod jest opensource? Mógłbyś podać jakiś namiar gdzie można obejrzeć źródła?

Widzę, że nikt poza mną nie zainteresował się na razie twoim pytaniem. To dość dziwne, bo to ciekawy temat.

Skoro wiesz jak zbudować nagłówek w C to kod w php sprowadza się do przetłumaczenia tego co już masz. Udostępnij fragment kodu w C - będzie można się do niego odnieść.

ok zaraz nadeślę

hehe, racja dragossani. Zresztą temat serwerów w php sam już poruszałem. Również chciałbym coś takiego zobaczyć. Aha, i jestem ciekawy w jaki sposób odczytujesz dane przekazane przez użytkownika i jak na nie odpowiadasz (readline, print, czy jak??), bo ten problem mnie już dawno męczy.

server komunikuje się na jakimś porcie, po prostu czytac z okreslonego portu, aby dowiedzieć się jaki jest IP klienta wystarczy wywołać funkcję
socket_getpeername($clisock, $IP);
w zmiennej $IP jest adres klienta.

Mnie osobiście interesuje budowanie nagłówków tcp/ip.

W C wygląda to tak że są odpowiednie struktury danych nagłówków IP, TCP. Poprostu wypełnia się je i wysyła. Struktury te są zdefiniowanie w plikach
<netinet/ip.h>
<netinet/tcp.h>
<arpa/inet.h>
<netinet/udp.h>

zamieszczam przykładowy program w C wykorzystujacy budowę nagłówków. Program nazywa się PEPSI i jest popularnym programem do przeciążąnia systemów tzn "flooding", używany przez hakerów.

Mógłbyś tutaj umieścić sourcy tego proxy, tak z czystej ciekawości.

Co do twojego projektu zawsze można napisać własne rozszerzenie php (w c oczywiście ).

fakt o tym nie pomyślałem. Dzięki.

kod proxy kożysta z trzech plików
1.) czyta konfiguracje
2.) obsługuje wątki (niestsety tylko pod linuxem)
3.) właściwy proxy

w takiej kolejności zamieszczam pliki:

[php:1:c66766329c]<?php
<?
class ReadConfFile
{
var $file;
var $var_conf;

function ReadConfFile($name_file)
{
$this->file = $name_file;
$this->var_conf = array();
}

function read_Config()
{
$fp = fopen($this->file, 'r');
if($fp){
while(!feof($fp)) {
$conf = trim(fgets($fp, 255));
if(substr($conf,0,1) != "#") {
array_push($this->var_conf, $conf);
};
};
fclose($fp);
} else {
exit();
};

print date("Y-m-d H:i:s")." CONFIG FILE READn";
foreach($this->var_conf as $var){
print $var."n";
};
}

function get_Acces($address, $ip)
{

$ACCESS = -1;
foreach($this->var_conf as $config)
eval($config);

$H = date('H:i');
$CHD = strtolower(date('l'));

$D = explode(",", $DAYES);
$HOST = explode(",", $HOST);
$IP = explode(",", $IP);

if(array_search($CHD, $D) > -1)
{
$ACCESS = 0;
} else {
if($HOUR_FROM > $H or $HOUR_TO < $H)
$ACCESS = 0;
};

if(array_search($address, $HOST) != FALSE || array_search($address, $HOST) > -1) {
$ACCESS = 0;
};

if(array_search($ip, $IP) != FALSE || array_search($ip, $IP) > -1) {
$ACCESS = 0;
};

return $ACCESS;
}
};
?>
?>[/php:1:c66766329c]


[php:1:c66766329c]<?php
<?
class Thread
{
var $uid;
var $gid;
var $pid;

function Thread()
{
pcntl_signal(SIGCHLD, array($this,"sig_handler"));
pcntl_signal(SIGTERM, array($this,"sig_handler"));
pcntl_signal(SIGINT, array($this,"sig_handler"));
$this->uid = 99;
$this->gid = 99;
}

function sig_handler($signo)
{
switch($signo)
{
case SIGTERM:
exit;
break;// handle shutdown tasks
case SIGHUP:
break;// handle restart tasks
case SIGUSR1:
print "Caught SIGUSR1...n"; break;
case SIGCHLD:
while( pcntl_waitpid(-1,$status,WNOHANG) > 0 ) {};
break;
case SIGINT:
exit;
default:
/* not implemented yet...*/
break;
};
}

function start_thread($object, $handler, $time, $arg=array())
{
$CH_PID = pcntl_fork();

if($CH_PID == -1)
{
//not child
}
elseif ($CH_PID == 0)
{
//parent
}
else
{
if(!posix_setsid())
exit;
set_time_limit($time);
$this->pid = posix_getpid();
$this->change_identity();
call_user_func(array($object,$handler),$arg);
exit;
};
exit();
}

function change_identity()
{
if(!posix_setgid($this->gid)) {
print "Unable to setgid to $gid!n";
exit;
}
if(!posix_setuid($this->uid)) {
print "Unable to setuid to $uid!n";
exit;
};
}

};
?>
?>[/php:1:c66766329c]




[php:1:c66766329c]<?php
#!/usr/local/bin/php
<?
require("c_Thread.php");
require("c_ReadConfFile.php");

class proxy_HTTP
{
var $SERVER_SOCK;
var $LOG;

function proxy_HTTP()
{
$this->LOG = 1;
if(!extension_loaded('sockets'))
dl('php_sockets');
set_time_limit(0);
ob_implicit_flush();
$port = 9000;
$address = "192.168.254.51";
$this->SERVER_SOCK = socket_create(AF_INET, SOCK_STREAM, 0);
socket_set_option($this->SERVER_SOCK, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($this->SERVER_SOCK, $address, $port);
socket_listen($this->SERVER_SOCK, 10);
$this->start();
}

function start()
{
$CONFIG = new ReadConfFile("conf");
$CONFIG->read_Config();

do {
if(!$this->SERVER_SOCK)
$this->proxy_HTTP();

if(($clisock = socket_accept($this->SERVER_SOCK)) > 0)
{
$BUF = socket_read($clisock, 2048);
/*
$fs = fopen("url.dat","w");
fputs($fs,$BUF);
fclose($fs);
break;
*/
if(trim($BUF) == "kill") {
socket_close($this->SERVER_SOCK);
break ;
};

eregi("HOST:.*",$BUF,$o);
$BUFF = substr($o[0],5);
$pos = strpos($BUFF,"r");
$address = trim(substr($BUFF,0,$pos));
$address = trim(str_replace("www.","",$address));

socket_getpeername($clisock, $client_ip);
$ACCESS = $CONFIG->get_Acces($address, $client_ip);

if( $ACCESS > -1)
{
$thread = new Thread();
$param[0] = $clisock;
$param[1] = $BUF;
$thread->start_thread($this,'get_connect',20,$param);
unset($thread);
}
else
{
$BUF2 = $this->info();
socket_write($clisock, $BUF2, strlen($BUF2));
socket_close($clisock);
};
}
else
{
break;
};
} while (TRUE);
socket_close($this->SERVER_SOCK);
}

function get_connect($arg)
{
$clisock = $arg[0];
$BUF = $arg[1];

eregi("HOST:.*",$BUF,$o);
$BUFF = substr($o[0],5);
$pos = strpos($BUFF,"r");
$address = trim(substr($BUFF,0,$pos));

if($this->LOG){
socket_getpeername($clisock, $IP);
$arg[0] = $IP;
$arg[1] = $address;
$arg[2] = "GET";
$arg[3] = strlen($BUF);
$this->log($arg);
};

//if(eregi("CONNECT",$BUF)) {
//$BUF = eregi_replace("https://$address","",$BUF);
// $port = 443;
//} else {
$BUF = str_replace("http://$address","",$BUF);
$port = 80;
//};
$fps = fsockopen(gethostbyname($address), $port, $errno, $errstr, 15);
//$socket = socket_create(AF_INET, SOCK_STREAM, 0);
//$stat = @socket_connect($socket, $address, $port);
if($fps)
{
$BUF.="rnrn";
$how_write = strlen($BUF);
//$ok = socket_write($socket, $BUF, $how_write);
fputs($fps, $BUF, $how_write);
//if($ok == $how_write) {
$buffer="";
$how_write=0;
while(!feof($fps))//$BUF = socket_read($socket, 2048)
{
//$how_write+= strlen($BUF);
$buffer.= fgets($fps,255);//$BUF;
$how_write+= strlen($buffer);
};
socket_write($clisock, $buffer, $how_write);
//};
//socket_close($socket);
fclose($fps);
}
else
{
$BUF = $this->info(1);
socket_write($clisock, $BUF, strlen($BUF));
};
socket_close($clisock);
exit();
}

function info($typ=0)
{
switch($typ) {
case 0 : $f = fopen('proxy_ERR/index.html','r'); break;
case 1 : $f = fopen('proxy_ERR/err.html','r'); break;
};
while(!feof($f))
$dat.= fgets($f, 255);
fclose($f);
$data= "HTTP/1.1 200 OKrnPragma: no-cachernCache-Control: no-cachernContent-Type: text/htmlrnContent-Length: ".strlen($dat)."rnConnection: closern";
return $data.$dat;
}

function log($arg)
{
$log = date("Y-m-d H:i:s"). " - IP: ".$arg[0]." OPTION: ".$arg[2]." HOST: ".$arg[1]." SIZE: ".$arg[3]."n";
$f = fopen("proxy_log","a");
fputs($f, $log);
fclose($f);
}
};
new proxy_HTTP;
?>
?>[/php:1:c66766329c]
?>[/php]

sorry za błędy ortograficzne

Ze skryptu można korzystać. Mam tylko jedną prośbę gdy ktokolwiek zmodyfikował, lub dodał coś interesującego to bardzo bym prosił o informację na tem temat.

e-mail : marcin@jazztranslation.com

do sprawnego dzialania trzeba dodać wywołanie funkcji [php:1:7a2f32c30e]<?php
posix_kill($pid,SIGCHLD);
?>[/php:1:7a2f32c30e] na końcu wywołanej funkcji w sekcji THREAD.

O kurka... niezle - w zyciu bym sie nie spodziewal, ze ktos bedzie cos takiego pisal Zagadnienie ciekawe w sumie...

Nigdy nie uzywalem TCP/IP bezposrednio w php ale uzywalem HTTP i to w tym protokole wyglada tak:
[php:1:d0ecec1634]<?php
$adres="www.google.pl";
$page_adres="/search/index.html";
$port=80;
$time_limit=30;
set_time_limit($time_limit);
if(!extension_loaded('sockets')) dl("php_sockets.dll");// .so jak po unixem
$like_file_open=fsockopen($adres, $port, $errorno, $error, $time_limit);
if($like_file_open) {
fputs($like_file_open, "HEAD " . $page_adres . " HTTP/1.0rnrn");
while(!feof($like_file_open)) $data[]=fgets($like_file_open, 1000);
fclose($like_file_open);
}
else {
echo "<br>Błąd: " . $errorno . "<br>". $error;
}
reset($data);
while(list($k , $v)=each($data)) echo "<br>Klucz: ".$k." <br>Wartosc: " . $v;

// i tak dalej wszystko tak jak dla pliku do odczytu i zapisu
?>[/php:1:d0ecec1634]
moze TCP/IP robi sie analogicznie podajesz rodzaj i wersje protokolu dlaej robisz co chcesz, co prawda zupelnie nie wiem jak wygladaja naglowki w TCP/IP ale moze cos to komus pomoze ...

czy przy dynamicznym ladowaniu rozszerzen nie trza podawac rozszerzenia biblioteki .so/.dll ? uswiadomcie mnie

naczy chodzi mi o funkcje dl() a nie extension_loaded()

możesz pisać dla dl sama nazwę bez rozszerzen