Проброс трафика с одного порта на другой PHP

Добрый день! Я не очень силен в написании скриптов PHP а уж темболее в stream_socket.

Задача перед мной стоит следуйщая сервер linux на нем крутититься PHP5
запущен скрипт РНР с бесконечным циклом создан сервер сокет который слушает порт 8000 и в этойще сети где сервер есть другой комп на который нужно отправить весь трафик приходящий с порта 8000 в порт 8003 другой машины и на оборот принять с 8003 порта другой машины и отправить клиенту который конетился на сервер порта 8000, что то типа порт maping.
знаю что можно сделать другими средствами, но нужно именно на РНР в большей части чтобы смотреть и вслучаи чего править header-ы. Если кто может помочь очень прошу! В долгу не останусь могу оплатить работу конечно в пределах разумного. спасибо! Ниже то что я накалякал.

Код (Text):

1.  
2. <?php
3.  
4. $socket = stream_socket_server("tcp://99.99.99.99:8000", $errno, $errstr); //сокет сервера
5.  
6. if (!$socket) {
7.     die("$errstr ($errno)\n");
8. }
9.  
10. $connects = array();
11.  
12. while (true) {
13.     //формируем массив прослушиваемых сокетов:
14.     $read = $connects;
15.     $read []= $socket;
16.     $write = $except = null;
17.    
18.     $fp_read = $fp_connects;
19.     $fp_read []= $fp;
20.     $fp_write = $fp_except = null;
21.  
22.     if (!stream_select($read, $write, $except, null)) {//ожидаем сокеты доступные для чтения (без таймаута)
23.         break;
24.     }
25.  
26.     if (in_array($socket, $read)) {//есть новое соединение
27.         $connect = stream_socket_accept($socket, -1);//принимаем новое соединение
28.         $connects[] = $connect;//добавляем его в список необходимых для обработки
29.         unset($read[ array_search($socket, $read) ]);
30.     }
31.     $fp = stream_socket_client("tcp://192.168.0.1:8003", $errno, $errstr, 30, STREAM_CLIENT_ASYNC_CONNECT); //клиент куда нужно подключаться и отправлять данные и принимать обратно и отправлять в 99.99.99.99:8000
32.     foreach($read as $connect) {//обрабатываем все соединения
33.         $headers = '';
34.        
35.         while ($buffer = rtrim(fgets($connect))) {
36.             $headers .= $buffer."\r\n";
37.             //fwrite($connect, fgets($fp));
38.         }
39.  
40.         //echo $headers."\r\n";
41.        
42.         $headers = '';
43.         while ($buffer = rtrim(fgets($fp))) {
44.             $headers .= $buffer."\r\n";
45.                
46.         }
47.         //fwrite($connect, $headers."\r\n");
48.         //if
49.         echo $headers;
50.         //}
51.         //fclose($fp);
52.         }
53.        
54.         //echo $headers;
55.        
56.         //fclose($connect);
57.         unset($connects[ array_search($connect, $connects) ]);
58.     }
59.  
60. }
61.  
62.  
63.  
64.  
65.  
66.  
67. ?>

 

дружище спасибо тебе огромное но я не профи некоторые слова для меня непонятны =) если можно примерным куском кода или последовательностью буду признателен.

Добавлено спустя 10 минут 39 секунд:
на данный момент получилось чтото вроде этого только клиент подключающийся на 8000 порт постояно реконет делает

Код (Text):

1.  
2. <?php
3.  
4. $socket = stream_socket_server("tcp://99.99.99.99:8000", $errno, $errstr);
5.  
6. if (!$socket) {
7.     die("$errstr ($errno)\n");
8. }
9.  
10. $connects = array();
11.  
12. while (true) {
13.     //формируем массив прослушиваемых сокетов:
14.     $read = $connects;
15.     $read []= $socket;
16.     $write = $except = null;
17.    
18.     if (!stream_select($read, $write, $except, null)) {//ожидаем сокеты доступные для чтения (без таймаута)
19.         break;
20.     }
21.  
22.     if (in_array($socket, $read)) {//есть новое соединение
23.         $connect = stream_socket_accept($socket, -1);//принимаем новое соединение
24.         $connects[] = $connect;//добавляем его в список необходимых для обработки
25.         unset($read[ array_search($socket, $read) ]);
26.     }
27.    
28.     foreach($read as $connect) {//обрабатываем все соединения
29.         $fp[$connect] = stream_socket_client("tcp://192.168.0.1:8003", $errno, $errstr, 30, STREAM_CLIENT_ASYNC_CONNECT);
30.         $headers = '';
31.        
32.         while ($buffer = rtrim(fgets($connect))) {
33.             $headers .= $buffer."\r\n";
34.     }
35.         fwrite($fp[$connect], $headers."\r\n");
36.         echo $headers;
37.        
38.         $headerss = '';
39.         while ($buffer = rtrim(fgets($fp[$connect]))) {
40.             $headerss .= $buffer."\r\n";
41.  
42.         }
43.         fwrite($connect, $headerss."\r\n");
44.         echo $headerss;
45.        
46.         //echo $headers;
47.         //fclose($fp[$connect]);
48.         //fclose($connect);
49.         unset($connects[ array_search($connect, $connects) ]);
50.     }
51.  
52. }

 

спасибо за информацию щас почитаю!

 

Спасибо всем за все! Я все понял почти доделал сам чуть позже допилю и выложу код!